Sleuth中自定义TraceID失败求助：MDC设置无法修改Span上下文TraceID

你遇到的问题根源是：MDC中的traceId仅用于日志输出，修改它不会改变Sleuth Span上下文实际的TraceID。Sleuth的Span上下文由Tracer组件管理，必须通过Tracer的官方API来修改或创建带有自定义TraceID的Span。

以下是两种可行的解决方案：

1. 全局自定义TraceID（所有请求生效） #

通过实现TraceIdGenerator接口，自定义TraceID的生成逻辑，全局替换默认的TraceID生成器。

步骤1：实现自定义TraceIdGenerator #

import org.springframework.cloud.sleuth.api.TraceIdGenerator;

public class CustomTraceIdGenerator implements TraceIdGenerator {
    @Override
    public String generateTraceId() {
        // 返回自定义TraceID，这里可以写固定值或自定义生成逻辑
        return "99999";
    }
}

步骤2：注册自定义生成器Bean #

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class SleuthConfig {
    @Bean
    public TraceIdGenerator customTraceIdGenerator() {
        return new CustomTraceIdGenerator();
    }
}

配置完成后，所有新发起的链路TraceID都会使用你定义的值。

2. 局部临时使用自定义TraceID（仅某段代码生效） #

如果只需要在特定代码块中使用自定义TraceID，可以手动创建带有指定TraceID的Span并激活它。

修改你的控制器代码如下：

import org.springframework.cloud.sleuth.api.Span;
import org.springframework.cloud.sleuth.api.SpanInScope;
import org.springframework.cloud.sleuth.api.TraceContext;
import org.springframework.cloud.sleuth.api.Tracer;
import java.util.UUID;

@GetMapping
public String get(Tracer tracer) {
    // 结束当前默认Span（如果不需要保留原有链路）
    Span currentSpan = tracer.currentSpan();
    if (currentSpan != null) {
        currentSpan.end();
    }

    // 构建带有自定义TraceID的TraceContext
    TraceContext customTraceContext = TraceContext.newBuilder()
            .traceId("99999") // 设置自定义TraceID
            .spanId(UUID.randomUUID().toString().replace("-", "").substring(0, 16)) // 生成随机SpanID
            .build();

    // 创建并激活自定义Span
    Span customSpan = tracer.nextSpan(customTraceContext);
    try (SpanInScope scope = tracer.withSpan(customSpan.start())) {
        System.out.println("traceId after custom");
        System.out.println(tracer.currentSpan().context().traceId()); // 输出99999
        log.info("KAFKA: SEND ...");
        
        MyClass myClass = new MyClass("test");
        kafkaTemplate.send("test-topic-pp-01", myClass);
        
        return "Test kafka traceId=" + tracer.currentSpan().context().traceId();
    } finally {
        // 结束自定义Span
        customSpan.end();
    }
}

这段代码会在try代码块内激活自定义Span，包括Kafka消息发送的链路都会使用这个TraceID，Kafka监听器中也会拿到99999作为TraceID。

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