深入解析RabbitMQ消息应答ack机制

小渣渣

登录可见。

当Consumer接收到消息、处理任务完成之后，会发送带有这个消息标示符的ack，来告诉server这个消息接收到并处理完成。RabbitMQ会一直等到处理某个消息的Consumer的链接失去之后，才确定这个消息没有正确处理，从而RabbitMQ重发这个消息。
Message acknowledgment是默认关闭的。初始化Consumer时有个noAck参数，如果设置为true，这个Consumer在收到消息之后会马上返回ack。

登录可见。

一般来说，常用的场景noack一般就是设置成true，但是对于风险要求比较高的项目，例如支付。对于每一条消息我们都需要保证他的完整性和正确性。就需要获取消息后确认执行完正确的业务逻辑后再主动返回一个ack给server。可以通过rabbitmqctl list_queues name message_rady message_unacknowleded 命令来查看队列中的消息情况，也可以通过后台管理界面。

如果noAck设置为false的时候，需要客户端主动发送一个ack给服务器，如果客户端不确认消息会出现如下情况：



只要程序还在运行，这10条消息就一直是 Unacked 状态，无法被 RabbitMQ 重新投递。更厉害的是，RabbitMQ 消息消费并没有超时机制，也就是说，程序不重启，消息就永远是 Unacked 状态。处理运维事件时不要忘了这些 Unacked 状态的消息。

Ready

此状态的消息存在于队列中待处理。

Unacknowledged

此状态的消息表示已经在处理但未确认。




当程序关闭时（实际只要 Consumer 关闭就行），这10条消息会恢复为 Ready 状态。


确认消息

客户端如果向服务端发送ack呢？也就是确认收到消息了呢？代码如下：

登录可见。

登录可见。

BasicAck方法的第二个参数 multiple 取值为 false 时，表示通知 RabbitMQ 当前消息被确认；如果为 true，则额外将比第一个参数指定的 delivery tag 小的消息一并确认。（批量确认针对的是整个信道）

取消确认

如果分布式程序其中一个客户端出现了异常，想取消确认这条消息，让其他客户端去处理这条消息怎么办？

当消费消息出现异常时，我们需要取消确认，这时我们可以使用 Channel 的 basicReject 方法。

登录可见。

第一个参数指定 delivery tag，第二个参数说明如何处理这个失败消息。requeue 值为 true 表示该消息重新放回队列头，值为 false 表示放弃这条消息。

飞鱼

学习学习。。。。