Spring sleuth行李钥匙未被传播

Question

我有一个过滤器(OncePerRequestFilter)，它基本上拦截传入的请求并记录traceId、spanId等。它运行良好，这个过滤器位于一个公共模块中，该模块包含在其他项目中，以避免在我的所有微服务中包含spring sleuth依赖项，这就是我将它创建为库的原因，因为对库的任何更改对所有模块都是公共的。现在，我必须添加一个新的传播密钥，它需要通过http头（如trace和spanId）传播到所有服务。为此，我从HttpTracing中提取了当前的span并向其添加了一个行李密钥（如下所示）

 Span span = httpTracing.tracing().tracer().currentSpan();
    String corelationId =
        StringUtils.isEmpty(request.getHeader(CORELATION_ID))
            ? "n/a"
            : request.getHeader(CORELATION_ID);
    ExtraFieldPropagation.set(CUSTOM_TRACE_ID_MDC_KEY_NAME, corelationId);
    span.annotate("baggage_set");
    span.tag(CUSTOM_TRACE_ID_MDC_KEY_NAME, corelationId);

spring:
  sleuth:
    propagation-keys:
      - x-corelationId
    log:
      slf4j:
        whitelisted-mdc-keys:
          - x-corelationId

Answer 1

在您的库中，您可以实现ApplicationEnvironmentPreparedEvent侦听器，并添加您需要的配置，例如：

@Component
public class CustomApplicationListener implements ApplicationListener<ApplicationEvent> {

    private static final Logger log = LoggerFactory.getLogger(LagortaApplicationListener.class);

    public void onApplicationEvent(ApplicationEvent event) {

        if (event instanceof ApplicationEnvironmentPreparedEvent) {
            log.debug("Custom ApplicationEnvironmentPreparedEvent Listener");
            ApplicationEnvironmentPreparedEvent envEvent = (ApplicationEnvironmentPreparedEvent) event;
            ConfigurableEnvironment env = envEvent.getEnvironment();
            Properties props = new Properties();
            props.put("spring.sleuth.propagation-keys", "x-corelationId");
            props.put("log.slf4j.whitelisted-mdc-keys:", "x-corelationId");

            env.getPropertySources().addFirst(new PropertiesPropertySource("custom", props));
        }
    }

}

然后在您的微服务中注册这个自定义监听器

public static void main(String[] args) {
        ConfigurableApplicationContext context = new SpringApplicationBuilder(MyApplication.class)
                .listeners(new CustomApplicationListener()).run();      
    }