python中sub-pub機制怎么實現Redis的訂閱與發布

本篇內容介紹了“python中sub-pub機制怎么實現Redis的訂閱與發布”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

先介紹一下redis的pub/sub功能：

Pub/Sub功能（means Publish, Subscribe）即發布及訂閱功能。基于事件的系統中，Pub/Sub是目前廣泛使用的通信模型，它采用事件作為基本的通信機制，提供大規模系統所要求的松散耦合的交互模式：訂閱者(如客戶端)以事件訂閱的方式表達出它有興趣接收的一個事件或一類事件；發布者(如服務器)可將訂閱者感興趣的事件隨時通知相關訂閱者。

通俗來講，就是說我sub端（訂閱者）一直監聽著，一旦pub端（發布者）發布了消息，那么我就接收過來，舉個例子，先是發布者：

#coding:utf-8
import time
import redis
 
number_list = ['300033', '300032', '300031', '300030']
signal = ['1', '-1', '1', '-1']
 
rc = redis.StrictRedis(host='***', port='6379', db=3, password='********')
for i in range(len(number_list)):
    value_new = str(number_list[i]) + ' ' + str(signal[i])
    rc.publish("liao", value_new)  #發布消息到liao

接著我們來看看訂閱者：

#coding:utf-8
import time
import redis
 
rc = redis.StrictRedis(host='****', port='6379', db=3, password='******')
ps = rc.pubsub()
ps.subscribe('liao')  #從liao訂閱消息
for item in ps.listen():        #監聽狀態：有消息發布了就拿過來
    if item['type'] == 'message':
        print item['channel']
        print item['data']

關于數據結構，也就是item，是類似于：{'pattern': None, 'type': 'message', 'channel': 'liao', 'data': '300033 1'}這樣的，所以可以通過channel來判斷這個消息是屬于哪一個隊列里的。（運行程序的時候，先運行訂閱者，在運行發布者程序）

總結，要點有兩個：

• 一是連接方式。使用python連接redis有三種方式：①使用庫中的Redis類（或StrictRedis類，其實差不多）；②使用ConnectionPool連接池（可保持長連接）；③使用Sentinel類（如果有多個redis做集群時，程序會自己選擇一個合適的連接）。

• 二是訂閱方法。這里使用的是StrictRedis類中的pubsub方法。連接好之后，可使用subscribe或psubscribe方法來訂閱redis消息。其中subscribe是訂閱一個頻道，psubscribe可訂閱多個頻道（這樣寫的時候，作為參數的頻道應該是一個列表）。之后就可以開始監聽了。

“python中sub-pub機制怎么實現Redis的訂閱與發布”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！