订单初版—2.生单链路中的技术问题说明文档

大纲
1.生单链路的业务代码
2.生单链路中可能会出现数据不一致的问题
3.Seata AT模式下的分布式事务的原理
4.Seata AT模式下的分布式事务的读写隔离原理
5.Seata AT模式下的死锁问题以及超时机制
6.Seata AT模式下的读写隔离机制的影响
7.生单链路使用Seata AT模式的具体步骤
8.生单链路使用Seata AT模式时的原理流程
9.生单链路使用Seata AT模式时的并发问题
10.生单链路如何解决库存全局锁争用问题
 
1.生单链路的业务代码
(1)生成订单流程
(2)入参检查与风控检查
(3)获取商品信息与计算订单价格及验证价格
(4)锁定优惠券与商品库存
(5)新增订单到数据库
(6)发送延迟消息到MQ
 
(1)生成订单流程

1. @Service
2. public class OrderServiceImpl implements OrderService {
3.     ...
4.     //提交订单/生成订单接口
5.     @GlobalTransactional(rollbackFor = Exception.class)
6.     @Override
7.     public CreateOrderDTO createOrder(CreateOrderRequest createOrderRequest) {
8.         //1.入参检查
9.         checkCreateOrderRequestParam(createOrderRequest);
10.         //2.风控检查
11.         checkRisk(createOrderRequest);
12.         //3.获取商品信息
13.         List<ProductSkuDTO> productSkuList = listProductSkus(createOrderRequest);
14.         //4.计算订单价格
15.         CalculateOrderAmountDTO calculateOrderAmountDTO = calculateOrderAmount(createOrderRequest, productSkuList);
16.         //5.验证订单实付金额
17.         checkRealPayAmount(createOrderRequest, calculateOrderAmountDTO);
18.         //6.锁定优惠券
19.         lockUserCoupon(createOrderRequest);
20.         //7.锁定商品库存
21.         lockProductStock(createOrderRequest);
22.         //8.生成订单到数据库
23.         addNewOrder(createOrderRequest, productSkuList, calculateOrderAmountDTO);
24.         //9.发送订单延迟消息用于支付超时自动关单
25.         sendPayOrderTimeoutDelayMessage(createOrderRequest);
26.         //返回订单信息
27.         CreateOrderDTO createOrderDTO = new CreateOrderDTO();
28.         createOrderDTO.setOrderId(createOrderRequest.getOrderId());
29.         return createOrderDTO;
30.     }
31.     ...
32. }

复制代码

(2)入参检查与风控检查

