为了防止消息队列的消息丢失,有一种方法是通过ack机制:消费者消费成功的时候通过ack通知消息队列告诉他我这边成功了,你可以删消息了。
但是我这边有一个疑问:假如消费者在发送ack之前,队列里面的那条消息被其他消费者消费去了怎么办?如何保证消费的幂等性?
为了防止消息队列的消息丢失,有一种方法是通过ack机制:消费者消费成功的时候通过ack通知消息队列告诉他我这边成功了,你可以删消息了。
但是我这边有一个疑问:假如消费者在发送ack之前,队列里面的那条消息被其他消费者消费去了怎么办?如何保证消费的幂等性?
1 回答1.3k 阅读✓ 已解决
1 回答1.1k 阅读
1 回答832 阅读
消息队列为啥要给你保证幂等性?
所有主流的消息队列:RabbitMQ、ActiveMQ、RocketMQ、Kafka 均指出,幂等性是你业务上才需要保证的,你需要利用其他手段来保证一条数据(比如加一个唯一的消息 ID 入库)不被处理多次。消息队列本身不 care 这件事。
消息队列最需要保证的是消息不能丢,至少会被消费一次。