基于ServiceStack的微服务：复用JsonServiceClient如何隔离线程HTTP头？

嘿，我来帮你理清这个问题——我在ServiceStack和分布式跟踪这块踩过不少坑，正好能给你靠谱的解决方案。首先得明确一个关键事实：ServiceStack的JsonServiceClient实例本身不是线程安全的，它的Headers集合是实例级别的共享状态，如果多个并发请求同时修改这个集合，必然会导致请求头泄露、互相覆盖的问题。不过咱们可以通过以下几种方式，既实现客户端复用（兼顾性能），又保证请求头的线程隔离：

方案1：使用请求级过滤器（Request Filter）+ 单例客户端 #

这是我最推荐的方式，既能复用客户端实例（避免频繁创建销毁的开销），又能确保每个请求的头是独立的。原理是利用ServiceStack的IClientFilter，在每次发送请求前动态添加当前请求的关联令牌，而不是修改客户端的全局Headers。

具体步骤： #

1. 先注册IHttpContextAccessor（.NET Core需要手动注册，用来获取当前请求上下文）：

services.AddHttpContextAccessor();

2. 注册单例的JsonServiceClient，并添加请求过滤器：

services.AddSingleton(sp => {
    var client = new JsonServiceClient("http://your-service-base-url");
    var httpContextAccessor = sp.GetRequiredService<IHttpContextAccessor>();
    
    // 添加请求过滤器，每次发送请求前设置关联令牌
    client.RequestFilter += (req, res, dto) => {
        var httpContext = httpContextAccessor.HttpContext;
        if (httpContext?.Request.Headers.TryGetValue("X-Correlation-Id", out var correlationId) == true)
        {
            // 为当前请求单独添加关联令牌头，不会碰客户端的全局Headers
            req.Headers.Add("X-Correlation-Id", correlationId.ToString());
        }
    };
    
    return client;
});

3. 在你的业务类里注入并使用客户端就行：

public class MyServiceClientWrapper
{
    private readonly JsonServiceClient _client;

    public MyServiceClientWrapper(JsonServiceClient client)
    {
        _client = client;
    }

    public TResponse Get<TResponse>(IReturn<TResponse> requestDto)
    {
        // 直接调用就行，过滤器会自动帮你加好关联令牌头
        return _client.Get(requestDto);
    }
}

为啥这个方案安全？ #

• 请求过滤器是针对每个请求单独执行的，req参数是当前请求的HttpWebRequest实例，修改它的Headers只会影响这一次请求，完全不会污染客户端的全局Headers集合。
• IHttpContextAccessor是通过AsyncLocal存储当前请求上下文的，并发请求之间绝对不会互相串线。

方案2：使用Scoped生命周期的客户端 #

如果对性能要求没那么极致，或者不想折腾过滤器，也可以把JsonServiceClient注册为Scoped（每个请求一个实例）：

services.AddScoped(sp => {
    var client = new JsonServiceClient("http://your-service-base-url");
    var httpContextAccessor = sp.GetRequiredService<IHttpContextAccessor>();
    
    var httpContext = httpContextAccessor.HttpContext;
    if (httpContext?.Request.Headers.TryGetValue("X-Correlation-Id", out var correlationId) == true)
    {
        client.Headers.Add("X-Correlation-Id", correlationId.ToString());
    }
    
    return client;
});

这种方式下，每个请求的客户端实例都是独立的，请求头自然不会泄露。虽然会增加一点实例创建销毁的开销，但ServiceStack客户端的创建成本其实很低，大部分业务场景下完全可以接受。

绝对要避开的坑 #

千万别直接复用单例客户端，还在业务代码里修改它的Headers：

// 大错特错！多个线程同时调用会导致Headers互相覆盖，关联令牌串到别的请求里
public TResponse Get<TResponse>(IReturn<TResponse> requestDto)
{
    _client.Headers["X-Correlation-Id"] = GetCurrentCorrelationId();
    return _client.Get(requestDto);
}

_client.Headers是共享状态，并发请求时肯定会出现线程安全问题，到时候你的Seq日志就乱套了。

额外提一句Seq跟踪的最佳实践 #

记得让你的所有微服务都把关联令牌加到日志上下文里：

• 在每个微服务的请求管道里，提取X-Correlation-Id头，把它添加到日志上下文（比如Serilog的LogContext）。
• 这样Seq就能通过关联令牌把整个请求链的日志串起来，实现真正的全链路跟踪。

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