<!-- 日志格式 -->
<property name="CONSOLE_LOG_PATTERN" value="[%X{traceId}] [%-5p] [%d{yyyy-MM-dd HH:mm:ss.SSS}] [%t@${PID}]  %c %M : %m%n"/>

public class WebTraceFilter extends OncePerRequestFilter {
?
?
 ? ?@Override
 ? ?protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response,
 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?FilterChain filterChain) throws IOException, ServletException {
 ? ? ? ?try {
 ? ? ? ? ? ?String traceId = request.getHeader(MDCTraceUtils.TRACE_ID_HEADER);
 ? ? ? ? ? ?if (StrUtil.isEmpty(traceId)) {
 ? ? ? ? ? ? ? ?MDCTraceUtils.addTrace();
 ? ? ? ? ?  } else {
 ? ? ? ? ? ? ? ?MDCTraceUtils.putTrace(traceId);
 ? ? ? ? ?  }
 ? ? ? ? ? ?filterChain.doFilter(request, response);
 ? ? ?  } finally {
 ? ? ? ? ? ?MDCTraceUtils.removeTrace();
 ? ? ?  }
 ?  }
}

public class MDCTraceUtils {
 ? ?/**
 ? ? * 追蹤id的名稱
 ? ? */
 ? ?public static final String KEY_TRACE_ID = "traceId";
?
 ? ?/**
 ? ? * 日志鏈路追蹤id信息頭
 ? ? */
 ? ?public static final String TRACE_ID_HEADER = "x-traceId-header";
?
?
 ? ?/**
 ? ? * 創(chuàng)建traceId并賦值MDC
 ? ? */
 ? ?public static void addTrace() {
 ? ? ? ?String traceId = createTraceId();
 ? ? ? ?MDC.put(KEY_TRACE_ID, traceId);
 ?  }
?
 ? ?/**
 ? ? * 賦值MDC
 ? ? */
 ? ?public static void putTrace(String traceId) {
 ? ? ? ?MDC.put(KEY_TRACE_ID, traceId);
 ?  }
?
 ? ?/**
 ? ? * 獲取MDC中的traceId值
 ? ? */
 ? ?public static String getTraceId() {
 ? ? ? ?return MDC.get(KEY_TRACE_ID);
 ?  }
?
 ? ?/**
 ? ? * 清除MDC的值
 ? ? */
 ? ?public static void removeTrace() {
 ? ? ? ?MDC.remove(KEY_TRACE_ID);
 ?  }
?
 ? ?/**
 ? ? * 創(chuàng)建traceId
 ? ? */
 ? ?public static String createTraceId() {
 ? ? ? ?return IdUtil.getSnowflake().nextIdStr();
 ?  }
?
}

@FeignClient(name = "workshopService", url = "http://127.0.0.1:16688/textile", path = "/workshop")
public interface WorkshopService {
 ? ?@GetMapping("/list/temp")
 ? ?ResponseVO<List<WorkshopDTO>> getList();
}

public class FeignInterceptor implements RequestInterceptor {
 ? ?@Override
 ? ?public void apply(RequestTemplate requestTemplate) {
 ? ? ? ?ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
 ? ? ? ?// 傳遞請(qǐng)求相關(guān)header
 ? ? ? ?if (requestAttributes != null) {
 ? ? ? ? ? ?HttpServletRequest request = requestAttributes.getRequest();
 ? ? ? ? ? ?Enumeration<String> headerNames = request.getHeaderNames();
 ? ? ? ? ? ?if (headerNames != null) {
 ? ? ? ? ? ? ? ?while (headerNames.hasMoreElements()) {
 ? ? ? ? ? ? ? ? ? ?String name = headerNames.nextElement();
 ? ? ? ? ? ? ? ? ? ?// 跳過 content-length
 ? ? ? ? ? ? ? ? ? ?if (Objects.equals("content-length", name)){
 ? ? ? ? ? ? ? ? ? ? ? ?continue;
 ? ? ? ? ? ? ? ? ?  }
 ? ? ? ? ? ? ? ? ? ?String value = request.getHeader(name);
 ? ? ? ? ? ? ? ? ? ?requestTemplate.header(name, value);
 ? ? ? ? ? ? ?  }
 ? ? ? ? ?  }
 ? ? ?  }
 ? ? ? ?// 傳遞日志追蹤的traceId
 ? ? ? ?String traceId = MDCTraceUtils.getTraceId();
 ? ? ? ?if (StringUtils.isNotBlank(traceId)) {
 ? ? ? ? ? ?requestTemplate.header(MDCTraceUtils.TRACE_ID_HEADER, traceId);
 ? ? ?  }
 ?  }
}

 ? ?@GetMapping("/trace")
 ? ?public void testTrace() {
 ? ? ? ?log.info("開始執(zhí)行咯");
 ? ? ? ?BaseQuery query = new BaseQuery();
 ? ? ? ?ResponseVO<List<WorkshopDTO>> responseVO = workshopService.getList();
 ? ? ? ?log.info("接口返回結(jié)果：{}", responseVO);
 ?  }

