gRPC服务端需用public async IAsyncEnumerable<T>方法配合[EnumeratorCancellation]参数返回流式数据，禁用Task<IAsyncEnumerable<T>>；客户端async foreach需捕获RpcException并基于游标重试，Protobuf须声明stream关键字。
gRPC 服务端如何正确返回 IAsyncEnumerable<T>
ASP.NET Core 6+ 的 gRPC 服务支持直接将 IAsyncEnumerable<T> 作为流式响应类型，但必须配合 yield return 或手动构造可取消的异步枚举器；直接返回 Task<IAsyncEnumerable<T>> 会导致客户端收不到任何消息，因为 gRPC 框架只识别裸的 IAsyncEnumerable<T>（不是 Task 包裹的）。
- 服务方法签名必须是
public async IAsyncEnumerable<Response> StreamData(Request request, [EnumeratorCancellation] CancellationToken cancellationToken = default) -
[EnumeratorCancellation]是关键：它让 gRPC 在客户端断连时自动触发 cancellation，避免后台任务泄漏 - 不要在方法内用
await foreach消费另一个IAsyncEnumerable后再 yield —— 这会阻塞流式推送；应直接yield return或使用Channel<T>.Reader.ReadAllAsync() - 若需组合多个数据源，优先用
Channel<T>+ 后台生产者，而非拼接多个IAsyncEnumerable
客户端调用 IAsyncEnumerable 流时的生命周期陷阱
客户端 C# 使用 async foreach 消费服务端流时，GrpcChannel 不会自动重连或重试；一旦底层 HTTP/2 连接中断（如超时、网络抖动），MoveNextAsync() 会抛出 RpcException 并终止循环 —— 不会自动恢复流。
- 显式捕获
RpcException并检查Status.StatusCode == StatusCode.Unavailable才考虑重试 - 不要在
async foreach外层套try/catch后简单重进循环：这会丢失已消费的项，且可能重复请求 - 若需断线续传，服务端必须支持游标（如
lastSeenId参数），客户端在异常前记录最后处理的 ID -
CancellationToken传给foreach仅控制当前迭代，不影响连接本身；连接级超时由CallOptions中的Deadline控制
IAsyncEnumerable 和传统 IServerStreamWriter<T> 的性能与调试差异
两者都走 gRPC Server Streaming，但底层行为不同：IAsyncEnumerable 由框架自动管理写入节奏和背压，而 IServerStreamWriter<T> 要求你手动调用 WriteAsync，并自行处理 HttpContext.RequestAborted。
- 调试时，
IAsyncEnumerable的异常堆栈更干净，错误直接出现在yield return行；IServerStreamWriter的异常可能被吞掉或延迟抛出 - 高吞吐场景下，
IAsyncEnumerable默认使用Channel<T>缓冲，缓冲区大小影响内存占用；可通过Channel.CreateBounded<T>(new BoundedChannelOptions(100))显式控制 - 若需精细控制每条消息的发送时机（如等待 ACK），必须用
IServerStreamWriter；IAsyncEnumerable是“fire-and-forget”模型 - 单元测试
IAsyncEnumerable方法更简单：直接await foreach+Assert，无需模拟ServerStreamWriter
常见编译错误和生成代码适配点
Protobuf 定义中必须声明 stream 关键字，否则 dotnet-grpc 工具不会为服务端生成 IAsyncEnumerable 返回类型，而是退化为单次响应。
service DataStreamer {
rpc StreamUpdates (StreamRequest) returns (stream StreamResponse); // ✅ 必须有 stream
}- 若升级到 .NET 6+ 但项目仍用旧版
Grpc.AspNetCore（IAsyncEnumerable 支持不完整，需更新 NuGet 包 - 客户端引用服务时，确保
Grpc.Net.Client≥ 2.46.0，否则CallInvoker.AsyncStreamingCall可能无法正确包装IAsyncEnumerable - 生成的
*.Grpc.cs文件里，服务端接口方法返回类型应为IAsyncEnumerable<StreamResponse>；若仍是Task<StreamResponse>，检查 .proto 是否漏了stream或是否启用了grpc_use_deprecated_api
实际用起来最易忽略的是：服务端 IAsyncEnumerable 方法里的 cancellationToken 必须加 [EnumeratorCancellation] 属性，否则客户端断开时，你的 while 循环根本收不到通知，协程就卡在那儿了。
