跳转至

ZeroRPC

Python3 RPC 方式

  • xmlrpc：系统内置库 SimpleXMLRPCServer + xmlrpclib，基于HTTP
  • jsonrpc：第三方库 jsonrpclib 或 python-jsonrpc，基于HTTP
  • ZeroRPC：基于 ZeroMQ + MessagePack(序列化) 的第三方库，基于 TCP，由 dotcloud 公司在 PyCon 2012 大会上开源

ZeroRPC 官网

ZeroRPC 分为三层：

  • Wire (or transport) layer, 利用 ZeroMQ 和 MessagePack 进行通信
  • Event (or message) layer, 最复杂的一层，处理心跳，事件等
  • RPC layer, RPC Request + Response

基础用法

安装：pip install zerorpc

  • 服务端
import zerorpc

class Caculate(object):
    def hello(self, name):
        return 'hi, {}'.format(name)

    def add(self, x, y):
        return x + y

    def multiply(self, x, y):
        return x * y

    def subtract(self, x, y):
        return abs(x - y)

    def divide(self, x, y):
        return x / y


s = zerorpc.Server(caculate())
s.bind("tcp://0.0.0.0:4242")
s.run()
  • 客户端
import zerorpc

c = zerorpc.Client()
url = "tcp://127.0.0.1:4242"
url2 = "tcp://127.0.0.1:4343"
c.connect(url)

print(c.hello("chonge"))
print(c.add(1, 2))

# 还可以命令行直接调用方法
zerorpc tcp://127.0.0.1:4242 hello RPC

# 通过命令行查看远程提供的所有方法，可以grep过滤
zerorpc tcp://127.0.0.1:4242
'''
connecting to "tcp://127.0.0.1:4242"
[Caculate]
add      <undocumented>
divide   <undocumented>
hello    <undocumented>
multiply <undocumented>
subtract <undocumented>
'''

# 查看方法的文档
zerorpc --inspect tcp://127.0.0.1:4242 hello

参考