RabbitMQ消息幂等性问题
什么是幂等性
在编程中一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同
HTTP方法的幂等性是指一次和多次请求某一个资源应该具有同样的副作用。幂等性属于语义范畴,正如编译器只能帮助检查语法错误一样,HTTP规范也没有办法通过消息格式等语法手段来定义它。
简之:一个请求,不管重复来多少次,结果是不会改变的。
消费者在消费 MQ
中的消息时,MQ
已把消息发送给消费者,消费者在给 MQ
返回 ack
时网络中断,
故 MQ
未收到确认信息,该条消息会重新发给其他的消费者,或者在网络重连后再次发送给该消费者,
但实际上该消费者已成功消费了该条消息,造成消费者消费了重复的消息
所以,MQ
消费者的幂等性问题,主要在于 MQ
的重试机制,因为网络原因或客户端延迟消费导致重复消费。
注意
注意,RabbitMQ
这种消息重试(补偿)机制是默认的。
确保幂等性方案
全局ID
每个消息都有一个自身ID
,以保证再重试中不会被重复消费
业务逻辑ID
比如使用订单号码(业务逻辑ID),以保证再重试中不会被重复消费
本博客所有文章除特别声明外,均采用 CC BY-SA 4.0 协议 ,转载请注明出处!