通过jedis客户端连接redis写入报"JedisConnectionException: java.net.SocketException:
通过jedis客户端连接redis写入报"JedisConnectionException: java.net.SocketException: Software caused connection abort: socket write error"异常
一、异常描述
通过客户端jedis连接redis服务器并发写入数据时报出“redis.clients.jedis.exceptions.JedisConnectionException: java.net.SocketException: Software caused connection abort: socket write error...Caused by: java.net.SocketException: Software caused connection abort: socket write error”等异常日志,详情如下所示
redis.clients.jedis.exceptions.JedisConnectionException: java.net.SocketException: Software caused connection abort: socket write error
[xwood-pms-publish][pool-2-thread-1] 2017-06-05 13:31:08,246 - com.xwood.publisher.master.PublishEntityDataHandler -61998 [pool-2-thread-1] INFO com.xwood.publisher.master.PublishEntityDataHandler-【 extract - PublishEntityDataHandler:1】s1-2@ entityNo:447@349779 ....
at redis.clients.jedis.Protocol.sendCommand(Protocol.java:94)
at redis.clients.jedis.Protocol.sendCommand(Protocol.java:74)
at redis.clients.jedis.Connection.sendCommand(Connection.java:80)
【通过jedis客户端连接redis写入报"JedisConnectionException: java.net.SocketException:】at redis.clients.jedis.BinaryClient.set(BinaryClient.java:92)
at redis.clients.jedis.Client.set(Client.java:24)
at redis.clients.jedis.Jedis.set(Jedis.java:62)
at com.xwood.publisher.util.JedisUtil.set(JedisUtil.java:35)
at com.xwood.publisher.master.PublishEntityDataHandler.pushRemoteRedis(PublishEntityDataHandler.java:43)
at com.xwood.publisher.master.PublishEntityDataHandler.run(PublishEntityDataHandler.java:36)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:98)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:206)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
[xwood-pms-publish][pool-2-thread-1] 2017-06-05 13:31:08,247 - com.xwood.publisher.master.PublishEntityDataHandler -61999 [pool-2-thread-1] INFO com.xwood.publisher.master.PublishEntityDataHandler-【extract - PublishEntityDataHandler:1】s1-3@ entityNo:447@349779 ....
Caused by: java.net.SocketException: Software caused connection abort: socket write error
at java.net.SocketOutputStream.socketWrite0(Native Method)
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
at redis.clients.util.RedisOutputStream.flushBuffer(RedisOutputStream.java:31)
at redis.clients.util.RedisOutputStream.write(RedisOutputStream.java:38)
at redis.clients.jedis.Protocol.sendCommand(Protocol.java:80)
二、解决方法
之前通过jedis单例方式创建客户端会话,具体代码如下
public
class
JedisUtil{
private
static
Jedis client =
new
Jedis(j_ip,j_port,
60000
);
public
static
Jedis getclient(){
return
client;
}
public
static
void
setcache(String key,String value){
JedisUtil.getclient().set(key, value);
}
...
}
改为单例+多例结合的方式解决问题,在单例异常的情况下,再调用多例的方式重新赋值,结果问题解决了,具体代码如下
public
class
JedisUtil{
private
static
BlockingQueue
new
LinkedBlockingQueue
private
static
Jedis client =
new
Jedis(j_ip,j_port,
60000
);
public
static
Jedis getclient(){
return
client;
}
public
static
JedisgetFactoryBean()
throws
Exception{
if
(pools.size()<
10
){
Jedis add_client =
new
Jedis(j_ip,j_port,
60000
);
pools.add(add_client);
}
return
pools.take();
}
public
static
void
setcache(String key,String value){
try
{
if
(value!=
null
&&!
""
.equals(value)&&key!=
null
&&!
""
.equals(key)){
JedisUtil.getclient().set(key, value);
}
else
{
logger.error(
" 【JedisUtil save NULL】 key-value:"
+key+
"@value:"
+value);
}
}
catch
(Exception e){
logger.error(
" 【JedisUtil save exception】 key:"
+key+
"@value:"
+value);
try
{
getFactoryBean().set(key, value);
}
catch
(Exception e1) {
e1.printStackTrace();
logger.error(
" 【JedisUtil getFactoryBean exception】key:"
+key+
"@value:"
+value);
}
}
}
}
转:
http://www.xwood.net/_site_domain_/_root/5870/5874/t_c266986.html
推荐阅读
- gitlab|gitlab 通过备份还原 admin/runner 500 Internal Server Error
- whlie循环和for循环的应用
- 如何通过锻炼的方法治疗前列腺肥大
- 通过复盘快速成长(附模板)
- MyBatis|MyBatis Generator配置
- 运维|如何限制IP 通过 SSH连接服务器
- 运维|Linux 禁止用户或 IP通过 SSH 登录
- thinkphp3.2下实现阿里云视频点播实例(客户端JavaScript上传)
- 青椒板书--足球
- 2021.5.27阅读思考题