| | |
| | | package com.java110.core.aop; |
| | | |
| | | import com.java110.core.factory.Java110TraceFactory; |
| | | import com.java110.core.trace.Java110TraceFactory; |
| | | import com.java110.core.factory.Java110TransactionalFactory; |
| | | import com.java110.dto.trace.TraceDto; |
| | | import com.java110.utils.constant.CommonConstant; |
| | |
| | | @Configuration |
| | | public class FeignRequestInterceptor implements RequestInterceptor { |
| | | |
| | | |
| | | /** |
| | | * 传入事务ID |
| | | * |
| | |
| | | String oId = Java110TransactionalFactory.getOId(); |
| | | if (!StringUtils.isEmpty(oId)) { |
| | | requestTemplate.header(Java110TransactionalFactory.O_ID, oId); |
| | | } |
| | | //调用链头信息 |
| | | TraceDto traceDto = Java110TraceFactory.getTraceDto(); |
| | | if (traceDto != null) { |
| | | requestTemplate.header(CommonConstant.TRACE_ID, traceDto.getTraceId()); |
| | | requestTemplate.header(CommonConstant.PARENT_SPAN_ID, traceDto.getId()); |
| | | } |
| | | } |
| | | } |