在Python中实现gRPC协议数据序列化和反序列化的标准方法

syntax = "proto3";

message MyMessage {
  string name = 1;
  int32 age = 2;
}

$ python -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. message.proto

import grpc
import message_pb2
import message_pb2_grpc

class MyService(message_pb2_grpc.MyServiceServicer):
    def MyMethod(self, request, context):
        response = message_pb2.MyResponse()
        response.message = "Hello, " + request.name
        return response

def serve():
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    message_pb2_grpc.add_MyServiceServicer_to_server(MyService(), server)
    server.add_insecure_port('[::]:50051')
    server.start()
    server.wait_for_termination()

if __name__ == '__main__':
    serve()

import grpc
import message_pb2
import message_pb2_grpc

def run():
    channel = grpc.insecure_channel('localhost:50051')
    stub = message_pb2_grpc.MyServiceStub(channel)
    request = message_pb2.MyRequest()
    request.name = "Alice"
    response = stub.MyMethod(request)
    print(response.message)

if __name__ == '__main__':
    run()