雷迪斯。客户。绝地武士。例外。JedisException:无法将资源返回池

Question

我试图从绝地人才库中回收资源时出错了。代码如下。

Jedis publisherJedis = jedispool.getResource();
if(!redisPassword.equals(""))
    publisherJedis.auth(redisPassword);
publisherJedis.publish(channel,data);
log.debug("Publisher jedis is connected: " + publisherJedis.isConnected());
log.debug("Jsondata is added into the queue " + data);
try {
    jedispool.returnResource(publisherJedis);
    jedispool.destroy();
    publisherJedis.close();
} catch (Exception e) {
    e.printStackTrace();
    log.error("Exception occured in returing resource " + e);
}

Answer 1

我在应用程序的其他地方关闭了redis客户端，这就是为什么当我要关闭redis客户端时，它会抛出异常。我还注意到，在使用redis客户端时，我们应该更加小心。如果我们从redis池中获取资源，那么在使用它之后，我们还必须断开它们的连接。如果我们不这样做，那么客户机将进入，在满足maxSizeClient限制后，它也将抛出异常。我更改了Publisher的启动方法。

public void start(JedisPool jedispool, Jedis publisherJedis, String channel,String data, String redisPassword)
{
    if(!redisPassword.equals(""))
        publisherJedis.auth(redisPassword);
    publisherJedis.publish(channel,data);
    log.debug("Jsondata is added into the queue " +data);
    try{
        publisherJedis.close();
        log.debug(" Is Jedis connected " +publisherJedis.isConnected());
        if(publisherJedis.isConnected())
            publisherJedis.disconnect();
        log.debug(" After disconnecting: is redis connected  " +publisherJedis.isConnected());
    }catch(Exception e){
        log.debug("Error occured " +e);
    }
}