论坛 › Redis › redis客户端jedis中的小bug

細細.魚 发表于 2016-12-20 11:14:34

redis客户端jedis中的小bug

　　前段时间写了些redis相关的代码
　　谁料最近一直出问题，错误是jedis添加数据的时候返回类型Arriylist不能转换为Long型
　　但仔细看了下，sadd方法返回类型的确是Long型，什么时候变成list了
　　网上找了下，同样有网友遇到相同问题，说是连接超时造成的，不知道是不是这样导致的，但我的代码的确有超时异常
　　调用时候cath下异常，调用连接池returnBrokenResource方法 如下：

view plaincopyprint?





[*]Jedis jedis = getJedispool().getResource();  
[*]
         try {  
[*]
             jedis.keys("*");  
[*]
        } catch (Exception e) {  
[*]            e.printStackTrace();  
[*]            jedisPool.returnBrokenResource(jedis);  
[*]
            System.out.println("return already");  
[*]        }  



Jedis jedis = getJedispool().getResource();
try {
jedis.keys("*");
} catch (Exception e) {
e.printStackTrace();
jedisPool.returnBrokenResource(jedis);
System.out.println("return already");
}

发现卡到returnbrokenresource那块不往下走了，然后找到源码　　JedisPool.java

view plaincopyprint?





[*]public void destroyObject(final Object obj) throws Exception {  
[*]
           if (obj instanceof Jedis) {  
[*]
               final Jedis jedis = (Jedis) obj;  
[*]
               if (jedis.isConnected()) {  
[*]
                   try {  
[*]
                       try {  
[*]                           jedis.quit();  
[*]
                       } catch (Exception e) {  
[*]                       }  
[*]                       jedis.disconnect();  
[*]
                   } catch (Exception e) {  
[*]  
[*]                   }  
[*]               }  
[*]           }  
[*]       }  



public void destroyObject(final Object obj) throws Exception {
if (obj instanceof Jedis) {
final Jedis jedis = (Jedis) obj;
if (jedis.isConnected()) {
try {
try {
jedis.quit();
} catch (Exception e) {
}
jedis.disconnect();
} catch (Exception e) {
}
}
}
}
　　停到jedis.quit() 这行不走了，再往里

view plaincopyprint?





[*]protected String getStatusCodeReply() {  
[*]       flush();  
[*]       pipelinedCommands--;  
[*]
       final byte[] resp = (byte[]) protocol.read(inputStream);  
[*]
       if (null == resp) {  
[*]
           return null;  
[*]
       } else {  
[*]
           return SafeEncoder.encode(resp);  
[*]       }  
[*]   }  



protected String getStatusCodeReply() {
flush();
pipelinedCommands--;
final byte[] resp = (byte[]) protocol.read(inputStream);
if (null == resp) {
return null;
} else {
return SafeEncoder.encode(resp);
}
}

　　卡到 final byte[] resp = (byte[]) protocol.read(inputStream)这行
　　本人能力有限，真跟不下去了
　　quit()走不下去，那我就直接往下走
　　改了代码，注掉jedis.quit(),直接走jedis.disconnect()
　　ok了，这个连接终于给正常返回连接池了
　　之后连接池连接数设为1，再次让它超时，不调用自带的returnBrokenResource

view plaincopyprint?





[*]jedis jedis = getJedispool().getResource();  
[*]
         try {  
[*]
             jedis.keys("*");  
[*]
        } catch (Exception e) {  
[*]            e.printStackTrace();  
[*]            jedis.disconnect();  
[*]
            System.out.println("return already");  
[*]        }  
[*]        jedisPool.returnResource(jedis);  
[*]        System.out.println(jedis.ping());  



jedis jedis = getJedispool().getResource();
try {
jedis.keys("*");
} catch (Exception e) {
e.printStackTrace();
jedis.disconnect();
System.out.println("return already");
}
jedisPool.returnResource(jedis);
System.out.println(jedis.ping());

输出PONG　　终于编辑完了

查看完整版本: redis客户端jedis中的小bug