diff --git a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java index 519af33..e8af576 100644 --- a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java +++ b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java @@ -71,7 +71,7 @@ public class LogMdcConfiguration { @Override public void onSubscribe(Subscription subscription) { - + //Tracer.createEntrySpan(Log4Constans.PRINT_LOG_ID, null); coreSubscriber.onSubscribe(subscription); } diff --git a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogWebFilter.java b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogWebFilter.java index 38ed37b..d6718ee 100644 --- a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogWebFilter.java +++ b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogWebFilter.java @@ -92,12 +92,10 @@ public class LogWebFilter implements WebFilter { log.info("api end time:{}, total time:{}", endTime, endTime - startTime); //Tracer.stopSpan(); MDC.remove(Log4Constans.PRINT_LOG_ID); + }).contextWrite(ctx -> { + Context contextTmp = ctx.put(Log4Constans.PRINT_LOG_ID, tracId); + return contextTmp; }); - - - - - } private ServerHttpRequest getRequest(ServerWebExchange exchange){