代码之家 › 专栏 › 技术社区 › Crusaderpyro

RabbitMQ对同一消息的多次确认关闭消费者

rabbitmq go

Crusaderpyro · 技术社区 · 7 年前

如果我使用 Delivery.Ack 方法,我的消费者渠道只会自动关闭。

这是预期行为吗?有人经历过吗?

我两次确认同一条消息的原因是一种特殊情况,在这种情况下,我必须将原始消息分解为副本,并在消费者身上进行处理。一旦消费者处理了一切,它就会循环并确认一切。由于实体有副本,它会两次确认同一条消息,我的消费者渠道就会关闭

1 回复 | 直到 7 年前

Amir Rahimi Farahani 7 年前

根据 AMQP reference ,当消息第二次得到确认时,会引发通道异常:

消息的确认次数不得超过一次。接收对等方必须验证非零交付标签是否指交付的消息,如果不是这样,则引发通道异常。

第二次呼叫 Ack(...) 对于相同的消息,不会返回错误,但由于从服务器接收到此异常,通道将关闭:

Exception (406) Reason: "PRECONDITION_FAILED - unknown delivery tag ?"

可以通过以下方式注册侦听器: Channel.NotifyClose 观察此异常。

推荐文章

Danish · 确认RabbitMQ中消费者的剩余消息

6 年前

iam.Carrot · RabbitMQ队列Pika的多处理

6 年前

Raja Anbazhagan · RabbitMq监听器的ServletFilter等价物是什么?

6 年前

lexma · RabbitMQ发布到Exchange确认

6 年前

azronda · 当通过队列消息进行负载均衡时,如何处理自动生成的ID?

6 年前

CmdrSharp · 发布前请确保存在AMQP exchange绑定

6 年前

Jas · Rabbit mq错误:在线程“main”java中获取异常。io。IOException由:com引起。rabbitmq。客户关机信号异常

6 年前

Ermintar · 驼峰连接到具有额外参数的RabbitMQ队列

6 年前

Demon Coldmist · 无法连接到docker中的rabbitmq服务器,错误为:连接被拒绝

6 年前

user1295235 · 当MessageListener第一次引发异常时,RabbitMQ侦听器停止侦听消息

6 年前