1. @Service
2. public class OrderServiceImpl implements OrderService {
3.     ...
4.     //检查创建订单请求参数
5.     private void checkCreateOrderRequestParam(CreateOrderRequest createOrderRequest) {
6.         ParamCheckUtil.checkObjectNonNull(createOrderRequest);
7.         //订单ID检查
8.         String orderId = createOrderRequest.getOrderId();
9.         ParamCheckUtil.checkStringNonEmpty(orderId, OrderErrorCodeEnum.ORDER_ID_IS_NULL);
11.         //业务线标识检查
12.         Integer businessIdentifier = createOrderRequest.getBusinessIdentifier();
13.         ParamCheckUtil.checkObjectNonNull(businessIdentifier, OrderErrorCodeEnum.BUSINESS_IDENTIFIER_IS_NULL);
14.         if (BusinessIdentifierEnum.getByCode(businessIdentifier) == null) {
15.             throw new OrderBizException(OrderErrorCodeEnum.BUSINESS_IDENTIFIER_ERROR);
16.         }
18.         //用户ID检查
19.         String userId = createOrderRequest.getUserId();
20.         ParamCheckUtil.checkStringNonEmpty(userId, OrderErrorCodeEnum.USER_ID_IS_NULL);
22.         //订单类型检查
23.         Integer orderType = createOrderRequest.getOrderType();
24.         ParamCheckUtil.checkObjectNonNull(businessIdentifier, OrderErrorCodeEnum.ORDER_TYPE_IS_NULL);
25.         if (OrderTypeEnum.getByCode(orderType) == null) {
26.             throw new OrderBizException(OrderErrorCodeEnum.ORDER_TYPE_ERROR);
27.         }
29.         //卖家ID检查
30.         String sellerId = createOrderRequest.getSellerId();
31.         ParamCheckUtil.checkStringNonEmpty(sellerId, OrderErrorCodeEnum.SELLER_ID_IS_NULL);
33.         //配送类型检查
34.         Integer deliveryType = createOrderRequest.getDeliveryType();
35.         ParamCheckUtil.checkObjectNonNull(deliveryType, OrderErrorCodeEnum.USER_ADDRESS_ERROR);
36.         if (DeliveryTypeEnum.getByCode(deliveryType) == null) {
37.             throw new OrderBizException(OrderErrorCodeEnum.DELIVERY_TYPE_ERROR);
38.         }
40.         //地址信息检查
41.         String province = createOrderRequest.getProvince();
42.         String city = createOrderRequest.getCity();
43.         String area = createOrderRequest.getArea();
44.         String streetAddress = createOrderRequest.getStreet();
45.         ParamCheckUtil.checkStringNonEmpty(province, OrderErrorCodeEnum.USER_ADDRESS_ERROR);
46.         ParamCheckUtil.checkStringNonEmpty(city, OrderErrorCodeEnum.USER_ADDRESS_ERROR);
47.         ParamCheckUtil.checkStringNonEmpty(area, OrderErrorCodeEnum.USER_ADDRESS_ERROR);
48.         ParamCheckUtil.checkStringNonEmpty(streetAddress, OrderErrorCodeEnum.USER_ADDRESS_ERROR);
50.         //区域ID检查
51.         String regionId = createOrderRequest.getRegionId();
52.         ParamCheckUtil.checkStringNonEmpty(regionId, OrderErrorCodeEnum.REGION_ID_IS_NULL);
54.         //经纬度检查
55.         BigDecimal lon = createOrderRequest.getLon();
56.         BigDecimal lat = createOrderRequest.getLat();
57.         ParamCheckUtil.checkObjectNonNull(lon, OrderErrorCodeEnum.USER_LOCATION_IS_NULL);
58.         ParamCheckUtil.checkObjectNonNull(lat, OrderErrorCodeEnum.USER_LOCATION_IS_NULL);
60.         //收货人信息检查
61.         String receiverName = createOrderRequest.getReceiverName();
62.         String receiverPhone = createOrderRequest.getReceiverPhone();
63.         ParamCheckUtil.checkStringNonEmpty(receiverName, OrderErrorCodeEnum.ORDER_RECEIVER_IS_NULL);
64.         ParamCheckUtil.checkStringNonEmpty(receiverPhone, OrderErrorCodeEnum.ORDER_RECEIVER_IS_NULL);
66.         //客户端设备信息检查
67.         String clientIp = createOrderRequest.getClientIp();
68.         ParamCheckUtil.checkStringNonEmpty(clientIp, OrderErrorCodeEnum.CLIENT_IP_IS_NULL);
70.         //商品条目信息检查
71.         List<CreateOrderRequest.OrderItemRequest> orderItemRequestList = createOrderRequest.getOrderItemRequestList();
72.         ParamCheckUtil.checkCollectionNonEmpty(orderItemRequestList, OrderErrorCodeEnum.ORDER_ITEM_IS_NULL);
73.         for (CreateOrderRequest.OrderItemRequest orderItemRequest : orderItemRequestList) {
74.             Integer productType = orderItemRequest.getProductType();
75.             Integer saleQuantity = orderItemRequest.getSaleQuantity();
76.             String skuCode = orderItemRequest.getSkuCode();
77.             ParamCheckUtil.checkObjectNonNull(productType, OrderErrorCodeEnum.ORDER_ITEM_PARAM_ERROR);
78.             ParamCheckUtil.checkObjectNonNull(saleQuantity, OrderErrorCodeEnum.ORDER_ITEM_PARAM_ERROR);
79.             ParamCheckUtil.checkStringNonEmpty(skuCode, OrderErrorCodeEnum.ORDER_ITEM_PARAM_ERROR);
80.         }
82.         //订单费用信息检查
83.         List<CreateOrderRequest.OrderAmountRequest> orderAmountRequestList = createOrderRequest.getOrderAmountRequestList();
84.         ParamCheckUtil.checkCollectionNonEmpty(orderAmountRequestList, OrderErrorCodeEnum.ORDER_AMOUNT_IS_NULL);
85.         for (CreateOrderRequest.OrderAmountRequest orderAmountRequest : orderAmountRequestList) {
86.             Integer amountType = orderAmountRequest.getAmountType();
87.             ParamCheckUtil.checkObjectNonNull(amountType, OrderErrorCodeEnum.ORDER_AMOUNT_TYPE_IS_NULL);
88.             if (AmountTypeEnum.getByCode(amountType) == null) {
89.                 throw new OrderBizException(OrderErrorCodeEnum.ORDER_AMOUNT_TYPE_PARAM_ERROR);
90.             }
91.         }
92.         Map<Integer, Integer> orderAmountMap = orderAmountRequestList.stream()
93.             .collect(Collectors.toMap(CreateOrderRequest.OrderAmountRequest::getAmountType, CreateOrderRequest.OrderAmountRequest::getAmount));
95.         //订单支付原价不能为空
96.         if (orderAmountMap.get(AmountTypeEnum.ORIGIN_PAY_AMOUNT.getCode()) == null) {
97.             throw new OrderBizException(OrderErrorCodeEnum.ORDER_ORIGIN_PAY_AMOUNT_IS_NULL);
98.         }
100.         //订单运费不能为空
101.         if (orderAmountMap.get(AmountTypeEnum.SHIPPING_AMOUNT.getCode()) == null) {
102.             throw new OrderBizException(OrderErrorCodeEnum.ORDER_SHIPPING_AMOUNT_IS_NULL);
103.         }
105.         //订单实付金额不能为空
106.         if (orderAmountMap.get(AmountTypeEnum.REAL_PAY_AMOUNT.getCode()) == null) {
107.             throw new OrderBizException(OrderErrorCodeEnum.ORDER_REAL_PAY_AMOUNT_IS_NULL);
108.         }
109.         if (StringUtils.isNotEmpty(createOrderRequest.getCouponId())) {
110.             //订单优惠券抵扣金额不能为空
111.             if (orderAmountMap.get(AmountTypeEnum.COUPON_DISCOUNT_AMOUNT.getCode()) == null) {
112.                 throw new OrderBizException(OrderErrorCodeEnum.ORDER_DISCOUNT_AMOUNT_IS_NULL);
113.             }
114.         }
116.         //订单支付信息检查
117.         List<CreateOrderRequest.PaymentRequest> paymentRequestList = createOrderRequest.getPaymentRequestList();
118.         ParamCheckUtil.checkCollectionNonEmpty(paymentRequestList, OrderErrorCodeEnum.ORDER_PAYMENT_IS_NULL);
119.         for (CreateOrderRequest.PaymentRequest paymentRequest : paymentRequestList) {
120.             Integer payType = paymentRequest.getPayType();
121.             Integer accountType = paymentRequest.getAccountType();
122.             if (payType == null || PayTypeEnum.getByCode(payType) == null) {
123.                 throw new OrderBizException(OrderErrorCodeEnum.PAY_TYPE_PARAM_ERROR);
124.             }
125.             if (accountType == null || AccountTypeEnum.getByCode(accountType) == null) {
126.                 throw new OrderBizException(OrderErrorCodeEnum.ACCOUNT_TYPE_PARAM_ERROR);
127.             }
128.         }
129.     }
131.     //风控检查
132.     private void checkRisk(CreateOrderRequest createOrderRequest) {
133.         //调用风控服务进行风控检查
134.         CheckOrderRiskRequest checkOrderRiskRequest = createOrderRequest.clone(CheckOrderRiskRequest.class);
135.         JsonResult<CheckOrderRiskDTO> jsonResult = riskApi.checkOrderRisk(checkOrderRiskRequest);
136.         if (!jsonResult.getSuccess()) {
137.             throw new OrderBizException(jsonResult.getErrorCode(), jsonResult.getErrorMessage());
138.         }
139.     }
140.     ...
141. }

