绝地武士：破管子

Question

所以，我有两个应用程序使用绝地武士。它们都连接到同一台服务器，其中一个监听发布以检查是否写入了某些内容。好吧，经过大约10个小时的持续使用和装载，设置/获取/发布/订阅等，绝地武士们返回了破碎的管道。我不知道为什么，因为我在绝地武士中有超时到0的时间。有什么想法吗？

Answer 1

从我发现的情况来看，绝地保持着与Redis的开放连接，不检查这些连接的状态。如果一个连接在空闲时间被中断（网络被重置或暂时断开，或连接超时），Jedis连接池基本上会失效，但Jedis客户端不会报告这一情况，除非您尝试发送命令。以下是关于github的讨论：https://github.com/xetorthio/jedis/issues/185

我解决这个问题的方法是在发送任何数据之前发送一个“ping”：

private Jedis getResource() {
    Jedis jedis;
    try{
        jedis = pool.getResource();
        jedis.ping();
    } catch (JedisException e) {
        pool.destroy();
        pool = getPool(this.url);
        jedis = pool.getResource();
    }
    return jedis;
}

public String get(EphemeralKey key, EphemeralLocation location) throws Exception {
    String encodedKey = encodeKey(key, location);
    try (Jedis jedis = getResource()) {
        return jedis.get(encodedKey);
    } catch (JedisException e) {
        throw wrapJedisException(e);
    }
    return null;
}