2017-10-06 113 views
1

我正在创建Web应用程序并使用Redis进行数据存储。 我已经使用JedisPoolConfig(redis client-jedis版本2.9.0)。 所以,当我测试我使用Apache的JMeter的帮助应用程序与以下配置:无法获取Jedis连接,无法从池中获取资源

Number of threads(Users): 30 
Ramp-Up period(in seconds) : 0 
Loop-Count : 1 

和JedisPoolConfig具有以下配置:

redis.sentinel.enable=true 
redis.sentinel.ip=localhost 
redis.sentinel.port=6379 
redis.instance.account.masterName=master 
redis.pool.max-active = 20 
redis.pool.max-idle = 10 

与此代码(这是因为豆上创建Spring应用程序的启动):

JedisConnectionFactory factory = new JedisConnectionFactory(); 
     factory.setPort(port); 
     factory.setHostName(hostName); 
     factory.afterPropertiesSet(); 
     factory.setUsePool(true); 
     JedisPoolConfig jedisPoolConfig = new JedisPoolConfig(); 
     jedisPoolConfig.setMaxTotal(redisPoolMaxActive); 
     jedisPoolConfig.setMaxIdle(redisPoolMaxIdle); 
     factory.setPoolConfig(jedisPoolConfig); 
     return factory; 

与此代码每次取新连接的请求来了:

@Autowired 
private JedisConnectionFactory redisConnectionFactory; 
private StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); 
private RedisTemplate getNewConnection(){ 
     RedisTemplate redisTemplate = new RedisTemplate(); 
     redisTemplate.setConnectionFactory(redisConnectionFactory); 
     redisTemplate.setKeySerializer(stringRedisSerializer); 
     redisTemplate.setHashKeySerializer(stringRedisSerializer); 
     redisTemplate.setValueSerializer(stringRedisSerializer); 
     redisTemplate.afterPropertiesSet(); 
     return redisTemplate; 
    } 

编辑:我使用的redisTemplate多/ EXEC内的Redis:

redisTemplate.setEnableTransactionSupport(true); 

redisTemplate.multi(); 

for (ArrayList<Pair<String, String>> pairs : keys){ 
    for (Pair<String,String> pair: pairs) 
     redisTemplate.opsForHash().get(makeMap(pair.getFirst(), version) , pair.getSecond()); 
} 

return redisTemplate.exec(); 

我顺利拿到了20个请求的响应,但不能得到休息10所请求的响应。我现在面临的问题是,经过20个连接已经使用了前20条的要求,其余10个请求无法从池中获取的jedis连接,因此我得到以下异常:

2017-10-06 17:38:11.753 ERROR 3539 --- [io-8080-exec-12] o.a.c.c.C.[.[.[/].[dispatcherServlet] : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.data.redis.RedisConnectionFailureException: Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a resource from the pool] with root cause 

java.util.NoSuchElementException: Timeout waiting for idle object 
    at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:449) ~[commons-pool2-2.4.2.jar:2.4.2] 
    at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:363) ~[commons-pool2-2.4.2.jar:2.4.2] 
    at redis.clients.util.Pool.getResource(Pool.java:49) ~[jedis-2.9.0.jar:na] 
    at redis.clients.jedis.JedisPool.getResource(JedisPool.java:226) ~[jedis-2.9.0.jar:na] 
    at redis.clients.jedis.JedisPool.getResource(JedisPool.java:16) ~[jedis-2.9.0.jar:na] 
    at org.springframework.data.redis.connection.jedis.JedisConnectionFactory.fetchJedisConnector(JedisConnectionFactory.java:194) ~[spring-data-redis-1.8.6.RELEASE.jar:na] 
    at org.springframework.data.redis.connection.jedis.JedisConnectionFactory.getConnection(JedisConnectionFactory.java:348) ~[spring-data-redis-1.8.6.RELEASE.jar:na] 
    at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:129) ~[spring-data-redis-1.8.6.RELEASE.jar:na] 
    at org.springframework.data.redis.core.RedisConnectionUtils.bindConnection(RedisConnectionUtils.java:67) ~[spring-data-redis-1.8.6.RELEASE.jar:na] 
    at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:192) ~[spring-data-redis-1.8.6.RELEASE.jar:na] 
    at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:169) ~[spring-data-redis-1.8.6.RELEASE.jar:na] 
    at org.springframework.data.redis.core.RedisTemplate.multi(RedisTemplate.java:868) ~[spring-data-redis-1.8.6.RELEASE.jar:na] 
    at net.media.mml.redis.repository.RedisRepository.makeTransaction(RedisRepository.java:50) ~[max-data-0.0.1-SNAPSHOT.jar:0.0.1-SNAPSHOT] 
    at net.media.mml.redis.repository.RedisRepository.getFromRedis(RedisRepository.java:66) ~[max-data-0.0.1-SNAPSHOT.jar:0.0.1-SNAPSHOT] 
    at net.media.mml.service.DimensionGetter.getDimensions(DimensionGetter.java:64) ~[ml-api.jar:0.0.1-SNAPSHOT] 
    at net.media.mml.service.MLQueriesGetter.makeQueries(MLQueriesGetter.java:32) ~[ml-api.jar:0.0.1-SNAPSHOT] 
    at net.media.mml.controller.MaxQueryController.query(MaxQueryController.java:61) ~[ml-api.jar:0.0.1-SNAPSHOT] 
    at sun.reflect.GeneratedMethodAccessor270.invoke(Unknown Source) ~[na:na] 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_131] 
    at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_131] 
    at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) ~[spring-web-4.3.10.RELEASE.jar:4.3.10.RELEASE] 

我已搜查通过网络,但无法找到解决方案。有谁能够帮助我?

+0

请发布完整的堆栈跟踪,因为它是从你的应用程序。 – mp911de

+0

@ mp911de,我编辑了完整的例外。 –

+0

我也在网上找到了这个配置:jedisPoolConfig.getBlockWhenExhausted();这个参数是通过deault来实现的。但似乎jedispoolconfig实际上并没有阻止所有连接使用中的请求。 –

回答

0

使用Redis事务需要在回调中调用。 setEnableTransactionSupport(true)用于交易管理器/ @Transactional的使用。有关更多详细信息,请参见reference documentation

除非你有一个事务管理器,否则不要使用setEnableTransactionSupport(true)

你的代码应该是这样的:

​​
相关问题