wulin/qiuguo-iot
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

优化日志

Browse Source
This commit is contained in:
wulin 2023-11-22 16:56:32 +08:00
parent 60692f5ff6
commit 36f56b40dd
2 changed files with 5 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java
View File

@ -27,10 +27,6 @@ public class LogMdcConfiguration {
@PostConstruct @PostConstruct
public void contextOperatorHook() { public void contextOperatorHook() {
Hooks.onEachOperator(PRINT_LOG_ID, Operators.lift((r, c) ->{ Hooks.onEachOperator(PRINT_LOG_ID, Operators.lift((r, c) ->{
/*Context ctx = c.currentContext();
if(ctx.hasKey(PRINT_LOG_ID)){
MDC.put(PRINT_LOG_ID, ctx.get(PRINT_LOG_ID));
}*/
return new MdcContextSubscriber(c); return new MdcContextSubscriber(c);
})); }));
} }
@ -69,9 +65,8 @@ public class LogMdcConfiguration {
@Override @Override
public void onNext(T t) { public void onNext(T t) {
Context ctx = currentContext(); if(currentContext().hasKey(PRINT_LOG_ID)){
if(ctx.hasKey(PRINT_LOG_ID)){ MDC.put(PRINT_LOG_ID, currentContext().get(PRINT_LOG_ID));
MDC.put(PRINT_LOG_ID, ctx.get(PRINT_LOG_ID));
} }
coreSubscriber.onNext(t); coreSubscriber.onNext(t);
} }

8
iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/filter/LogMdcConfiguration.java
View File

@ -26,10 +26,6 @@ public class LogMdcConfiguration {
@PostConstruct @PostConstruct
public void contextOperatorHook() { public void contextOperatorHook() {
Hooks.onEachOperator(PRINT_LOG_ID, Operators.lift((r, c) ->{ Hooks.onEachOperator(PRINT_LOG_ID, Operators.lift((r, c) ->{
Context ctx = c.currentContext();
if(ctx.hasKey(PRINT_LOG_ID)){
MDC.put(PRINT_LOG_ID, ctx.get(PRINT_LOG_ID));
}
return new MdcContextSubscriber(c); return new MdcContextSubscriber(c);
})); }));
} }
@ -69,7 +65,9 @@ public class LogMdcConfiguration {
@Override @Override
public void onNext(T t) { public void onNext(T t) {
if(coreSubscriber.currentContext().hasKey(PRINT_LOG_ID)){
MDC.put(PRINT_LOG_ID, coreSubscriber.currentContext().get(PRINT_LOG_ID));
}
coreSubscriber.onNext(t); coreSubscriber.onNext(t);
} }