复制代码

(3)获取商品信息与计算订单价格及验证价格

1. @Service
2. public class OrderServiceImpl implements OrderService {
3.     ...
4.     //获取订单条目商品信息
5.     private List<ProductSkuDTO> listProductSkus(CreateOrderRequest createOrderRequest) {
6.         List<CreateOrderRequest.OrderItemRequest> orderItemRequestList = createOrderRequest.getOrderItemRequestList();
7.         List<ProductSkuDTO> productSkuList = new ArrayList<>();
8.         for (CreateOrderRequest.OrderItemRequest orderItemRequest : orderItemRequestList) {
9.             String skuCode = orderItemRequest.getSkuCode();
10.             ProductSkuQuery productSkuQuery = new ProductSkuQuery();
11.             productSkuQuery.setSkuCode(skuCode);
12.             productSkuQuery.setSellerId(createOrderRequest.getSellerId());
13.             JsonResult<ProductSkuDTO> jsonResult = productApi.getProductSku(productSkuQuery);
14.             if (!jsonResult.getSuccess()) {
15.                 throw new OrderBizException(jsonResult.getErrorCode(), jsonResult.getErrorMessage());
16.             }
17.             ProductSkuDTO productSkuDTO = jsonResult.getData();
18.             //sku不存在
19.             if (productSkuDTO == null) {
20.                 throw new OrderBizException(OrderErrorCodeEnum.PRODUCT_SKU_CODE_ERROR, skuCode);
21.             }
22.             productSkuList.add(productSkuDTO);
23.         }
24.         return productSkuList;
25.     }
27.     //计算订单价格，如果使用了优惠券、红包、积分等，会一并进行扣减
28.     //@param createOrderRequest 订单信息
29.     //@param productSkuList     商品信息
30.     private CalculateOrderAmountDTO calculateOrderAmount(CreateOrderRequest createOrderRequest, List<ProductSkuDTO> productSkuList) {
31.         CalculateOrderAmountRequest calculateOrderPriceRequest = createOrderRequest.clone(CalculateOrderAmountRequest.class, CloneDirection.FORWARD);
32.         //订单条目补充商品信息
33.         Map<String, ProductSkuDTO> productSkuDTOMap = productSkuList.stream().collect(Collectors.toMap(ProductSkuDTO::getSkuCode, Function.identity()));
34.         calculateOrderPriceRequest.getOrderItemRequestList().forEach(item -> {
35.             String skuCode = item.getSkuCode();
36.             ProductSkuDTO productSkuDTO = productSkuDTOMap.get(skuCode);
37.             item.setProductId(productSkuDTO.getProductId());
38.             item.setSalePrice(productSkuDTO.getSalePrice());
39.         });
40.         //调用营销服务计算订单价格
41.         JsonResult<CalculateOrderAmountDTO> jsonResult = marketApi.calculateOrderAmount(calculateOrderPriceRequest);
42.         //检查价格计算结果
43.         if (!jsonResult.getSuccess()) {
44.             throw new OrderBizException(jsonResult.getErrorCode(), jsonResult.getErrorMessage());
45.         }
46.         CalculateOrderAmountDTO calculateOrderAmountDTO = jsonResult.getData();
47.         if (calculateOrderAmountDTO == null) {
48.             throw new OrderBizException(OrderErrorCodeEnum.CALCULATE_ORDER_AMOUNT_ERROR);
49.         }
50.         //订单费用信息
51.         List<OrderAmountDTO> orderAmountList = ObjectUtil.convertList(calculateOrderAmountDTO.getOrderAmountList(), OrderAmountDTO.class);
52.         if (orderAmountList == null || orderAmountList.isEmpty()) {
53.             throw new OrderBizException(OrderErrorCodeEnum.CALCULATE_ORDER_AMOUNT_ERROR);
54.         }
55.         //订单条目费用明细
56.         List<OrderAmountDetailDTO> orderItemAmountList = ObjectUtil.convertList(calculateOrderAmountDTO.getOrderAmountDetail(), OrderAmountDetailDTO.class);
57.         if (orderItemAmountList == null || orderItemAmountList.isEmpty()) {
58.             throw new OrderBizException(OrderErrorCodeEnum.CALCULATE_ORDER_AMOUNT_ERROR);
59.         }
60.         return calculateOrderAmountDTO;
61.     }
63.     //验证订单实付金额
64.     private void checkRealPayAmount(CreateOrderRequest createOrderRequest, CalculateOrderAmountDTO calculateOrderAmountDTO) {
65.         List<CreateOrderRequest.OrderAmountRequest> originOrderAmountRequestList = createOrderRequest.getOrderAmountRequestList();
66.         Map<Integer, CreateOrderRequest.OrderAmountRequest> originOrderAmountMap =
67.             originOrderAmountRequestList.stream().collect(Collectors.toMap(CreateOrderRequest.OrderAmountRequest::getAmountType, Function.identity()));
68.         //前端给的实付金额
69.         Integer originRealPayAmount = originOrderAmountMap.get(AmountTypeEnum.REAL_PAY_AMOUNT.getCode()).getAmount();
70.         List<CalculateOrderAmountDTO.OrderAmountDTO> orderAmountDTOList = calculateOrderAmountDTO.getOrderAmountList();
71.         Map<Integer, CalculateOrderAmountDTO.OrderAmountDTO> orderAmountMap =
72.             orderAmountDTOList.stream().collect(Collectors.toMap(CalculateOrderAmountDTO.OrderAmountDTO::getAmountType, Function.identity()));
73.         //营销计算出来的实付金额
74.         Integer realPayAmount = orderAmountMap.get(AmountTypeEnum.REAL_PAY_AMOUNT.getCode()).getAmount();
75.         if (!originRealPayAmount.equals(realPayAmount)) {
76.             //订单验价失败
77.             throw new OrderBizException(OrderErrorCodeEnum.ORDER_CHECK_REAL_PAY_AMOUNT_FAIL);
78.         }
79.     }
80.     ...
81. }

