RabbitMQ可靠性投递、等幂性(三)
目录
什么是可靠性投递?
- 保障消息的成功发出
- 保障MQ节点的成功接收
- 发送端收到MQ节点确认应答
- 完善消息的补偿机制
方案一
- 消息入库
- 发送消息到队列
- MQ节点确认应答
- 消费端收到应答后将状态值写入DB
- 定时任务检查DB中的状态值,如果为0,重新请求生产端发送消息,超过尝试次数,则把状态值为2写入库。
方案二
消息延迟投递,做二次确认,回调检查
等幂性
什么是等幂性
确保多次的重复请求之后,最终程序运行的结果是一致的。(好比我们在做支付操作的时候,如果重复点击支付,最终只会成功支付一次,不会因为重复支付而重复扣余额)
如何保障消费端的等幂性( 通过version的迭代)
- 唯一ID+指纹码 机制(实现简单,但是高并发下有数据库写入的性能瓶颈)
- 利用redis原子特性实现