MQ客户端正常运行,突然就报连接错误,
错误信息写的很明确,是客户端连接超时。
不过很疑虑,为什么会出现连接超时呢?代码没动过,网络也ok,也设置了心跳和重连机制。
最终在官网中找到了答案:
消息“手动确认”的模式下,MQ服务会强制执行超时机制,以防止消息一直不确认的潜在bug。
RabbitMQ默认的超时时间是30分钟,30分钟内一直无消息消费的话,则RabbitMQ会将Channel销毁,无法继续消费,导致代码报错。
因此需要自行解决,可以考虑几种解决方案:
方案一:修改客户端连接超时时间;
方法1:临时修改;
优点:无须重启MQ服务;
缺点:MQ服务重启后,设置失效,需要重新设置;
以Linux系统为例,直接登录服务器,执行如下命令:
#通过命令 修改超时时间:
rabbitmqctl eval 'application:set_env(rabbit,consumer_timeout,180000000).'
#通过命令 查看MQ的超时时间:
rabbitmqctl eval 'application:get_env(rabbit,consumer_timeout).'
方法2:永久修改;
优点:MQ服务重启,设置依然生效;
缺点:需要重启MQ服务才能使设置生效,生产环境下,需要考虑业务是否可中断;
以Linux系统为例,
1、创建RabbitMQ的配置文件(默认没有该配置文件):/etc/rabbitmq.conf
2、文件中设置
consumer_timeout = 18000000
3、重启RabbitMQ。
方案二:修改业务,定时发送空消息,防止超时(在无权修改MQ服务配置的场景);
优点:无须或无权修改MQ服务的设置;
缺点:代码冗余,可能会影响业务;
略。
PS,看到有篇文章也详细讲解了BUG的原因以及解决方法,又重复造轮子了.......
版权归原作者 wangjunjun2008 所有, 如有侵权,请联系我们删除。