复制代码

(4)锁定优惠券与商品库存

1. @Service
2. public class OrderServiceImpl implements OrderService {
3.     ...
4.     //锁定用户优惠券
5.     private void lockUserCoupon(CreateOrderRequest createOrderRequest) {
6.         String couponId = createOrderRequest.getCouponId();
7.         if (StringUtils.isEmpty(couponId)) {
8.             return;
9.         }
10.         LockUserCouponRequest lockUserCouponRequest = createOrderRequest.clone(LockUserCouponRequest.class);
11.         //调用营销服务锁定用户优惠券
12.         JsonResult<Boolean> jsonResult = marketApi.lockUserCoupon(lockUserCouponRequest);
13.         //检查锁定用户优惠券结果
14.         if (!jsonResult.getSuccess()) {
15.             throw new OrderBizException(jsonResult.getErrorCode(), jsonResult.getErrorMessage());
16.         }
17.     }
19.     //锁定商品库存
20.     private void lockProductStock(CreateOrderRequest createOrderRequest) {
21.         String orderId = createOrderRequest.getOrderId();
22.         List<LockProductStockRequest.OrderItemRequest> orderItemRequestList = ObjectUtil.convertList(
23.             createOrderRequest.getOrderItemRequestList(), LockProductStockRequest.OrderItemRequest.class);
24.         LockProductStockRequest lockProductStockRequest = new LockProductStockRequest();
25.         lockProductStockRequest.setOrderId(orderId);
26.         lockProductStockRequest.setOrderItemRequestList(orderItemRequestList);
27.         JsonResult<Boolean> jsonResult = inventoryApi.lockProductStock(lockProductStockRequest);
28.         //检查锁定商品库存结果
29.         if (!jsonResult.getSuccess()) {
30.             throw new OrderBizException(jsonResult.getErrorCode(), jsonResult.getErrorMessage());
31.         }
32.     }
33.     ...
34. }
36. @DubboService(version = "1.0.0", interfaceClass = MarketApi.class, retries = 0)
37. public class MarketApiImpl implements MarketApi {
38.     ...
39.     //锁定用户优惠券记录
40.     @Override
41.     public JsonResult<Boolean> lockUserCoupon(LockUserCouponRequest lockUserCouponRequest) {
42.         try {
43.             Boolean result = couponService.lockUserCoupon(lockUserCouponRequest);
44.             return JsonResult.buildSuccess(result);
45.         } catch (MarketBizException e) {
46.             log.error("biz error", e);
47.             return JsonResult.buildError(e.getErrorCode(), e.getErrorMsg());
48.         } catch (Exception e) {
49.             log.error("system error", e);
50.             return JsonResult.buildError(e.getMessage());
51.         }
52.     }
53.     ...
54. }
56. @Service
57. public class CouponServiceImpl implements CouponService {
58.     ...
59.     //锁定用户优惠券
60.     @Transactional(rollbackFor = Exception.class)
61.     @Override
62.     public Boolean lockUserCoupon(LockUserCouponRequest lockUserCouponRequest) {
63.         //检查入参
64.         checkLockUserCouponRequest(lockUserCouponRequest);
65.         String userId = lockUserCouponRequest.getUserId();
66.         String couponId = lockUserCouponRequest.getCouponId();
67.         CouponDO couponDO = couponDAO.getUserCoupon(userId, couponId);
68.         if (couponDO == null) {
69.             throw new MarketBizException(MarketErrorCodeEnum.USER_COUPON_IS_NULL);
70.         }
71.         //判断优惠券是否已经使用了
72.         if (CouponUsedStatusEnum.USED.getCode().equals(couponDO.getUsed())) {
73.             throw new MarketBizException(MarketErrorCodeEnum.USER_COUPON_IS_USED);
74.         }
75.         couponDO.setUsed(CouponUsedStatusEnum.USED.getCode());
76.         couponDO.setUsedTime(new Date());
77.         couponDAO.updateById(couponDO);
78.         return true;
79.     }
80.     ...
81. }
83. @DubboService(version = "1.0.0", interfaceClass = InventoryApi.class, retries = 0)
84. public class InventoryApiImpl implements InventoryApi {
85.     @Autowired
86.     private InventoryService inventoryService;
88.     //锁定商品库存
89.     @Override
90.     public JsonResult<Boolean> lockProductStock(LockProductStockRequest lockProductStockRequest) {
91.         try {
92.             Boolean result = inventoryService.lockProductStock(lockProductStockRequest);
93.             return JsonResult.buildSuccess(result);
94.         } catch (InventoryBizException e) {
95.             log.error("biz error", e);
96.             return JsonResult.buildError(e.getErrorCode(), e.getErrorMsg());
97.         } catch (Exception e) {
98.             log.error("system error", e);
99.             return JsonResult.buildError(e.getMessage());
100.         }
101.     }
102.     ...
103. }
105. @Service
106. public class InventoryServiceImpl implements InventoryService {
107.     ...
108.     //锁定商品库存
109.     @Transactional(rollbackFor = Exception.class)
110.     @Override
111.     public Boolean lockProductStock(LockProductStockRequest lockProductStockRequest) {
112.         //检查入参
113.         checkLockProductStockRequest(lockProductStockRequest);
114.         List<LockProductStockRequest.OrderItemRequest> orderItemRequestList = lockProductStockRequest.getOrderItemRequestList();
115.         for (LockProductStockRequest.OrderItemRequest orderItemRequest : orderItemRequestList) {
116.             String skuCode = orderItemRequest.getSkuCode();
117.             ProductStockDO productStockDO = productStockDAO.getBySkuCode(skuCode);
118.             if (productStockDO == null) {
119.                 throw new InventoryBizException(InventoryErrorCodeEnum.PRODUCT_SKU_STOCK_ERROR);
120.             }
121.             Integer saleQuantity = orderItemRequest.getSaleQuantity();
122.             //执行库存扣减，并需要解决防止超卖的问题
123.             int nums = productStockDAO.lockProductStock(skuCode, saleQuantity);
124.             if (nums <= 0) {
125.                 throw new InventoryBizException(InventoryErrorCodeEnum.LOCK_PRODUCT_SKU_STOCK_ERROR);
126.             }
127.         }
128.         return true;
129.     }
130.     ...
131. }

