异常复现/错误日志
错误日志
:
Unhandled exception. RabbitMQ.Client.Exceptions.AlreadyClosedException: Already closed: The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=406, text='PRECONDITION_FAILED - delivery acknowledgement on channel 1 timed out. Timeout value used: 1800000 ms. This timeout value can be configured, see consumers doc guide to learn more', classId=0, methodId=0
ERROR MESSAGE
ack failed,Exception=Already closed: The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=406, text='PRECONDITION_FAILED - deli
very acknowledgement on channel 1 timed out. Timeout value used: 60000 ms. This timeout value can be configured, see consumers doc guide to learn more', classId=0, methodId=0
这个错误发生在 RabbitMQ 客户端,提示连接已经被关闭,并给出了关闭的原因:
- close-reason,由对等方(Peer)发起;
- code=406,表示 PRECONDITION_FAILED;
- text=‘PRECONDITION_FAILED - delivery acknowledgement on channel 1 timed out. Timeout value used: 1800000 ms. This timeout value can be configured, see consumers doc guide to learn more’,说明是因为一个名为“channel 1”的通道上的消息确认超时了,并且在规定的时间内没有得到确认。在这里,超时值为 1800000 毫秒(30 分钟)。
通俗解释就是:你的消息超时未处理,rabbbitmq服务端认为你这个客户端是有问题的,服务端已经踢出了你这个客户端,注意是整个客户端,connect连接都没了哦!
那么如何解决呢,只要配置ack的超时时间即可,官方说明:
https://www.rabbitmq.com/consumers.html#acknowledgement-timeout
如果你是docker环境,那么有一点坑,就是通过环境变量所配置的consumer_timeout
是不生效的,如下:
version: "3"
services:
rabbitmq:
image: rabbitmq:3.8-management-alpine
environment:
- RABBITMQ_CONSUMER_TIMEOUT=600000 # 设置consumer_timeout参数为600000毫秒
需要在配置文件中动态设置参数:
version: "3"
services:
rabbitmq:
image: rabbitmq:3.8-management-alpine
volumes:
- ./rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf
environment:
- RABBITMQ_CONFIG_FILE=/etc/rabbitmq/rabbitmq.conf
在rabbitmq.conf文件中,设置consumer_timeout参数。如下:
default_pass = guest
default_user = guest
default_vhost = /
consumer_timeout = 600000
常见问题:
- 如果我这个客户端有n条消息还没处理完或者正在处理,只有一条超时了,那么其余n-1消息怎么办?
答:一条消息超时后mq服务端就会认定你这个client是有问题的,mq服务端会直接断开与你这个client的连接,也就是说不管你这个client还有多少条消息,都会被送回mq的服务端,将被投递到别的客户端或者等待下次投递。文章来源:https://www.toymoban.com/news/detail-499667.html
- 该错误是否会使我的服务宕机?
答:是的,如果未正确处理异常会使服务异常关闭。如果处理了异常,也会导致mq不可用(无法接收消息,因为connect已经关闭),正确处理方式是处理异常并重新连接MQ(初始化操作)文章来源地址https://www.toymoban.com/news/detail-499667.html
到了这里,关于rabbitmq中客户端30分钟未ack报错解决的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!