python gRPC接口调用

            1 pip install grpcio
2 pip install protobuf
3 pip install grpcio_tools    # python下的protoc编译器

• 命令：

                 1 python3  -m  grpc_tools.protoc  --python_out=.  --grpc_python_out=.  -I. xxx.proto  -I=/workspace  -I=xxx/yyy/
 2 3#说明：
 4 -I=：在proto文件中远程调用的内容，导入路径为实际调用的上一级目录即可。
 5python_out：指定xxx_pb2.py的输出路径，编译生成处理protobuf相关的代码路径。传入.，则默认生成到当前目录。
 6grpc_python_out：指定xxx_pb2_grpc.py的输出路径，编译生成处理grpc相关的代码路径，传入.，则默认生成到当前目录。
 7grpc_tools.protoc：工具包，刚安装的。
 8 -I：这个参数指定协议文件的查找目录。
 910# 生成的文件中：
11xxx_pb2.py：里面有消息序列化类。是用来和protobuf数据进行交互。
12 xxx_pb2_grpc.py：包含了服务器Stub类和客户端Stub类，以及待实现的服务RPC接口。是用来和grpc进行交互。

             1
            #
             coding:utf-8
             2
             3
            import
             grpc

             4
            import
             json

             5
            from concurrent import futures
 6import xxx_pb2,yyy_pb2_grpc
 7 8 _HOST = ‘‘# todo 9 _PORT = ‘‘# todo101112# 实现 proto 文件中定义的 xxxServicer13class xxxServer(yyy_pb2_grpc.xxxServicer):
14# 实现 proto 文件中定义的GRPC调用15def SendRequest(self, request, context):
16         json_response = xxx_pb2.xxxResponse()
17         json_response.rst_string = json.dumps({"ret": "Hi grpc"})
18return json_response
192021def 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()  # 开始接收请求进行服务27try:
28while True:
29             time.sleep(60 * 60 * 24)  # one day in seconds30except KeyboardInterrupt:
31        server.stop(0)
323334if__name__ == ‘__main__‘:
35     serve()

             1
            #
             coding:utf-8
             2
             3
            import
             grpc

             4
            import
             xxx_pb2, yyy_pb2_grpc

             5
             6 _HOST = ‘‘# todo 7 _PORT = ‘‘# todo 8 910def 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())
14print("received: " + response.message + response.result)
151617if__name__ == ‘__main__‘:
18     main()

• 客服端一次请求, 服务器一次应答
• 客服端一次请求, 服务器多次应答(流式)
• 客服端多次请求(流式), 服务器一次应答
• 客服端多次请求(流式), 服务器多次应答(流式)