redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.

異常信息：

java.lang.RuntimeException: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.
at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128)
at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99)
at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80)
at backtype.storm.daemon.executor$fn__6214$fn__6227$fn__6278.invoke(executor.clj:808)
at backtype.storm.util$async_loop$fn__543.invoke(util.clj:475) at clojure.lang.AFn.run(AFn.java:22)
at java.lang.Thread.run(Thread.java:745)
Caused by: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.
at redis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:198)
at redis.clients.util.RedisInputStream.readByte(RedisInputStream.java:40)
at redis.clients.jedis.Protocol.process(Protocol.java:141)
at redis.clients.jedis.Protocol.read(Protocol.java:205)
at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:297)
at redis.clients.jedis.Connection.getBinaryMultiBulkReply(Connection.java:233)
at redis.clients.jedis.Jedis.keys(Jedis.java:194)
at com.jk.utils.RedisUtils.keys(RedisUtils.java:174)
at com.jk.bolt.IPSumBolt.execute(IPSumBolt.java:47) （異常代碼：Set<String> keys = jedis.keys("2017")）
at backtype.storm.daemon.executor$fn__6214$tuple_action_fn__6216.invoke(executor.clj:670)
at backtype.storm.daemon.executor$mk_task_receiver$fn__6137.invoke(executor.clj:426)
at backtype.storm.disruptor$clojure_handler$reify__5713.onEvent(disruptor.clj:58)
at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:125) ... 6 more

解決方案：

　　首先網上有不少，好比客戶端緩衝區大小，可是試過以後依然沒有解決。

　　咱們用的是兩臺Redis服務器節點，使用Codis代理搭建的Redis集羣服務，最後經一一排查代碼，發現是Codis代理不支持redis keys這種模糊查詢操做，改用 scan操做發現codis 貌似也不支持。