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

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

阅读 3.6k
1 个回答

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

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

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

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进