补充

朱晔 · 朱晔 · commit 025aea76e63b · 2023-04-19T20:16:02.000+08:00
diff --git a/src/main/java/org/geekbang/time/commonmistakes/cachedesign/redistransaction/CommonMistakesApplication.java b/src/main/java/org/geekbang/time/commonmistakes/cachedesign/redistransaction/CommonMistakesApplication.java
@@ -2,12 +2,27 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.StringRedisTemplate;
 
 @SpringBootApplication
 public class CommonMistakesApplication {
 
     public static void main(String[] args) {
         SpringApplication.run(CommonMistakesApplication.class, args);
     }
+
+    @Bean
+    public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
+        return new StringRedisTemplate(redisConnectionFactory);
+    }
+
+    @Bean
+    public StringRedisTemplate stringRedisTemplateTran(RedisConnectionFactory redisConnectionFactory) {
+        StringRedisTemplate stringRedisTemplate = new StringRedisTemplate(redisConnectionFactory);
+        stringRedisTemplate.setEnableTransactionSupport(true);
+        return stringRedisTemplate;
+    }
 }
 
diff --git a/src/main/java/org/geekbang/time/commonmistakes/cachedesign/redistransaction/RedisTemplateTransactionController.java b/src/main/java/org/geekbang/time/commonmistakes/cachedesign/redistransaction/RedisTemplateTransactionController.java
@@ -10,23 +10,27 @@
 @RequestMapping("redistemplatetransaction")
 @RestController
 public class RedisTemplateTransactionController {
-    ;
 
     @Autowired
     private TestService testService;
 
     @GetMapping("test1")
-    public Long test1() {
-        return testService.test1();
+    public String test1() {
+        return testService.multiTest();
     }
 
     @GetMapping("test2")
-    public Long test2() {
-        return testService.test2();
+    public String test2() {
+        return testService.noMultiTest();
     }
 
     @GetMapping("test3")
-    public Long test3() {
-        return testService.test3();
+    public String test3() {
+        return testService.redisTemplateInTransactional();
+    }
+
+    @GetMapping("test4")
+    public String test4() {
+        return testService.multiTestInTransactional();
     }
 }
diff --git a/src/main/java/org/geekbang/time/commonmistakes/cachedesign/redistransaction/TestService.java b/src/main/java/org/geekbang/time/commonmistakes/cachedesign/redistransaction/TestService.java
@@ -15,28 +15,44 @@
 import java.lang.reflect.Field;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.IntStream;
 
 @Component
 @Slf4j
 public class TestService {
     @Autowired
     private StringRedisTemplate stringRedisTemplate;
     @Autowired
+    private StringRedisTemplate stringRedisTemplateTran;
+    @Autowired
     private RedisConnectionFactory redisConnectionFactory;
 
-    public Long test1() {
-        return stringRedisTemplate.opsForValue().increment("test", 1);
+    public String multiTest() {
+        Long current = System.currentTimeMillis();
+        stringRedisTemplateTran.multi();
+        IntStream.rangeClosed(1, 1000).forEach(i -> stringRedisTemplateTran.opsForValue().increment("test", 1));
+        stringRedisTemplateTran.exec();
+        return System.currentTimeMillis() - current + "ms " + stringRedisTemplateTran.opsForValue().get("test");
+    }
+
+    public String noMultiTest() {
+        Long current = System.currentTimeMillis();
+        IntStream.rangeClosed(1, 1000).forEach(i -> stringRedisTemplate.opsForValue().increment("test", 1));
+        return System.currentTimeMillis() - current + "ms " + stringRedisTemplate.opsForValue().get("test");
     }
 
-    public Long test2() {
-        stringRedisTemplate.setEnableTransactionSupport(true);
-        return stringRedisTemplate.opsForValue().increment("test", 1);
+    @Transactional
+    public String redisTemplateInTransactional() {
+        return "" + stringRedisTemplateTran.opsForValue().increment("test", 1);
     }
 
     @Transactional
-    public Long test3() {
-        stringRedisTemplate.setEnableTransactionSupport(true);
-        return stringRedisTemplate.opsForValue().increment("test", 1);
+    public String multiTestInTransactional() {
+        Long current = System.currentTimeMillis();
+        stringRedisTemplateTran.multi();
+        IntStream.rangeClosed(1, 1000).forEach(i -> stringRedisTemplateTran.opsForValue().increment("test", 1));
+        stringRedisTemplateTran.exec();
+        return System.currentTimeMillis() - current + "ms " + stringRedisTemplate.opsForValue().get("test");
     }
 
     @PostConstruct
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
@@ -1,5 +1,6 @@
 server.port=45678
-server.tomcat.max-threads=50
+#server.tomcat.min-spare-threads=15
+server.tomcat.max-threads=30
 spring.jpa.show-sql=false
 spring.jpa.hibernate.ddl-auto=update
 logging.level.ROOT=INFO
