Redis学习笔记（七）jedis超时重试机制注意事项

淡淡的烟草味﹌ 2022-07-13 03:26 893阅读 0赞

# redis系列文章目录 #

*  [使用spring-data-redis实现incr自增][spring-data-redis_incr]
 *  [Redis 利用Hash存储节约内存][Redis _Hash]
 *  [Redis学习笔记（九）redis实现时时直播列表缓存,支持分页\[热点数据存储\]][Redis_redis]
 *  [Redis学习笔记（八）redis之lua脚本学习][Redis_redis_lua]
 *  [Redis学习笔记（七）jedis超时重试机制注意事项][Redis_jedis]
 *  [Redis学习笔记（六）redis实现分布式锁][Redis_redis 1]
 *  [Redis学习笔记（五）jedis(JedisCluster)操作Redis集群 redis-cluster][Redis_jedis_JedisCluster_Redis_ redis-cluster]
 *  [redis学习笔记（四）缓存与数据库一致性问题][redis]
 *  [redis学习笔记（三）数据淘汰策略][redis 1]
 *  [redis学习笔记（二）JedisCluster + redis 3.2.5集群][redis_JedisCluster _ redis 3.2.5]
 *  [redis学习笔记（一）redis3.2.5集群安装与测试][redis_redis3.2.5]

> jedis客户端在创建连接时会设置一个超时，并且会有重试机制。

# 问题起源 #

在使用jedis客户端的时候，我测试了一下`incr`命令，该命令在执行过程中是原子的，所以理论上不会出现问题（不论单线程还是多线程）

代码如下：

/** * incrf: * 将 key 中储存的数字值增一。 如果 key 不存在，那么 key 的值会先被初始化为 0 ，然后再执行 INCR 操作。 如果值包含错误的类型，或字符串类型的值不能表示为数字，那么返回一个错误。 本操作的值限制在 64 位(bit)有符号数字表示之内。 这是一个针对字符串的操作，因为 Redis 没有专用的整数类型，所以 key 内储存的字符串被解释为十进制 64 位有符号整数来执行 INCR 操作。 返回值： 执行 INCR 命令之后 key 的值。 这里有问题，最终数据结果大于10000 这是因为设置的超时时间太小了，他去重试了，所以最终结果大于10000 */
        @Test
        public void incrTest() throws InterruptedException {
            /** * 测试线程安全 */
            jedisCluster.del("incrNum");
            final AtomicInteger atomicInteger = new AtomicInteger(0);
            final CountDownLatch countDownLatch = new CountDownLatch(10);
            ExecutorService executorService = Executors.newFixedThreadPool(10);
            for(int i = 0 ; i < 10 ; i ++){
                executorService.submit(new Runnable() {
                    @Override
                    public void run() {
                        //每个线程增加1000次，每次加1
                        for(int j = 0 ; j < 1000 ; j ++){
                            atomicInteger.incrementAndGet();
                            jedisCluster.incr("incrNum");
                        }
    
                        countDownLatch.countDown();
                    }
                });
            }
    
            countDownLatch.await();
            System.out.println(jedisCluster.get("incrNum"));
            System.out.println(atomicInteger);
        }

这是个多线程的demo，不管多线程还是单线程，我最终得到的结果都是比10000大。这就奇怪了，`incr`是原子的，理论上不应该会这样。我起初以为是jedis客户端的BUG，后来仔细一看才发现，这不是BUG，是我在创建jediscluster的时候设置的超时时间太短了，导致其超时重试。

我使用的是这个构造方法:

public JedisCluster(Set<HostAndPort> jedisClusterNode, int connectionTimeout, int soTimeout,
                          int maxAttempts, String password, final GenericObjectPoolConfig poolConfig) {
        super(jedisClusterNode, connectionTimeout, soTimeout, maxAttempts, password, poolConfig);
      }

*  soTimeout: 返回值的超时时间
 *  maxAttempts：出现异常最大重试次数

# 解决办法 #

**将超时时间设置的大一些。**

我们在使用这些开源框架的时候，一定要全面了解其运作原理，这样才能事半功倍。另外需要注意，想httpclient、dubbo等RPC框架都会有超时重试机制，在使用的时候要注意。

[spring-data-redis_incr]: http://blog.csdn.net/liubenlong007/article/details/77817742
[Redis _Hash]: http://blog.csdn.net/liubenlong007/article/details/53816561
[Redis_redis]: http://blog.csdn.net/liubenlong007/article/details/53838737
[Redis_redis_lua]: http://blog.csdn.net/liubenlong007/article/details/53816087
[Redis_jedis]: http://blog.csdn.net/liubenlong007/article/details/53815968
[Redis_redis 1]: http://blog.csdn.net/liubenlong007/article/details/53782934
[Redis_jedis_JedisCluster_Redis_ redis-cluster]: http://blog.csdn.net/liubenlong007/article/details/53766734
[redis]: http://blog.csdn.net/liubenlong007/article/details/53690312
[redis 1]: http://blog.csdn.net/liubenlong007/article/details/53690103
[redis_JedisCluster _ redis 3.2.5]: http://blog.csdn.net/liubenlong007/article/details/53689306
[redis_redis3.2.5]: http://blog.csdn.net/liubenlong007/article/details/53471459