Redis 發布訂閱

Redis 發布訂閱可以用在像消息通知，群聊，定向推送，參數刷新加載等業務場景

發布訂閱模型有三個角色：

1. 發布者（Publisher）
2. 訂閱者(Subscriber)
3. 頻道(channel)

每個訂閱者可以訂閱多個頻道，發布者可以在某個頻道里發布消息，訂閱者會接受到自己訂閱頻道里發布的消息。

1.相關命令 (參考)

publish channel message         發布消息
subscribe [channel]             訂閱頻道
unsubscribe [channel]           取消訂閱
psubscribe [pattern...]         訂閱指定模式的頻道
punsubscribe [pattern...]       退訂指定模式的頻道
pubsub channels                 列出至少有一個訂閱者的頻道
pubsub numsub [channel...]      列表給定頻道的訂閱者數量
pubsub numpat                   列表被訂閱模式的數量 

# 在 終端1 訂閱cctv1
127.0.0.1:8100> subscribe cctv1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "cctv1"
3) (integer) 1

# 在 終端2 向cctv1 發布消息
127.0.0.1:8100> publish cctv1 "this is cctv1"
(integer) 1

# 終端1 接受到終端2發的消息
127.0.0.1:8100> subscribe cctv1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "cctv1"
3) (integer) 1
1) "message"
2) "cctv1"
3) "this is cctv1"

2. python 實現

訂閱者類，只寫了訂閱功能，退訂原理是一樣的，偷了懶，把訂閱頻道和接收消息寫到了一個方法里面，如果嚴格按面向對象的思想應該分開。

from PublishAndSubscribe.Channel import Channel
from PublishAndSubscribe.RedisTool import RedisToolclass Subscriber:def __init__(self, conn):self._conn = conndef subscribe(self, channel: Channel):# 獲取發布/訂閱對象pub = self._conn.pubsub()# 選擇要訂閱的頻道pub.subscribe(channel.name)while True:# 接收消息msg = pub.parse_response()print(msg)if __name__ == '__main__':client = RedisTool.redis_connection("0.0.0.0", 8100, "password")cctv1 = Channel("CCTV1")Subscriber(client).subscribe(cctv1)

發布者類

from PublishAndSubscribe.Channel import Channel
from PublishAndSubscribe.RedisTool import RedisToolclass Publisher:def __init__(self, conn):self._conn = conndef publish(self, channel: Channel, mess: str):# 向特定頻道發布消息self._conn.publish(channel.name, mess)if __name__ == '__main__':cctv1 = Channel("CCTV1")client = RedisTool.redis_connection("0.0.0.0", 8100, "password")publisher = Publisher(client)while True:publisher.publish(cctv1, input("請輸入要發送的消息："))

頻道類，Redis中頻道的概念只是一個字符串

class Channel:def __init__(self, name: str):self.name = name

一個工具類，用來連接redis

import redisclass RedisTool:@staticmethoddef redis_connection(address: str, port: int, password: str):"""用來連接RedisArgs:address: Redis 服務端IP地址port: [int] Redis 服務端口password: Redis client 登錄憑證Return:type[Redis]: 返回一個redis對象"""return redis.StrictRedis(address, port, password=password)

• 為了簡便在訂閱者和發布者兩處都實例化了一個“CCTV1”的頻道，雖然用起來不會有什么問題（Redis中簡單的通過字符串區分頻道），但在實際中這應該是同一個對象。

結果：