記一次Redis發布訂閱與websocket聯用

2021-10-06 13:49:14 字數 669 閱讀 1460

程式設計菜鳥,首次發帖,記錄一下近期工作中使用到了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 時,這個訊息就會被傳送給訂閱它的三...