1. 程式人生 > >Redis一個異常的解決辦法,異常描述:Could not get a resource from the pool

Redis一個異常的解決辦法,異常描述:Could not get a resource from the pool

異常描述: 

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();
        }
    }
}