Python之RPC开发讲解第4篇:RPC基本原理,二进制消息协议实现
【摘要】 客户端 安装 1 安装依赖工具和库 2 安装Thrift编译器和程序库 Thrift的接口定义语言IDL 1 基本类型 2 容器类型 协议与传输选择 1 协议 服务器 Thrift 简介 架构 使用方法 gRPC HTTP/2 1 HTTP/1.x gRPC接口类型 1 Unary RPC 2 Server Streaming RPC Protocol Buffers 1 文档
2. 解析方法名实现
class MethodProtocol(object):
def __init__(self, connection):
self.conn = connection
def _read_all(self, size):
"""
读取指定长度的字节
:param size: 长度
:return: 读取出的二进制数据
"""
if isinstance(self.conn, BytesIO):
# BytesIO类型,用于演示
buff = b''
have = 0
while have < siz
### 测试
```python
if __name__ == '__main__':
proto = DivideProtocol()
# 构造消息
buff = BytesIO()
# buff.write(proto.args_encode(100, 200))
buff.write(proto.args_encode(100))
# 解读消息
buff.seek(0)
name = MethodProtocol(buff).get_method_name()
print(name)
args = proto.args_decode(buff)
print(args)
buff.close()
RPC传输
在构造好RPC消息数据后,就可以通过网络在调用双方进行传递了。
传递消息数据常用的有两种方式:TCP 和 HTTP
1. TCP
由于TCP的可靠性,所以TCP是最常用的方式。我们可以直接借助socket工具进行TCP开发。
TCP服务端编写
sock = socket.socket() # 创建一个套接字
sock.bind() # 绑定端口
sock.listen() # 监听连接
sock.accept() # 接受新连接
sock.close() # 关闭服务器套接字
TCP客户端编写 ```python sock = socket.socket() # 创建一个套接字 sock.connect() # 连接远程服务器 sock.recv(
【声明】本内容来自华为云开发者社区博主,不代表华为云及华为云开发者社区的观点和立场。转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息,否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱:
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论(0)