.NET8 Web Api GraphQL代理服务：获取原查询并转发的最优方案咨询

需求背景 #

基于.NET 8 Web API + HotChocolate开发GraphQL代理服务，核心需求：

• 转发GraphQL请求到黑盒GraphQL服务，并注入额外认证头
• 服务需支持Schema Stitching，被前端代理服务整合展示（前端仅做Schema合并，无业务实现）

现有方案分析 #

方案1：HTTP请求拦截转发 #

• 思路：捕获原始HTTP请求体，筛选GraphQL请求后通过HttpClient转发到远程服务
• 问题：
  • HotChocolate处理请求后会清空context.Request.Body，直接在HttpRequestInterceptor中无法读取原始请求体
  • 若提前用.NET中间件缓存请求体，需额外过滤非GraphQL请求（如健康检查、静态资源），增加逻辑复杂度
• 可行性：技术上可实现（需缓存请求体到内存流），但不够优雅，且无法结合Schema Stitching的字段级代理需求

方案2：Resolver中提取查询片段转发 #

• 思路：在每个Query的Resolver方法（如GetFoo）中，通过IQueryRequestBuilder提取对应查询片段再转发
• 问题：
  • IQueryRequestBuilder无法精准获取当前Resolver对应的子查询片段，HotChocolate的Resolver上下文仅聚焦当前字段执行，不暴露局部查询内容
  • 每个Resolver都要重复实现转发逻辑，代码冗余，且无法处理嵌套查询、变量传递等复杂场景
• 可行性：基本不可行，无法满足实际业务需求

最优方案：利用HotChocolate原生Remote Schema/Stitching能力 #

HotChocolate内置了Schema Stitching和远程Schema代理的支持，完全适配你的场景，无需手动处理请求转发或查询提取：

实现步骤 #

1. 配置HttpClient注入认证头，连接远程黑盒服务
2. 通过AddSchemaStitching整合远程Schema，自动实现请求代理

代码示例 #

// Program.cs
builder.Services.AddHttpClient("BlackBoxGraphQL", client =>
{
    client.BaseAddress = new Uri("https://your-blackbox-graphql-endpoint.com/graphql");
    // 添加全局认证头
    client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", "your-auth-token");
});

builder.Services.AddGraphQLServer()
    .AddSchemaStitching()
    .AddRemoteSchema("BlackBoxService", async sp =>
    {
        var httpClient = sp.GetRequiredService<IHttpClientFactory>().CreateClient("BlackBoxGraphQL");
        // 自动拉取远程Schema并代理请求
        return await SchemaClient.CreateAsync(httpClient);
    });

优势 #

• 自动同步远程Schema，支持Schema Stitching无缝整合
• 无需手动处理请求转发、变量解析、嵌套查询，HotChocolate全量代理
• 通过HttpClient统一配置认证头，无需在每个请求中重复处理
• 完美适配前端代理服务的Schema展示需求

备选方案：手动缓存请求体的HTTP拦截（特殊场景） #

如果有特殊业务逻辑需要完全透传原始请求（而非字段级代理），可以通过中间件缓存请求体：

代码示例 #

// 注册缓存请求体的中间件（放在GraphQL中间件之前）
app.Use(async (context, next) =>
{
    if (context.Request.Path.StartsWithSegments("/graphql"))
    {
        // 启用请求体缓存，允许重复读取
        context.Request.EnableBuffering();
        // 重置流位置，确保HotChocolate能正常读取
        context.Request.Body.Position = 0;
    }
    await next();
});

// 自定义HttpRequestInterceptor读取原始请求体
public class HttpRequestInterceptor : DefaultHttpRequestInterceptor
{
    private readonly IHttpClientFactory _httpClientFactory;

    public HttpRequestInterceptor(IHttpClientFactory httpClientFactory)
    {
        _httpClientFactory = httpClientFactory;
    }

    public override async ValueTask OnCreateAsync(HttpContext context,
        IRequestExecutor requestExecutor, OperationRequestBuilder requestBuilder,
        CancellationToken cancellationToken)
    {
        if (context.Request.Path.StartsWithSegments("/graphql"))
        {
            context.Request.Body.Position = 0;
            var rawRequestBody = await new StreamReader(context.Request.Body).ReadToEndAsync(cancellationToken);
            
            // 转发到远程服务
            var httpClient = _httpClientFactory.CreateClient("BlackBoxGraphQL");
            var response = await httpClient.PostAsync("", 
                new StringContent(rawRequestBody, Encoding.UTF8, "application/json"), 
                cancellationToken);
            
            // 处理响应并返回（此方式会绕过HotChocolate的Schema验证，仅适合完全透传）
            var responseContent = await response.Content.ReadAsStringAsync(cancellationToken);
            context.Response.ContentType = "application/json";
            await context.Response.WriteAsync(responseContent, cancellationToken);
            return;
        }

        await base.OnCreateAsync(context, requestExecutor, requestBuilder, cancellationToken);
    }
}

注意：此方案会绕过HotChocolate的Schema处理，仅适合无需Schema Stitching字段级控制的场景。

内容的提问来源于stack exchange，提问作者V. A.