如何实现基于HTTP23的流模式消息交换机制？
摘要：我想很多人已经体验过GRPC提供的三种流式消息交换（Client Stream、Server Stream和Duplex Stream）模式，在.NET Core上构建的GRPC应用本质上是采用HTTP2HTTP3协议的ASP.NET C
我想很多人已经体验过GRPC提供的三种流式消息交换（Client Stream、Server Stream和Duplex Stream）模式，在.NET Core上构建的GRPC应用本质上是采用HTTP2/HTTP3协议的ASP.NET Core应用，我们当然也可以在一个普通的ASP.NET Core应用实现这些流模式。不仅如此，HttpClient也提供了响应的支持，这篇文章通过一个简单的实例提供了相应的实现，源代码从这里下载。
一、双向流的效果
二、[服务端]流式请求/响应的读写
三、[客户端]流式响应/请求的读写
一、双向流的效果在提供具体实现之前，我们不妨先来演示一下最终的效果。我们通过下面这段代码构建了一个简单的ASP.NET Core应用，如代码片段所示，在调用WebApplication的静态方法CreateBuilder将WebApplicationBuilder创建出来后，我们调用其扩展方法UseKestrel将默认终结点的监听协议设置为Http1AndHttp2AndHttp3，这样我们的应用将提供针对不同HTTP协议的全面支持。
var url = "http://localhost:9999";
var builder = WebApplication.CreateBuilder(args);
builder.WebHost
.UseKestrel(kestrel=> kestrel.ConfigureEndpointDefaults(listen=>listen.Protocols = HttpProtocols.Http1AndHttp2AndHttp3))
.UseUrls(url);
var app = builder.Build();
app.MapPost("/", httpContext=> HandleRequestAsync(httpContext, async (request, writer) => {
Console.WriteLine($"[Server]Receive request message: {request}");
await writer.WriteStringAsync(request);
}));
await app.StartAsync();
await SendStreamRequestAsync(url, ["foo", "bar", "baz", "qux"], reply => {
Console.WriteLine($"[Client]Receive reply message: {reply}\n");
return Task.CompletedTask;
});我们针对根路径（/）注册了一个HTTP方法为POST的路由终结点，终结点处理器调用HanleRequestAsync来处理请求。这个方法提供一个Func<string， PipeWriter, Task>类型的参数作为处理器，该委托的第一个参数表示接收到的单条请求消息，PipeWriter用来写入响应内容。在这里我们将接收到的消息进行简单格式化后将其输出到控制台上，随之将其作为响应内容进行回写。
在应用启动之后，我们调用SendStreamRequestAsync方法以流的方式发送请求，并处理接收到的响应内容。该方法的第一个参数为请求发送的目标URL，第二个参数是一个字符串数组，我们将以流的方式逐个发送每个字符串。最后的参数是一个Func<string,Task>类型的委托，用来处理接收到的响应内容（字符串），在这里我们依然是将格式化的响应内容直接打印在控制台上。
程序启动后控制台上将出现如上图所示的输出，客户端/服务端接收内容的交错输出体现了我们希望的“双向流式”消息交换模式。我们将在后续介绍HanleRequestAsync和SendStreamRequestAsync方法的实现逻辑。
二、[服务端]流式请求/响应的读写HanleRequestAsync方法定义如下。如代码片段所示，我们利用请求的BodyReader和响应的BodyWriter来对请求和响应内容进行读写，它们的类型分别是PipeReader和PipeWriter。在一个循环中，在利用BodyReader将请求缓冲区内容读取出来后，我们将得到的ReadOnlySequence<byte>对象作为参数调用辅助方法TryReadMessage读取单条请求消息，并调用handler参数表示的处理器进行处理。当请求内容接收完毕后，循环终止。