jedis 连接异常导致不能订阅的解决办法

原创
2013/03/15 11:33
阅读数 1.8K
当jedis连接异常导致不能订阅时,我们可以把获得连接和订阅代码放到 while 循环里,这样异常时会重新获取连接进行订阅,希望对大家有用。
Thread asyncSubscribeThread = new Thread(new Runnable() {
            public void run() {
                while (true) {
                    Jedis jedis = null;
                    boolean borrowOrOprSuccess = true;
                    try {
                        jedis = getResource(_redisName);

                        jedis.subscribe(_jedisPubSub, _channels);
                    }
                    catch (Exception e) {
                    	borrowOrOprSuccess = false;
                    	logger.error(e.getMessage(), e);
                    }
                    finally {
                    	returnResource(borrowOrOprSuccess, _redisName, jedis);
                    }
                }
            }
        });

展开阅读全文
打赏
0
1 收藏
分享
加载中
挺棒的,我也是这样用的
2013/03/15 22:53
回复
举报
更多评论
打赏
1 评论
1 收藏
0
分享
返回顶部
顶部