應用程式在Redis重新啟動、網路閃斷並恢復正常後,應用程式必須能夠自恢復,以下以Java語言的jedis用戶端為例說明:
1 、作為發布者
Jedis物件不能作為單例,網路閃斷後該Jedis物件無法自恢復。應該每次發布訊息時,從JedisPool中取Jedis對象,再呼叫set方法。
2、作為訂閱者
當網路閃斷後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){ } }
更多redis知識請關注redis入門教學欄位。
以上是redis斷線重連的詳細內容。更多資訊請關注PHP中文網其他相關文章!