Redis 發(fā)布訂閱與事物

一、Redis的發(fā)布和訂閱

  • Redis 發(fā)布訂閱(pub/sub)是一種消息通信模式:發(fā)送者(pub)發(fā)送消息,訂閱者(sub)接收消息
  • Redis 客戶端可以訂閱任意數(shù)量的頻道
  • Redis的發(fā)布訂閱機制包括三個部分,發(fā)布者,訂閱者和Channel
發(fā)布訂閱架構(gòu)
發(fā)布訂閱架構(gòu)

發(fā)布者和訂閱者都是Redis客戶端,Channel則為Redis服務(wù)器端,發(fā)布者將消息發(fā)送到某個的頻道,訂閱了這個頻道的訂閱者就能接收到這條消息。Redis的這種發(fā)布訂閱機制與基于主題的發(fā)布訂閱類似,Channel相當(dāng)于主題。

示例
以下實例演示了發(fā)布訂閱是如何工作的。在我們實例中我們創(chuàng)建了訂閱頻道名為 redisChat:

127.0.0.1:6379> subscribe redisChat
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "redisChat"
3) (integer) 1

重新開啟個 redis 客戶端,然后在同一個頻道 redisChat 發(fā)布兩次消息

127.0.0.1:6379> publish redisChat "redis is a caching teching"
(integer) 1
127.0.0.1:6379> publish redisChat "hello"
(integer) 1

訂閱者就能接收到消息

127.0.0.1:6379> subscribe redisChat
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "redisChat"
3) (integer) 1
1) "message"
2) "redisChat"
3) "redis is a caching teching"
1) "message"
2) "redisChat"
3) "hello"

命令
下面列出了Redis 發(fā)布訂閱的常用命令:

序號 命令 描述
1 PSUBSCRIBE pattern [pattern ...] 訂閱一個或多個符合給定模式的頻道
2 PUBSUB subcommand [argument [argument ...]] 查看訂閱與發(fā)布系統(tǒng)狀態(tài)
3 PUBLISH channel message 將信息發(fā)送到指定的頻道
4 PUNSUBSCRIBE [pattern [pattern ...]] 退訂所有給定模式的頻道
5 SUBSCRIBE channel [channel ...] 訂閱給定的一個或多個頻道的信息
6 UNSUBSCRIBE [channel [channel ...]] 指退訂給定的頻道

Redis發(fā)布訂閱與ActiveMQ的比較

  1. ActiveMQ支持多種消息協(xié)議,包括AMQP,MQTT,Stomp等,并且支持JMS規(guī)范,但Redis沒有提供對這些協(xié)議的支持;
  2. ActiveMQ提供持久化功能,但Redis無法對消息持久化存儲,一旦消息被發(fā)送,如果沒有訂閱者接收,那么消息就會丟失;
  3. ActiveMQ提供了消息傳輸保障,當(dāng)客戶端連接超時或事務(wù)回滾等情況發(fā)生時,消息會被重新發(fā)送給客戶端,Redis沒有提供消息傳輸保障。

總之,ActiveMQ所提供的功能遠(yuǎn)比Redis發(fā)布訂閱要復(fù)雜,畢竟Redis不是專門做發(fā)布訂閱的,但是如果系統(tǒng)中已經(jīng)有了Redis,并且需要基本的發(fā)布訂閱功能,就沒有必要再安裝ActiveMQ了,因為可能ActiveMQ提供的功能大部分都用不到,而Redis的發(fā)布訂閱機制就能滿足需求。

二、Redis 事務(wù)

Redis 通過 MULTI 、 DISCARD 、 EXEC 和 WATCH 四個命令來實現(xiàn)事務(wù)功能。事務(wù)提供了一種 將多個命令打包, 然后一次性、按順序地執(zhí)行 的機制, 并且事務(wù)在執(zhí)行的期間不會主動中斷 —— 服務(wù)器在執(zhí)行完事務(wù)中的所有命令之后, 才會繼續(xù)處理其他客戶端的其他命令。

一個事務(wù)從開始到執(zhí)行會經(jīng)歷以下三個階段:

  • 開始事務(wù)。
  • 命令入隊。
  • 執(zhí)行事務(wù)。

