RedisPubSub无法重新连接”

Redis PubSub是Redis用于发布/订阅消息的一种机制。但是，在某些情况下，PubSub可能会失去连接，而无法自动重新连接。以下是一种解决方法，可以在连接丢失后进行重新连接：

import redis
import time 

def redis_pubsub(host='localhost', port=6379):
    r = redis.Redis(host=host, port=port)

    while True:
        pubsub = r.pubsub()
        pubsub.subscribe('channel-name')
        try:
            for message in pubsub.listen():
                print(message)
        except redis.exceptions.ConnectionError:
            # 如果连接失败，等待一段时间后重新连接
            time.sleep(5)

上述代码会不断地重复订阅并监听来自指定通道的消息。如果由于连接错误而无法监听，它会等待5秒钟并重新尝试连接。这种方法确保了Redis PubSub在连接丢失后的自动重新连接。