用c语言编写的python工作服务器
mrworkserver的Python项目详细描述
mrworkserver
一个简单的基于python 3.5+异步的集群工作服务器，使用mrq接口。
示例
importasyncioimportmrworkserverasyncdefcallback(msgs):print("Callback:")forminmsgs:print(m)ws=mrworkserver.WorkServer()ws.cb=callbackws.run()
示例客户机
# pip install asyncmrq mrjsonimportasynciofrommrq.clientimportClientimportmrjsonasyncdefrun(loop):c=Client()awaitc.connect(io_loop=loop,servers=[("127.0.0.1",7100)])msg=mrjson.dumpb([1,2,3,4,5,6,7,8,9,10])forxinrange(10):awaitc.push(0,0,msg,len(msg))awaitasyncio.sleep(1)awaitc.close()if__name__=='__main__':loop=asyncio.get_event_loop()loop.run_until_complete(run(loop))loop.close()
欢迎加入QQ群-->： 979659372
