### 使用Python实现gRPC客户端和服务端 #### 创建项目结构 为了更好地理解如何使用Python构建gRPC客户端和服务端，先了解基本的文件夹布局： ```plaintext my_grpc_project/ │ ├── my_service_pb2.py # Protocol Buffer编译后的Python类 ├── my_service_pb2_grpc.py # gRPC stubs 和 server接口 ├── service_server.py # 服务端逻辑实现 └── service_client.py # 客户端逻辑实现 ``` #### 准备工作环境 安装必要的库和工具对于设置开发环境至关重要。确保已安装`grpcio`和`grpcio-tools`这两个包[^2]。 ```bash virtualenv venv call venv\Scripts\activate pip install grpcio grpcio-tools ``` #### 编写Protocol Buffers定义 创建`.proto`文件来描述服务及其方法。这里提供了一个简单的例子作为示范： ```protobuf syntax = "proto3"; package example; service MyService { rpc SayHello (HelloRequest) returns (HelloReply); } message HelloRequest { string name = 1; } message HelloReply { string message = 1; } ``` 保存此文件名为`my_service.proto`并将其放置于项目的根目录下。 #### 生成Python代码 利用命令行工具从上述`.proto`文件自动生成所需的Python模块： ```bash python -m grpc_tools.protoc -I=. --python_out=. --grpc_python_out=. ./my_service.proto ``` 这会生成两个新的Python脚本——一个是用于序列化的协议缓冲区类(`*_pb2.py`)；另一个包含了服务器存根及客户端stub (`*_pb2_grpc.py`)。 #### 实现服务端 编写`service_server.py`以启动gRPC服务器，并注册实现了所定义的服务接口的对象实例。 ```python import grpc from concurrent import futures import time import my_service_pb2 as pb2 import my_service_pb2_grpc as pb2_grpc class MyServicer(pb2_grpc.MyServiceServicer): def SayHello(self, request, context): response = pb2.HelloReply() response.message = f'Hello {request.name}' return response def serve(): server = grpc.server(futures.ThreadPoolExecutor(max_workers=10)) pb2_grpc.add_MyServiceServicer_to_server(MyServicer(), server) server.add_insecure_port('[::]:50051') server.start() try: while True: time.sleep(86400) except KeyboardInterrupt: server.stop(0) if __name__ == '__main__': serve() ``` #### 构建客户端 接下来，在`service_client.py`中编码一段程序去连接到之前建立好的gRPC服务器，并调用它的API。 ```python import grpc import my_service_pb2 as pb2 import my_service_pb2_grpc as pb2_grpc def run(): with grpc.insecure_channel('localhost:50051') as channel: stub = pb2_grpc.MyServiceStub(channel) hello_request = pb2.HelloRequest(name='World') reply = stub.SayHello(hello_request) print("Greeter client received:", reply.message) if __name__ == '__main__': run() ``` 以上就是完整的流程介绍，展示了怎样借助Python语言搭建起一套基础版的gRPC通信框架[^1]。