示例
以下是一個事務(wù)的例子, 它先以 MULTI 開始一個事務(wù), 然后將多個命令入隊到事務(wù)中, 最后由 EXEC 命令觸發(fā)事務(wù), 一并執(zhí)行事務(wù)中的所有命令:

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set book "c++"
QUEUED
127.0.0.1:6379> get book
QUEUED
127.0.0.1:6379> exec
1) OK
2) "c++"

注意

  • 單個 Redis 命令的執(zhí)行是原子性的,但 Redis 沒有在事務(wù)上增加任何維持原子性的機制,所以 Redis 事務(wù)的執(zhí)行并不是原子性的
  • 事務(wù)可以理解為一個打包的批量執(zhí)行腳本,但批量指令并非原子化的操作,中間某條指令的失敗不會導(dǎo)致前面已做指令的回滾,也不會造成后續(xù)的指令不做

命令
下表列出了 redis 事務(wù)的相關(guān)命令:

序號 命令 描述
1 DISCARD 取消事務(wù),放棄執(zhí)行事務(wù)塊內(nèi)的所有命令
2 EXEC 執(zhí)行所有事務(wù)塊內(nèi)的命令
3 MULTI 標(biāo)記一個事務(wù)塊的開始
4 UNWATCH 取消 WATCH 命令對所有 key 的監(jiān)視
5 WATCH key [key ...] 監(jiān)視一個(或多個) key ,如果在事務(wù)執(zhí)行之前這個(或這些) key 被其他命令所改動,那么事務(wù)將被打斷

為什么redis事務(wù)不支持回滾
以下是這種做法的優(yōu)點:

  • Redis 命令只會因為錯誤的語法而失?。ú⑶疫@些問題不能在入隊時發(fā)現(xiàn)),或是命令用在了錯誤類型的鍵上面:這也就是說,從實用性的角度來說,失敗的命令是由編程錯誤造成的,而這些錯誤應(yīng)該在開發(fā)的過程中被發(fā)現(xiàn),而不應(yīng)該出現(xiàn)在生產(chǎn)環(huán)境中
  • 因為不需要對回滾進(jìn)行支持,所以 Redis 的內(nèi)部可以保持簡單且快速

有種觀點認(rèn)為 Redis 處理事務(wù)的做法會產(chǎn)生 bug , 然而需要注意的是, 在通常情況下, 回滾并不能解決編程錯誤帶來的問題。 舉個例子, 如果你本來想通過 INCR 命令將鍵的值加上 1 , 卻不小心加上了 2 , 又或者對錯誤類型的鍵執(zhí)行了 INCR , 回滾是沒有辦法處理這些情況的。

鑒于沒有任何機制能避免程序員自己造成的錯誤, 并且這類錯誤通常不會在生產(chǎn)環(huán)境中出現(xiàn), 所以 Redis 選擇了更簡單、更快速的無回滾方式來處理事務(wù)。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • 基于內(nèi)存的NoSQL數(shù)據(jù)庫。提供五種數(shù)據(jù)結(jié)構(gòu)的存儲。字符串、列表、集合、有序集合、散列表。Redis 支持很多特性...
    韓絕交閱讀 813評論 0 1
  • 第一章 季府 昨夜,國師與陛下徹夜長談的事傳遍了朝堂,不知又有幾個妃子嚼碎了牙,暗恨那禍國殃民的妖道。...
    浣妗閱讀 340評論 4 2
  • 常年求學(xué)在他方,日日思鄉(xiāng)頻望鄉(xiāng)。 端午回家見雙老,悠悠情長路更長。 終得再見父母面,不覺心暖淚兩行。 愿得早日功名...
    夜下航船閱讀 440評論 0 1
  • 做一個小實驗,看看大家對我的評價 親切.愛笑.對生活充滿熱情,喜歡拍照.臭美.吃美食!性格也很好!
    李燕平_81bf閱讀 170評論 0 0
  • 整數(shù)和浮點轉(zhuǎn)換 整數(shù)和浮點數(shù)字類型之間的轉(zhuǎn)換必須顯式: 浮點到整數(shù)轉(zhuǎn)換也必須顯式。 整數(shù)類型可以使用Double或...
    Joker_King閱讀 563評論 0 0

友情鏈接更多精彩內(nèi)容