redis客户端jedis中的小bug

細細.魚

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

[java] 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

[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() 这行不走了，再往里

[java] 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

[java] 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　　终于编辑完了