aiozmq是Asycio(pep3156)与ZeroMQ的集成。
高级客户端-服务器RPC示例：
import asycioimport aiozmq.rpcclass ServerHadler(aiozmq.rpc.AttrHadler): @aiozmq.rpc.method def remote_fuc(self, a:it, b:it) -> it: retur a + b@asycio.coroutiedef go(): server = yield from aiozmq.rpc.serve_rpc( ServerHadler(), bid='tcp://127.0.0.1:5555') cliet = yield from aiozmq.rpc.coect_rpc( coect='tcp://127.0.0.1:5555') ret = yield from cliet.call.remote_fuc(1, 2) assert 3 == ret server.close() cliet.close()asycio.get_evet_loop().ru_util_complete(go())
评论