Redis订阅模式的高级功能-模式订阅

import redis
import threading

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

# 发布消息的方法
def publish_message():
    while True:
        message = input("Please input your message:")
        r.publish('my_channel', message)

# 订阅频道的方法
def subscribe_channel():
    p = r.pubsub()
    p.psubscribe('my_*')
    for message in p.listen():
        print(f"Received message: {message['data'].decode('utf-8')}")

# 启动两个线程，一个用于发布消息，一个用于订阅频道
if __name__ == '__main__':
    t1 = threading.Thread(target=publish_message)
    t2 = threading.Thread(target=subscribe_channel)
    t1.start()
    t2.start()