redis保存AtomicInteger对象踩坑及解决详解

91次阅读

共计 1678 个字符，预计需要花费 5 分钟才能阅读完成。

导读	这篇文章主要介绍了 redis 保存 AtomicInteger 对象踩坑及解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

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 redisTemplate;

解决方案

去除泛型：

@Autowired
private RedisTemplate redisTemplate;

运行服务再次跟踪源码，执行的是 DefaultValueOperations 的实现，问题解决

RedisAtomicInteger 的使用

RedisAtomicInteger 从名字上来说就是 redis 的原子 Integer 数据类型，由于其原子性，可用于秒杀活动物品数量的控制。

以及保证顺序生成数字。

@Resource
  RedisTemplate 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  {
              // 配额码原子变量值增加, 每次增加 1
              for (int j = 0; j 
 结果 
.
.
.
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

 阿里云 2 核 2G 服务器 3M 带宽 61 元 1 年，有高配 
 腾讯云新客低至 82 元 / 年，老客户 99 元 / 年 
 代金券：在阿里云专用满减优惠券

正文完

星哥玩云-微信公众号