為什么用訂閱發布機制？原因在于它的速度要比pop、push快很多。

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

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

下圖展示了頻道 channel1 ， 以及訂閱這個頻道的三個客戶端 —— client2 、 client5 和 client1 之間的關系

當有新消息通過 PUBLISH 命令發送給頻道 channel1 時， 這個消息就會被發送給訂閱它的三個客戶端：

?

實例一

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

#coding:utf-8import time import redisnumber_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-8import time import redisrc = redis.StrictRedis(host="192.168.101.3", port="6379", db=0, password="chishiba") ps = rc.pubsub() ps.subscribe("chishiba") # 訂閱消息 a = 0 for item in ps.listen(): # 監聽狀態：有消息發布了就拿過來#print(type(item))a += 1if a % 1000 == 0:print(a)

?

實例二（連接池）

redis訂閱/發布機制工具類：

import redisclass RedisHelper:def __init__(self):self.connection_pool = redis.ConnectionPool(host="127.0.0.1", port=6379)self.__conn = redis.Redis(connection_pool=self.connection_pool)#連接redisdef publish(self, pub, msg):self.__conn.publish(pub, msg)#根據提供的頻道進行消息發布return Truedef subscribe(self, sub):pub = self.__conn.pubsub() # 打開收音機pub.subscribe(sub) # 調頻道pub.parse_response() # 準備接收return pub

訂閱端：

from redis_utils import RedisHelperred = RedisHelper()#得到實例化對象 while 1:data = red.subscribe("Bao").parse_response()#此時會處于一直訂閱的狀態有數據就會接收過來if data:print(str(data[2], encoding="utf-8"))

發布端：

from redis_utils import RedisHelperred = RedisHelper() while 1:data = str(input("請輸入您想推送的數據："))if data:red.publish("Bao", data)print("finished")

?

總結，要點有兩個：

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

總結

以上是生活随笔為你收集整理的Python redis的订阅发布机制（publish、pubsub）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。