/**
 *重構(gòu){@link LogbackMDCAdapter}類，搭配TransmittableThreadLocal實(shí)現(xiàn)父子線程之間的數(shù)據(jù)傳遞
 *
 * @author fjzheng
 * @version 1.0
 * @date 2022/7/14 13:50
 */
public class TtlMDCAdapter implements MDCAdapter {
 ? ?private final ThreadLocal<Map<String, String>> copyOnInheritThreadLocal = new TransmittableThreadLocal<>();
?
 ? ?private static final int WRITE_OPERATION = 1;
 ? ?private static final int MAP_COPY_OPERATION = 2;
?
 ? ?private static TtlMDCAdapter mtcMDCAdapter;
?
 ? ?/**
 ? ? * keeps track of the last operation performed
 ? ? */
 ? ?private final ThreadLocal<Integer> lastOperation = new ThreadLocal<>();
?
 ? ?static {
 ? ? ? ?mtcMDCAdapter = new TtlMDCAdapter();
 ? ? ? ?MDC.mdcAdapter = mtcMDCAdapter;
 ?  }
?
 ? ?public static MDCAdapter getInstance() {
 ? ? ? ?return mtcMDCAdapter;
 ?  }
?
 ? ?private Integer getAndSetLastOperation(int op) {
 ? ? ? ?Integer lastOp = lastOperation.get();
 ? ? ? ?lastOperation.set(op);
 ? ? ? ?return lastOp;
 ?  }
?
 ? ?private static boolean wasLastOpReadOrNull(Integer lastOp) {
 ? ? ? ?return lastOp == null || lastOp == MAP_COPY_OPERATION;
 ?  }
?
 ? ?private Map<String, String> duplicateAndInsertNewMap(Map<String, String> oldMap) {
 ? ? ? ?Map<String, String> newMap = Collections.synchronizedMap(new HashMap<>());
 ? ? ? ?if (oldMap != null) {
 ? ? ? ? ? ?// we don't want the parent thread modifying oldMap while we are
 ? ? ? ? ? ?// iterating over it
 ? ? ? ? ? ?synchronized (oldMap) {
 ? ? ? ? ? ? ? ?newMap.putAll(oldMap);
 ? ? ? ? ?  }
 ? ? ?  }
?
 ? ? ? ?copyOnInheritThreadLocal.set(newMap);
 ? ? ? ?return newMap;
 ?  }
?
 ? ?/**
 ? ? * Put a context value (the <code>val</code> parameter) as identified with the
 ? ? * <code>key</code> parameter into the current thread's context map. Note that
 ? ? * contrary to log4j, the <code>val</code> parameter can be null.
 ? ? * <p/>
 ? ? * <p/>
 ? ? * If the current thread does not have a context map it is created as a side
 ? ? * effect of this call.
 ? ? *
 ? ? * @throws IllegalArgumentException in case the "key" parameter is null
 ? ? */
 ? ?@Override
 ? ?public void put(String key, String val) {
 ? ? ? ?if (key == null) {
 ? ? ? ? ? ?throw new IllegalArgumentException("key cannot be null");
 ? ? ?  }
?
 ? ? ? ?Map<String, String> oldMap = copyOnInheritThreadLocal.get();
 ? ? ? ?Integer lastOp = getAndSetLastOperation(WRITE_OPERATION);
?
 ? ? ? ?if (wasLastOpReadOrNull(lastOp) || oldMap == null) {
 ? ? ? ? ? ?Map<String, String> newMap = duplicateAndInsertNewMap(oldMap);
 ? ? ? ? ? ?newMap.put(key, val);
 ? ? ?  } else {
 ? ? ? ? ? ?oldMap.put(key, val);
 ? ? ?  }
 ?  }
?
 ? ?/**
 ? ? * Remove the the context identified by the <code>key</code> parameter.
 ? ? * <p/>
 ? ? */
 ? ?@Override
 ? ?public void remove(String key) {
 ? ? ? ?if (key == null) {
 ? ? ? ? ? ?return;
 ? ? ?  }
 ? ? ? ?Map<String, String> oldMap = copyOnInheritThreadLocal.get();
 ? ? ? ?if (oldMap == null) {
 ? ? ? ? ? ?return;
 ? ? ?  }
?
 ? ? ? ?Integer lastOp = getAndSetLastOperation(WRITE_OPERATION);
?
 ? ? ? ?if (wasLastOpReadOrNull(lastOp)) {
 ? ? ? ? ? ?Map<String, String> newMap = duplicateAndInsertNewMap(oldMap);
 ? ? ? ? ? ?newMap.remove(key);
 ? ? ?  } else {
 ? ? ? ? ? ?oldMap.remove(key);
 ? ? ?  }
?
 ?  }
?
?
 ? ?/**
 ? ? * Clear all entries in the MDC.
 ? ? */
 ? ?@Override
 ? ?public void clear() {
 ? ? ? ?lastOperation.set(WRITE_OPERATION);
 ? ? ? ?copyOnInheritThreadLocal.remove();
 ?  }
?
 ? ?/**
 ? ? * Get the context identified by the <code>key</code> parameter.
 ? ? * <p/>
 ? ? */
 ? ?@Override
 ? ?public String get(String key) {
 ? ? ? ?final Map<String, String> map = copyOnInheritThreadLocal.get();
 ? ? ? ?if ((map != null) && (key != null)) {
 ? ? ? ? ? ?return map.get(key);
 ? ? ?  } else {
 ? ? ? ? ? ?return null;
 ? ? ?  }
 ?  }
?
 ? ?/**
 ? ? * Get the current thread's MDC as a map. This method is intended to be used
 ? ? * internally.
 ? ? */
 ? ?public Map<String, String> getPropertyMap() {
 ? ? ? ?lastOperation.set(MAP_COPY_OPERATION);
 ? ? ? ?return copyOnInheritThreadLocal.get();
 ?  }
?
 ? ?/**
 ? ? * Returns the keys in the MDC as a {@link Set}. The returned value can be
 ? ? * null.
 ? ? */
 ? ?public Set<String> getKeys() {
 ? ? ? ?Map<String, String> map = getPropertyMap();
?
 ? ? ? ?if (map != null) {
 ? ? ? ? ? ?return map.keySet();
 ? ? ?  } else {
 ? ? ? ? ? ?return null;
 ? ? ?  }
 ?  }
?
 ? ?/**
 ? ? * Return a copy of the current thread's context map. Returned value may be
 ? ? * null.
 ? ? */
 ? ?@Override
 ? ?public Map<String, String> getCopyOfContextMap() {
 ? ? ? ?Map<String, String> hashMap = copyOnInheritThreadLocal.get();
 ? ? ? ?if (hashMap == null) {
 ? ? ? ? ? ?return null;
 ? ? ?  } else {
 ? ? ? ? ? ?return new HashMap<>(hashMap);
 ? ? ?  }
 ?  }
?
 ? ?@Override
 ? ?public void setContextMap(Map<String, String> contextMap) {
 ? ? ? ?lastOperation.set(WRITE_OPERATION);
?
 ? ? ? ?Map<String, String> newMap = Collections.synchronizedMap(new HashMap<>());
 ? ? ? ?newMap.putAll(contextMap);
?
 ? ? ? ?// the newMap replaces the old one for serialisation's sake
 ? ? ? ?copyOnInheritThreadLocal.set(newMap);
 ?  }
}