复制代码

(6)发送延迟消息到MQ

1. @Service
2. public class OrderServiceImpl implements OrderService {
3.     ...
4.     //新增订单数据到数据库
5.     private void addNewOrder(CreateOrderRequest createOrderRequest, List<ProductSkuDTO> productSkuList, CalculateOrderAmountDTO calculateOrderAmountDTO) {
6.         //封装新订单数据
7.         NewOrderDataHolder newOrderDataHolder = new NewOrderDataHolder();
8.         //生成主订单
9.         FullOrderData fullMasterOrderData = addNewMasterOrder(createOrderRequest, productSkuList, calculateOrderAmountDTO);
10.         //封装主订单数据到NewOrderData对象中
11.         newOrderDataHolder.appendOrderData(fullMasterOrderData);
13.         //如果存在多种商品类型，需要按商品类型进行拆单
14.         Map<Integer, List<ProductSkuDTO>> productTypeMap = productSkuList.stream().collect(Collectors.groupingBy(ProductSkuDTO::getProductType));
15.         if (productTypeMap.keySet().size() > 1) {
16.             for (Integer productType : productTypeMap.keySet()) {
17.                 //生成子订单
18.                 FullOrderData fullSubOrderData = addNewSubOrder(fullMasterOrderData, productType);
19.                 //封装子订单数据到NewOrderData对象中
20.                 newOrderDataHolder.appendOrderData(fullSubOrderData);
21.             }
22.         }
24.         //保存订单到数据库
25.         //订单信息
26.         List<OrderInfoDO> orderInfoDOList = newOrderDataHolder.getOrderInfoDOList();
27.         if (!orderInfoDOList.isEmpty()) {
28.             orderInfoDAO.saveBatch(orderInfoDOList);
29.         }
30.         //订单条目
31.         List<OrderItemDO> orderItemDOList = newOrderDataHolder.getOrderItemDOList();
32.         if (!orderItemDOList.isEmpty()) {
33.             orderItemDAO.saveBatch(orderItemDOList);
34.         }
35.         //订单配送信息
36.         List<OrderDeliveryDetailDO> orderDeliveryDetailDOList = newOrderDataHolder.getOrderDeliveryDetailDOList();
37.         if (!orderDeliveryDetailDOList.isEmpty()) {
38.             orderDeliveryDetailDAO.saveBatch(orderDeliveryDetailDOList);
39.         }
40.         //订单支付信息
41.         List<OrderPaymentDetailDO> orderPaymentDetailDOList = newOrderDataHolder.getOrderPaymentDetailDOList();
42.         if (!orderPaymentDetailDOList.isEmpty()) {
43.             orderPaymentDetailDAO.saveBatch(orderPaymentDetailDOList);
44.         }
45.         //订单费用信息
46.         List<OrderAmountDO> orderAmountDOList = newOrderDataHolder.getOrderAmountDOList();
47.         if (!orderAmountDOList.isEmpty()) {
48.             orderAmountDAO.saveBatch(orderAmountDOList);
49.         }
50.         //订单费用明细
51.         List<OrderAmountDetailDO> orderAmountDetailDOList = newOrderDataHolder.getOrderAmountDetailDOList();
52.         if (!orderAmountDetailDOList.isEmpty()) {
53.             orderAmountDetailDAO.saveBatch(orderAmountDetailDOList);
54.         }
55.         //订单状态变更日志信息
56.         List<OrderOperateLogDO> orderOperateLogDOList = newOrderDataHolder.getOrderOperateLogDOList();
57.         if (!orderOperateLogDOList.isEmpty()) {
58.             orderOperateLogDAO.saveBatch(orderOperateLogDOList);
59.         }
60.         //订单快照数据
61.         List<OrderSnapshotDO> orderSnapshotDOList = newOrderDataHolder.getOrderSnapshotDOList();
62.         if (!orderSnapshotDOList.isEmpty()) {
63.             orderSnapshotDAO.saveBatch(orderSnapshotDOList);
64.         }
65.     }
67.     //新增主订单信息订单
68.     private FullOrderData addNewMasterOrder(CreateOrderRequest createOrderRequest, List<ProductSkuDTO> productSkuList, CalculateOrderAmountDTO calculateOrderAmountDTO) {
69.         NewOrderBuilder newOrderBuilder = new NewOrderBuilder(createOrderRequest, productSkuList, calculateOrderAmountDTO, orderProperties);
70.         FullOrderData fullOrderData = newOrderBuilder.buildOrder()
71.             .buildOrderItems()
72.             .buildOrderDeliveryDetail()
73.             .buildOrderPaymentDetail()
74.             .buildOrderAmount()
75.             .buildOrderAmountDetail()
76.             .buildOperateLog()
77.             .buildOrderSnapshot()
78.             .build();
79.         //订单信息
80.         OrderInfoDO orderInfoDO = fullOrderData.getOrderInfoDO();
81.         //订单条目信息
82.         List<OrderItemDO> orderItemDOList = fullOrderData.getOrderItemDOList();
83.         //订单费用信息
84.         List<OrderAmountDO> orderAmountDOList = fullOrderData.getOrderAmountDOList();
85.         //补全地址信息
86.         OrderDeliveryDetailDO orderDeliveryDetailDO = fullOrderData.getOrderDeliveryDetailDO();
87.         String detailAddress = getDetailAddress(orderDeliveryDetailDO);
88.         orderDeliveryDetailDO.setDetailAddress(detailAddress);
89.         //补全订单状态变更日志
90.         OrderOperateLogDO orderOperateLogDO = fullOrderData.getOrderOperateLogDO();
91.         String remark = "创建订单操作0-10";
92.         orderOperateLogDO.setRemark(remark);
93.         //补全订单商品快照信息
94.         List<OrderSnapshotDO> orderSnapshotDOList = fullOrderData.getOrderSnapshotDOList();
95.         for (OrderSnapshotDO orderSnapshotDO : orderSnapshotDOList) {
96.             //优惠券信息
97.             if (orderSnapshotDO.getSnapshotType().equals(SnapshotTypeEnum.ORDER_COUPON.getCode())) {
98.                 ...
99.             }
100.             //订单费用信息
101.             else if (orderSnapshotDO.getSnapshotType().equals(SnapshotTypeEnum.ORDER_AMOUNT.getCode())) {
102.                 orderSnapshotDO.setSnapshotJson(JsonUtil.object2Json(orderAmountDOList));
103.             }
104.             //订单条目信息
105.             else if (orderSnapshotDO.getSnapshotType().equals(SnapshotTypeEnum.ORDER_ITEM.getCode())) {
106.                 orderSnapshotDO.setSnapshotJson(JsonUtil.object2Json(orderItemDOList));
107.             }
108.         }
109.         return fullOrderData;
110.     }
111.     ...
112. }

