Redis连接超时异常的处理方法
0、问题描述
使用Jedis连接redis进行数据查询操作，正常的代码运行没有问题，但是时不时会报出如下错误：
Exceptioninthread"main"redis.clients.jedis.exceptions.JedisConnectionException:java.net.SocketTimeoutException:Readtimedout
atredis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:202)
atredis.clients.util.RedisInputStream.read(RedisInputStream.java:181)
atredis.clients.jedis.Protocol.processBulkReply(Protocol.java:181)
atredis.clients.jedis.Protocol.process(Protocol.java:155)
atredis.clients.jedis.Protocol.processMultiBulkReply(Protocol.java:206)
atredis.clients.jedis.Protocol.process(Protocol.java:157)
atredis.clients.jedis.Protocol.processMultiBulkReply(Protocol.java:206)
atredis.clients.jedis.Protocol.process(Protocol.java:157)
atredis.clients.jedis.Protocol.read(Protocol.java:215)
atredis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:340)
atredis.clients.jedis.Connection.getRawObjectMultiBulkReply(Connection.java:285)
atredis.clients.jedis.Connection.getObjectMultiBulkReply(Connection.java:291)
atredis.clients.jedis.BinaryJedis.hscan(BinaryJedis.java:3390)
atcom.ict.mcg.filter.DuplicateClueFilterV2.hscan(DuplicateClueFilterV2.java:867)
atcom.ict.mcg.filter.DuplicateClueFilterV2.collectRecentCluekeywords(DuplicateClueFilterV2.java:487)
atcom.ict.mcg.main.GetCluesMain.run_online(GetCluesMain.java:208)
atcom.ict.mcg.main.GetCluesMain.main(GetCluesMain.java:1685)
Causedby:java.net.SocketTimeoutException:Readtimedout
atjava.net.SocketInputStream.socketRead0(NativeMethod)
atjava.net.SocketInputStream.socketRead(SocketInputStream.java:116)
atjava.net.SocketInputStream.read(SocketInputStream.java:171)
atjava.net.SocketInputStream.read(SocketInputStream.java:141)
atjava.net.SocketInputStream.read(SocketInputStream.java:127)
atredis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:196)
...16more
究其原因，可以定位为java.net.SocketTimeoutException:Readtimedout，即网络连接异常；
1、可能的原因
1.1服务器资源包括内存、磁盘、cpu等利用率高
经过查看redis部署机器的状态信息，发现整体机器运行状态良好
1.2服务器设置防火墙，导致连接失败
因为正常的代码流程都可以跑通，所以防火墙设置没有问题；
1.3redis配置文件bind监听host配置不当
redis的配置文件中bind对应host的配置如下：
#BydefaultRedislistensforconnectionsfromallthenetworkinterfaces #availableontheserver.Itispossibletolistentojustoneormultiple #interfacesusingthe"bind"configurationdirective,followedbyoneor #moreIPaddresses. # #Examples: # #bind192.168.1.10010.0.0.1 #bind127.0.0.1
默认的bind绑定的host为0.0.0.0，即可以监听每一个可用的网络接口；相当于配置为：
bind0.0.0.0
我们的配置文件也配置正常，而且正常的代码流程运行正常，也可以佐证这一点；
1.4Jedis使用配置问题
目前Jedis的连接池配置如下：
privatestaticJedisPoolgetPool(){
if(pool==null){
JedisPoolConfigconfig=newJedisPoolConfig();
//控制一个pool可分配多少个jedis实例，通过pool.getResource()来获取；
//如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
config.setMaxActive(10);
//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例。
config.setMaxIdle(2);
//表示当borrow(引入)一个jedis实例时，最大的等待时间，如果超过等待时间，则直接抛出JedisConnectionException；
config.setMaxWait(1000*200000);
//在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
config.setTestOnBorrow(true);
config.setTestOnReturn(true);
//目前redis只有一个服务器
pool=newJedisPool(config,"localhost",6379);
}
returnpool;
}
privatestaticJedisgetJedis(){
Jedisjedis=null;
intcount=0;
do{
try{
pool=getPool();
jedis=pool.getResource();
}catch(Exceptione){
//System.out.println(e.getMessage());
e.printStackTrace();
pool.returnBrokenResource(jedis);
}
count++;
}while(jedis==null&&count<3);
returnjedis;
}
构建JedisPool的逻辑中，只是设置了config.setMaxWait(1000*200000);，这个是引入新的jedis实例的最大等待时间，并没有进行其他相关的连接超时的配置；于是查看JedisPool的源代码，发现如下：
publicJedisPool(finalConfigpoolConfig,finalStringhost){
this(poolConfig,host,Protocol.DEFAULT_PORT,Protocol.DEFAULT_TIMEOUT,null,Protocol.DEFAULT_DATABASE);
}
publicJedisPool(Stringhost,intport){
this(newConfig(),host,port,Protocol.DEFAULT_TIMEOUT,null,Protocol.DEFAULT_DATABASE);
}
publicJedisPool(finalStringhost){
this(host,Protocol.DEFAULT_PORT);
}
publicJedisPool(finalConfigpoolConfig,finalStringhost,intport,
inttimeout,finalStringpassword){
this(poolConfig,host,port,timeout,password,Protocol.DEFAULT_DATABASE);
}
publicJedisPool(finalConfigpoolConfig,finalStringhost,finalintport){
this(poolConfig,host,port,Protocol.DEFAULT_TIMEOUT,null,Protocol.DEFAULT_DATABASE);
}
publicJedisPool(finalConfigpoolConfig,finalStringhost,finalintport,finalinttimeout){
this(poolConfig,host,port,timeout,null,Protocol.DEFAULT_DATABASE);
}
publicJedisPool(finalConfigpoolConfig,finalStringhost,intport,inttimeout,finalStringpassword,
finalintdatabase){
super(poolConfig,newJedisFactory(host,port,timeout,password,database));
}
由上述代码可以看到，JedisPool有多个重载的构造函数，并且构造函数中需要传入一个timeout参数作为连接的超时时间，如果没有传，则采用Protocol.DEFAULT_TIMEOUT作为默认的超时时间，继续跟踪源码：
publicfinalclassProtocol{
publicstaticfinalintDEFAULT_PORT=6379;
publicstaticfinalintDEFAULT_TIMEOUT=2000;
publicstaticfinalintDEFAULT_DATABASE=0;
publicstaticfinalStringCHARSET="UTF-8";
publicstaticfinalbyteDOLLAR_BYTE='$';
publicstaticfinalbyteASTERISK_BYTE='*';
publicstaticfinalbytePLUS_BYTE='+';
publicstaticfinalbyteMINUS_BYTE='-';
publicstaticfinalbyteCOLON_BYTE=':';
privateProtocol(){
//thispreventtheclassfrominstantiation
}
可以得出结论，默认JedisPool中连接的默认超时时间为2秒，而我们调用的JedisPool构造函数，恰恰采用的是这个配置，只要两秒钟没有连接成功，redis的连接就断开，从而报错，这在数据库请求并发量比较大的时候是有可能发生的，遂做如下更改，在创建JedisPool的时候，传入一个较大的超时时间：
pool=newJedisPool(config,ParamUtil.REDIS_ADDRESS[0],ParamUtil.REDIS_PORT,1000*10);
2、总结
遇到问题还是多查，多看源码，多看源码中的配置，仔细一项一项地排查问题！
到此这篇关于Redis连接超时异常处理的文章就介绍到这了,更多相关Redis连接超时异常内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！