先介紹一下redis的pub/sub功能：
Pub/Sub功能（means Publish, Subscribe）即發(fā)布及訂閱功能【现担基于事件的系統(tǒng)中刹前，Pub/Sub是目前廣泛使用的通信模型，它采用事件作為基本的通信機制裳仆，提供大規(guī)模系統(tǒng)所要求的松散耦合的交互模式：訂閱者(如客戶端)以事件訂閱的方式表達出它有興趣接收的一個事件或一類事件溉箕；發(fā)布者(如服務器)可將訂閱者感興趣的事件隨時通知相關訂閱者晦墙。
通俗來講，就是說我sub端（訂閱者）一直監(jiān)聽著肴茄，一旦pub端（發(fā)布者）發(fā)布了消息晌畅，那么我就接收過來，舉個例子寡痰，先是發(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']
關于數(shù)據(jù)結構抗楔，也就是item棋凳，是類似于：{'pattern': None, 'type': 'message', 'channel': 'liao', 'data': '300033 1'}這樣的，所以可以通過channel來判斷這個消息是屬于哪一個隊列里的连躏。（運行程序的時候剩岳，先運行訂閱者，在運行發(fā)布者程序）
總結入热，要點有兩個：
一是連接方式拍棕。使用python連接redis有三種方式：①使用庫中的Redis類（或StrictRedis類，其實差不多）勺良；②使用ConnectionPool連接池（可保持長連接）绰播；③使用Sentinel類（如果有多個redis做集群時，程序會自己選擇一個合適的連接）尚困。
二是訂閱方法幅垮。這里使用的是StrictRedis類中的pubsub方法。連接好之后尾组，可使用subscribe或psubscribe方法來訂閱redis消息。其中subscribe是訂閱一個頻道示弓，psubscribe可訂閱多個頻道（這樣寫的時候讳侨，作為參數(shù)的頻道應該是一個列表）。之后就可以開始監(jiān)聽了奏属。
作者：豬笨是念來過倒
來源：CSDN
原文：https://blog.csdn.net/liao392781/article/details/81180999
版權聲明：本文為博主原創(chuàng)文章跨跨，轉載請附上博文鏈接！
