redis发布和订阅代码示例

以下是使用Python Redis客户端库`redis-py`实现Redis发布和订阅的示例代码：

import redis

# 创建Redis连接
r = redis.Redis(host='localhost', port=6379, db=0)

# 定义消息处理函数
def handle_message(message):
    print(message['data'])

# 创建订阅者对象
subscriber = r.pubsub()

# 订阅指定的频道
subscriber.subscribe('channel')

# 启动订阅线程，等待接收消息
for message in subscriber.listen():
    handle_message(message)

在上述代码中，我们首先创建了一个Redis连接对象`r`，然后定义了一个消息处理函数`handle_message`，用于处理接收到的消息。接着，我们创建了一个订阅者对象`subscriber`，并使用`subscriber.subscribe('channel')`方法订阅了指定的频道。最后，我们启动了订阅线程，等待接收消息，并在收到消息时调用`handle_message`函数进行处理。

以下是发布消息的示例代码：

import redis

# 创建Redis连接
r = redis.Redis(host='localhost', port=6379, db=0)

# 发布消息到指定的频道
r.publish('channel', 'hello, world')

在上述代码中，我们使用`r.publish('channel', 'hello, world')`方法向指定的频道发布了一条消息。当有订阅者订阅了该频道时，就会收到这条消息。