简述：

继之前我在《mdc 实现日志链路追踪方便迅速排查问题》一文中抛出的问题，MDC无法很好地实现多线程之间的值传递问题，我自己私下也是抽空去找了，目前找到一个初次尝试，效果还不错的方案，下面给大家介绍一下吧。

1、新建一个简单的spring boot 项目

2、引入依赖

<!--web项目所需-->
<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 本次核心依赖 -->
        <dependency>
            <groupId>com.yomahub</groupId>
            <artifactId>tlog-all-spring-boot-starter</artifactId>
            <version>1.3.1</version>
</dependency>

3、编写logback.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false">
    <property name="APP_NAME" value="logtest"/>
    <property name="LOG_HOME" value="./logs" />
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        <!--这里替换成AspectLogbackEncoder-->
        <encoder class="com.yomahub.tlog.core.enhance.logback.AspectLogbackEncoder">
            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
        </encoder>
    </appender>
    <root level="INFO">
        <appender-ref ref="STDOUT" />
    </root>
</configuration>

4、新建一个service类 TestService

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class TestService {
    public void test(int n) {
        log.info("service输出内容：{}", n);
    }
}

5、新建一个测试接口类 TestThread，并注入service

import com.example.spring_hibernate.service.TestService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;

@RestController
@Slf4j
public class TestThread {

    @Autowired
    private TestService testService;

    @GetMapping(value = "/hello")
    public void get() {
        //构建两个线程池
        ExecutorService executorService = new ScheduledThreadPoolExecutor(4);
        ExecutorService executorService2 = new ScheduledThreadPoolExecutor(2);
        for (int i = 0; i < 10; i++) {
            executorService.submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread.sleep(200);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    log.info(Thread.currentThread().getName() + ">>线程名>>" + System.currentTimeMillis());
                    //启动线程池2
                   executorService2.submit(new Runnable() {

                        @Override
                        public void run() {
                            log.info("线程池2》》" + Thread.currentThread().getName());
                            //调用service方法
                            testService.test(4);
                        }
                    });
                }
            });
        }
    }
}