wangli/axzo-framework-commons
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feign调用加上traceId/ctxLogId/x-request-id

Browse Source
This commit is contained in:
xudawei 2024-05-31 11:10:45 +08:00
parent fcfebf712e
commit 78a4566ef2
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
axzo-common-loggings/axzo-common-trace/src/main/java/com/axzo/framework/trace/interceptor/FeignFillHeaderInterceptor.java
View File

@ -17,6 +17,8 @@ import java.util.concurrent.atomic.AtomicLong;
@Configuration @Configuration
@Slf4j @Slf4j
public class FeignFillHeaderInterceptor implements RequestInterceptor { public class FeignFillHeaderInterceptor implements RequestInterceptor {
private static final String CTX_LOG_ID = "ctxLogId";
private static final String X_REQUEST_ID = "x-request-id";
private static final String TRACE_ID = "traceId"; private static final String TRACE_ID = "traceId";
private static final String SPAN_ID = "spanId"; private static final String SPAN_ID = "spanId";
private static final String LOGIC_ID = "logicId"; private static final String LOGIC_ID = "logicId";
@ -25,6 +27,8 @@ public class FeignFillHeaderInterceptor implements RequestInterceptor {
public void apply(RequestTemplate requestTemplate) { public void apply(RequestTemplate requestTemplate) {
log.info("FeignFillHeaderInterceptor,traceId:{}", MDC.get(TRACE_ID)); log.info("FeignFillHeaderInterceptor,traceId:{}", MDC.get(TRACE_ID));
requestTemplate.header(TRACE_ID, MDC.get(TRACE_ID)); requestTemplate.header(TRACE_ID, MDC.get(TRACE_ID));
requestTemplate.header(CTX_LOG_ID, MDC.get(TRACE_ID));
requestTemplate.header(X_REQUEST_ID, MDC.get(TRACE_ID));
requestTemplate.header(SPAN_ID, this.buildNextSpanId()); requestTemplate.header(SPAN_ID, this.buildNextSpanId());
} }