如何在服务端访问FabricTransportServiceRemotingClientFactory的TraceId？

我来帮你解决这个问题——我之前在项目里正好实现过类似的TraceId传递逻辑，分客户端（APIGateway）传递和服务端获取两步来操作，非常清晰：

一、客户端：把HttpContext.TraceIdentifier传给微服务 #

Fabric Remoting v2的FabricTransportServiceRemotingClientFactory确实支持传入TraceId，核心是通过自定义ITraceIdProvider来提供从HttpContext拿到的TraceIdentifier。

步骤1：实现自定义TraceIdProvider #

首先创建一个类实现ITraceIdProvider，它的作用就是从当前请求的HttpContext里取出TraceIdentifier：

using Microsoft.AspNetCore.Http;
using Microsoft.ServiceFabric.Services.Remoting.V2;

public class HttpContextTraceIdProvider : ITraceIdProvider
{
    private readonly IHttpContextAccessor _httpContextAccessor;

    // 通过DI注入IHttpContextAccessor，ASP.NET Core里必备
    public HttpContextTraceIdProvider(IHttpContextAccessor httpContextAccessor)
    {
        _httpContextAccessor = httpContextAccessor;
    }

    public string GetTraceId()
    {
        // 如果拿不到HttpContext，就生成一个默认的TraceId兜底
        return _httpContextAccessor.HttpContext?.TraceIdentifier ?? Guid.NewGuid().ToString("N");
    }
}

步骤2：注册并使用这个Provider #

在APIGateway的DI配置里，先注册IHttpContextAccessor（ASP.NET Core默认不注册，必须手动加），然后把自定义的TraceIdProvider也注册进去：

services.AddHttpContextAccessor();
services.AddSingleton<ITraceIdProvider, HttpContextTraceIdProvider>();

之后在创建微服务的客户端代理时，把这个TraceIdProvider传入FabricTransportServiceRemotingClientFactory：

var traceIdProvider = serviceProvider.GetRequiredService<ITraceIdProvider>();
var clientFactory = new FabricTransportServiceRemotingClientFactory(
    traceIdProvider: traceIdProvider,
    settings: new FabricTransportRemotingSettings());

// 用这个clientFactory创建你的微服务代理，比如：
var myServiceProxy = ServiceProxy.Create<IMyMicroService>(
    new Uri("fabric:/MyApp/MyMicroService"),
    clientFactory: clientFactory);

这样每次通过代理调用微服务时，TraceId就会自动跟着Remoting请求发过去了。

二、服务端：获取传递过来的TraceId #

服务端获取TraceId有两种常用方式，根据你的需求选：

方式1：在单个服务方法里直接获取 #

如果只需要在特定方法里用TraceId，直接通过ServiceRemotingContext.Current拿就行：

using Microsoft.ServiceFabric.Services.Remoting.V2;

public async Task<MyServiceResponse> DoSomethingAsync()
{
    var traceId = ServiceRemotingContext.Current.TraceId;
    // 直接用这个TraceId打日志或者做追踪
    _logger.LogInformation("处理请求，TraceId: {TraceId}", traceId);
    
    // 你的业务逻辑...
    return new MyServiceResponse();
}

方式2：全局拦截所有请求，自动注入日志上下文 #

如果希望所有微服务请求的日志都自动带上TraceId，不用每个方法手动写，可以自定义FabricTransportServiceRemotingDispatcher，在请求进来时统一处理：

步骤1：实现自定义Dispatcher

using Microsoft.ServiceFabric.Services.Remoting.V2;
using Microsoft.ServiceFabric.Services.Remoting.V2.FabricTransport.Runtime;

public class TraceIdInjectingDispatcher : FabricTransportServiceRemotingDispatcher
{
    private readonly ILogger<TraceIdInjectingDispatcher> _logger;

    public TraceIdInjectingDispatcher(ServiceContext serviceContext, IService serviceImpl, ILogger<TraceIdInjectingDispatcher> logger)
        : base(serviceContext, serviceImpl)
    {
        _logger = logger;
    }

    public override async Task<object> DispatchAsync(ServiceRemotingMessageHeaders headers, object requestBody, CancellationToken cancellationToken)
    {
        // 从请求头里拿到TraceId
        var traceId = headers.TraceId;
        
        // 用日志Scope把TraceId注入，后续所有日志都会自动带上这个字段（比如Serilog、Microsoft.Extensions.Logging都支持）
        using (_logger.BeginScope("{TraceId}", traceId))
        {
            _logger.LogInformation("收到Remoting请求，TraceId: {TraceId}", traceId);
            // 调用原有的处理逻辑
            return await base.DispatchAsync(headers, requestBody, cancellationToken);
        }
    }
}

步骤2：在微服务里配置使用这个Dispatcher

在你的微服务类的CreateServiceInstanceListeners方法里，替换默认的Dispatcher为我们自定义的：

protected override IEnumerable<ServiceInstanceListener> CreateServiceInstanceListeners()
{
    yield return new ServiceInstanceListener(context =>
        new FabricTransportServiceRemotingListener(
            context,
            this,
            // 指定自定义的Dispatcher
            dispatcher: new TraceIdInjectingDispatcher(context, this, _logger)));
}

这样所有进来的Remoting请求都会自动把TraceId加入日志上下文，日志里就会统一带上这个追踪标识，排查问题非常方便。

一些注意点 #

• 确保你的Service Fabric版本是6.4及以上（Remoting v2的TraceId功能从这个版本开始支持，建议用最新稳定版）。
• ASP.NET Core里必须注册IHttpContextAccessor，否则拿不到当前请求的HttpContext。
• 如果你的微服务也需要反向调用APIGateway，同样的逻辑可以反过来用，把TraceId传回去。

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