本篇紧接上文《从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架（五） SEATA分布式事务篇（上） 运行原理以及AT模式源码启动版集成》
读写分离/分库分表 配置集成参考我之前的该篇文章《从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架（四） (mini-cloud) 集成shardingSphere 读写分离 》
mini-cloud下构建分布式事务案例场景-电商订单-库存分布式事务问题 电商订单-库存分布式事务场景图示场景描述
订单库存是典型的微服务分布式事务问题，首先看看如上图所示的流程
1.用户下单，订单服务首先调用库存服务校验以及扣除库存
2.如果扣除成功，订单服务则创建一个订单并返回用户提示下单成功
3.如果扣除失败，订单服务则返回用户提示库存不足，下单失败。
场景很简单，正常情况下只要业务数据逻辑正确，本身是没有什么大问题的，
但是注意看红框框住的部分，如果扣除库存成功了，但是订单服务后续业务处理报错了，那么将会是什么结果呢，首先订单服务本身的数据肯定是会回滚的，因为在一个事务里报错了，但是库存服务的数据已经commit了，所以现在就会造成库存多扣了实际订单没有创建的情况，其实实际情况要复杂得多，因为图示是简化版，真实项目里可能会调用了更多的服务，相关联的数据有可能横跨很多数据库，所以分布式事务的控制是很必要的，其实现在有很多分布式事务的解决方案
1. 最简单的是xa分布式事务方案，因为是基于数据库本身的机制进行的，少许代码即可
2.二段式，三段式，这些就和业务挂钩相对紧密了，需要手动去写业务回滚的业务处理部分
3.saga 本身其实也是需要手动写业务归滚部分代码，但是现如今框架会帮助处理大部分逻辑流程
4.最终一致性，一般应用mq消息中间件，业务发起到结束期间允许数据的不一致，最后结束时保证一直，这种情况一般不会发生在强一直行场景下，比如转账，支付，扣除库存等，所以这里不太适合，但是可以配和缓存做伪强一致性处理，后续可以单独写一篇高并发下订单问题篇
4.at 模式，比如seata的at模式，框架本身会帮助你拦截你本次涉及的所有服务的数据库sql,并生成反向sql保存起来，如果成功则删除这些sql,失败就执行这些sql恢复数据，可以参考上一篇，里面对原理有所介绍，下面图是简单画的seata at模式原理图
从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架（五） SEATA分布式事务篇（上） 运行原理以及AT模式源码启动版集成
mini-cloud 集成订单服务与库存服务（shardingsphere读写分离） 创建订单服务和库存服务在mini-cloud 框架中有一个simulate模块，专门用来创建各个业务创建的模拟服务，这里我们直接创建两个服务，订单服务和库存服务，过程不细说了，就是正常创建服务并且注册到我们的nacos里面，可以参考我之前的文章，结果如下
创建订单服务和库存服务数据库由于我们是三个库的读写分离，简化起见只展示库和表设计
商品库存库 与表设计
订单库与表设计
为了简单起见每个库只有一个表，每个表就俩字段，undo_log是后面seata 需要的回滚表，后续回有介绍
创建订单服务和库存服务配置中心内sharesphere 读写分离由于我们是shareshpere的读写分离库，所以需要配置shareshpere 读写分离并写入nacos配置中心
商品库存库
spring:
shardingsphere:
props:
sql:
show: true
datasource:
names: master,slave0,slave1
master:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://${MYSQL_HOST:master}:${MYSQL_PORT:3306}/${MYSQL_DB:mini_cloud_goods}?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&allowMultiQueries=true&allowPublicKeyRetrieval=true
username: root
password: root
slave0:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://${MYSQL_HOST:slave0}:${MYSQL_PORT:3306}/${MYSQL_DB:mini_cloud_goods}?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&allowMultiQueries=true&allowPublicKeyRetrieval=true
username: root
password: root
slave1:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://${MYSQL_HOST:slave1}:${MYSQL_PORT:3306}/${MYSQL_DB:mini_cloud_goods}?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&allowMultiQueries=true&allowPublicKeyRetrieval=true
username: root
password: root
sharding:
master-slave-rules:
master:
master-data-source-name: master
slave-data-source-names: slave0,slave1
application:
name: @artifactId@
cloud:
nacos:
discovery:
server-addr: ${NACOS_HOST:127.0.0.1}:${NACOS_PORT:8848}
config:
server-addr: ${spring.cloud.nacos.discovery.server-addr}
file-extension: yml
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
profiles:
active: @profiles.active@
订单库
spring:
shardingsphere:
props:
sql:
show: true
datasource:
names: master,slave0,slave1
master:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://${MYSQL_HOST:master}:${MYSQL_PORT:3306}/${MYSQL_DB:mini_cloud_order}?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&allowMultiQueries=true&allowPublicKeyRetrieval=true
username: root
password: root
slave0:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://${MYSQL_HOST:slave0}:${MYSQL_PORT:3306}/${MYSQL_DB:mini_cloud_order}?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&allowMultiQueries=true&allowPublicKeyRetrieval=true
username: root
password: root
slave1:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://${MYSQL_HOST:slave1}:${MYSQL_PORT:3306}/${MYSQL_DB:mini_cloud_order}?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&allowMultiQueries=true&allowPublicKeyRetrieval=true
username: root
password: root
sharding:
master-slave-rules:
master:
master-data-source-name: master
slave-data-source-names: slave0,slave1
application:
name: @artifactId@
cloud:
nacos:
discovery:
server-addr: ${NACOS_HOST:127.0.0.1}:${NACOS_PORT:8848}
config:
server-addr: ${spring.cloud.nacos.discovery.server-addr}
file-extension: yml
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
profiles:
active: @profiles.active@
security:
enable: false
client:
ignore-urls:
- /order
@PostMapping("/subStock/{goodsId}/{num}")
public boolean subStock(@PathVariable("goodsId")Integer goodsId,@PathVariable("num")Integer num){
boolean result = goodsService.subStock(goodsId,num);
if(!result){
return false;
}else {
return true;
}
}
}
GoodsServiceImpl
package com.minicloud.goods.service.impl;
import cn.org.atool.fluent.mybatis.base.crud.IUpdate;
import com.minicloud.goods.entity.GoodsEntity;
import com.minicloud.goods.mapper.GoodsMapper;
import com.minicloud.goods.service.GoodsService;
import com.minicloud.goods.wrapper.GoodsQuery;
import com.minicloud.goods.wrapper.GoodsUpdate;
import io.seata.core.context.RootContext;
import io.seata.spring.annotation.GlobalTransactional;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.transaction.annotation.ShardingTransactionType;
import org.apache.shardingsphere.transaction.core.TransactionType;
import org.apache.shardingsphere.transaction.core.TransactionTypeHolder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
@Slf4j
@Service
public class GoodsServiceImpl implements GoodsService {
@Autowired
private GoodsMapper goodsMapper;
@Override
@Transactional(rollbackFor = Exception.class)
public boolean subStock(Integer goodsId, Integer num) {
log.info("开始全局事务，XID = " + RootContext.getXID());
IUpdate iUpdate = new GoodsUpdate().set.goodsStock().applyFunc("goods_stock -"+num).end().where.goodsId().eq(goodsId).end();
goodsMapper.updateBy(iUpdate);
GoodsEntity goodsEntity = goodsMapper.findById(goodsId);
if(goodsEntity.getGoodsStock()>0){
log.info("库存扣除成功 ,goodsId:{},num:{}",goodsId,num);
return true;
}else {
log.info("库存扣除失败 ,goodsId:{},num:{}",goodsId,num);
return false;
}
}
}
订单服务
OrderController
package com.minicloud.simulate.order.controller;
import com.minicloud.simulate.order.service.OrderService;
import io.seata.spring.annotation.GlobalTransactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/order")
public class OrderController {
@Autowired
private OrderService orderService;
@PutMapping("/create")
public ResponseEntity createOrder() throws Exception {
orderService.newOrder();
return ResponseEntity.ok().build();
}
}
OrderServiceImpl
package com.minicloud.simulate.order.service.impl;
import com.minicloud.goods.fegin.RemoteSimulateGoodsService;
import com.minicloud.simulate.order.entity.OrdersEntity;
import com.minicloud.simulate.order.mapper.OrdersMapper;
import com.minicloud.simulate.order.service.OrderService;
import io.seata.core.context.RootContext;
import io.seata.spring.annotation.GlobalTransactional;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.transaction.annotation.ShardingTransactionType;
import org.apache.shardingsphere.transaction.core.TransactionType;
import org.apache.shardingsphere.transaction.core.TransactionTypeHolder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.time.LocalDateTime;
@Slf4j
@Service
public class OrderServiceImpl implements OrderService {
@Autowired
private OrdersMapper ordersMapper;
@Resource
private RemoteSimulateGoodsService remoteSimulateGoodsService;
@Override
@Transactional(rollbackFor = Exception.class)
@ShardingTransactionType(TransactionType.BASE)
public String newOrder() throws Exception {
log.info("开始全局事务，XID = " + RootContext.getXID());
//demo 测试使用，实际应该用有意义的分布式id
String orderId = System.nanoTime()+"";
OrdersEntity ordersEntity = new OrdersEntity();
ordersEntity.setOrderId(orderId);
ordersEntity.setOrderCreateTime(LocalDateTime.now());
ordersMapper.insertWithPk(ordersEntity);
boolean result = remoteSimulateGoodsService.subStock(1,3);
if(result){
log.info("创建订单成功 ,id:{}",orderId);
}else {
throw new Exception("库存不足，创建订单失败");
}
return orderId;
}
}
启动服务并测试正常情况
首先启动所有服务，注册中心，认证中心，用户中心，网关，订单服务，库存服务，并查看
nacos服务注册情况
我们首先在库存数据库创建一个商品并且赋值初始库存为10
然后用请求创建订单接口，针对goods_id是1的商品扣除3个，正常情况下应该是库存少3变为7
然后订单表里多一条数据，那么我们测一下
运行结果：
库存表确实变为了7
订单表创建了一条数据
篇幅原因，下篇介绍异常情况下数据不一致以及seata at 的强一致性回滚
