将自定义行李添加到当前跨度，并通过日志MDC访问

Question

我试图添加额外的行李到HTTP服务器上的现有跨度，我想添加一个路径变量到跨度，从日志MDC访问，并通过超文本传输协议或kafka在电线上传播到下一个服务器。

我的设置：春云侦探霍克斯顿。SR5和Spring启动2.2.5

我尝试添加以下设置和配置：

spring:
  sleuth:
    propagation-keys: context-id, context-type
    log:
      slf4j:
        whitelisted-mdc-keys: context-id, context-type

并添加了http拦截器：

public class HttpContextInterceptor implements HandlerInterceptor {

    
    private final Tracer tracer;
    private final HttpContextSupplier httpContextSupplier;

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        if (httpContextSupplier != null) {
            addContext(request, handler);
        }
        return true;
    }

    private void addContext(HttpServletRequest request, Object handler) {
        final Context context = httpContextSupplier.getContext(request);
        if (!StringUtils.isEmpty(context.getContextId())) {
            ExtraFieldPropagation.set(tracer.currentSpan().context(), TracingHeadersConsts.HEADER_CONTEXT_ID, context.getContextId());
        }
        if (!StringUtils.isEmpty(context.getContextType())) {
            ExtraFieldPropagation.set(tracer.currentSpan().context(), TracingHeadersConsts.HEADER_CONTEXT_TYPE, context.getContextType());
        }
    }
}

和http筛选器以影响当前范围（根据spring文档）

public class TracingFilter extends OncePerRequestFilter {

    private final Tracer tracer;

    @Override
    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
        try (Tracer.SpanInScope ws = tracer.withSpanInScope(tracer.currentSpan())){
            filterChain.doFilter(request, response);
        }
    }
}

问题是日志不包含我的自定义上下文id，上下文类型，虽然是在span上下文中看到它。

我错过了什么？

Answer 1

官方的Sleuth 2.0中也描述了在当前span中刷新MDC的方法-

@Configuration
class BusinessProcessBaggageConfiguration {
  BaggageField BUSINESS_PROCESS = BaggageField.create("bp");

  /** {@link BaggageField#updateValue(TraceContext, String)} now flushes to MDC */
  @Bean
  CorrelationScopeCustomizer flushBusinessProcessToMDCOnUpdate() {
    return b -> b.add(
        SingleCorrelationField.newBuilder(BUSINESS_PROCESS).flushOnUpdate().build()
    );
  }
}

Answer 2

类似的问题春云侦探添加标签和答案https://stackoverflow.com/a/66554834

对于某些上下文：这来自Spring文档。

为了将行李值自动设置为Slf4j的MDC，您必须使用允许的本地或远程密钥列表设置spring.sleuth.baggage.correlation字段属性。例如spring.sleuth.baggage.correlation-field=国家代码将把国家代码行李的值设置为MDC。

请注意，额外的字段将从下一个下游跟踪上下文开始传播并添加到MDC。若要在当前跟踪上下文中立即向MDC添加额外字段，请将该字段配置为在更新时刷新。

// configuration
@Bean
BaggageField countryCodeField() {
    return BaggageField.create("country-code");
}

@Bean
ScopeDecorator mdcScopeDecorator() {
    return MDCScopeDecorator.newBuilder()
            .clear()
            .add(SingleCorrelationField.newBuilder(countryCodeField())
                    .flushOnUpdate()
                    .build())
            .build();
}

// service
@Autowired
BaggageField countryCodeField;

countryCodeField.updateValue("new-value");