微服务：消息队列高级消费者可靠性

目录

1.用户的可信度

1.1.用户验证机制

1.2.异常重传机制

1.3.异常应对策略

1.4.事务幂等性

1.4.1.唯一消息标识符

1.4.2.业务逻辑判定

1.5.应急处理方案

---

1.消费者的可靠性

在RabbitMQ将消息发送给消费者之后，必须了解消费者对消息的处理情况。因为消息被传递给消费者并不意味着其已被正确消费，其间可能出现多种异常状况，例如：

消息在传输过程中遭遇网络中断

消费者在接收到消息后突然出现系统崩溃

消费者接收到消息后，由于处理逻辑存在缺陷而引发错误

...

一旦上述问题发生，消息就有可能丢失。因此，RabbitMQ需要掌握消费者的处理状态，以便在消息处理失败时能够重新发送该消息。

然而，随之而来的问题是：RabbitMQ如何能够准确获取消费者的处理状态？

本节内容将共同探讨消费者在处理消息过程中的可靠性保障机制。

1.1.消费者确认机制

为验证消费者是否有效处理消息，RabbitMQ引入了消费者确认机制（Consumer Acknowledgement）。具体而言，当消费者完成消息处理后，需向RabbitMQ发送一个确认信号，用以反馈当前的消息处理状态。该确认信号包含三种可选类型：

ack：表示消息已成功处理，RabbitMQ将从队列中移除该消息；

nack：表示消息处理失败