### 在 .NET Framework 4.8 和 Python 之间使用 gRPC 实现双向通信 gRPC 提供了一种高效的方式，在不同的编程语言之间建立高效的远程过程调用（Remote Procedure Call, RPC）。以下是关于如何在 .NET Framework 4.8 和 Python 之间实现 gRPC 双向通信的具体说明和示例代码。 #### 关键技术点 1. **Proto 文件定义**：gRPC 使用 `.proto` 文件来定义服务接口和数据模型。此文件会被用来生成客户端和服务端的存根代码。 2. **服务端 (.NET Framework 4.8)**：由于 .NET Framework 4.8 支持 .NET Standard 2.0，可以直接使用官方的 gRPC NuGet 包[^1]。 3. **客户端 (Python)**：Python 社区提供了 `grpcio` 工具链，能够轻松生成客户端代码并与服务端交互[^4]。 --- ### 步骤一：定义 Proto 文件 首先创建一个名为 `example.proto` 的文件，用于描述服务及其方法： ```protobuf syntax = "proto3"; option csharp_namespace = "Example.Grpc"; package example; // 定义服务 service ExampleService { rpc BidirectionalStream (stream StreamMessage) returns (stream StreamMessage); } // 定义消息结构 message StreamMessage { string message = 1; } ``` --- ### 步骤二：生成 C# 和 Python 存根代码 #### 对于 C# 安装以下 NuGet 包： - Grpc.Tools - Grpc.Core.Api 运行命令生成 C# 类文件： ```bash protoc --csharp_out=./GeneratedCode ./example.proto --grpc_out=./GeneratedCode --plugin=protoc-gen-grpc=C:\Path\To\grpc_csharp_plugin.exe ``` #### 对于 Python 安装依赖项： ```bash pip install grpcio grpcio-tools protobuf ``` 运行命令生成 Python 类文件： ```bash python -m grpc_tools.protoc -I=. --python_out=./generated_code --grpc_python_out=./generated_code ./example.proto ``` --- ### 步骤三：实现服务端逻辑 (.NET Framework 4.8) 以下是服务端的核心实现代码： ```csharp using System; using System.Collections.Generic; using System.Threading.Tasks; using Grpc.Core; using Example.Grpc; // 自动生成的命名空间 class Program { const int Port = 50051; public static void Main(string[] args) { Server server = new Server { Services = { ExampleService.BindService(new ExampleServiceImpl()) }, Ports = { new ChannelPort("localhost", Port, ServerCredentials.Insecure) } }; server.Start(); Console.WriteLine("Server started on port " + Port); Console.ReadKey(); server.ShutdownAsync().Wait(); } } public class ExampleServiceImpl : ExampleService.ExampleServiceBase { public override async Task BidirectionalStream( IAsyncStreamReader<StreamMessage> requestStream, IServerStreamWriter<StreamMessage> responseStream, ServerCallContext context) { while (await requestStream.MoveNext()) { var incomingMessage = requestStream.Current.Message; Console.WriteLine($"Received from client: {incomingMessage}"); await responseStream.WriteAsync(new StreamMessage { Message = $"Echoed by server: {incomingMessage}" }); } } } ``` --- ### 步骤四：实现客户端逻辑 (Python) 以下是 Python 客户端的核心实现代码： ```python import grpc from generated_code.example_pb2 import StreamMessage from generated_code.example_pb2_grpc import ExampleServiceStub def run_client(): channel = grpc.insecure_channel('localhost:50051') stub = ExampleServiceStub(channel) def generate_messages(): messages = ["Hello", "World", "This is bidirectional streaming"] for msg in messages: yield StreamMessage(message=msg) time.sleep(1) # Simulate delay between sending messages responses = stub.BidirectionalStream(generate_messages()) try: for response in responses: print(f"Response received: {response.message}") except grpc.RpcError as e: print(f"gRPC Error: {e.details()}") if __name__ == '__main__': run_client() ``` --- ### 测试流程 1. 启动服务端程序，监听指定端口。 2. 运行 Python 客户端脚本，观察控制台输出是否显示双方的消息交换情况。 --- ### 技术细节补充 - **双工流原理**：gRPC 的双工流允许可读写操作在同一连接上并发进行，从而减少延迟并提高效率[^3]。 - **跨语言互操作性**：通过标准化的 `.proto` 文件定义，确保了不同语言之间的无缝协作[^1]。 ---