Redis斷線重連編碼注意事項

應用在Redis重啓、網絡閃斷並恢復正常後，應用必須可以自恢復，下面以Java語言的jedis客戶端爲例說明：

一、做爲發佈者

 

Jedis對象不能做爲單例，網絡閃斷後該Jedis對象沒法自恢復。應該每次發佈消息時，從JedisPool中取Jedis對象，再調用set方法。

二、做爲訂閱者

     當網絡閃斷後psubscribe()方法再也不阻塞並拋出異常，因此能夠使用while循環，在循環內部處理異常，代碼以下：

while(true){

            Jedis redis = this.jedisPool.getResource();

            try{

                redis.psubscribe(this, channelArray);

            }catch(JedisConnectionException e){

                logger.warn("Exception :", e);

                logger.warn("Exit redis psubscribe, retry after 1 second");

            }catch(Exception e){

                logger.error("Exception:", e);

            }

            try{

                Thread.sleep(1000);

            }catch(Exception unused){

            }

            try{

                if(redis != null){

                    redis.close();

                }

            }catch(Exception unused){

            }

        }