补充

朱晔 · 朱晔 · commit c835b5a4f79e · 2023-04-19T22:19:55.000+08:00
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
@@ -14,6 +14,11 @@ public class RedisTemplateTransactionController {
     @Autowired
     private TestService testService;
 
+    @GetMapping("test0")
+    public String test0() throws InterruptedException {
+        return testService.redisTemplateNotInTransactional();
+    }
+
     @GetMapping("test1")
     public String test1() {
         return testService.multiTest();
@@ -31,6 +36,6 @@ public String test3() {
 
     @GetMapping("test4")
     public String test4() {
-        return testService.multiTestInTransactional();
+        return testService.multiTestCallback();
     }
 }
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
@@ -3,8 +3,11 @@
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.pool2.impl.GenericObjectPool;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.DataAccessException;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
+import org.springframework.data.redis.core.RedisOperations;
+import org.springframework.data.redis.core.SessionCallback;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 import redis.clients.jedis.Jedis;
@@ -13,6 +16,7 @@
 import javax.annotation.PostConstruct;
 import javax.transaction.Transactional;
 import java.lang.reflect.Field;
+import java.util.List;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.IntStream;
@@ -30,14 +34,14 @@ public class TestService {
     public String multiTest() {
         Long current = System.currentTimeMillis();
         stringRedisTemplateTran.multi();
-        IntStream.rangeClosed(1, 1000).forEach(i -> stringRedisTemplateTran.opsForValue().increment("test", 1));
+        IntStream.rangeClosed(1, 10000).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));
+        IntStream.rangeClosed(1, 10000).forEach(i -> stringRedisTemplate.opsForValue().increment("test", 1));
         return System.currentTimeMillis() - current + "ms " + stringRedisTemplate.opsForValue().get("test");
     }
 
@@ -46,12 +50,21 @@ public String redisTemplateInTransactional() {
         return "" + stringRedisTemplateTran.opsForValue().increment("test", 1);
     }
 
-    @Transactional
-    public String multiTestInTransactional() {
+    public String redisTemplateNotInTransactional() throws InterruptedException {
+        TimeUnit.SECONDS.sleep(10);
+        return "" + stringRedisTemplateTran.opsForValue().increment("test", 1);
+    }
+
+    public String multiTestCallback() {
         Long current = System.currentTimeMillis();
-        stringRedisTemplateTran.multi();
-        IntStream.rangeClosed(1, 1000).forEach(i -> stringRedisTemplateTran.opsForValue().increment("test", 1));
-        stringRedisTemplateTran.exec();
+        List<Object> txResults = stringRedisTemplate.execute(new SessionCallback<List<Object>>() {
+            public List<Object> execute(RedisOperations operations) throws DataAccessException {
+                operations.multi();
+                IntStream.rangeClosed(1, 10000).forEach(i -> stringRedisTemplate.opsForValue().increment("test", 1));
+                return operations.exec();
+            }
+        });
+        log.info("txResults = {}", txResults);
         return System.currentTimeMillis() - current + "ms " + stringRedisTemplate.opsForValue().get("test");
     }
 
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
@@ -1,5 +1,5 @@
 server.port=45678
-#server.tomcat.min-spare-threads=15
+server.tomcat.min-spare-threads=2
 server.tomcat.max-threads=30
 spring.jpa.show-sql=false
 spring.jpa.hibernate.ddl-auto=update
