如何获取要保存到 MDC 的请求标头

Question

我有一个带有 spring-cloud-sleuth (Hoxton.SR3) 的 spring boot (2.2.5.RELEASE) 项目。 我想向包含标头的控制器发送请求，并且此标头为：

1. 填充在控制器的跨距行李中（即currentSpan.context().extra()）
2. 已保存到 MDC

我有一个自定义TracingConfiguration

@Bean
public Tracing tracing(@Value("${spring.application.name}") String serviceName, TracingProperties tracingProperties,
                       CurrentTraceContext currentTraceContext) {

    String profile = String.join(",", env.getActiveProfiles());

    log.info("Enable tracing for service {}", serviceName + ":" + profile);
    return Tracing.newBuilder()
            .localServiceName(serviceName + ":" + profile)
            .currentTraceContext(ThreadLocalCurrentTraceContext.newBuilder()
                    .addScopeDecorator(MDCScopeDecorator.create()) // puts trace IDs into logs
                    .build()
            )
            .sampler(Sampler.NEVER_SAMPLE)
            .propagationFactory(
                    ExtraFieldPropagation.newFactoryBuilder(B3Propagation.FACTORY)
                            .addPrefixedFields(TracingConstant.BAGGAGE_HEADER_PREFIX, tracingProperties.getAllBaggageKeys())
                            .build())
            .build();
}

当tracingProperties.getAllBaggageKeys 返回从我的配置文件中读取的行李密钥列表时。

我也在application.yml中定义了：

spring:
  sleuth:
    log:
      slf4j:
        whitelisted-mdc-keys:
          - behalf-flow-id
          - behalf-requested-time
          - x-behalf-ach-file-name
          - behalf-principal-id
          - x-http-request-id
          - behalf-principal
          - requestid
    baggage-keys:
      - behalf-flow-id
      - behalf-requested-time
      - x-behalf-ach-file-name
      - behalf-principal-id
      - x-http-request-id
      - behalf-principal
      - requestid

当我（通过 POSTMAN）调用带有键 baggage-behalf-requested-time 和值 123456 的标头的服务控制器时，我得到 currentSpan.context().extra() 的值 baggage-behalf-requested-time（即 123456）

问题

1. 是否需要在标题前加上baggage- 前缀？框架不是应该自己处理吗？或者它只是在我使用 Spring 本身发送请求时才这样做（即RestTemplate）？
2. 为什么 MDC 没有填充 baggage-behalf-requested-time 标头的值？

Answer 1

您拥有自定义跟踪机制，这就是为什么您需要处理所有 baggage- 前缀等。如果您查看 Sleuth 的 2.2.2.RELEASE，您会发现我们自己为这些字段添加前缀https://github.com/spring-cloud/spring-cloud-sleuth/blob/v2.2.2.RELEASE/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/autoconfig/TraceAutoConfiguration.java#L168-L174 然后，它们也被填充到 MDC (https://github.com/spring-cloud/spring-cloud-sleuth/blob/v2.2.2.RELEASE/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/log/Slf4jScopeDecorator.java) 但没有 baggage- 前缀。在最新版本 (2.2.3.RELEAE) 中，代码进行了重构，但在概念上是相似的。

Answer 2

您可以编写customeFilter来拦截每个请求并将请求中的数据放入MDC。

@Component
public class CustomFilter implements Filter {

  @Override
  public void doFilter(ServletRequest req, ServletResponse res,
      FilterChain chain) throws IOException, ServletException {
      final String correlationId = getCorrelationIdFromHeader(req);
      MDC.put(HttpConstants.CORRELATION_ID_HEADER_NAME, correlationId);
      chain.doFilter(req, res);
  }
}

Answer 3

做事

    public String someMethod(HttpServletRequest request, HttpServletResponse httprespons)
{
 MDC.put(request.getHeader("header_name"););
}

传递 HttpServletRequest,HttpServletResponse 作为参数。