1 pip install grpcio 2 pip install protobuf 3 pip install grpcio_tools # python下的protoc编译器
参考protobuf语法编写.proto文件
将protoc文件转化为pb2和pb2_grpc文件，操作步骤如下：
1 python3 -m grpc_tools.protoc --python_out=. --grpc_python_out=. -I. xxx.proto -I=/workspace -I=xxx/yyy/ 2 3 #说明： 4 -I=：在proto文件中远程调用的内容，导入路径为实际调用的上一级目录即可。 5 python_out：指定xxx_pb2.py的输出路径，编译生成处理protobuf相关的代码路径。传入.，则默认生成到当前目录。 6 grpc_python_out：指定xxx_pb2_grpc.py的输出路径，编译生成处理grpc相关的代码路径，传入.，则默认生成到当前目录。 7 grpc_tools.protoc：工具包，刚安装的。 8 -I：这个参数指定协议文件的查找目录。 9 10 # 生成的文件中： 11 xxx_pb2.py：里面有消息序列化类。是用来和protobuf数据进行交互。 12 xxx_pb2_grpc.py：包含了服务器Stub类和客户端Stub类，以及待实现的服务RPC接口。是用来和grpc进行交互。
demo如下：
1 # coding:utf-8 2 3 import grpc 4 import json 5 from concurrent import futures 6 import xxx_pb2,yyy_pb2_grpc 7 8 _HOST = ‘‘ # todo 9 _PORT = ‘‘ # todo 10 11 12 # 实现 proto 文件中定义的 xxxServicer 13 class xxxServer(yyy_pb2_grpc.xxxServicer): 14 # 实现 proto 文件中定义的GRPC调用 15 def SendRequest(self, request, context): 16 json_response = xxx_pb2.xxxResponse() 17 json_response.rst_string = json.dumps({"ret": "Hi grpc"}) 18 return json_response 19 20 21 def serve(): 22 # 启动GRPC服务,监听特定的端口 23 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10)) # 多线程服务器 24 yyy_pb2_grpc.add_xxxServicer_to_server(xxxServer(), server) # 注册本地服务 25 server.add_insecure_port("{0}:{1}".format(_HOST, _PORT)) # 监听端口 26 server.start() # 开始接收请求进行服务 27 try: 28 while True: 29 time.sleep(60 * 60 * 24) # one day in seconds 30 except KeyboardInterrupt: 31 server.stop(0) 32 33 34 if __name__ == ‘__main__‘: 35 serve()
demo如下：
1 # coding:utf-8 2 3 import grpc 4 import xxx_pb2, yyy_pb2_grpc 5 6 _HOST = ‘‘ # todo 7 _PORT = ‘‘ # todo 8 9 10 def main(): 11 with grpc.insecure_channel("{0}:{1}".format(_HOST, _PORT)) as channel: 12 client = yyy_pb2_grpc.xxxStub(channel=channel) 13 response = client.xxxMessage(xxx_pb2.xxxRequest()) 14 print("received: " + response.message + response.result) 15 16 17 if __name__ == ‘__main__‘: 18 main()
原文：https://www.cnblogs.com/sunshine-blog/p/12193064.html