python怎样实现redis断开后自动重连的机制 您所在的位置:网站首页 redis自动重启无法链接 python怎样实现redis断开后自动重连的机制

python怎样实现redis断开后自动重连的机制

2023-07-25 10:50| 来源: 网络整理| 查看: 265

#python怎样实现redis断开后自动重连的机制

近来在做的一个项目,利用redis实现消息队列,在发布端用lpush,将数据写入到队列中,在订阅端用rpop方法依次读出每条数据并处理,需要在windows服务中循环读取redis里的数据并做进一步处理。

在这过程中遇到一个比较麻烦的问题,就是redis的连接每过一段时间会被redis服务器主动断开,查看redis的日志,记录的原因是psubscribe scheduled to be closed ASAP for overcoming of output buffer limits,刚开始的时候发现确实在处理消息时耗时太长,引起队列堵塞,导致缓冲区的内容过多,超出了redis连接的内存限制而被强制断开了,经过优化后处理每条消息的时长已经缩短到3毫秒左右,但偶尔仍然会出现redis连接被强制断开的情况。

考虑到这个服务要常驻在系统中的,就算redis服务器不主动断开连接,也有可能会出现redis服务器宕机或需要重启的情况,所以要建立redis连接断开后自动重连的机制比较可靠,于是写了一个getRedis方法,当在redis操作中抛出异常时,就自动重连直至连接成功后再返回。

刚开始写的代码,运行后发现redis的连接异常一直捕获不到,因为redis实例化时虽然传入了ip,端口等参数,但是没有真正连接的,所以并没有触发异常。知道了原因,解决也很简单,就是在实例化redis连接后调用一下ping方法或get方法(key随意,就算是一个不存在的key也不影响结果),这样当连接有问题时就会抛出异常,这时候再去尝试重连,直至成功再返回实例就可以了,最终代码如下:

from redis import ConnectionPool, Redis #获取redis服务器连接 def getRedis(): while True: try: pool = ConnectionPool(host='192.168.8.211', port=6379, db=0, password=None, decode_responses=True, health_check_interval=30) redis = Redis(connection_pool=pool) redis.ping() except Exception as e: print('redis连接失败,正在尝试重连') continue else: return redis


【本文地址】

公司简介

联系我们

今日新闻

    推荐新闻

    专题文章
      CopyRight 2018-2019 实验室设备网 版权所有