【发布时间】：2014-03-30 08:27:42
【问题描述】：
大家好，我正在尝试使用 java 设置 redis 服务器。 我的 Redis 服务器是 ulimit 无限制的 linux 服务器。
这是我创建连接的spring bean
公共类 JedisService 实现 IJedisService、InitializingBean、DisposableBean{ 私有 JedisPool jedisPool;
public JedisService() {
}
public JedisPool getJedisPool() {
return jedisPool;
}
@Override
public void destroy() throws Exception {
if(jedisPool != null){
jedisPool.destroy();
}
}
@Override
public void afterPropertiesSet() throws Exception {
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxActive(1000);
poolConfig.setMaxIdle(10);
poolConfig.setMinIdle(1);
poolConfig.setMaxWait(30000);
poolConfig.setNumTestsPerEvictionRun(10);
poolConfig.setTestOnBorrow(true);
poolConfig.setTestOnReturn(true);
poolConfig.setTestWhileIdle(true);
poolConfig.setTimeBetweenEvictionRunsMillis(30000);
jedisPool = new JedisPool(poolConfig,Config.REDIS_HOST,
RestrictionUtils.REDIS_PORT,RestrictionUtils.REDIS_CONNECTION_TIMEOUT);
}
public boolean validateHitsCount(String hostKey,String urlKey,int hostHitsCount, int urlHitsCount, long timeKey,Map<String, Object> overLimit){
int retryCount = 0;
return recursiveRedisConnection(retryCount,hostKey,urlKey,hostHitsCount,urlHitsCount,timeKey,overLimit);
}
private boolean recursiveRedisConnection(int retryCount,String hostKey,String urlKey,int hostHitsCount, int urlHitsCount, long timeKey,Map<String, Object> overLimit){
Jedis jedis = null;
boolean returnObj = true;
try {
//Connection
jedis = getJedisPool().getResource();
jedis.connect();
//Delete previous keys
try {
deletePreviouskeys(jedis, urlKey, hostKey, timeKey);
} catch (Exception e) {
}
//Validation
String value = jedis.get(hostKey+timeKey);
if(value != null){
try {
int count = Integer.parseInt(value);
System.out.println("HostCount: "+hostKey+ " "+count);
if(count < hostHitsCount){
jedis.incr(hostKey+timeKey);
returnObj = validateURLHits(jedis, urlKey, urlHitsCount, timeKey, overLimit);
}else{
returnObj = false;
overLimit.put("Data", "You have reached maximum limit for hits---"+hostKey);
}
} catch (Exception e) {
}
}else{
value = 1+"";
jedis.set(hostKey+timeKey, value);
jedis.expire(hostKey+timeKey, 60);
returnObj = validateURLHits(jedis, urlKey, urlHitsCount, timeKey, overLimit);
}
} catch (Exception e) {
retryCount ++;
if(retryCount < 3){
recursiveRedisConnection(retryCount,hostKey,urlKey,hostHitsCount,urlHitsCount,timeKey,overLimit);
}else{
e.printStackTrace();
returnObj = false;
}
}finally{
if(jedis != null && jedis.isConnected()){
getJedisPool().returnResource(jedis);
}
}
return returnObj;
}
private boolean validateURLHits(Jedis jedis,String urlKey, int urlHitsCount, long timeKey,Map<String, Object> overLimit){
boolean returnObj = true;
String value = jedis.get(urlKey+timeKey);
if(value != null){
try {
int count = Integer.parseInt(value);
System.out.println("URLCount: "+urlKey+ " "+count);
if(count < urlHitsCount){
jedis.incr(urlKey+timeKey);
}else{
returnObj = false;
overLimit.put("Data", "Reached maximum limit of hits for this URL");
}
}catch(Exception e){
}
}else{
jedis.set(urlKey+timeKey, 1+"");
jedis.expire(urlKey+timeKey, 60);
}
return returnObj;
}
private void deletePreviouskeys(Jedis jedis,String urlKey, String hostKey, long timeKey){
/*Set<String> keys = jedis.keys("*");
for(String key : keys){
if(!key.equalsIgnoreCase(urlKey+timeKey)){
if(!key.equalsIgnoreCase(hostKey+timeKey)){
jedis.del(key);
}
}
}*/
}
}
方法 validateURLHits 在控制器中被调用。 但是当我在多个线程中运行这段代码时，我得到了这个错误
redis.clients.jedis.exceptions.JedisConnectionException: 无法从池中获取资源 在 redis.clients.util.Pool.getResource(Pool.java:22) 在 com.til.ibeat.service.JedisService.recursiveRedisConnection(JedisService.java:60) 在 com.til.ibeat.service.JedisService.recursiveRedisConnection(JedisService.java:95) 在 com.til.ibeat.service.JedisService.recursiveRedisConnection(JedisService.java:95) 在 com.til.ibeat.service.JedisService.validateHitsCount(JedisService.java:52) 在 com.til.ibeat.controller.MashupController.handleRequest(MashupController.java:66) 在 org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter.handle(SimpleControllerHandlerAdapter.java:48) 在 org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:763) 在 org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:709) 在 org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:613) 在 org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:525) 在 javax.servlet.http.HttpServlet.service(HttpServlet.java:621) 在 javax.servlet.http.HttpServlet.service(HttpServlet.java:728) 在 org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305) 在 org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210) 在 org.apache.catalina.core.StandardWrapperValve.invoke（StandardWrapperValve.java:222） 在 org.apache.catalina.core.StandardContextValve.invoke（StandardContextValve.java:123） 在 org.apache.catalina.authenticator.AuthenticatorBase.invoke（AuthenticatorBase.java:472） 在 org.apache.catalina.core.StandardHostValve.invoke（StandardHostValve.java:171） 在 org.apache.catalina.valves.ErrorReportValve.invoke（ErrorReportValve.java:99） 在 org.apache.catalina.valves.AccessLogValve.invoke（AccessLogValve.java:936） 在 org.apache.catalina.core.StandardEngineValve.invoke（StandardEngineValve.java:118） 在 org.apache.catalina.connector.CoyoteAdapter.service（CoyoteAdapter.java:407） 在 org.apache.coyote.http11.AbstractHttp11Processor.process（AbstractHttp11Processor.java:1004） 在 org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:589) 在 org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:310) 在 java.util.concurrent.ThreadPoolExecutor$Worker.runTask（未知来源） 在 java.util.concurrent.ThreadPoolExecutor$Worker.run（未知来源） 在 java.lang.Thread.run（未知来源） 原因：java.util.NoSuchElementException：无法创建已验证的对象，原因：ValidateObject 失败
【问题讨论】：