python中sub-pub機(jī)制實(shí)現(xiàn)Redis的訂閱與發(fā)布

更新時(shí)間：2023年03月28日 15:04:23 作者：豬笨是念來過倒

本文主要介紹了python中sub-pub機(jī)制實(shí)現(xiàn)Redis的訂閱與發(fā)布，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

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

Pub/Sub功能（means Publish, Subscribe）即發(fā)布及訂閱功能?；谑录南到y(tǒng)中，Pub/Sub是目前廣泛使用的通信模型，它采用事件作為基本的通信機(jī)制，提供大規(guī)模系統(tǒng)所要求的松散耦合的交互模式：訂閱者(如客戶端)以事件訂閱的方式表達(dá)出它有興趣接收的一個(gè)事件或一類事件；發(fā)布者(如服務(wù)器)可將訂閱者感興趣的事件隨時(shí)通知相關(guān)訂閱者。

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

#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)  #發(fā)布消息到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():        #監(jiān)聽狀態(tài)：有消息發(fā)布了就拿過來
    if item['type'] == 'message':
        print item['channel']
        print item['data']

關(guān)于數(shù)據(jù)結(jié)構(gòu)，也就是item，是類似于：{'pattern': None, 'type': 'message', 'channel': 'liao', 'data': '300033 1'}這樣的，所以可以通過channel來判斷這個(gè)消息是屬于哪一個(gè)隊(duì)列里的。（運(yùn)行程序的時(shí)候，先運(yùn)行訂閱者，在運(yùn)行發(fā)布者程序）

總結(jié)，要點(diǎn)有兩個(gè)：

一是連接方式。使用python連接redis有三種方式：①使用庫中的Redis類（或StrictRedis類，其實(shí)差不多）；②使用ConnectionPool連接池（可保持長連接）；③使用Sentinel類（如果有多個(gè)redis做集群時(shí)，程序會自己選擇一個(gè)合適的連接）。
二是訂閱方法。這里使用的是StrictRedis類中的pubsub方法。連接好之后，可使用subscribe或psubscribe方法來訂閱redis消息。其中subscribe是訂閱一個(gè)頻道，psubscribe可訂閱多個(gè)頻道（這樣寫的時(shí)候，作為參數(shù)的頻道應(yīng)該是一個(gè)列表）。之后就可以開始監(jiān)聽了。

到此這篇關(guān)于python中sub-pub機(jī)制實(shí)現(xiàn)Redis的訂閱與發(fā)布的文章就介紹到這了,更多相關(guān)python Redis的訂閱與發(fā)布內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: