天道酬勤,学无止境

直播服务

python实现直播服务非rtmp版本(非常简单)

主程序使用说明"""执行主程序 执行直播程序 执行用户程序"""import multiprocessing.managersfrom multiprocessing import Queue# 任务队列task_queue=Queue()# 结果队列result_queue=Queue()result_queue1=Queue()# 提供给从机调用后得到队列中的数据# 就是接口class QueueManager(multiprocessing.managers.BaseManager): passclass StartMain(): def return_task(self): return task_queue def return_result(self): return result_queue def return_result1(self): return result_queue1 # 开启分布式支持 def start_main(self): multiprocessing.freeze_support() QueueManager.register('get_task', callable=self.return_task) QueueManager.register('get_result', callable=self.return_result)

2021-05-13 21:39:57    分类:博客    python   直播服务