Merge branch 'master' of gitee.com:dromara/dynamic-tp

dromara · Jan 22, 2024 · 44744f8 · 44744f8
2 parents 6f65745 + bd2a19f
commit 44744f8
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...main/java/org/dromara/dynamictp/extension/opentelemetry/wrapper/OpenTelemetryWrapper.java b/...main/java/org/dromara/dynamictp/extension/opentelemetry/wrapper/OpenTelemetryWrapper.java
@@ -17,9 +17,13 @@
 
 package org.dromara.dynamictp.extension.opentelemetry.wrapper;
 
+import io.opentelemetry.api.trace.Span;
 import org.dromara.dynamictp.core.support.task.runnable.MdcRunnable;
 import org.dromara.dynamictp.core.support.task.wrapper.TaskWrapper;
 import io.opentelemetry.context.Context;
+import org.slf4j.MDC;
+
+import static org.dromara.dynamictp.common.constant.DynamicTpConst.TRACE_ID;
 
 /**
  * OpenTelemetryWrapper related
@@ -39,6 +43,8 @@ public String name() {
     @Override
     public Runnable wrap(Runnable runnable) {
         Context context = Context.current();
+        //把Trace信息传入DynamicTP中
+         MDC.put(TRACE_ID, Span.current().getSpanContext().getTraceId());
         // 被wrap方法包装后，该Executor执行的所有Runnable都会跑在特定的context中
         return MdcRunnable.get(context.wrap(runnable));
     }