现在的位置: 首页 > 综合 > 正文

jedis 用连接池时超时返回值类型错误

2017年12月23日 ⁄ 综合 ⁄ 共 1767字 ⁄ 字号 评论关闭

这个是今天发现一个bug:在测试redis并发读写的时候(jedis作为客户端,并使用了连接池),总是报 java.lang.ClassCastException: java.util.ArrayList cannot be cast to java.lang.Long

at redis.clients.jedis.Connection.getIntegerReply(Connection.java:161)
at redis.clients.jedis.Jedis.del(Jedis.java:108)
类似的错误,就是返回值类型和文档上的返回值类型不相符,感觉很不应该;开始怀疑是jedis实现的一个bug,后来发现一个现象,当抛一个超时异常的时候,后面就连续的出现一个类似上面的错误,最后终于发现了问题所在。

原先的代码是这样的:

Java代码
复制代码
 收藏代码
  1. public long del(String key) {   
  2.         long rt = 0L;   
  3.         Jedis jedis = null;   
  4.         try {   
  5.             jedis = getJedis();   
  6.             rt = jedis.del(key);   
  7.         }    
  8.         finally  
  9.         {   
  10.             releaseJedisInstance(jedis);   
  11.         }   
  12.         return rt;   
  13.     }  

这样写貌似OK,但实际上有问题,假设jedis在执行这个命令的时候,因为redis超负荷,jedis可能返回超时的异常,这个时候发生了什么,没有处理这个异常,直接将这个jedis的链接返回到了连接池,这样有没有问题呢?

查看jedis源码发现他的connection中对网络输出流做了一个封装,其中自建了一个buffer,所以当发生异常的时候,这个buffer里还残存着上次没有发送或者发送不完整的命令,这个时候没有做处理,直接将该连接返回到连接池,那么重用该连接执行下次命令的时候,就会将上次没有发送的命令一起发送过去,所以才会出现上面的错误“返回值类型不对”;

所以正确的写法应该是在发送异常的时候,销毁这个连接,不能再重用!
正确的写法如下:

Java代码
复制代码
 收藏代码
  1. public long del(String key) {   
  2.         long rt = 0L;   
  3.         Jedis jedis = null;   
  4.         try {   
  5.             jedis = getJedis();   
  6.             rt = jedis.del(key);   
  7.         } catch (Exception e) {   
  8.             returnBrokenResource(jedis);   
  9.         }   
  10.         finally  
  11.         {   
  12.             releaseJedisInstance(jedis);   
  13.         }   
  14.         return rt;   
  15.     }  

从上面的分析来看,我更认为是jedis实现的一个bug,当连接出现异常的时候,应该对该连接的buffer进行清空的,你认为呢?

转载自:http://hellojimmy.iteye.com/blog/1197543

抱歉!评论已关闭.