Ocelot网关中动态替换下游Host的问题求助

问题根源 #

Ocelot默认会缓存路由匹配结果，首次请求时你修改了下游Host信息，但后续请求会复用缓存中的路由配置，导致无法重新根据tenantId切换到对应存储账户。

解决方案 #

1. 禁用目标路由的缓存 #

在你的Ocelot配置文件中，给该路由添加缓存禁用配置，确保每次请求都会重新执行路由匹配流程：

{
  "DownstreamPathTemplate": "/{sasToken}",
  "DownstreamScheme": "https",
  "DownstreamHostAndPorts": [
    {
      "Host": "ReplacedInRuntime",
      "Port": 443
    }
  ],
  "UpstreamPathTemplate": "/api/{version}/Media/{tenantId}/{sasToken}",
  "UpstreamHttpMethod": [ "POST", "PUT", "GET", "DELETE" ],
  "SwaggerKey": "backgroundService",
  "CacheOptions": {
    "IsCached": false,
    "TtlSeconds": 0
  }
}

2. 调整中间件执行时机并简化路由修改逻辑 #

将中间件从PreQueryStringBuilderMiddleware改为PreRoutingMiddleware（路由匹配完成后立即执行），同时直接修改已有路由对象的下游地址，避免重新创建整个DownstreamRoute对象：

Program.cs配置修改：

var configuration = new OcelotPipelineConfiguration
{
    PreRoutingMiddleware = async (ctx, next) =>
    {
        await preRoutingMiddleware.InvokeAsync(ctx, options, next);
    }
};

中间件内部逻辑修改：

// 从URL路由参数中获取tenantId
var tenantId = httpContext.Request.RouteValues["tenantId"]?.ToString();
if (string.IsNullOrEmpty(tenantId))
{
    httpContext.Response.StatusCode = StatusCodes.Status400BadRequest;
    await httpContext.Response.WriteAsync("tenantId参数缺失");
    return;
}

var downstreamRoute = httpContext.Items.DownstreamRoute();
if (downstreamRoute != null)
{
    // 直接替换下游地址列表，无需重建整个DownstreamRoute对象
    downstreamRoute.DownstreamAddresses = new List<DownstreamHostAndPort>()
    { 
        new DownstreamHostAndPort($"{tenantId}{storageAccountOptions.StorageAccountSuffix}", storageAccountOptions.StorageAccountDefaultPort)
    };
    // 更新上下文路由确保修改生效
    httpContext.Items.UpsertDownstreamRoute(downstreamRoute);
}

await next.Invoke();

说明 #

• 禁用路由缓存是核心：确保每次请求都会触发路由匹配流程，让中间件有机会根据当前请求的tenantId更新下游地址。
• 提前中间件执行时机：PreRoutingMiddleware在路由匹配完成后立即执行，此时修改路由不会被后续缓存逻辑覆盖。
• 简化路由修改：直接修改现有路由对象的DownstreamAddresses字段，避免因重建对象导致的上下文同步问题。

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