feat: 集成 TTL

Author: cadecode

README.md

@@ -33,4 +33,5 @@
 - [x] 集成 druid 连接池
 - [x] 集成 pagehelper
 - [x] 集成 Spring Boot Admin 监控
+- [x] 集成 TransmittableThreadLocal
 - [ ] 集成 dynamicTp

application/src/main/java/top/cadecode/uniboot/demo/controller/TtlExecutorController.java

@@ -0,0 +1,63 @@
+package top.cadecode.uniboot.demo.controller;
+
+import com.alibaba.ttl.TransmittableThreadLocal;
+import com.alibaba.ttl.threadpool.TtlExecutors;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import top.cadecode.uniboot.common.annotation.ApiFormat;
+
+import java.util.concurrent.Executor;
+import java.util.concurrent.Executors;
+
+/**
+ * 阿里 TransmittableThreadLocal 测试
+ *
+ * @author Cade Li
+ * @date 2023/3/13
+ */
+@ApiFormat
+@Slf4j
+@RequiredArgsConstructor
+@Api(tags = "TransmittableThreadLocal 测试")
+@RestController
+@RequestMapping("demo/ttl")
+public class TtlExecutorController {
+
+    @ApiOperation("测试普通 ThreadLocal")
+    @PostMapping("test_thread_local")
+    public String testThreadLocal() {
+        ThreadLocal<String> threadLocal = new ThreadLocal<>();
+        threadLocal.set("A");
+        Executor executor = Executors.newFixedThreadPool(2);
+        for (int i = 0; i < 5; i++) {
+            executor.execute(() -> {
+                // 前两个线程打印出 null，因为普通的 ThreadLocal 不能被子线程继承
+                System.out.println(threadLocal.get());
+                threadLocal.set("B");
+                // 修改了之后，后续线程被复用时会打印出修改后的值
+            });
+        }
+        return "OK";
+    }
+
+    @ApiOperation("测试 TransmittableThreadLocal")
+    @PostMapping("test_ttl")
+    public String testTransmittableThreadLocal() {
+        ThreadLocal<String> threadLocal = new TransmittableThreadLocal<>();
+        threadLocal.set("A");
+        Executor executor = TtlExecutors.getTtlExecutor(Executors.newFixedThreadPool(2));
+        for (int i = 0; i < 5; i++) {
+            executor.execute(() -> {
+                System.out.println(threadLocal.get());
+                threadLocal.set("B");
+                // 使用 ttl 后，5 次都打印出 A，说明 ttl 可以被子线程继承，并且线程复用时没有相互影响
+            });
+        }
+        return "OK";
+    }
+}

common/pom.xml

@@ -108,5 +108,10 @@
             <groupId>com.baomidou</groupId>
             <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
         </dependency>
+        <!--ttl-->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>transmittable-thread-local</artifactId>
+        </dependency>
     </dependencies>
 </project>

pom.xml

@@ -43,6 +43,7 @@
         <druid.version>1.2.15</druid.version>
         <dynamic-ds.version>3.6.0</dynamic-ds.version>
         <sba.version>2.6.11</sba.version>
+        <ttl.version>2.12.2</ttl.version>
     </properties>
 
     <dependencies>
@@ -153,6 +154,11 @@
                 <artifactId>spring-boot-admin-starter-client</artifactId>
                 <version>${sba.version}</version>
             </dependency>
+            <dependency>
+                <groupId>com.alibaba</groupId>
+                <artifactId>transmittable-thread-local</artifactId>
+                <version>${ttl.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>