Jedis接続異常による購読不可の解決策
846 ワード
jedis , while , , 。
Thread asyncSubscribeThread = new Thread(new Runnable() {
public void run() {
while (true) {
Jedis jedis = null;
boolean borrowOrOprSuccess = true;
try {
jedis = getResource(_redisName);
jedis.subscribe(_jedisPubSub, _channels);
}
catch (Exception e) {
borrowOrOprSuccess = false;
logger.error(e.getMessage(), e);
}
finally {
returnResource(borrowOrOprSuccess, _redisName, jedis);
}
}
}
});