一般來說,消息隊列有兩種場景,一種是發布者訂閱者模式,一種是生產者消費者模式。利用redis這兩種場景的消息隊列都能夠實現。
定義:
生產者消費者模式:生產者生產消息放到隊列里,多個消費者同時監聽隊列,誰先搶到消息誰就會從隊列中取走消息;即對於每個消息只能被最多一個消費者擁有。
發布者訂閱者模式:發布者生產消息放到隊列里,多個監聽隊列的消費者都會收到同一份消息;即正常情況下每個消費者收到的消息應該都是一樣的。
Redis不僅可作為緩存服務器,還可用作消息隊列。它的列表類型天生支持用作消息隊列。如下圖所示:
由於Redis的列表是使用雙向鏈表實現的,保存了頭尾節點,所以在列表頭尾兩邊插取元素都是非常快的。
在Redis中,List類型是按照插入順序排序的字符串鏈表。和數據結構中的普通鏈表一樣,我們可以在其頭部(left)和尾部(right)添加新的元素。在插入時,如果該鍵並不存在,Redis將為該鍵創建一個新的鏈表。與此相反,如果鏈表中所有的元素均被移除,那么該鍵也將會被從數據庫中刪除。List中可以包含的最大元素數量是4294967295。
從元素插入和刪除的效率視角來看,如果我們是在鏈表的兩頭插入或刪除元素,這將會是非常高效的操作,即使鏈表中已經存儲了百萬條記錄,該操作也可以在常量時間內完成。然而需要說明的是,如果元素插入或刪除操作是作用於鏈表中間,那將會是非常低效的。相信對於有良好數據結構基礎的開發者而言,這一點並不難理解。
Redis List的主要操作為lpush/lpop/rpush/rpop四種,分別代表從頭部和尾部的push/pop,除此之外List還提供了兩種pop操作的阻塞版本blpop/brpop,用於阻塞獲取一個對象。
Redis通常都被用做一個處理各種后台工作或消息任務的消息服務器。 一個簡單的隊列模式就是:生產者把消息放入一個列表中,等待消息的消費者用 RPOP 命令(用輪詢方式), 或者用 BRPOP 命令(如果客戶端使用阻塞操作會更好)來得到這個消息。
1、Redis 生產者/消費者模式實現消息隊列的簡單例子(此外用的是jedisCluster連接redis)
springboot的application-dev.yml中redis的配置如下:
redis:
database: 0
password: # Redis服務器連接密碼(默認為空)
timeout: 0 # 連接超時時間(毫秒)
commandTimeout: 5000
cluster:
nodes: 10.201.1.27:7001,10.201.1.27:7002,10.201.1.27:7003,10.201.1.27:7004,10.201.1.27:7005,10.201.1.27:7006
redis放入Spring容器中: