栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

本地事务表+普通mq实现最终一致性

本地事务表+普通mq实现最终一致性

主要流程步骤
  1. 1,本地业务数据处理
  2. 2.1本地消息数据处理(1+2.1需要在同一个事务),要么成功,要么失败
  3. 2.2 发送消息给mq
  4. 3,消息投递到Consumer消费端
  5. 4,消费端服务处理业务数据
  6. 5,业务端业务数据消费成功,反馈给comsumer
  7. 6,comsumer返回ack非消息中间件MQ
  8. 7,发送ack消息,更新本地消息表,表示已经完成或者消费成功,修改消息状态
  9. 8,恢复系统定时轮询消息表,找出没有消费成功ack的消息
  10. 9,重新发送没有消费成功的消息

bad case
  1. 如果1,2.1出错,本地事务回滚,业务数据,消息都没有变化,啥都没做
  2. 如果2.2 发送失败,定时任务系统会查询消息表,依据状态重新发送
  3. 3-7步骤出错,也没法ack本地消息表,都会重新发送消息
  4. 既然会重新发送消息,那消费端就要考虑重复消息的问题,也就是幂等,尤其是在7.1/7.2确认过程中失败了,一旦重复发送,如果不幂等,业务逻辑就会重复执行,如果是减库存或者支付场景,就会出现多加或者多减数据,出现不一致

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/672415.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号