Redis訊息佇列

2021-07-02 07:44:08 字數 1693 閱讀 5252

redis的訊息佇列使用簡單,沒有什麼配置,比activemq要輕量級太多,當然功能也比較簡單,如果只需要簡單的訂閱以及發布,可以考慮使用它。

訂閱操作

命令為:subscribe [channel] [channel] ..,如【**1】所示,即成功訂閱頻道[redis.blog]。

發布操作

命令為publish [channel] [message],如【**2】所示,【圖1】為訂閱的客戶端展示效果。

【**1】:

subscribe "redis. blog"
【**2】

publish "redis.blog"

"hello redis"

【圖1】

退訂操作

命令為:unsubscribe [channel] [channel] ..,如【**3】所示。

【**3】

unsubscribe "redis.blog"
模式訂閱命令為:psubscribe [pattern] [pattern]…,如【**4】所示,如果發布的訊息符合當前訂閱的模式,亦會收到訊息通知,如【圖2】所示。

【**4】

psubscribe "redis.*"
【圖2】

模式退訂

命令為:punsubscribe [pattern] [pattern]…,如【**5】所示。

【**5】

punsubscribe "redis.*"
資料結構關於頻道以及模式,redis通過兩個struct實現,在redisserver中是如下定義的:

struct rediserver
模式是乙個list,list中每個node為乙個pubsubpattern結構,定義如下:

typedef

struct pubsubpattern

訂閱模式:即是在當前list隊尾插入乙個pubsubpattern;

退訂模式:則是遍歷list刪除匹配節點的過程。

即使不同client訂閱同乙個模式,也是兩個不同的node,或者同乙個client訂閱2個不同模式,亦為兩個node,這一點從pubsubpattern的資料結構上能看出來。

傳送訊息

發布一條資訊,redis伺服器會執行2個操作:

另外的三個命令

至於如何將發布的訊息及時反饋給所有訂閱者,redis是通過伺服器的檔案事件來操作的,不單單是訊息佇列功能,所有的get,set操作都是通過檔案事件(file event)來驅動的,事件會單獨開一篇來介紹。

Redis 訊息佇列

訊息佇列,是在構建大型專案的時候 經常會用到的中間價系統,使用訊息佇列有很多好處,例如 1.實現各元件之間的松耦合。利用訊息系統可以使各個元件之間面向資料,而不是面向具體的介面。2.易於擴充套件。對於訊息系統而言,消費者和生產者都可以橫向擴充套件。提到佇列,很自然的就會想到redis的列表型別,可以...

Redis訊息佇列

redis的訊息佇列使用簡單,沒有什麼配置,比activemq要輕量級太多,當然功能也比較簡單,如果只需要簡單的訂閱以及發布,可以考慮使用它。訂閱操作 命令為 subscribe channel channel 如 1 所示,即成功訂閱頻道 redis.blog 發布操作 命令為publish ch...

redis實現訊息佇列

用redis實現乙個訊息通知系統,總結了一下技術細節,其中演示 如果沒有特殊說明,使用的都是phpredis擴充套件來實現的。記憶體 比如要推送一條全域性訊息,如果真的給所有使用者都推送一遍的話,那麼會占用很大的記憶體,實際上不管粘性有多高的產品,活躍使用者同全部使用者比起來,都會小很多,所以如果只...