如何在创建者日志时添加 MDC

Question

我正在尝试将一个值设置为MDC，以便在有日志的情况下显示在每个日志行中。如果kafka producer中有info（“”），那么日志就不会显示我之前为MDC添加的值。

我有一个拦截器来为correlationId设置“默认值”

 @Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response,
                         Object handler) {
    MDC.put("correlationId", "correlation-id-to-be-set");
    return true;
}

@Override
public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
                       @Nullable ModelAndView modelAndView){
    MDC.clear();
}

我设置了 MDC 相关 Id 值，当它进入控制器时。

    @RequestMapping(value = "/notifications", method = RequestMethod.POST, produces = {"application/json"})
@ResponseStatus(HttpStatus.CREATED)
@RolesAllowed({"ROLE_CREATE_NOTIFICATION"})
@LogMethodExecutionTime
public @ResponseBody
OutboundNotificationEvent createNotification(@Valid @RequestBody OutboundNotificationEvent notificationRequest,
                                             HttpServletRequest request){

    log.info("Request Received. CorrelationId {} ",notificationRequest.getCorrelationId());
    if(notificationRequest.getCorrelationId()!=null)
        MDC.put("correlationId", notificationRequest.getCorrelationId());

    bpmProducer.sendMessage(ArgosUtils.mapNotificationPayloadToBpmEvent(notificationRequest, MSG_RECEIVED, EVENT_RECEIVED));

仅用于Kafka日志不包括之前添加的 MDC 消息

2022-06-08 10:15:31.616 INFO { correlation id = correlation-id-to-be-set } 19608-[nio-8080-exec-2]. a . c . unsubscribed notifications controller:请求已收到。correlation id HQ 12345678888 2022-06-08 10:15:33.734信息{ } 19608-[rest-services-1]c . u . b . u . n . a . p .取消订阅AlertsProducer:消息已成功发送2022-06-08 10:15:33.735信息{ } 19608-[rest-services-1]c . u . b . u . n . Argos . producer

因此，正如您在时间戳之后的日志中看到的那样，{}内有一个INFO {}应该是MDC值，该值仅出现在nio-8080-exec-2线程中，从BpmProducer和取消订阅的警报器触发的日志（这是用于Kafka生成事件的类）不包括先前添加的MDC值。我的问题是我需要做什么才能在每个日志行中显示reactId，如果有任何问题，请让我知道，提前感谢。

Answer 1

您的项目中应该有一个日志回溯配置文件（回溯Spring.xml）。在此文件中，我们可以配置包级记录器。

示例：在下面的配置中，将为com的DEBUG日志打印mdc键。并将打印其他软件包的INFO日志的mdc密钥。

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
  <appender class="ch.qos.logback.core.rolling.RollingFileAppender" name="RFA">
    <encoder class="net.logstash.logback.encoder.LogstashEncoder">
      <includeCallerData>true</includeCallerData>
      <includeMdcKeyName>url</includeMdcKeyName>
      <includeMdcKeyName>service</includeMdcKeyName>
      <includeMdcKeyName>userId</includeMdcKeyName>
    </encoder>
    <file>logs/service.log</file>
  </appender>


  <springProfile name="!production">
    <logger additivity="false" level="DEBUG" name="com.company"> //check this
      <appender-ref ref="RFA"/>
    </logger>
    <root level="INFO">
      <appender-ref ref="RFA"/>
    </root>
  </springProfile>

</configuration>