16原理6小道消息pubsub天下無魚

前?我們講了Redis消息隊列的使??法，但是沒有提到Redis消為了?持消息多播，Redis不能再依賴于那5種基本數(shù)據(jù)類型了。PubSub，也就是 使?Python語?來演示?下PubSub如何使?。#-*-coding:utf-8-*-importtimeimportclient=redis.StrictRedis()p=client.pubsub()printp.get_message()client.publish("codehole","javacomes")printp.get_message()client.publish("codehole","pythoncomes")printp.get_message()printNone,'subscribe','data':None,'message','data':None,'message','codehole','data':'python客戶端發(fā)起訂閱命令后，Redis會?即給予?個反饋消息通知訂閱成get\_message才能拿到反饋消息?？蛻舳私酉聛韴?zhí)?publish命令get\_message才能拿到發(fā)布的消息。如果當(dāng)前沒有消息，get\_message會返回空，告知當(dāng)前沒有RedisPubSub?實際上使?了兩個Redis的連接。這是必須的，因為Redis不允許連接在subscribe等待消息時還要進?其它的操作。##-*-coding:utf-8-*-importtimeimportclient=redis.StrictRedis()p=client.pubsub()whileTrue:msg=p.get_message()ifnotmsg:print##-*-coding:utf-8-*-importredisclient=redis.StrictRedis()client.publish("codehole","pythoncomes")client.publish("codehole","javacomes")client.publish("codehole","golangpubsub{{'pattern':None,'type':'subscribe','channel':'codehole','data':1L}{'pattern':None,'type':'message','channel':'codehole','data':'pythoncomes'}{'pattern':None,'type':'message','channel':'codehole','data':'javacomes'}{'pattern':None,'type':'message','codehole','data':'golang上?的消費者是通過輪詢get_message來收取消息的，如果收取不到就休眠1s。這讓我們想起了第3節(jié)的消息隊列模型，我們使?blpop來代替休眠來提?消息處理的及時性。PubSub的消費者如果使?休眠的?式來輪詢消息，也會遭遇消息處理不及時的問題。不過我們可以使?listen來阻塞監(jiān)聽消息來進?處理，這點同blpop原理是?樣的。下?我們改造?下消費者##-*-coding:utf-8-*-importtimeimportclient=redis.StrictRedis()p=client.pubsub()formsginprint明確指定主題的名稱。如果我們想要訂閱多個主題，那就subscribesubscribecodehole.imagecodehole.textcodehole.blogsubscribecodehole.imagecodehole.textcodehole.blog同時訂閱三個主題，會有三條訂閱成功反饋(integer)(integer)(integer)publishcodehole.imagepublishcodehole.image(integer)1publishcodehole.text你好，歡迎加?碼洞(integer)publishcodehole.blog'{"content":"hello,everyone","title":"welcome"}'(integer)為了簡化訂閱的繁瑣，redis提供了模式訂閱功能Patternpsubscribepsubscribecodehole.*#?模式匹配?次訂閱多個主題，主題以codehole.字符開頭的消息都可以收到(integer){{'pattern':None,'type':'subscribe','channel':'codehole','data':1L}{'pattern':None,'type':'message','channel':'codehole','data':'pythoncomes'}{'pattern':None,'type':'message','channel':'codehole','data':'javacomes'}{'pattern':None,'type':'message','codehole','data':'golangsubscribe，如果是模式訂閱的反饋，它的類型就是psubscribe，還有取消訂閱指令的反饋unsubscribe和punsubscribe。PubSubPubSub的?產(chǎn)者傳遞過來?個消息，Redis會直接找到相應(yīng)的消費如果Redis停機重啟，PubSubRedis正是因為PubSub有這些缺點，它?乎找不到合適的應(yīng)?場景。所以Redis的作者單獨開啟了?個項?Disque專??來做多播消息Beta版本，但是相應(yīng)的客戶端sdk已經(jīng)?常豐富了，就待Redis作者臨??腳發(fā)布?個Release版本。關(guān)于Disque的更多細節(jié)，本?冊不