我正在使用 redis-py 2.10.6 和 redis 4.0.11。
我的应用程序使用 redis 作为数据库和 pubsub。当我关闭时,我经常会遇到挂起或崩溃的情况。后者通常会抱怨处理 pubsub 回调时发生的错误文件描述符或文件上的 I/O 错误(我不使用任何错误),所以我猜测根本问题是相同的:不知怎的,我不'无法正确断开连接,并且我的 redis.Redis 对象使用的池处于活动状态。
前一种错误的输出示例(在 _read_from_socket 期间):
redis.exceptions.ConnectionError:从套接字读取时出错:(9,'错误文件描述符')
其他时候,堆栈跟踪清楚地显示 redis/connection.py -> redis/client.py -> threading.py,这证明 redis 没有杀死它使用的线程。
当我启动应用程序时,我运行:
self.redis = redis.Redis(host=XXXX, port=XXXX)
self.pubsub = self.redis.pubsub()
subscriptions = {'chan1': self.cb1, 'chan2': self.cb2} # cb1 and cb2 are functions
self.pubsub.subscribe(**subscriptions)
self.pubsub_thread = self.pubsub.run_in_thread(sleep_time=1)
当我想退出应用程序时,我执行的最后一条指令main是对我的 redis using 类中函数的调用,其实现是:
self.pubsub.close()
self.pubsub_thread.stop()
self.redis.connection_pool.disconnect()
我的理解是,理论上我什至不需要执行任何这些“关闭”调用,但是,无论有或没有它们,我仍然无法保证彻底关闭。
我的问题是,我该如何保证干净关闭?