复制代码

 
2.生单链路中可能会出现数据不一致的问题
在更新优惠券本地事务、更新库存本地事务、插入订单数据本地事务中，可能会出现优惠券和库存都已经更新成功了，但订单数据却插入失败，此时就会出现数据不一致的问题。

 
3.Seata AT模式下的分布式事务的原理
说明一：需要部署一个Seata Server服务器。
 
说明二：在各个服务的分支事务的数据库中，需要新增一张undo_log表，用来记录各个服务的分支事务失败时可以执行的回滚SQL。
 
说明三：当入口服务开启一个分布式事务时，需要向Seata Server开启一个全局事务。
 
说明四：各个服务对其分支事务的执行情况会同步给Seata Server服务器。
 
说明五：当Seata Server发现某分支事务失败时，便会通知各服务进行事务回滚。
 
说明六：当各个服务进行事务回滚时，会从undo_log表查出对应SQL去执行。

 
4.Seata AT模式下的分布式事务的读写隔离原理
为了避免有其他线程修改某数据后又进行回滚，就一定要加本地锁 + 全局锁。本地锁是为了避免当前机器的其他线程对数据进行修改并回滚，全局锁是为了避免分布式机器的线程对数据进行修改并回滚。
 
服务A在更新某数据之前，需要先获取本地锁。服务A在成功获取本地锁之后，需要插入undo log数据。接着，服务A需要向Seata Server服务器获取全局锁。服务A在成功获取全局锁之后，会提交本地事务并释放本地锁。
 
