基于HTTP2/3的流模式消息交换如何实现？
内容提要
这篇文章介绍了在.NET Core上构建GRPC应用的流式消息交换模式。通过一个简单的实例演示了双向流的效果，以及服务端和客户端的流式请求和响应的读写。文章提供了相应的实现代码和方法逻辑。
延伸解读
流式消息交换的协议基础
文章指出，在.NET Core上构建的gRPC应用本质上是采用HTTP/2或HTTP/3协议的ASP.NET Core应用。这意味着开发者可以在普通ASP.NET Core应用中直接利用HTTP/2/3的多路复用和流特性实现流式消息交换，而无需依赖gRPC框架。示例中通过Kestrel配置同时支持HTTP/1、HTTP/2和HTTP/3，为不同客户端提供了协议兼容性。
自定义消息帧格式的必要性
由于流式传输中消息边界不固定，文章采用“长度前缀+负载”的自定义帧格式来区分每条消息。服务端和客户端都使用TryReadMessage方法读取4字节小端整数表示的消息长度，再根据长度截取UTF-8编码的消息内容。这种简单帧格式确保了在连续字节流中能准确解析出单条消息，但需要通信双方严格遵守相同的编码规则。
客户端流式请求的实现机制
客户端通过继承HttpContent并重写SerializeToStreamAsync方法，将自定义的StreamContentWriter与请求输出流关联。StreamContentWriter利用TaskCompletionSource协调流的设置与写入，WriteAsync方法最终调用PipeWriter的WriteStringAsync扩展方法发送消息。发送完成后调用Complete方法通知序列化结束，从而完成整个流式请求的发送。
双向流式交互的并发处理
示例中客户端使用HttpClient发送请求时指定HttpCompletionOption.ResponseHeadersRead，以便在收到响应头后立即开始处理响应流，而不必等待整个响应体接收完毕。同时，客户端在一个独立Task中异步读取响应流，主线程则继续通过writer.WriteAsync逐条发送请求消息。这种设计实现了请求发送与响应接收的并行，体现了双向流式交换的交互特性。
Q&A
GRPC的流式消息交换模式有哪些？
GRPC提供三种流式消息交换模式：Client Stream、Server Stream和Duplex Stream。
如何在.NET Core上实现双向流的消息交换？
可以通过ASP.NET Core应用，使用HttpClient发送流式请求和响应，结合HandleRequestAsync和SendStreamRequestAsync方法实现双向流。
HandleRequestAsync方法的作用是什么？
HandleRequestAsync方法用于处理服务端的流式请求和响应，通过读取请求内容并调用处理器进行处理。
如何使用HttpClient发送流式请求？
使用HttpClient创建HttpRequestMessage对象，并通过重写StreamContent类的SerializeToStreamAsync方法实现流式请求的发送。
TryReadMessage方法的功能是什么？
TryReadMessage方法用于读取请求消息的长度和内容，并将其解码为字符串。
StreamContentWriter类的作用是什么？
StreamContentWriter类用于设置请求输出流并实现流式请求内容的写入。
