redis儲存AtomicInteger物件踩坑及解決

2022-11-25 14:01:33

redis儲存AtomicInteger物件踩坑

redisTemplate 儲存AtomicInteger物件異常：

java.lang.ClassCastException: java.util.concurrent.atomic.AtomicInteger cannot be cast to java.lang.String
   at org.springframework.data.redis.serializer.StringRedisSerializer.serialize(StringRedisSerializer.java:36)
   at org.springframework.data.redis.core.AbstractOperations.rawValue(AbstractOperations.java:127)
   at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:235)
   at com.quan.starter.service.impl.RedisServiceImpl.set(RedisServiceImpl.java:139)

跟蹤原始碼發現其執行的是 StringRedisSerializer 的實現，serialize預設接收的引數型別為String 從而丟擲以上異常

經過檢查，發現是RedisTemplate泛型惹的禍：

@Autowired
private RedisTemplate<String, String> redisTemplate;

解決方案

去除泛型：

@Autowired
private RedisTemplate redisTemplate;

執行服務再次跟蹤原始碼，執行的是 DefaultValueOperations 的實現，問題解決

RedisAtomicInteger的使用

RedisAtomicInteger 從名字上來說就是 redis 的原子Integer 資料型別，由於其原子性，可用於秒殺活動物品數量的控制。

以及保證順序生成數位。

  @Resource
    RedisTemplate<String, Object> redisTemplate;


    /**
     * RedisAtomicInteger
     *
     * @throws Exception 異常
     */
    @Test
    public void testTransaction1() throws Exception {
        RedisAtomicInteger redisCount = new RedisAtomicInteger("key1", this.redisTemplate.getConnectionFactory());
        redisCount.set(0);
        // 建立 100 個執行緒 並行執行  increment 操作
        ExecutorService pool = Executors.newFixedThreadPool(10);
        for (int i = 0; i < 100; i++) {
            pool.submit(() -> {
                // 配額碼原子變數值增加,每次增加1
                for (int j = 0; j < 100; j++) {
                    int count = redisCount.incrementAndGet();
                    log.info(Thread.currentThread().getName() + ": " + count);
                }
            });
        }
    }

結果

.
.
.
pool-2-thread-90: 9989
pool-2-thread-61: 9987
pool-2-thread-3: 9986
pool-2-thread-12: 9990
pool-2-thread-25: 9991
pool-2-thread-90: 9992
pool-2-thread-12: 9994
pool-2-thread-61: 9993
pool-2-thread-25: 9995
pool-2-thread-61: 10000
pool-2-thread-12: 9996
pool-2-thread-61: 9997
pool-2-thread-25: 9998
pool-2-thread-12: 9999

以上為個人經驗，希望能給大家一個參考，也希望大家多多支援it145.com。

redis儲存AtomicInteger物件踩坑及解決

目錄

redis儲存AtomicInteger物件踩坑

解決方案

RedisAtomicInteger的使用

熱門文章