0


rabbitmq中客户端30分钟未ack报错解决

异常复现/错误日志

错误日志

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的服务端,将被投递到别的客户端或者等待下次投递。

  • 该错误是否会使我的服务宕机?

答:是的,如果未正确处理异常会使服务异常关闭。如果处理了异常,也会导致mq不可用(无法接收消息,因为connect已经关闭),正确处理方式是处理异常并重新连接MQ(初始化操作)


本文转载自: https://blog.csdn.net/weixin_43702146/article/details/129580443
版权归原作者 L-960 所有, 如有侵权,请联系我们删除。

“rabbitmq中客户端30分钟未ack报错解决”的评论:

还没有评论