如果服务A对服务B进行RPC调用并提交其本地事务，则继续按前面的步骤处理服务B的数据更新。当服务B的本地事务也提交完成后，不需要继续执行其他分支事务了，服务A便可以提交分布式事务，并释放全局锁。
 
分布式事务的全链路在执行完毕前，对应数据的全局锁是不会释放的。

 
5.Seata AT模式下的死锁问题以及超时机制
Seata的一条事务链路里，每一个事务都会按如下顺序执行：首先获取本地锁更新本地数据，然后插入undo log记录，接着获取本地数据对应的全局锁，最后提交本地事务并释放本地锁。
 
Seata的一条事务链路里，一个事务执行完就会继续执行下一个事务。如果事务链路里的所有事务都执行完成了，那么就提交事务，并释放全局锁。如果某个事务需要回滚，那么就需要获取该事务本地数据的本地锁，然后获取undo log记录生成逆向操作的SQL语句来进行补偿和更新，补偿完毕才能释放本地数据的全局锁。
 
由于Seata AT模式的写隔离是通过本地数据的全局锁来实现的，所以写隔离的过程中，就涉及到了本地数据的本地锁和全局锁两把锁，这时候就很容易导致出现死锁的情况。
 
比如当事务1的分支事务提交数据1的本地事务后，会释放数据1的本地锁。此时事务2的分支事务就可以获取数据1的本地锁，但要等待获取事务1释放数据1的全局锁后，才能释放数据1的本地锁。如果事务1的后续分支事务出现异常需要进行回滚，那么事务1就需要获取数据1的本地锁，执行回滚补偿处理。事务1执行完分支事务的回滚补偿处理后，才能释放数据1的全局锁。
 
于是就出现了这样的死锁场景：事务1对数据1的回滚，占用了数据1的全局锁，需等待获取数据1的本地锁。事务2对数据1的更新，占用了数据1的本地锁，需等待获取数据1的全局锁。
 
Seata为了解决这个问题，会引入等待全局锁的超时机制。如果事务2在等待数据1的全局锁时出现超时，就会释放其占用的本地锁。从而让事务1能获取到数据1的本地锁，完成其事务操作，而不用一直等待。

 
6.Seata AT模式下的读写隔离机制的影响
由于全局锁的存在，会严重影响Seata AT分布式事务的并发吞吐量。所以除非是金融级别的系统，才会使用像Seata AT模式这么严格的事务来保证数据的强一致性。
 
当然，通常情况下分布式事务基本都是更新不同的数据。只要更新不同的数据，那么Seata AT分布式事务也不会出现全局锁等待。只有一些特殊情况下，才可能会出现大量分布式事务更新同一条数据。当使用Seata AT分布式事务时，特别注意尽量不要让全局锁等待。
 
如果不使用全局锁，那么Seata AT模式的分布式事务就会出现写未提交。就可能出现分支事务更新失败时无法回滚，因为回滚的数据已被覆盖。
 
Seata AT模式的分布式事务默认是读未提交的，即分布式事务在未提交前，分支事务更新的数据是可被其他事务读到的。
 
此外，很多公司都是使用基于RocketMQ的柔性事务来实现分布式事务。
 
7.生单链路使用Seata AT模式的具体步骤
(1)生单链路中分布式事务的主要分支事务
(2)订单系统 + 优惠券系统 + 商品库存系统都需要在pom.xml文件中引入Seata
(3)订单系统的生单接口作为分布式事务入口需添加@GlobalTransactional注解开启全局事务
(4)优惠券系统的锁定优惠券接口需添加Spring的事务注解@Transactional
(5)商品库存系统的锁定库存接口需添加Spring的事务注解@Transactional
(6)各分支事务操作的数据库需要添加undo log表
 
(1)生单链路中分布式事务的主要分支事务
分布式事务入口：订单系统的生单接口
分支事务1：优惠券系统锁定优惠券
分支事务2：商品库存系统锁定商品库存
分支事务3：订单系统创建订单数据
 
(2)订单系统 + 优惠券系统 + 商品库存系统都需要在pom.xml文件中引入Seata

