利用Redis实现订阅发布模式（redis订阅模型）

利用Redis实现订阅发布模式

Redis是一种高性能的键值数据存储系统，它提供了订阅发布（Pub/Sub）模式，该模式可以用来实现实时消息推送、事件驱动等应用场景。本文将介绍如何使用Redis的Pub/Sub模式来实现订阅发布模式。

1. 订阅

订阅模式的核心是订阅者（subscriber）对某种消息的“订阅”。在Redis中，通过以下命令进行订阅：

SUBSCRIBE channel [channel ...]

其中的“channel“参数为需要订阅的消息通道。可以同时订阅多个通道，例如：

SUBSCRIBE news weather sports

当有消息发布到某个订阅的通道时，Redis会将消息推送给所有订阅该通道的订阅者。订阅者可以使用以下命令取消订阅：

UNSUBSCRIBE [channel [channel ...]]

例如：

UNSUBSCRIBE weather

即可取消订阅“weather“通道。

以下是一个Python示例，演示如何使用Redis的Pub/Sub模式进行订阅：

import redis
r = redis.Redis(host='localhost', port=6379)

p = r.pubsub()
p.subscribe('news')
for message in p.listen():
    print(message['channel'], message['data'])

上述代码中，通过“r.pubsub()“创建了一个发布/订阅实例“p“，并订阅了“news“通道。之后，使用“p.listen()“函数进入一个无限循环，从而等待新的消息发布。当有新的消息发布到“news“通道时，将会通过“message[‘data’]“返回消息的具体内容。

2. 发布

发布模式的核心是发布者（publisher）向某个消息通道发布消息。在Redis中，通过以下命令进行发布：

PUBLISH channel message

其中的“channel“参数为消息通道，“message“参数为具体的消息内容。

以下是一个Python示例，演示如何使用Redis的Pub/Sub模式进行发布：

import redis
r = redis.Redis(host='localhost', port=6379)

r.publish('news', 'Hello, world!')

上述代码中，通过“r.publish(‘news’, ‘Hello, world!’)“向“news“通道发布了一条消息。

3. 订阅发布示例

以下是一个Python示例，演示如何使用Redis的Pub/Sub模式实现一个简单的订阅发布应用。该应用支持多个订阅者同时订阅消息，并灵活添加、删除订阅者。

import redis
class Publisher:
    def __init__(self):
        self.r = redis.Redis(host='localhost', port=6379)

    def publish(self, channel, message):
        self.r.publish(channel, message)
class Subscriber:
    def __init__(self):
        self.r = redis.Redis(host='localhost', port=6379)
        self.p = self.r.pubsub()
    def subscribe(self, channel):
        self.p.subscribe(channel)
    def unsubscribe(self, channel):
        self.p.unsubscribe(channel)
    def listen(self):
        for message in self.p.listen():
            print(message['channel'], message['data'])

# 测试订阅发布应用
p1 = Publisher()
s1 = Subscriber()
s2 = Subscriber()
s3 = Subscriber()
s1.subscribe('news')
s2.subscribe('news')
s3.subscribe('news')
p1.publish('news', 'Hello, world!')
s1.listen()
s2.listen()
s3.listen()

上述代码中，“Publisher“类负责发布消息，“Subscriber“类负责订阅消息。在测试代码中，首先创建了一个“Publisher“实例“p1“和3个“Subscriber“实例“s1“、“s2“、“s3“。之后，“s1“、“s2“、“s3“实例分别订阅了“news“通道，并通过“p1.publish()“向该通道发布了一条消息。分别启动了“s1.listen()“、“s2.listen()“和“s3.listen()“函数，等待消息发布并打印出来。