当前位置: 首页 > news >正文

商城系统分布式下单

一、锁定库存的sql
select * from ware where id={id} and total-lock>0
update ware set lock=lock+{num} where id={id} and total-lock>={num}
二、下单服务要用分布式事务,因为seat的二阶段提交要说很多资源,会造成处理变成串行化,高并发下不使用,采用柔性事务+消息队列最终一致化方案

到这里终于懂了,采用柔性事务+消息队列最终一致化方案就是当事务中的某一个操作失败后,采用消息队列补偿机制,通过发送消息将执行的操作进行反省操作 达到回滚的目的。
这里有两种方案:一、当try操作失败以后,在catch中发送一条消息,消息处理方收到消息以后,将数据还原
二、在try的时候,直接发送一条消息,而不是登发生异常以后再发送,这条消息是发到延迟队列的,这样做的好处是,不用再catch中做补偿了,延时队列中的消息到时间以后,判断数据状态,需要补偿的进行数据的回滚,不需要的直接忽略。

三、采用延时队列的好处,可以实现自动关单的功能同时还能实现消息补偿

其实分布式事务 就是把原先在一个方法中的事务 分到了不同的服务中,这个时候就要考虑,这个时候就要考虑被调用方 和调用方 发生错误回滚的不同情况,

@Transactional
public void test (){save(classA);feginB();feginC();feginD();
}
@Transactional
public R feginB(){
doService()
sendMessage();
}
@Transactional
public R feginC(){
doService()
sendMessage();
}
@Transactional
public R feginD(){
doService()
sendMessage();
}

fegin中的消息队列就是为了fegin事务回滚用的
比如feginC()发生错误,这时候需要回滚feginB,这时候可以采用在test()方法中catch异常然后发送消息,进行数据的补偿回滚,我们采用在fegin主动调用延时队列的方式,就不用catch了,并且还可以做到期自动关单
发送消息是为了回滚,需要新增表专门记录需要回滚的数据id是哪个,回滚数据的值为哪些。
为什么延迟队列用能做到期自动关单呢,其实把下单逻辑当成一个大事务来看,feginD就是支付方法,到期未支付就是fefinD发生异常,所以也需要发送消息就行数据的补偿,和大逻辑就吻合了。

另一个问题feginC中发生了异常,这时候就不能catch异常,必须抛异常使得test方法回滚,因为feginC也是事务方法,所以feginC的方法也回滚了。如果feginC中是循环发送消息的,也没关系,因为消息记录表中的数据也回滚了,当处理消息的时候 在消息记录表中查不到数据,也不会过多处理。这里发送消息的时候处理发送消息记录表中的id,最好把主表的相关数据也传过去,要不然容易造成主表记录没有回滚

解锁库存 三种情况
1、到期自动关单
2、用户手动关单
3、因为调用feginC失败,需要将feginB回滚

一个事务中调用fegin fegin也是一个事务,并且fegin中调用了消息队列

http://www.lryc.cn/news/223921.html

相关文章:

  • Java自学第5课:Java web开发环境概述,更换Eclipse版本
  • [网鼎杯 2020 青龙组]AreUSerialz
  • 使用Kotlin与Unirest库抓取音频文件的技术实践
  • gdb调试常用命令
  • CH11_重构API
  • UPLOAD-LABS1
  • WordPress相关文章推荐
  • 【QML】Qt和QML获取操作系统类型
  • CSS 显示、定位、布局、浮动
  • Java 学习笔记
  • 项目实战:优化Servlet,把所有围绕Fruit操作的Servlet封装成一个Servlet
  • Go语言函数参数
  • 【遍历二叉树的非递归算法,二叉树的层次遍历】
  • 数模之线性规划
  • 【C++】AVL树的4中旋转调整
  • 【MATLAB源码-第69期】基于matlab的LDPC码,turbo码,卷积码误码率对比,码率均为1/3,BPSK调制。
  • Java获取时间戳、字符串和Date对象的相互转换、日期时间格式化、获取年月日
  • 用c语言实现矩阵转置
  • 蓝桥杯官网练习题(移动距离)
  • 不止于“初见成效”,阿斯利康要让数据流转,以 AI 带动决策智能
  • nav2 调节纯追踪算法
  • 安装RabbitMQ
  • Spring基础(1):两个概念
  • 国产化精密划片机已得到国内更多厂家青睐
  • Voice Control for ChatGPT简单高效的与ChatGPT进行交流学习。
  • flutter生态一统甜夏 @Android @ios @windowse @macos @linux @Web
  • 计算机基础知识49
  • el-table给某一行加背景色
  • 搭建 Makefile+OpenOCD+CMSIS-DAP+Vscode arm-none-eabi-gcc 工程模板
  • Unity场景ab包加载压缩(LZ4,LZMA)格式的测试