Python使⽤gRPC传输协议教程
gRPC 简介：
gRPC 是⼀款⾼性能、开源的 RPC 框架，产⾃ Google，基于 ProtoBuf 序列化协议进⾏开发，⽀持多种语⾔（Golang、Python、Java等），本篇只介绍 Python 的 gRPC 使⽤。因为 gRPC 对 HTTP/2 协议的⽀持使其在 Android、IOS 等客户端后端服务的开发领域具有良好的前景。gRPC 提供了⼀种简单的⽅法来定义服务，同时客户端可以充分利⽤ HTTP2 stream 的特性，从⽽有助于节省带宽、降低 TCP 的连接次数、节省CPU的使⽤等。
安装：
gRPC 的安装：
$ pip install grpcio
安装 ProtoBuf 相关的 python 依赖库：
$ pip install protobufpython安装教程非常详细
安装 python grpc 的 protobuf 编译⼯具：
$ pip install grpcio-tools
GRPC使⽤案例
下看⼀下项⽬⽬录结构
grpc是⼀套传输协议，我们需要在底层实现这套传输协议.当然这些⼯作都已经被做完了，所以我们只要学会使⽤⼀个具有grpc传输协议的服务器和在客户端上调⽤grpc传输协议传输数据就可以了.
grpc传输协议传输的数据类型为protobuf数据.所以grpc都是和protobuf⼀块使⽤.
(1)新建data.proto⽂件，定义传输的数据格式和grpc服务要实现的函数
syntax = "proto3";
package example;
service FormatData {  //定义服务,⽤在rpc传输中
rpc DoFormat(actionrequest) returns (actionresponse){}
}
message actionrequest {
string text = 1;
}
message actionresponse{
string text=1;
}
(2)⽣成proto数据的python调⽤格式和grpc服务接⼝
在proto⽂件⽬录下调⽤下列命令
$ python -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. ./data.proto
会⽣成：data_pb2.py 与 data_pb2_grpc.py, 其中data_pb2.py是数据格式调⽤的⽂件,data_pb2_grpc.py是grpc传输协议接⼝调⽤的⽂件.
(3)创建实现了grpc传输协议的服务器端
在服务器端代码中需要实现proto⽂件中编写的服务接⼝，并重写处理函数，将重写后的服务类实例化以后添加到grpc服务器中，这样创建的grpc服务器就可以实现⾃定义的proto传输服务了.
# 实现了 server 端⽤于接收客户端发送的数据，并对数据进⾏⼤写处理后返回给客户端
# ! /usr/bin/env python
# -*- coding: utf-8 -*-
import grpc
import time
from concurrent import futures
from example import data_pb2, data_pb2_grpc
_ONE_DAY_IN_SECONDS = 60 * 60 * 24
_HOST = 'localhost'
_PORT = '8080'
# 实现⼀个派⽣类，重写rpc中的接⼝函数.⾃动⽣成的grpc⽂件中⽐proto中的服务名称多了⼀个Servicer
class FormatData(data_pb2_grpc.FormatDataServicer):
# 重写接⼝函数.输⼊和输出都是proto中定义的Data类型
def DoFormat(self, request, context):
str =
return data_pb2.actionresponse(text=str.upper()) # 返回⼀个类实例
def serve():
# 定义服务器并设置最⼤连接数,corcurrent.futures是⼀个并发库，类似于线程池的概念
grpcServer = grpc.server(futures.ThreadPoolExecutor(max_workers=4))  # 创建⼀个服务器
data_pb2_grpc.add_FormatDataServicer_to_server(FormatData(), grpcServer) # 在服务器中添加派⽣的接⼝服务（⾃⼰实现了处理函数）
grpcServer.add_insecure_port(_HOST + ':' + _PORT)  # 添加监听端⼝
grpcServer.start()  # 启动服务器
try:
while True:
time.sleep(_ONE_DAY_IN_SECONDS)
except KeyboardInterrupt:
grpcServer.stop(0) # 关闭服务器
if __name__ == '__main__':
serve()
(4)创建实现能识别proto数据类和实现grpc传输协议.
# 实现了客户端⽤于发送数据并打印接收到 server 端处理后的数据
# ! /usr/bin/env python
# -*- coding: utf-8 -*-
import grpc
from example import data_pb2, data_pb2_grpc
_HOST = 'localhost'
_PORT = '8080'
def run():
conn = grpc.insecure_channel(_HOST + ':' + _PORT) # 监听频道
print(conn)
client = data_pb2_grpc.FormatDataStub(channel=conn)  # 客户端使⽤Stub类发送请求，参数为频道，为了绑定链接
print(client)
response = client.DoFormat(data_pb2.actionrequest(text='hello,world!'))  # 返回的结果就是proto中定义的类
print("received: " + )
if __name__ == '__main__':
run()
客户端链接的主机号和端⼝号，必须是服务器创建的主机号和端⼝号.
总结
以上就是这篇⽂章的全部内容了，希望本⽂的内容对⼤家的学习或者⼯作具有⼀定的参考学习价值，谢谢⼤家对的⽀持。如果你想了解更多相关内容请查看下⾯相关链接

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。