WebAssembly环境下Streaming GRPC调用仅在流结束后返回数据求助

Uno WASM目标平台基于浏览器运行时，依赖Fetch API处理HTTP请求，默认会缓冲完整响应体后才返回内容；叠加旧版Grpc客户端包兼容性缺陷、服务端+客户端双重响应缓冲、CORS策略未暴露Grpc必需响应头三个问题，共同导致服务端流式响应无法实时返回。

1. 升级Grpc相关依赖包 #

你当前使用的2.39.0版本Grpc客户端包存在WASM环境下流式处理的已知bug，将所有Grpc相关包升级至2.45.0及以上稳定版即可修复：

<PackageReference Include="Google.Protobuf" Version="3.24.3" />
<PackageReference Include="Google.Protobuf.Tools" Version="3.24.3" />
<PackageReference Include="Grpc.Net.Client" Version="2.57.0" />
<PackageReference Include="Grpc.Net.Client.Web" Version="2.57.0" />
<PackageReference Include="Grpc.Tools" Version="2.57.0">
  <PrivateAssets>all</PrivateAssets>
  <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference>

2. 修改客户端GrpcChannel配置，禁用所有缓冲 #

显式关闭通道层面、Http处理层面的响应缓冲，同时开启GrpcWeb流式响应支持：

var address = "http://127.0.0.1:5052";
var httpHandler = new HttpClientHandler();
// 针对WASM平台做特殊配置
if (RuntimeInformation.IsOSPlatform(OSPlatform.Create("BROWSER")))
{
    httpHandler.UseCookies = false;
}
var grpcWebHandler = new GrpcWebHandler(httpHandler) 
{ 
    GrpcWebMode = GrpcWebMode.GrpcWeb,
    EnableStreamingResponses = true
};
var grpcChannel = GrpcChannel.ForAddress(address, new GrpcChannelOptions 
{ 
    HttpHandler = grpcWebHandler,
    DisableResponseBuffering = true // 关键配置：禁用Grpc通道响应缓冲
});

3. 调整服务端配置 #

3.1 完善CORS策略，暴露Grpc必需响应头 #

WASM环境下浏览器会拦截未在CORS策略中声明暴露的自定义头，导致Grpc客户端无法识别流式分块标记：

// 服务端服务注册逻辑中修改CORS配置
builder.Services.AddCors(o => o.AddPolicy("AllowAll", policy =>
{
    policy.AllowAnyOrigin()
          .AllowAnyMethod()
          .AllowAnyHeader()
          // 暴露Grpc流式处理必需的响应头
          .WithExposedHeaders("Grpc-Status", "Grpc-Message", "Grpc-Encoding", "Grpc-Accept-Encoding");
}));

3.2 禁用Grpc接口的服务端响应缓冲 #

在服务端中间件配置中添加如下逻辑，关闭Grpc请求的响应缓冲：

// Startup.cs/Program.cs 路由配置之前添加
app.Use(async (context, next) =>
{
    // 只针对Grpc请求关闭缓冲
    if (context.Request.ContentType == "application/grpc-web" || 
        context.Request.ContentType == "application/grpc-web-text")
    {
        var bodyFeature = context.Features.Get<IHttpResponseBodyFeature>();
        bodyFeature?.DisableBuffering();
    }
    await next();
});

4. 确认Proto接口定义 #

检查你的.proto文件中对应接口是否明确声明为服务端流式：

service StatusApi {
  rpc SubscribeForLogs (LogSubscriptionRequest) returns (stream LogResponse);
}

内容的提问来源于stack exchange，提问作者richej