nested exception is redis.clients.jedis.exceptions.JedisConnectionException: Unknown reply: O 异常处理记录
前几天修改redis中value 的时间时遇到了个坑，使用的是redis版本 2.4.1 + spring-data-redis-1.6.0 服务端使用的是twemproxy。
具体操作是 原来value 的过期时间为 3600*24 *7 单位是 TimeUnit.SECONDS (7天)。现在要求修改为30天，
我直接修改3600*24 *30 单位保持不变。不过通过查阅资料和翻看源码。找到了问题所在，在这里记录下。
异常如下：
Unknown reply: O; nested exception is redis.clients.jedis.exceptions.JedisConnectionException: Unknown reply: O
Caused by: redis.clients.jedis.exceptions.JedisConnectionException: Unknown reply: O
at redis.clients.jedis.Protocol.process(Protocol.java:128)
at redis.clients.jedis.Protocol.read(Protocol.java:187)
at redis.clients.jedis.Connection.getIntegerReply(Connection.java:201)
at redis.clients.jedis.BinaryJedis.expire(BinaryJedis.java:330)
at org.springframework.data.redis.connection.jedis.JedisConnection.expire(JedisConnection.java:807)
at org.springframework.data.redis.core.RedisTemplate
at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:191)
at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:153)
at org.springframework.data.redis.core.RedisTemplate.expire(RedisTemplate.java:640)
at com.youku.ddshow.service.impl.UserDeviceTokenServiceImpl.addUserDeviceToken(UserDeviceTokenServiceImpl.java:32)
at com.youku.ddshow.service.impl.UserDeviceTokenServiceImpl.updateUserDeviceToken(UserDeviceTokenServiceImpl.java:66)
at com.youku.ddshow.service.MACTokenHandler.getMACToken4Logined(MACTokenHandler.java:95)
… 37 more
通过跟踪代码发现是 RedisTemplate.expire 出现异常。
public Boolean expire(K key, final long timeout, final TimeUnit unit) {
final byte[] rawKey = this.rawKey(key);
final long rawTimeout = TimeoutUtils.toMillis(timeout, unit);
return (Boolean)this.execute(new RedisCallback() {
public Boolean doInRedis(RedisConnection connection) {
try {
return connection.pExpire(rawKey, rawTimeout);
} catch (Exception var3) {
return connection.expire(rawKey, TimeoutUtils.toSeconds(timeout, unit));
}
}
}, true);
}
//这里使用了twemproxy 是不支持Time的操作，故抛出异常使用connection.expire处理，此处是个坑
public Boolean pExpire(byte[] key, long millis) {
if(millis > 2147483647L) {
return this.pExpireAt(key, this.time().longValue() + millis);
} else {
try {
if(this.isPipelined()) {
this.pipeline(new JedisConnection.JedisResult(this.pipeline.pexpire(key, (int)millis), JedisConverters.longToBoolean()));
return null;
} else if(this.isQueueing()) {
this.transaction(new JedisConnection.JedisResult(this.transaction.pexpire(key, (int)millis), JedisConverters.longToBoolean()));
return null;
} else {
return JedisConverters.toBoolean(this.jedis.pexpire(key, (int)millis));
}
} catch (Exception var5) {
throw this.convertJedisAccessException(var5);
}
}
}
//跳到这里继续执行 注意参数 是秒 long seconds
public Boolean expire(byte[] key, long seconds) {
if(seconds > 2147483647L) {
return this.pExpireAt(key, this.time().longValue() + TimeUnit.SECONDS.toMillis(seconds));
} else {
try {
if(this.isPipelined()) {
this.pipeline(new JedisConnection.JedisResult(this.pipeline.expire(key, (int)seconds), JedisConverters.longToBoolean()));
return null;
} else if(this.isQueueing()) {
this.transaction(new JedisConnection.JedisResult(this.transaction.expire(key, (int)seconds), JedisConverters.longToBoolean()));
return null;
} else {
return JedisConverters.toBoolean(this.jedis.expire(key, (int)seconds));//**执行此处**
}
} catch (Exception var5) {
throw this.convertJedisAccessException(var5);
}
}
}
//通过继续向下找源码，终于找到抛出异常的代码
private static Object process(RedisInputStream is) {
try {
byte e = is.readByte();
if(e == 45) {
processError(is);
return null;
} else if(e == 42) {
return processMultiBulkReply(is);
} else if(e == 58) {
return processInteger(is);
} else if(e == 36) {
return processBulkReply(is);
} else if(e == 43) {
return processStatusCodeReply(is);
} else {
throw new JedisConnectionException("Unknown reply: " + (char)e);
}
} catch (IOException var2) {
throw new JedisConnectionException(var2);
}
}对照ASCII码表 O 代码 77 不是这几个常量，其实还是通信错误导致。
然后修改TimeUnit.DAYS 30 问题解决。