程式設計菜鳥,首次發帖,記錄一下近期工作中使用到了redis的發布訂閱模式。
專案要求使用websocket與後端互動,並且需要兩個系統的應用同步,所以想到了使用redis的發布訂閱模式來實現後端的資料實時同步功能。
public
void sendmessage (
)
public
class
listener
extends
jedispubsub
}
// 宣告乙個***
listener listener =
newlistener()
;// 當頁面連線時建立乙個消費者執行緒
@onopen
public
void onopen (session session, string msg)))
;// 消費者宣告之後會一直保持阻塞狀態,宣告後立刻呼叫shutdown()方法
thread.
shutdown()
;}// 頁面關閉操作
@onclose
public
void
onclose()
throws ioexception
Redis 發布與訂閱
redis 自從2.0版本後,增加發布與訂閱等新特性,該功能有點類似設計模式中的觀察者模式,對訊息的生產者與接收者進行松耦合。也可以用該特性實現系統與系統之間的訊息傳遞,該功能的 的實現非常實用和高效。下面我們介紹一下,如何使用發布與訂閱 redis提供發布與訂閱幾個命令 subscribe cha...
redis發布與訂閱
redis在2.8.0版本之後出了乙個新功能,叫pub sub,也叫 發布與訂閱 在這篇文章中不僅要介紹它是如何用的,更重要的是要介紹它的應用場景。在之前介紹websocket之用tubesock在rails實現聊天室 五 的時候,就用redis的pub sub實現過聊天室。相關的 是這樣的 red...
Redis發布與訂閱
訂閱 發布訊息圖 第乙個 訊息傳送者,第二個 頻道 第三個 訊息訂閱者!下圖展示了頻道 channel1 以及訂閱這個頻道的三個客戶端 client2 client5 和 client1 之間的關係 當有新訊息通過 publish 命令傳送給頻道 channel1 時,這個訊息就會被傳送給訂閱它的三...