python中的rpc库

2021-12-18 21:05:28 阅读：157 来源： 互联网

标签：zerorpc python server rpc print import def

基于xml的rpc调用

rpcserver.py

from xmlrpc.server import SimpleXMLRPCServer


# python中类的命名方式遵循驼峰命名法
# 1. 没有出现url的映射
# 2. 没有出现编码和解码
# 3. 序列化和反序列化协议是：xml
class Calculate:
    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


obj = Calculate()
server = SimpleXMLRPCServer(("localhost", 8088))
# 将实例注册给rpc server
server.register_instance(obj)
print("Listening on port 8088")
server.serve_forever()

rpc服务通俗来讲：通过一定协议和方法使得调用远程计算机上的服务，就像调用本地服务一样。

xml_rpc_client.py

from xmlrpc import client

# xmlrpc挺好用的
# rpc强调的是本地调用效果
# rpc在内部调用很多
server = client.ServerProxy("http://localhost:8088")
print(server.divide(2, 3))

基于json的rpc调用

安装
pip install jsonrpclib
json_rpc_server.py

from jsonrpclib.SimpleJSONRPCServer import SimpleJSONRPCServer


def my_dict(d):
    d["gender"] = "男"
    return d


# 实例化server
server = SimpleJSONRPCServer(("127.0.0.1", 8883))
# 将函数注册到server中
server.register_function(pow)
server.register_function(lambda x, y: x + y, "add")
server.register_function(my_dict)
# 启动server
server.serve_forever()

json_rpc_client.py

import jsonrpclib

server = jsonrpclib.Server("http://127.0.0.1:8883")
print(server.add(11, 22))  # 33
print(server.pow(5, 3))  # 125
ret = server.my_dict(dict(name="马亚南", age=18))
print(ret, type(ret))

总结：

超时机制 - 重试
限流使服务处于长期可用的状态 - 高可用
解耦
负载均衡微服务 - 分布式应用的一种具体的提现
json-rpc是否满足上述的要求
序列化和反序列化数据压缩是否高效
该rpc框架是否支持多语言

更加高效和更加全面的技术 - zerorpc

基于zeromq的rpc框架: zerorpc

zerorpc实现rpc调用

一元调用

服务端

import zerorpc


class HelloRPC(object):
    def hello(self, name):
        return f"hello {name}"

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


# 1. 实例化一个server
# 2. 绑定我们的业务代码到server中
server = zerorpc.Server(HelloRPC())
# 3. 设置协议、ip、端口
server.bind("tcp://0.0.0.0:8842")
# 3. 启动server
server.run()

客户端

import zerorpc

# 在功能体验上，client端没有太大的差异
c = zerorpc.Client()
c.connect("tcp://127.0.0.1:8842")
print(c.hello("马亚南"))
print(c.add(11, 22))

流式响应

服务端

import zerorpc


class StreamingRPC(object):
    @zerorpc.stream  # @zerorpc.stream这里的装饰器是必须的，否则会有异常，如TypeError:cant't serialize
    def streaming_range(self, fr, to, step):
        return range(fr, to, step)


s = zerorpc.Server(StreamingRPC())
s.bind("tcp://0.0.0.0:4242")
s.run()

客户端

import zerorpc

c = zerorpc.Client()
c.connect("tcp://127.0.0.1:4242")
for item in c.streaming_range(10, 20, 2):
    print(item)

基于zerorpc的调用过程

zerorpc支持nodejs和python的
zerorpc github链接
 zerorpc官网

RPC需要解决的问题

Id映射
传输协议 tcp/http
数据的编码和解码xml/json/msgpack
如何解决高并发问题
负载均衡问题
集群问题

选择哪一种rpc解决方案

生态
支持的语言（多语言/单语言）

标签：zerorpc,python,server,rpc,print,import,def
来源： https://www.cnblogs.com/mayanan/p/15705500.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9