后端随身听|消费者明明处理成功了,消息为什么还会重复
消费者已经成功增加积分,为什么同一条消息还会再次出现?这一集从消息队列基础概念讲起,对照 RabbitMQ 的消费者确认与 Kafka 的消费偏移量,解释重复消息真正发生的时间窗口。
重点内容:
生产者、消息代理、队列、消费者分别做什么
RabbitMQ 的交换器、队列、手动确认和预取数量
Kafka 的主题、分区、消费者组和偏移量
至少一次、至多一次、恰好一次分别意味着什么
为什么业务成功后仍可能重复投递
如何使用业务唯一标识、数据库事务和唯一约束实现消费幂等
英文词对照:
Producer:生产者
Consumer:消费者
Broker:消息代理
Queue:队列
Exchange:交换器
Acknowledgement:确认
Topic:主题
Partition:分区
Consumer Group:消费者组
Offset:偏移量
Idempotency:幂等
Dead Letter Queue:死信队列

