Redis一個異常的解決辦法,異常描述:Could not get a resource from the pool
阿新 • • 發佈:2018-12-21
異常描述:
redis.clients.jedis.exceptions.JedisConnectionException: Could not get a resource from the pool at redis.clients.util.Pool.getResource(Pool.java:22) at com.derbysoft.jredis.longkeytest.BorrowObject.run(BorrowObject.java:22) at java.lang.Thread.run(Thread.java:662) Caused by: java.util.NoSuchElementException: Timeout waiting for idle object at org.apache.commons.pool.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:1134) at redis.clients.util.Pool.getResource(Pool.java:20) ... 2 more
1、產生原因:客戶端去redis伺服器拿連線(程式碼描述的是租用物件borrowObject)的時候,池中無可用連線,即池中所有連線被佔用,且在等待時候設定的超時時間後還沒拿到時,報出此異常。
2、解決辦法:調整JedisPoolConfig中maxActive為適合自己系統的閥值。
<bean id="dataJedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxActive" value="300"/>
<property name="maxIdle" value="100"/>
<property name="maxWait" value="10000"/>
<property name="testOnBorrow" value="true"/>
</bean>
3、重試:
public class BorrowObject implements Runnable { private ShardedJedisPool jedisPool; public BorrowObject(ShardedJedisPool jedisPool) { this.jedisPool = jedisPool; } @Override public void run() { ShardedJedis shardedJedis = null; try { shardedJedis = jedisPool.getResource(); String value = shardedJedis.hget("LONG_KEY_TEST:AA059E03E0AB7D806E6C351F87404B06C1190", "Roc El Pinar Aparthotel"); System.out.println(value); } catch (Exception e) { //logger.error(e); e.printStackTrace(); } finally { jedisPool.returnResource(shardedJedis); } } }
public class BorrowObjectTest {
private ShardedJedisPool jedisPool = null;
public BorrowObjectTest() {
List<JedisShardInfo> jedisShardInfos = new ArrayList<JedisShardInfo>();
JedisShardInfo jedisShardInfo = new JedisShardInfo("192.168.1.112");
jedisShardInfo.setTimeout(1000000);
jedisShardInfos.add(jedisShardInfo);
jedisPool = new ShardedJedisPool(createJedisConfig(), jedisShardInfos);
}
private JedisPoolConfig createJedisConfig() {
JedisPoolConfig jedisConfig = new JedisPoolConfig();
jedisConfig.setMaxActive(2);
jedisConfig.setMaxIdle(2);
jedisConfig.setMaxWait(5);
jedisConfig.setTestOnBorrow(true);
return jedisConfig;
}
public static void main(String[] args) {
BorrowObjectTest borrowObjectTest = new BorrowObjectTest();
for (int i = 0; i < 300; i++) {
new Thread(new BorrowObject(borrowObjectTest.jedisPool)).start();
}
}
}