/**
 *
 * 初始化TtlMDCAdapter實(shí)例，并替換MDC中的adapter對(duì)象
 *
 * @author fjzheng
 * @version 1.0
 * @date 2022/7/14 13:55
 */
public class TtlMDCAdapterInitializer implements ApplicationContextInitializer<ConfigurableApplicationContext> {
 ? ?@Override
 ? ?public void initialize(ConfigurableApplicationContext applicationContext) {
 ? ? ? ?//加載TtlMDCAdapter實(shí)例
 ? ? ? ?TtlMDCAdapter.getInstance();
 ?  }
}

 ? // 定義線程池
 ? private ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
 ? ? ? ? ?  .setNameFormat("letter-pool-%d").build();
 ? private ExecutorService fixedThreadPool = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors()*2,
 ? ? ? ? ? ?Runtime.getRuntime().availableProcessors() * 40,
 ? ? ? ? ? ?0L,
 ? ? ? ? ? ?TimeUnit.MILLISECONDS,
 ? ? ? ? ? ?new LinkedBlockingQueue<Runnable>(Runtime.getRuntime().availableProcessors() * 20),
 ? ? ? ? ? ?namedThreadFactory);
 ? ?// 測(cè)試接口
 ? ?@GetMapping("/async")
 ? ?public void testAsync() {
 ? ? ? ?log.info("打印日志了");
 ? ? ? ?fixedThreadPool.execute(()->{
 ? ? ? ? ? ?log.info("異步執(zhí)行了");
 ? ? ? ? ? ?try {
 ? ? ? ? ? ? ? ?Student student = null;
 ? ? ? ? ? ? ? ?String name = student.getName();
 ? ? ? ? ?  } catch (Exception e) {
 ? ? ? ? ? ? ? ?log.error("異步報(bào)錯(cuò)了：", e);
 ? ? ? ? ?  }
?
 ? ? ?  });
 ?  }