ed exception is redis.clients.jedis.exceptions.JedisConnectionException: Unknown reply: O 异常处理记录

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 单位保持不变。不过通过查阅资料和翻看源码。找到了问题所在，在这里记录下。
异常如下：
1
2
3
4

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$7.doInRedis(RedisTemplate.java:647) at org.springframework.data.redis.core.RedisTemplate$7.doInRedis(RedisTemplate.java:640)
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);
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

对照ASCII码表 O 代码 77 不是这几个常量，其实还是通信错误导致。

然后修改TimeUnit.DAYS 30 问题解决。

参考: http://irfen.me/redis-expire-exception