gRPC是Google开源的高性能远程过程调用框架，基于HTTP/2协议设计，支持多种通信模式，其中双向流模式允许客户端和服务端在单个连接上同时双向发送消息，非常适合实时通信、批量数据传输等场景，能有效减少连接开销，提升RPC调用的整体效率。
gRPC双向流核心概念
gRPC定义了四种通信模式，双向流是其中一种高级模式，和一元调用、服务端流、客户端流的区别如下：
| 通信模式 | 客户端发送消息数 | 服务端发送消息数 | 适用场景 |
|---|---|---|---|
| 一元调用 | 1 | 1 | 简单请求响应场景 |
| 客户端流 | 多 | 1 | 客户端批量上传数据 |
| 服务端流 | 1 | 多 | 服务端推送实时数据 |
| 双向流 | 多 | 多 | 实时双向交互场景 |
双向流的核心是stream关键字，在proto文件中定义服务方法时，使用stream修饰请求参数和响应参数，就可以开启双向流模式。
环境准备与proto文件定义
首先需要在C#项目中安装gRPC相关依赖，以.NET 6及以上版本为例，需要安装以下NuGet包：
- Grpc.AspNetCore
- Grpc.Tools
- Google.Protobuf
接下来定义proto文件，假设我们要实现一个实时消息同步的双向流服务，proto文件内容如下：
syntax = "proto3";
option csharp_namespace = "GrpcBidirectionalStreamDemo";
package message;
// 定义消息结构
message ChatMessage {
string sender = 1;
string content = 2;
int64 timestamp = 3;
}
// 定义双向流服务
service ChatService {
// 双向流方法，客户端和服务端都可以持续发送消息
rpc SyncMessage (stream ChatMessage) returns (stream ChatMessage);
}
定义完成后，编译项目会自动生成对应的C#服务基类和客户端调用类。
服务端双向流实现
创建继承自生成的服务基类的实现类，处理双向流的消息收发逻辑：
using Grpc.Core;
using GrpcBidirectionalStreamDemo;
namespace GrpcBidirectionalStreamDemo.Services;
public class ChatServiceImpl : ChatService.ChatServiceBase
{
// 实现双向流方法
public override async Task SyncMessage(IAsyncStreamReader<ChatMessage> requestStream, IServerStreamWriter<ChatMessage> responseStream, ServerCallContext context)
{
// 启动一个任务处理客户端发送的消息
var readClientMessageTask = Task.Run(async () =>
{
// 循环读取客户端发送的消息
while (await requestStream.MoveNext() && !context.CancellationToken.IsCancellationRequested)
{
var clientMessage = requestStream.Current;
Console.WriteLine($"收到客户端消息：发送者{clientMessage.Sender}，内容{clientMessage.Content}");
// 这里可以添加业务逻辑，比如消息转发、存储等
}
});
// 模拟服务端主动发送消息的逻辑
var sendServerMessageTask = Task.Run(async () =>
{
// 模拟每隔1秒发送一条服务端消息
for (int i = 0; i < 5; i++)
{
if (context.CancellationToken.IsCancellationRequested)
{
break;
}
var serverMessage = new ChatMessage
{
Sender = "Server",
Content = $"服务端推送消息{i + 1}",
Timestamp = DateTimeOffset.UtcNow.ToUnixTimeSeconds()
};
await responseStream.WriteAsync(serverMessage);
await Task.Delay(1000);
}
});
// 等待两个任务完成
await Task.WhenAll(readClientMessageTask, sendServerMessageTask);
}
}
然后在Program.cs中注册gRPC服务：
var builder = WebApplication.CreateBuilder(args);
// 添加gRPC服务
builder.Services.AddGrpc();
var app = builder.Build();
// 映射gRPC服务
app.MapGrpcService<ChatServiceImpl>();
// 配置HTTP端口
app.MapGet("/", () => "gRPC服务运行中");
app.Run();
客户端双向流实现
客户端需要创建gRPC通道，然后调用双向流方法，同时处理消息的发送和接收：
using Grpc.Core;
using GrpcBidirectionalStreamDemo;
using Grpc.Net.Client;
namespace GrpcBidirectionalStreamDemo.Client;
class Program
{
static async Task Main(string[] args)
{
// 创建gRPC通道，地址为服务端地址
using var channel = GrpcChannel.ForAddress("http://localhost:5000");
var client = new ChatService.ChatServiceClient(channel);
// 调用双向流方法，获取请求流和响应流
using var call = client.SyncMessage();
// 启动任务处理服务端返回的消息
var readResponseTask = Task.Run(async () =>
{
while (await call.ResponseStream.MoveNext() && !call.CancellationToken.IsCancellationRequested)
{
var serverMessage = call.ResponseStream.Current;
Console.WriteLine($"收到服务端消息：发送者{serverMessage.Sender}，内容{serverMessage.Content}");
}
});
// 模拟客户端发送消息
for (int i = 0; i < 3; i++)
{
var clientMessage = new ChatMessage
{
Sender = "Client",
Content = $"客户端发送消息{i + 1}",
Timestamp = DateTimeOffset.UtcNow.ToUnixTimeSeconds()
};
await call.RequestStream.WriteAsync(clientMessage);
await Task.Delay(500);
}
// 客户端发送完消息后，标记请求流完成
await call.RequestStream.CompleteAsync();
// 等待响应处理完成
await readResponseTask;
Console.WriteLine("双向流通信结束");
}
}
提升gRPC双向流调用效率的技巧
连接复用
gRPC基于HTTP/2协议，单个连接支持多路复用，不需要为每个调用创建新连接，客户端可以复用同一个GrpcChannel实例，减少连接建立的开销。
消息批处理
如果有大量小消息需要发送，可以将多个小消息合并成一个批量消息发送，减少消息头部的开销，提升传输效率。
合理设置消息大小限制
默认情况下gRPC有消息大小限制，如果传输大文件等场景，可以合理调整MaxReceiveMessageSize和MaxSendMessageSize配置，避免消息被截断。
使用异步编程
双向流的消息读写都是异步操作，尽量使用异步方法，避免阻塞线程，提升并发处理能力。
常见问题与注意事项
1. 双向流的生命周期：当客户端调用RequestStream.CompleteAsync()后，不能再发送消息，服务端读取完客户端消息后会结束对应的读取任务。
2. 异常处理：需要在代码中捕获RpcException等异常，处理连接断开、超时等场景，避免程序崩溃。
3. 取消令牌：可以通过CancellationToken控制双向流的取消，在不需要通信时及时取消，释放资源。
双向流模式适合需要持续双向交互的场景，如果只需要单次请求响应，使用一元调用会更简单高效，需要根据实际业务场景选择合适的通信模式。
gRPC双向流C#RPC调用Protocol_Buffers修改时间：2026-07-14 18:54:36