redis客户端jedis中的小bug

前段时间写了些redis相关的代码

谁料最近一直出问题，错误是jedis添加数据的时候返回类型Arriylist不能转换为Long型

但仔细看了下，sadd方法返回类型的确是Long型，什么时候变成list了

网上找了下，同样有网友遇到相同问题，说是连接超时造成的，不知道是不是这样导致的，但我的代码的确有超时异常

调用时候cath下异常，调用连接池returnBrokenResource方法 如下：

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

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

 

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

 

 

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

 

 

终于编辑完了