转载

JedisPool异常Jedis链接处理

问题现象

基于JedisPool管理Jedis对象，通过get方法获取值，出现key对应的value值错误，例如：

K V

a a

b b

Jedis.get(“a”)==’b’;

通过获取key为a的值，但获取了值b来。

同一套代码的项目，分别部署在两个不同的应用集群，其中一个集群出现这种问题，而另一个集群却没有出现。

问题分析

通过表象可以看出，应该是链接池的Jedis对象链接出现错乱而导致的。而两个集群中的其中一个集群出现，这两个集群的唯一区别就是网络环境不一样，所以连接Redis服务器的网络是有差别的。

问题思考

根据以上信息，可以大致判断出应该跟网速和JedisPool链接池的超时时间（500毫秒）设置有关。那接下来的问题是，如果网络差的集群，出现redis连接超时，那么Jedis为什么会错误呢？是否在连接池的配置不当知道呢？

问题发现

带着以上的疑问，继续Google和百度相关资料，结果发现returnBrokenResource这个方法。通过资料查找和对JedisPool的源码分析，此方法是销毁异常Jedis连接的。如果Jedis链接发现异常（如连接超时），不对异常连接销毁的话，会有数据缓存问题。

异常流程：

重现问题测试代码：

 1 package test;  2   3 import java.io.IOException;  4 import java.io.InputStream;  5 import java.util.Properties;  6 import java.util.Random;  7 import org.apache.commons.lang.StringUtils;  8 import redis.clients.jedis.Jedis;  9 import redis.clients.jedis.JedisPool; 10 import redis.clients.jedis.JedisPoolConfig; 11  12 public class RedisTest implements Runnable{ 13      14     public static JedisPool pool = null; 15      16     static { 17          try { 18                     JedisPoolConfig config = new JedisPoolConfig();   19                     config.setMaxActive(100); 20                     config.setMaxIdle(10); 21                     config.setMaxWait(1000); 22                     config.setTestOnBorrow(false); 23                     config.setTestOnReturn(false); 24                     config.setTestWhileIdle(true); 25                     config.setTimeBetweenEvictionRunsMillis(30000); 26                     config.setNumTestsPerEvictionRun(10); 27                     config.setMinEvictableIdleTimeMillis(60000); 28             pool = new JedisPool(config, "192.168.22.213", 6379,1); 29         } catch (Exception e) { 30             System.out.println("【jedispool init error】"); 31         } 32   } 33  34 public void run() { 35          36         Jedis jedis = null; 37         String result = ""; 38         int i = new Random().nextInt(1000); 39          40         try{ 41             jedis=pool.getResource(); 42             result = jedis.get("T"+i); 43              44             if(StringUtils.isNotEmpty(result) && !result.equals("T"+i)){ 45                 System.out.println(result+"!=T"+i); 46             } 47              48         }catch(Exception e){ 49             System.out.println(jedis+e.toString()); 50              51         }finally{ 52             if(jedis!=null){ 53                 pool.returnResource(jedis); 54             }     55         } 56          57     } 58      59     /** 60      * 模拟2000线程并发 61      */ 62     public static void main(String[] args) throws Exception { 63          64         for(int i=0;i<2000;i++){ 65             new Thread(new RedisTest()).start(); 66         } 67     } 68 }

执行结果：

……

T50!=T47

redis.clients.jedis.Jedis@1295fe8redis.clients.jedis.exceptions.JedisConnectionException : java.net.SocketTimeoutException : Read timed out

T56!=T94

redis.clients.jedis.Jedis@151b0a5redis.clients.jedis.exceptions.JedisConnectionException : java.net.SocketTimeoutException : Read timed out

T717!=T380

redis.clients.jedis.Jedis@131303fredis.clients.jedis.exceptions.JedisConnectionException : java.net.SocketTimeoutException : Read timed out

redis.clients.jedis.Jedis@602b6bredis.clients.jedis.exceptions.JedisConnectionException : java.net.SocketTimeoutException : Read timed out

T204!=T787

T474!=T763

T163!=T542

T552!=T60

T604!=T820

T733!=T624

redis.clients.jedis.Jedis@131303fredis.clients.jedis.exceptions.JedisConnectionException : java.net.SocketTimeoutException : Read timed out

redis.clients.jedis.Jedis@d56b37redis.clients.jedis.exceptions.JedisConnectionException : java.net.SocketTimeoutException : Read timed out

redis.clients.jedis.Jedis@151b0a5redis.clients.jedis.exceptions.JedisConnectionException : java.net.SocketTimeoutException : Read timed out

redis.clients.jedis.Jedis@1295fe8redis.clients.jedis.exceptions.JedisConnectionException : java.net.SocketTimeoutException : Read timed out

T784!=T948

T440!=T672

T97!=T867

……

以上结果出现许多键值不对应的情况。

解决方案

当Jedis读超时时，把此实例销毁，以免造成后续伤害。

销毁异常Jedis有三种方法：

JedisPool异常Jedis链接处理

方法1：加入红色代码，当读取Redis数据时任何异常都抛弃此Jedis实例

try{    jedis=pool.getResource();    result = jedis.get("T"+i);    if(StringUtils.isNotEmpty(result) && !result.equals("T"+i)){     System.out.println(result+"!=T"+i);    }   }catch(Exception e){    System.out.println(jedis+e.toString());    if(jedis!=null){     pool.returnBrokenResource(jedis);    }   }finally{    if(jedis!=null){     pool.returnResource(jedis);    }  }