Python语言下的RPC开发

一、httpserver实现rpc

 1、server.py

from http.server import HTTPServer, BaseHTTPRequestHandler
from urllib.parse import urlparse, parse_qsl
import json
host = ('', 8000)
class UserHandler(BaseHTTPRequestHandler):
def do_GET(self):
"""处理get请求"""
parse_url = urlparse(self.path) # 处理请求地址
qs = dict(parse_qsl(parse_url.query)) # 获取请求地址中携带的参数
uid = int(qs.get("uid", 0)) # 比如携带的参数是uid
self.send_response(200) # 设置响应码
self.send_header('Content-type', 'application/json') # 设置响应头
self.end_headers()
if uid == 1: # 写入响应体
self.wfile.write(
json.dumps(
{
"username": "bily",
"gender": "male"
}
).encode("utf-8")
)
if __name__ == '__main__':
server = HTTPServer(host, UserHandler)
server.serve_forever()

2、client.py

import requests
# 请求
res = requests.get(url="http://127.0.0.1:8000/?uid=1")
print(res.text)

上面其实就是实现了一个http的服务，通过http请求来完成客户端对于服务端的请求，但是显然有一些不满足远程过程调用的要求，比如客户端的调用应该向本地调用一样，而不是发送请求，那么我们可以将客户端进行一下封装：

import requests
class Client:
def __init__(self, url):
self.url = url
def get_user(self):
res = requests.get(url=self.url)
return res.text
c = Client("http://127.0.0.1:8000/?uid=1")
# 模拟本地调用
res = c.get_user()
print(res)

可以看到通过封装后调用get_user方法，屏蔽了底层一些网络协议的细节。

二、基于xml实现rpc

 1、server.py

from xmlrpc.server import SimpleXMLRPCServer
class Calculate:
def add(self, x, y):
return x + y
obj = Calculate()
server = SimpleXMLRPCServer(("localhost", 8000))
# 将实例注册到rpc server
server.register_instance(obj)
server.serve_forever()

2、client.py

from xmlrpc import client
c = client.ServerProxy("http://localhost:8000")
# 远程调用服务端的函数
res = c.add(3, 5)
print(res)

三、基于json实现rpc

基于xml是通过xml来进行数据的编码和解码，不过经常用到的的序列化和反序列化的还有json，那么如何通过json来实现rpc呢？

需要借助于jsonrpclib这个库，安装：

pip install jsonrpclib-pelix

1、server.py

from jsonrpclib.SimpleJSONRPCServer import SimpleJSONRPCServer
class Calculate:
def sub(self, x, y):
return x - y
server = SimpleJSONRPCServer(("localhost", 8000))
# 注册函数
server.register_function(lambda x, y: x + y, "add")
# 注册实例
obj = Calculate()
server.register_instance(obj)
server.serve_forever()

2、client.py

import jsonrpclib
client = jsonrpclib.ServerProxy("http://localhost:8000")
res1 = client.add(1, 2)
res2 = client.sub(3, 5)
print(res1)
print(res2)

四、 基于zerorpc实现rpc

zerorpc是利用 zeroMQ消息队列 + msgpack 消息序列化(二进制) 来实现类似 grpc 的功能，跨语言远程调用。

zerorpc可以以编程方式或从命令行使用。它带有一个方便的脚本“zerorpc”，允许：

• 无需修改任何代码即可公开 Python 模块


• 通过命令行远程调用这些模块

不过它会依赖一些库，比如：msgpack-python, pyzmq, future, greenlet, gevent

所以使用它之前需要先进行安装：

pip install zerorpc

（一）一元调用

1、server.py

import zerorpc
class Calculate:
def add(self, a, b):
return a + b
server = zerorpc.Server(Calculate())
server.bind("tcp://0.0.0.0:8000")
server.run()

2、client.py

import zerorpc
client = zerorpc.Client()
client.connect("tcp://127.0.0.1:8000")
res = client.add(2, 3)
print(res)

（二）流式响应

1、server.py

import zerorpc
class StreamingNum:
@zerorpc.stream
def streaming_range(self, start, end, step):
return range(start, end, step) # 返回的是一个生成器

server = zerorpc.Server(StreamingNum())
server.bind("tcp://0.0.0.0:8000")
server.run()

2、client.py

import zerorpc
client = zerorpc.Client()
client.connect("tcp://127.0.0.1:8000")
res = client.streaming_range(1, 10, 2)
for i in res:
print(i)

作者：iveBoy

出处：http://www.cnblogs.com/shenjianping/

本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须在文章页面给出原文连接，否则保留追究法律责任的权利。