消息队列如何保证消费的幂等性?

烧麦
  • 212

为了防止消息队列的消息丢失,有一种方法是通过ack机制:消费者消费成功的时候通过ack通知消息队列告诉他我这边成功了,你可以删消息了。
但是我这边有一个疑问:假如消费者在发送ack之前,队列里面的那条消息被其他消费者消费去了怎么办?如何保证消费的幂等性?

回复
阅读 2.1k
1 个回答

消息队列为啥要给你保证幂等性?

所有主流的消息队列:RabbitMQ、ActiveMQ、RocketMQ、Kafka 均指出,幂等性是你业务上才需要保证的,你需要利用其他手段来保证一条数据(比如加一个唯一的消息 ID 入库)不被处理多次。消息队列本身不 care 这件事。

消息队列最需要保证的是消息不能丢,至少会被消费一次

宣传栏