1. @Service
2. public class OrderServiceImpl implements OrderService {
3.     ...
4.     //发送支付订单超时延迟消息，用于支付超时自动关单
5.     private void sendPayOrderTimeoutDelayMessage(CreateOrderRequest createOrderRequest) {
6.         PayOrderTimeoutDelayMessage message = new PayOrderTimeoutDelayMessage();
7.         message.setOrderId(createOrderRequest.getOrderId());
8.         message.setBusinessIdentifier(createOrderRequest.getBusinessIdentifier());
9.         message.setCancelType(OrderCancelTypeEnum.TIMEOUT_CANCELED.getCode());
10.         message.setUserId(createOrderRequest.getUserId());
11.         message.setOrderType(createOrderRequest.getOrderType());
12.         message.setOrderStatus(OrderStatusEnum.CREATED.getCode());
13.         String msgJson = JsonUtil.object2Json(message);
14.         defaultProducer.sendMessage(
15.             RocketMqConstant.PAY_ORDER_TIMEOUT_DELAY_TOPIC,
16.             msgJson,
17.             RocketDelayedLevel.DELAYED_30m,
18.             "支付订单超时延迟消息"
19.         );
20.     }
21.     ...
22. }
24. @Component
25. public class DefaultProducer {
26.     private final DefaultMQProducer producer;
28.     @Autowired
29.     public DefaultProducer(RocketMQProperties rocketMQProperties) {
30.         producer = new DefaultMQProducer(RocketMqConstant.ORDER_DEFAULT_PRODUCER_GROUP);
31.         producer.setNamesrvAddr(rocketMQProperties.getNameServer());
32.         start();
33.     }
35.     //对象在使用之前必须要调用一次，只能初始化一次
36.     public void start() {
37.         try {
38.             this.producer.start();
39.         } catch (MQClientException e) {
40.             log.error("producer start error", e);
41.         }
42.     }
43.     ...
45.     //发送消息
46.     public void sendMessage(String topic, String message, Integer delayTimeLevel, String type) {
47.         Message msg = new Message(topic, message.getBytes(StandardCharsets.UTF_8));
48.         try {
49.             if (delayTimeLevel > 0) {
50.                 msg.setDelayTimeLevel(delayTimeLevel);
51.             }
52.             SendResult send = producer.send(msg);
53.             if (SendStatus.SEND_OK == send.getSendStatus()) {
54.                 log.info("发送MQ消息成功, type:{}, message:{}", type, message);
55.             } else {
56.                 throw new OrderBizException(send.getSendStatus().toString());
57.             }
58.         } catch (Exception e) {
59.             log.error("发送MQ消息失败：", e);
60.             throw new OrderBizException(OrderErrorCodeEnum.SEND_MQ_FAILED);
61.         }
62.     }
63.     ...
64. }

复制代码

(3)订单系统的生单接口作为分布式事务入口需添加@GlobalTransactional注解开启全局事务
通过添加Seata提供的注解@GlobalTransactional来开启全局事务。

1. <dependency>
2.     <groupId>com.alibaba.cloud</groupId>
3.     spring-cloud-starter-alibaba-seata</artifactId>
4.     <exclusions>
5.         <exclusion>
6.             <groupId>io.seata</groupId>
7.             seata-spring-boot-starter</artifactId>
8.         </exclusion>
9.     </exclusions>
10. </dependency>
13. <dependency>
14.     <groupId>io.seata</groupId>
15.     seata-spring-boot-starter</artifactId>
16.     <version>1.3.0</version>
17. </dependency>

复制代码

(4)优惠券系统的锁定优惠券接口需添加Spring的事务注解@Transactional
通过添加Spring提供的@Transactional注解来开启本地事务。Seata会代理Spring的事务，进行本地锁申请 + undo log写入 + 全局锁请求 + 提交/回滚本地事务等操作。

1. @Service
2. public class OrderServiceImpl implements OrderService {
3.     ...
4.     //提交订单/生成订单接口
5.     //@param createOrderRequest 提交订单请求入参
6.     //@return 订单号
7.     @GlobalTransactional(rollbackFor = Exception.class)
8.     @Override
9.     public CreateOrderDTO createOrder(CreateOrderRequest createOrderRequest) {
10.         //1.入参检查
11.         checkCreateOrderRequestParam(createOrderRequest);
12.         //2.风控检查
13.         checkRisk(createOrderRequest);
14.         //3.获取商品信息
15.         List<ProductSkuDTO> productSkuList = listProductSkus(createOrderRequest);
16.         //4.计算订单价格
17.         CalculateOrderAmountDTO calculateOrderAmountDTO = calculateOrderAmount(createOrderRequest, productSkuList);
18.         //5.验证订单实付金额
19.         checkRealPayAmount(createOrderRequest, calculateOrderAmountDTO);
20.         //6.锁定优惠券
21.         lockUserCoupon(createOrderRequest);
22.         //7.锁定商品库存
23.         lockProductStock(createOrderRequest);
24.         //8.生成订单到数据库
25.         addNewOrder(createOrderRequest, productSkuList, calculateOrderAmountDTO);
26.         //9.发送订单延迟消息用于支付超时自动关单
27.         sendPayOrderTimeoutDelayMessage(createOrderRequest);
28.         //返回订单信息
29.         CreateOrderDTO createOrderDTO = new CreateOrderDTO();
30.         createOrderDTO.setOrderId(createOrderRequest.getOrderId());
31.         return createOrderDTO;
32.     }
33.     ...
34. }

复制代码

(5)商品库存系统的锁定库存接口需添加Spring的事务注解@Transactional
通过添加Spring提供的@Transactional注解来开启本地事务。Seata会代理Spring的事务，进行本地锁申请 + undo log写入 + 全局锁请求 + 提交/回滚本地事务等操作。
[code]@Servicepublic class InventoryServiceImpl implements InventoryService {    ...    //锁定商品库存    @Transactional(rollbackFor = Exception.class)    @Override    public Boolean lockProductStock(LockProductStockRequest lockProductStockRequest) {        //检查入参        checkLockProductStockRequest(lockProductStockRequest);        List orderItemRequestList = lockProductStockRequest.getOrderItemRequestList();        for (LockProductStockRequest.OrderItemRequest orderItemRequest : orderItemRequestList) {            String skuCode = orderItemRequest.getSkuCode();            ProductStockDO productStockDO = productStockDAO.getBySkuCode(skuCode);            if (productStockDO == null) {                throw new InventoryBizException(InventoryErrorCodeEnum.PRODUCT_SKU_STOCK_ERROR);            }            Integer saleQuantity = orderItemRequest.getSaleQuantity();            //执行库存扣减，并需要解决防止超卖的问题            int nums = productStockDAO.lockProductStock(skuCode, saleQuantity);            if (nums