RabbitMQ可靠性投递、等幂性(三)

目录

 

什么是可靠性投递?

方案一

方案二

等幂性

什么是等幂性


什么是可靠性投递?

  • 保障消息的成功发出
  • 保障MQ节点的成功接收
  • 发送端收到MQ节点确认应答
  • 完善消息的补偿机制

方案一

RabbitMQ可靠性投递、等幂性(三)

  1. 消息入库
  2. 发送消息到队列
  3. MQ节点确认应答
  4. 消费端收到应答后将状态值写入DB
  5. 定时任务检查DB中的状态值,如果为0,重新请求生产端发送消息,超过尝试次数,则把状态值为2写入库。

 

方案二

消息延迟投递,做二次确认,回调检查

RabbitMQ可靠性投递、等幂性(三)

 

等幂性

什么是等幂性

确保多次的重复请求之后,最终程序运行的结果是一致的。(好比我们在做支付操作的时候,如果重复点击支付,最终只会成功支付一次,不会因为重复支付而重复扣余额)

如何保障消费端的等幂性( 通过version的迭代)

  1. 唯一ID+指纹码 机制(实现简单,但是高并发下有数据库写入的性能瓶颈)
  2. 利用redis原子特性实现