devbox
很楠不爱3
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

谷粒商城笔记+踩坑（21）——提交订单。原子性验令牌+锁定库存_谷粒商城前端笔记

作者：很楠不爱3 | 2024-04-21 09:57:08

赞

踩

谷粒商城前端笔记

导航：

谷粒商城笔记+踩坑汇总篇

目录

1、环境准备

1.1、业务流程

1.2、Controller 层编写下单功能接口

1.3、订单提交的模型类

1.4、前端页面 confirm.html 提供数据

2、提交订单业务完整代码

3、原子性验令牌：令牌的对比和删除保证原子性

4、初始化新订单，包含订单、订单项等信息

4.1、抽取订单创建传输类

4.2、service

4.3、创建订单

4.3.1、远程调用仓库服务，计算运费和详细地址的接口

4.3.2、封装运费模型类

4.3.3、创建订单service

4.4、构造订单项数据

4.4.1、构建订单项数据service

4.4.2、【商品模块】通过skuId查询spu信息

4.4.3、订单服务远程调用商品服务

4.4.4、抽取商品信息vo

4.5、计算价格

5、锁定库存

5.1、保存订单数据并锁定库存

5.1.1、service保存订单数据并锁定库存

5.1.2、【公共模块】无库存异常类

5.2、【仓库模块】锁定库存

5.2.1、订单服务远程调用仓库服务

5.2.2、锁定库存controller

5.2.3、锁定库存的vo类

5.2.4、锁定指定订单的库存service

5.2.5、dao，根据sku_id查询在有库存的仓库

5.2.6、【公共模块】错误码枚举类添加库存相关错误码

6、前端页面的修改

7、提交订单的完整代码

7.1、Controller层接口编写

7.2、Service层代码

7.2.1、提交订单业务

7.2.2、创建订单、构建订单、计算价格等调用的方法

8、分布式事务优化

8.1、解决低并发场景的分布式事务

8.1.1 Seata的AT模式

8.1.2【商品模块】保存spu信息业务设为分布式事务  

8.2、解决低并发场景的分布式事务

8.2.1、可靠消息+最终一致性方案

8.2.2、若订单失败，自动解锁库存

1、环境准备

1.1、业务流程

img

1.2、Controller 层编写下单功能接口

订单服务 com.atguigu.gulimall.order.web 路径下的 OrderWebController 类，代码如下

  1. /**
  2.  * 下单功能
  3.  * @param vo
  4.  * @return
  5.  */
  6. @PostMapping("/submitOrder")
  7. public String submitOrder(OrderSubmitVo vo, Model model, RedirectAttributes redirectAttributes){
  8.     // 1、创建订单、验令牌、验价格、验库存
  9.     try {
  10.         SubmitOrderResponseVo responseVo = orderService.submitOrder(vo);
  11.         if (responseVo.getCode() == 0) {
  12.             // 下单成功来到支付选择页
  13.             model.addAttribute("submitOrderResp",responseVo);
  14.             return "pay";
  15.         } else {
  16.             // 下单失败回到订单确认页重新确认订单信息
  17.             String msg = "下单失败: ";
  18.             switch ( responseVo.getCode()){
  19.                 case 1: msg+="订单信息过期，请刷新再次提交";break;
  20.                 case 2: msg+="订单商品价格发生变化，请确认后再次提交";break;
  21.                 case 3: msg+="商品库存不足";break;
  22.             }
  23.             redirectAttributes.addAttribute("msg",msg);
  24.             return "redirect:http://order.gulimall.cn/toTrade";
  25.         }
  26.     } catch (Exception e){
  27.         if (e instanceof NoStockException) {
  28.             String message = e.getMessage();
  29.             redirectAttributes.addFlashAttribute("msg", message);
  30.         }
  31.         return "redirect:http://order.gulimall.cn/toTrade";
  32.     }
  33.  
  34. }

1.3、订单提交的模型类

页面提交数据 添加“com.atguigu.gulimall.order.vo.OrderSubmitVo”类，代码如下：

  1. @Data
  2. @ToString
  3. public class OrderSubmitVo {
  4.     /**
  5.      * 收货地址Id
  6.      */
  7.     private Long addrId;
  8.     /**
  9.      * 支付方式
  10.      */
  11.     private Integer payType;
  12.     // 无需提交需要购买的商品，去购物车再获取一遍
  13.     // 优惠发票
  14.     /**
  15.      * 防重令牌
  16.      */
  17.     private String orderToken;
  18.     /**
  19.      * 应付价格，验价
  20.      */
  21.     private BigDecimal payPrice;
  22.     /**
  23.      * 订单备注
  24.      */
  25.     private String note;
  26.  
  27.     /**
  28.      * 用户相关信息，直接去Session取出登录的用户
  29.      */
  30. }

1.4、前端页面 confirm.html 提供数据

  1. <form action="http://order.gulimall.cn/submitOrder" method="post">
  2.    <input id="addrIdInput" type="hidden" name="addrId">
  3.    <input id="payPriceInput" type="hidden" name="payPrice">
  4.    <input type="hidden" name="orderToken" th:value="${orderConfirmData.orderToken}">
  5.    <button class="tijiao" type="submit">提交订单</button>
  6. </form>

  1. function getFare(addrId) {
  2.    // 给表单回填的地址
  3.    $("#addrIdInput").val(addrId);
  4.    $.get("http://gulimall.cn/api/ware/wareinfo/fare?addrId="+addrId,function (resp) {
  5.       console.log(resp);
  6.       $("#fareEle").text(resp.data.fare);
  7.       var total = [[${orderConfirmData.total}]]
  8.       // 设置运费信息
  9.       var pryPrice = total*1 + resp.data.fare*1;
  10.       $("#payPriceEle").text(pryPrice);
  11.       $("#payPriceInput").val(pryPrice);
  12.       // 设置收货人信息
  13.       $("#reciveAddressEle").text(resp.data.address.province+" " + resp.data.address.region+ "" + resp.data.address.detailAddress);
  14.       $("#reveiverEle").text(resp.data.address.name);
  15.    })
  16. }

2、提交订单业务完整代码

  1.    /**
  2.      * 提交订单
  3.      * @param vo
  4.      * @return
  5.      */
  6.     // @Transactional(isolation = Isolation.READ_COMMITTED) 设置事务的隔离级别
  7.     // @Transactional(propagation = Propagation.REQUIRED)   设置事务的传播级别
  8.     @Transactional(rollbackFor = Exception.class)
  9.     // @GlobalTransactional(rollbackFor = Exception.class)
  10.     @Override
  11.     public SubmitOrderResponseVo submitOrder(OrderSubmitVo vo) {
  12.  
  13.         confirmVoThreadLocal.set(vo);
  14.  
  15.         SubmitOrderResponseVo responseVo = new SubmitOrderResponseVo();
  16.         //去创建、下订单、验令牌、验价格、锁定库存...
  17.  
  18.         //1.从拦截器中获取当前用户登录的信息
  19.         MemberResponseVo memberResponseVo = LoginUserInterceptor.loginUser.get();
  20.         responseVo.setCode(0);
  21.  
  22.         //2、验证令牌是否合法【令牌的对比和删除必须保证原子性】
  23.         String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
  24.         String orderToken = vo.getOrderToken();
  25.  
  26.         //通过lure脚本原子验证令牌和删除令牌
  27.         Long result = redisTemplate.execute(new DefaultRedisScript<Long>(script, Long.class),
  28.                 Arrays.asList(USER_ORDER_TOKEN_PREFIX + memberResponseVo.getId()),
  29.                 orderToken);
  30.  
  31.         if (result == 0L) {
  32.             //令牌验证失败
  33.             responseVo.setCode(1);
  34.             return responseVo;
  35.         } else {
  36.             //令牌验证成功
  37.             //1、创建订单、订单项等信息
  38.             OrderCreateTo order = createOrder();
  39.  
  40.             //2、验证价格
  41.             BigDecimal payAmount = order.getOrder().getPayAmount();
  42.             BigDecimal payPrice = vo.getPayPrice();
  43.  
  44.             if (Math.abs(payAmount.subtract(payPrice).doubleValue()) < 0.01) {
  45.                 //金额对比
  46.                 //TODO 3、保存订单
  47.                 saveOrder(order);
  48.  
  49.                 //4、库存锁定,只要有异常，回滚订单数据
  50.                 //订单号、所有订单项信息(skuId,skuNum,skuName)
  51.                 WareSkuLockVo lockVo = new WareSkuLockVo();
  52.                 lockVo.setOrderSn(order.getOrder().getOrderSn());
  53.  
  54.                 //获取出要锁定的商品数据信息
  55.                 List<OrderItemVo> orderItemVos = order.getOrderItems().stream().map((item) -> {
  56.                     OrderItemVo orderItemVo = new OrderItemVo();
  57.                     orderItemVo.setSkuId(item.getSkuId());
  58.                     orderItemVo.setCount(item.getSkuQuantity());
  59.                     orderItemVo.setTitle(item.getSkuName());
  60.                     return orderItemVo;
  61.                 }).collect(Collectors.toList());
  62.                 lockVo.setLocks(orderItemVos);
  63.  
  64.                 //TODO 调用远程锁定库存的方法
  65.                 //出现的问题：扣减库存成功了，但是由于网络原因超时，出现异常，导致订单事务回滚，库存事务不回滚(解决方案：seata)
  66.                 //为了保证高并发，不推荐使用seata，因为是加锁，并行化，提升不了效率,可以发消息给库存服务
  67.                 R r = wmsFeignService.orderLockStock(lockVo);
  68.                 if (r.getCode() == 0) {
  69.                     //锁定成功
  70.                     responseVo.setOrder(order.getOrder());
  71.                     // int i = 10/0;
  72.  
  73.                     //TODO 订单创建成功，发送消息给MQ
  74.                     rabbitTemplate.convertAndSend("order-event-exchange","order.create.order",order.getOrder());
  75.  
  76.                     //删除购物车里的数据
  77.                     redisTemplate.delete(CART_PREFIX+memberResponseVo.getId());
  78.                     return responseVo;
  79.                 } else {
  80.                     //锁定失败
  81.                     String msg = (String) r.get("msg");
  82.                     throw new NoStockException(msg);
  83.                     // responseVo.setCode(3);
  84.                     // return responseVo;
  85.                 }
  86.  
  87.             } else {
  88.                 responseVo.setCode(2);
  89.                 return responseVo;
  90.             }
  91.         }
  92.     }

3、原子性验令牌：令牌的对比和删除保证原子性

问题：存在网路延时，同时提交从Redis拿到的令牌一直，导致重复提交

解决：令牌的对比和删除必须保证原子性

1)、封装提交订单数据

  1. package com.atguigu.gulimall.order.vo;
  2.  
  3. @Data
  4. public class SubmitOrderResponseVo {
  5.     private OrderEntity order;
  6.     private Integer code;   //0成功,错误状态码
  7. }

2)、修改 SubmitOrderResponseVo 类编写验证令牌操作

  1. /**
  2.  * 下单操作：验令牌、创建订单、验价格、验库存
  3.  * @param vo
  4.  * @return
  5.  */
  6. @Override
  7. public SubmitOrderResponseVo submitOrder(OrderSubmitVo vo) {
  8.     SubmitOrderResponseVo response = new SubmitOrderResponseVo();
  9.  
  10.     // 从拦截器中拿到当前的用户
  11.     MemberRespVo memberRespVo = LoginUserInterceptor.loginUser.get();
  12.     // 1、验证令牌【令牌的对比和删除必须保证原子性】,通过使用脚本来完成(0：令牌校验失败; 1: 删除成功)
  13.     String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
  14.     String orderToken = vo.getOrderToken();
  15.     // 原子验证令牌和删除令牌
  16.     Long result = redisTemplate.execute(new DefaultRedisScript<Long>(script, Long.class), Arrays.asList(),
  17.             OrderConstant.USER_ORDER_TOKEN_PREFIX + memberRespVo.getId(), orderToken);
  18.     if (result == 0L) {
  19.         // 令牌验证失败
  20.         response.setCode(1);
  21.         return response;
  22.     } else {
  23.         // 令牌验证成功
  24.         return response;
  25.     }
  26. }

4、初始化新订单，包含订单、订单项等信息

4.1、抽取订单创建传输类

  1. @Data
  2. public class OrderCreateTo {
  3.  
  4.     private OrderEntity order;
  5.  
  6.     private List<OrderItemEntity> orderItems;
  7.  
  8.     /** 订单计算的应付价格 **/
  9.     private BigDecimal payPrice;
  10.  
  11.     /** 运费 **/
  12.     private BigDecimal fare;
  13.  
  14. }

4.2、service

gulimall-order服务中 com.atguigu.gulimall.order.service.impl 路径下的 OrderServiceImpl 类

  1. /**
  2.  * 创建订单、订单项等信息
  3.  * @return
  4.  */
  5. private OrderCreateTo createOrder(){
  6.     OrderCreateTo createTo = new OrderCreateTo();
  7.     // 1、生成一个订单号。IdWorker.getTimeId()是Mybatis提供的生成订单号方法，ID=Time+Id
  8.     String orderSn = IdWorker.getTimeId();
  9.     // 2、构建一个订单
  10.     OrderEntity orderEntity = buildOrder(orderSn);
  11.     // 3、获取到所有的订单项
  12.     List<OrderItemEntity> itemEntities = buildOrderItems(orderSn);
  13.     // 4、计算价格、积分等相关信息
  14.     computePrice(orderEntity,itemEntities);
  15.  
  16.     createTo.setOrder(orderEntity);
  17.     createTo.setOrderItems(itemEntities);
  18.     return createTo;
  19. }

4.3、创建订单

4.3.1、远程调用仓库服务，计算运费和详细地址的接口

  1. package com.atguigu.gulimall.order.feign;
  2.  
  3. @FeignClient("gulimall-ware")
  4. public interface WareFeignService {
  5.  
  6.     @PostMapping("/ware/waresku/hasstock")
  7.     R getSkusHasStock(@RequestBody List<Long> skuIds);
  8.  
  9.     /**
  10.      * 计算运费和详细地址
  11.      * @param addrId
  12.      * @return
  13.      */
  14.     @GetMapping("/ware/wareinfo/fare")
  15.     R getFare(@RequestParam("addrId") Long addrId);
  16. }

4.3.2、封装运费模型类

  1. package com.atguigu.gulimall.order.vo;
  2.  
  3. @Data
  4. public class FareVo {
  5.     private MemberAddressVo address;
  6.     private BigDecimal fare;
  7. }

4.3.3、创建订单service

  1. /**
  2.  * 构建订单
  3.  * @param orderSn
  4.  * @return
  5.  */
  6. private OrderEntity buildOrder(String orderSn) {
  7.     MemberRespVo respVp = LoginUserInterceptor.loginUser.get();
  8.     OrderEntity entity = new OrderEntity();
  9.     entity.setOrderSn(orderSn);
  10.     entity.setMemberId(respVp.getId());
  11.  
  12.     OrderSubmitVo orderSubmitVo = confirmVoThreadLocal.get();
  13.     // 1、获取运费 和 收货信息
  14.     R fare = wareFeignService.getFare(orderSubmitVo.getAddrId());
  15.     FareVo fareResp = fare.getData(new TypeReference<FareVo>() {
  16.     });
  17.     // 2、设置运费
  18.     entity.setFreightAmount(fareResp.getFare());
  19.     // 3、设置收货人信息
  20.     entity.setReceiverPostCode(fareResp.getAddress().getPostCode());
  21.     entity.setReceiverProvince(fareResp.getAddress().getProvince());
  22.     entity.setReceiverRegion(fareResp.getAddress().getRegion());
  23.     entity.setReceiverCity(fareResp.getAddress().getCity());
  24.     entity.setReceiverDetailAddress(fareResp.getAddress().getDetailAddress());
  25.     entity.setReceiverName(fareResp.getAddress().getName());
  26.     entity.setReceiverPhone(fareResp.getAddress().getPhone());
  27.     // 4、设置订单的相关状态信息
  28.     entity.setStatus(OrderStatusEnum.CREATE_NEW.getCode());
  29.     // 5、默认取消信息
  30.     entity.setAutoConfirmDay(7);
  31.     return entity;
  32. }

4.4、构造订单项数据

4.4.1、构建订单项数据service

OrderServiceImpl 类

  1. /**
  2.  * 构建所有订单项数据
  3.  * @return
  4.  */
  5. private  List<OrderItemEntity> buildOrderItems(String orderSn) {
  6.     // 最后确定每个购物项的价格
  7.     List<OrderItemVo> currentUserCartItems = cartFeignService.getCurrentUserCartItems();
  8.     if (currentUserCartItems != null && currentUserCartItems.size()>0){
  9.         List<OrderItemEntity> itemEntities = currentUserCartItems.stream().map(cartItem -> {
  10.             OrderItemEntity itemEntity = buildOrderItem(cartItem);
  11.             itemEntity.setOrderSn(orderSn);
  12.             return itemEntity;
  13.         }).collect(Collectors.toList());
  14.         return itemEntities;
  15.     }
  16.     return null;
  17. }
  18.  
  19. /**
  20.  * 构建某一个订单项
  21.  * @param cartItem
  22.  * @return
  23.  */
  24. private OrderItemEntity buildOrderItem(OrderItemVo cartItem) {
  25.     OrderItemEntity itemEntity = new OrderItemEntity();
  26.     // 1、订单信息：订单号 v
  27.     // 2、商品的spu信息
  28.     Long skuId = cartItem.getSkuId();
  29.     R r = productFeignService.getSpuInfoBySkuId(skuId);
  30.     SpuInfoVo data = r.getData(new TypeReference<SpuInfoVo>() {
  31.     });
  32.     itemEntity.setSpuId(data.getId());
  33.     itemEntity.setSpuBrand(data.getBrandId().toString());
  34.     itemEntity.setSpuName(data.getSpuName());
  35.     itemEntity.setCategoryId(data.getCatalogId());
  36.     // 3、商品的sku信息  v
  37.     itemEntity.setSkuId(cartItem.getSkuId());
  38.     itemEntity.setSkuName(cartItem.getTitle());
  39.     itemEntity.setSkuPic(cartItem.getImage());
  40.     itemEntity.setSkuPrice(cartItem.getPrice());
  41.     itemEntity.setSkuQuantity(cartItem.getCount());
  42.     itemEntity.setSkuAttrsVals(StringUtils.collectionToDelimitedString(cartItem.getSkuAttr(),";"));
  43.     // 4、优惠信息【不做】
  44.     // 5、积分信息
  45.     itemEntity.setGiftGrowth(cartItem.getPrice().multiply(new BigDecimal(cartItem.getCount().toString())).intValue());
  46.     itemEntity.setGiftIntegration(cartItem.getPrice().multiply(new BigDecimal(cartItem.getCount().toString())).intValue());
  47.     // 6、订单项的价格信息
  48.     itemEntity.setPromotionAmount(new BigDecimal("0"));
  49.     itemEntity.setCouponAmount(new BigDecimal("0"));
  50.     itemEntity.setIntegrationAmount(new BigDecimal("0"));
  51.     // 当前订单项的实际金额 总额-各种优惠
  52.     BigDecimal orign = itemEntity.getSkuPrice().multiply(new BigDecimal(itemEntity.getSkuQuantity().toString()));
  53.     BigDecimal subtract = orign.subtract(itemEntity.getCouponAmount()).
  54.             subtract(itemEntity.getCouponAmount()).
  55.             subtract(itemEntity.getIntegrationAmount());
  56.     itemEntity.setRealAmount(subtract);
  57.     return itemEntity;
  58. }

4.4.2、【商品模块】通过skuId查询spu信息

  1. package com.atguigu.gulimall.product.app;
  2.  
  3. @RestController
  4. @RequestMapping("product/spuinfo")
  5. public class SpuInfoController {
  6.     @Autowired
  7.     private SpuInfoService spuInfoService;
  8.  
  9.  
  10.     /**
  11.      * 查询指定sku的spu信息
  12.      * @param skuId
  13.      * @return
  14.      */
  15.     @GetMapping("/skuId/{id}")
  16.     public R getSpuInfoBySkuId(@PathVariable("id") Long skuId) {
  17.         SpuInfoEntity entity = spuInfoService.getSpuInfoBySkuId(skuId);
  18.         return R.ok().setData(entity);
  19.     }

  1. package com.atguigu.gulimall.product.service.impl;
  2.  
  3. @Override
  4. public SpuInfoEntity getSpuInfoBySkuId(Long skuId) {
  5.     SkuInfoEntity byId = skuInfoService.getById(skuId);
  6.     Long spuId = byId.getSpuId();
  7.     SpuInfoEntity spuInfoEntity = getById(spuId);
  8.     return spuInfoEntity;
  9. }

4.4.3、订单服务远程调用商品服务

  1. package com.atguigu.gulimall.order.feign;
  2. @FeignClient("gulimall-product")
  3. public interface ProductFeignService {
  4.  
  5.     @GetMapping("/product/spuinfo/skuId/{id}")
  6.     R getSpuInfoBySkuId(@PathVariable("id") Long skuId);
  7. }

4.4.4、抽取商品信息vo

  1. package com.atguigu.gulimall.order.vo;
  2.  
  3. @Data
  4. public class SpuInfoVo {
  5.     /**
  6.      * 商品id
  7.      */
  8.     @TableId
  9.     private Long id;
  10.     /**
  11.      * 商品名称
  12.      */
  13.     private String spuName;
  14.     /**
  15.      * 商品描述
  16.      */
  17.     private String spuDescription;
  18.     /**
  19.      * 所属分类id
  20.      */
  21.     private Long catalogId;
  22.     /**
  23.      * 品牌id
  24.      */
  25.     private Long brandId;
  26.     /**
  27.      *
  28.      */
  29.     private BigDecimal weight;
  30.     /**
  31.      * 上架状态[0 - 新建，1 - 上架，2-下架]
  32.      */
  33.     private Integer publishStatus;
  34.     /**
  35.      *
  36.      */
  37.     private Date createTime;
  38.     /**
  39.      *
  40.      */
  41.     private Date updateTime;
  42. }

4.5、计算价格

  1. /**
  2.  * 计算价格
  3.  * @param orderEntity
  4.  * @param itemEntities
  5.  */
  6. private void computePrice(OrderEntity orderEntity, List<OrderItemEntity> itemEntities) {
  7.     BigDecimal total = new BigDecimal("0.0");
  8.     BigDecimal coupon = new BigDecimal("0.0");
  9.     BigDecimal integration = new BigDecimal("0.0");
  10.     BigDecimal promotion = new BigDecimal("0.0");
  11.     BigDecimal gift = new BigDecimal("0.0");
  12.     BigDecimal growth = new BigDecimal("0.0");
  13.     // 1、订单的总额，叠加每一个订单项的总额信息
  14.     for (OrderItemEntity entity : itemEntities) {
  15.         total = total.add(entity.getRealAmount());
  16.         coupon = coupon.add(entity.getCouponAmount());
  17.         integration = integration.add(entity.getIntegrationAmount());
  18.         promotion = promotion.add(entity.getPromotionAmount());
  19.         gift = gift.add(new BigDecimal(entity.getGiftIntegration()));
  20.         growth = growth.add(new BigDecimal(entity.getGiftGrowth()));
  21.     }
  22.     // 订单总额
  23.     orderEntity.setTotalAmount(total);
  24.     // 应付总额
  25.     orderEntity.setPayAmount(total.add(orderEntity.getFreightAmount()));
  26.     orderEntity.setCouponAmount(coupon);
  27.     orderEntity.setIntegrationAmount(integration);
  28.     orderEntity.setPromotionAmount(promotion);
  29.     // 设置积分等信息
  30.     orderEntity.setIntegration(gift.intValue());
  31.     orderEntity.setGrowth(growth.intValue());
  32.     orderEntity.setDeleteStatus(0);//0 未删除
  33. }

5、锁定库存

在这里插入图片描述

5.1、保存订单数据并锁定库存

5.1.1、service保存订单数据并锁定库存

  1. /**
  2.  * 下单操作：验令牌、创建订单、验价格、验库存
  3.  * @param vo
  4.  * @return
  5.  */
  6. @Transactional
  7. @Override
  8. public SubmitOrderResponseVo submitOrder(OrderSubmitVo vo) {
  9.     // 在当前线程共享 OrderSubmitVo
  10.     confirmVoThreadLocal.set(vo);
  11.     SubmitOrderResponseVo response = new SubmitOrderResponseVo();
  12.     // 从拦截器中拿到当前的用户
  13.     MemberRespVo memberRespVo = LoginUserInterceptor.loginUser.get();
  14.     response.setCode(0);
  15.  
  16.     // 1、验证令牌【令牌的对比和删除必须保证原子性】,通过使用脚本来完成(0：令牌校验失败; 1: 删除成功)
  17.     String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
  18.     String orderToken = vo.getOrderToken();
  19.     // 原子验证令牌和删除令牌
  20.     Long result = redisTemplate.execute(new DefaultRedisScript<>(script, Long.class),
  21.             Arrays.asList(OrderConstant.USER_ORDER_TOKEN_PREFIX + memberRespVo.getId()), orderToken);
  22.     if (result == 0L) {
  23.         // 令牌验证失败
  24.         response.setCode(1);
  25.         return response;
  26.     } else {
  27.         // 令牌验证成功
  28.         // 2、创建订单、订单项等信息
  29.         OrderCreateTo order = createOrder();
  30.         // 3、验价
  31.         BigDecimal payAmount = order.getOrder().getPayAmount();
  32.         BigDecimal payPrice = vo.getPayPrice();
  33.         if (Math.abs(payAmount.subtract(payPrice).doubleValue())<0.01){
  34.             // 金额对比成功
  35.             // 4、保存订单;
  36.             saveOrder(order);
  37.             // 5、库存锁定，只要有异常回滚订单数据
  38.             // 订单号，所有订单项(skuId,skuName,num)
  39.             WareSkuLockVo lockVo = new WareSkuLockVo();
  40.             lockVo.setOrderSn(order.getOrder().getOrderSn());
  41.             List<OrderItemVo> locks = order.getOrderItems().stream().map(item -> {
  42.                 OrderItemVo itemVo = new OrderItemVo();
  43.                 itemVo.setSkuId(item.getSkuId());
  44.                 itemVo.setCount(item.getSkuQuantity());
  45.                 itemVo.setTitle(item.getSkuName());
  46.                 return itemVo;
  47.             }).collect(Collectors.toList());
  48.             lockVo.setLocks(locks);
  49.             // TODO 远程锁库存
  50.             R r = wareFeignService.orderLockStock(lockVo);
  51.             if (r.getCode() == 0) {
  52.                 // 锁成功了
  53.                 response.setOrder(order.getOrder());
  54.                 return response;
  55.             }else {
  56.                 // 锁定失败
  57.                 throw new NoStockException((String) r.get("msg"));
  58.             }
  59.  
  60.         } else {
  61.             // 金额对比失败
  62.             response.setCode(2);
  63.             return response;
  64.         }
  65.     }
  66. }

5.1.2、【公共模块】无库存异常类

  1. package com.atguigu.common.exception;
  2.  
  3. public class NoStockException extends RuntimeException{
  4.     private Long skuId;
  5.  
  6.     public NoStockException(Long skuId){
  7.         super("商品id:"+skuId+"；没有足够的库存了！");
  8.     }
  9.  
  10.     public NoStockException(String message) {
  11.         super(message);
  12.     }
  13.  
  14.     @Override
  15.     public String getMessage() {
  16.         return super.getMessage();
  17.     }
  18.  
  19.     public Long getSkuId() {
  20.         return skuId;
  21.     }
  22.  
  23.     public void setSkuId(Long skuId) {
  24.         this.skuId = skuId;
  25.     }
  26.  
  27. }

5.2、【仓库模块】锁定库存

5.2.1、订单服务远程调用仓库服务

  1. package com.atguigu.gulimall.order.feign;
  2.  
  3. @FeignClient("gulimall-ware")
  4. public interface WareFeignService {
  5.         //....
  6.  
  7.     /**
  8.      * 锁定指定订单的库存
  9.      * @param vo
  10.      * @return
  11.      */
  12.     @PostMapping("/ware/waresku/lock/order")
  13.     R orderLockStock(@RequestBody WareSkuLockVo vo);
  14. }

5.2.2、锁定库存controller

  1. package com.atguigu.gulimall.ware.controller;
  2.  
  3. @RestController
  4. @RequestMapping("ware/waresku")
  5. public class WareSkuController {
  6.     @Autowired
  7.     private WareSkuService wareSkuService;
  8.  
  9.     /**
  10.      * 锁定订单项库存
  11.      * @param vo
  12.      * @return
  13.      */
  14.     @PostMapping("/lock/order")
  15.     public R orderLockStock(@RequestBody WareSkuLockVo vo){
  16.         try {
  17.             Boolean stock = wareSkuService.orderLockStock(vo);
  18.             return R.ok();
  19.         } catch (NoStockException e){
  20.             return R.error(BizCodeEnume.NO_STOCK_EXCEPTION.getCode(),BizCodeEnume.NO_STOCK_EXCEPTION.getMsg());
  21.         }
  22.     }
  23.   //....
  24. }

5.2.3、锁定库存的vo类

  1. /**
  2.  * @Description: 锁定库存的vo
  3.  **/
  4.  
  5. @Data
  6. public class WareSkuLockVo {
  7.  
  8.     private String orderSn;
  9.  
  10.     /** 需要锁住的所有库存信息 **/
  11.     private List<OrderItemVo> locks;
  12.  
  13.  
  14.  
  15. }

5.2.4、锁定指定订单的库存service

  1. package com.atguigu.gulimall.ware.service.impl;
  2.  
  3. @Service("wareSkuService")
  4. public class WareSkuServiceImpl extends ServiceImpl<WareSkuDao, WareSkuEntity> implements WareSkuService {
  5.  
  6.     @Autowired
  7.     WareSkuDao wareSkuDao;
  8.  
  9.     @Autowired
  10.     ProductFeignService productFeignService;
  11.         //......
  12.  
  13.     /**
  14.      * 锁定指定订单的库存
  15.      * @param vo
  16.      * @return
  17.      * (rollbackFor = NoStockException.class)
  18.      * 默认只要是运行时异常都会回滚
  19.      */
  20.     @Transactional
  21.     @Override
  22.     public Boolean orderLockStock(WareSkuLockVo vo) {
  23.         // 1、每个商品在哪个库存里有库存
  24.         List<OrderItemVo> locks = vo.getLocks();
  25.         List<SkuWareHashStock> collect = locks.stream().map(item -> {
  26.             SkuWareHashStock stock = new SkuWareHashStock();
  27.             Long skuId = item.getSkuId();
  28.             stock.setSkuId(skuId);
  29.             stock.setNum(item.getCount());
  30.             // 查询这个商品在哪里有库存
  31.             List<Long> wareIds = wareSkuDao.listWareIdHashSkuStock(skuId);
  32.             stock.setWareId(wareIds);
  33.             return stock;
  34.         }).collect(Collectors.toList());
  35.  
  36.         // 2、锁定库存
  37.         for (SkuWareHashStock hashStock : collect) {
  38.             Boolean skuStocked = false;
  39.             Long skuId = hashStock.getSkuId();
  40.             List<Long> wareIds = hashStock.getWareId();
  41.             if (wareIds == null || wareIds.size()==0){
  42.                 // 没有任何仓库有这个商品的库存
  43.                 throw new NoStockException(skuId);
  44.             }
  45.             for (Long wareId : wareIds) {
  46.                 // 成功就返回1，否则就返回0
  47.                 Long count = wareSkuDao.lockSkuStock(skuId,wareId,hashStock.getNum());
  48.                 if (count == 1){
  49.                     skuStocked = true;
  50.                     break;
  51.                 } else {
  52.                     // 当前仓库锁失败，重试下一个仓库
  53.  
  54.                 }
  55.             }
  56.             if (skuStocked == false){
  57.                 // 当前商品所有仓库都没有锁住，其他商品也不需要锁了，直接返回没有库存了
  58.                 throw new NoStockException(skuId);
  59.             }
  60.         }
  61.  
  62.         // 3、运行到这，全部都是锁定成功的
  63.         return true;
  64.     }
  65.     @Data
  66.     class SkuWareHashStock{
  67.         private Long skuId;     // skuid
  68.         private Integer num;    // 锁定件数
  69.         private List<Long> wareId;  // 锁定仓库id
  70.     }
  71.  
  72. }

5.2.5、dao，根据sku_id查询在有库存的仓库

gulimall-ware服务中com.atguigu.gulimall.ware.dao路径下的 WareSkuDao 类：

  1. package com.atguigu.gulimall.ware.dao;
  2.  
  3. @Mapper
  4. public interface WareSkuDao extends BaseMapper<WareSkuEntity> {
  5.  
  6.     /**
  7.      * 通过skuId查询在哪个仓库有库存
  8.      * @param skuId
  9.      * @return  仓库的编号
  10.      */
  11.     List<Long> listWareIdHashSkuStock(@Param("skuId") Long skuId);
  12.  
  13.     /**
  14.      * 锁库存
  15.      * @param skuId
  16.      * @param wareId
  17.      * @param num
  18.      * @return
  19.      */
  20.     Long lockSkuStock(@Param("skuId") Long skuId, @Param("wareId") Long wareId, @Param("num") Integer num);
  21.  
  22. }

gulimall-ware服务中gulimall-ware/src/main/resources/mapper/ware路径下的 WareSkuDao.xml：

  1. <update id="addStock">
  2.     UPDATE `wms_ware_sku` SET stock=stock+#{skuNum} WHERE sku_id=#{skuId} AND ware_id=#{wareId}
  3. </update>
  4.  
  5. <select id="listWareIdHashSkuStock" resultType="java.lang.Long">
  6.     SELECT ware_id FROM wms_ware_sku WHERE sku_id=#{skuId} and stock-stock_locked>0;
  7. </select>

5.2.6、【公共模块】错误码枚举类添加库存相关错误码

在 错误码和错误信息定义类 BizCodeEnume枚举类中新增 库存 错误码和信息

gulimall-common服务中com.atguigu.common.exception路径下的 BizCodeEnume：

以21开头的错误码： 库存

  1. package com.atguigu.common.exception;
  2.  
  3. public enum BizCodeEnume {
  4.     UNKNOW_EXCEPTION(10000,"系统未知异常"),
  5.     VAILD_EXCEPTION(10001,"参数格式校验失败"),
  6.     SMS_CODE_EXCEPTION(10002,"验证码获取频率太高，稍后再试"),
  7.     PRODUCT_UP_EXCEPTION(11000,"商品上架异常"),
  8.     USER_EXIST_EXCEPTION(15001,"用户名已存在"),
  9.     PHONE_EXIST_EXCEPTION(15002,"手机号已被注册"),
  10.     NO_STOCK_EXCEPTION(21000,"商品库存不足"),
  11.     LOGINACCT_PASSWORD_INVAILD_EXCEPTION(15003,"账号或密码错误");
  12.  
  13.     private int code;
  14.     private String msg;
  15.     BizCodeEnume(int code,String msg){
  16.         this.code = code;
  17.         this.msg = msg;
  18.     }
  19.  
  20.     public int getCode() {
  21.         return code;
  22.     }
  23.  
  24.     public String getMsg() {
  25.         return msg;
  26.     }
  27. }

6、前端页面的修改

订单提交成功，跳转到支付页面 pay.html

  1. <div class="Jdbox_BuySuc">
  2.   <dl>
  3.     <dt><img src="/static/order/pay/img/saoyisao.png" alt=""></dt>
  4.     <dd>
  5.       <span>订单提交成功，请尽快付款！订单号：[[${submitOrderResp.order.orderSn}]]</span>
  6.       <span>应付金额<font>[[${#numbers.formatDecimal(submitOrderResp.order.payAmount,1,2)}]]</font>元</span>
  7.     </dd>
  8.     <dd>
  9.       <span>推荐使用</span>
  10.       <span>扫码支付请您在<font>24小时</font>内完成支付，否则订单会被自动取消(库存紧订单请参见详情页时限)</span>
  11.       <span>订单详细</span>
  12.     </dd>
  13.   </dl>
  14. </div>

在这里插入图片描述

订单提交失败，重定项到confirm.html 并回显 失败原因

<p class="p1">填写并核对订单信息 <span style="color: red" th:value="${msg!=null}" th:text="${msg}"></span></p>

在这里插入图片描述

在这里插入图片描述

7、提交订单的完整代码

7.1、Controller层接口编写

  1. /**
  2.  * 下单功能
  3.  * @param vo
  4.  * @return
  5.  */
  6. @PostMapping("/submitOrder")
  7. public String submitOrder(OrderSubmitVo vo, Model model, RedirectAttributes redirectAttributes){
  8.     // 1、创建订单、验令牌、验价格、验库存
  9.     try {
  10.         SubmitOrderResponseVo responseVo = orderService.submitOrder(vo);
  11.         if (responseVo.getCode() == 0) {
  12.             // 下单成功来到支付选择页
  13.             model.addAttribute("submitOrderResp",responseVo);
  14.             return "pay";
  15.         } else {
  16.             // 下单失败回到订单确认页重新确认订单信息
  17.             String msg = "下单失败: ";
  18.             switch ( responseVo.getCode()){
  19.                 case 1: msg+="订单信息过期，请刷新再次提交";break;
  20.                 case 2: msg+="订单商品价格发生变化，请确认后再次提交";break;
  21.                 case 3: msg+="商品库存不足";break;
  22.             }
  23.             redirectAttributes.addAttribute("msg",msg);
  24.             return "redirect:http://order.gulimall.cn/toTrade";
  25.         }
  26.     } catch (Exception e){
  27.         if (e instanceof NoStockException) {
  28.             String message = e.getMessage();
  29.             redirectAttributes.addFlashAttribute("msg", message);
  30.         }
  31.         return "redirect:http://order.gulimall.cn/toTrade";
  32.     }
  33.  
  34. }

7.2、Service层代码

7.2.1、提交订单业务

  1.    /**
  2.      * 提交订单
  3.      * @param vo
  4.      * @return
  5.      */
  6.     // @Transactional(isolation = Isolation.READ_COMMITTED) 设置事务的隔离级别
  7.     // @Transactional(propagation = Propagation.REQUIRED)   设置事务的传播级别
  8.     @Transactional(rollbackFor = Exception.class)
  9.     // @GlobalTransactional(rollbackFor = Exception.class)
  10.     @Override
  11.     public SubmitOrderResponseVo submitOrder(OrderSubmitVo vo) {
  12.  
  13.         confirmVoThreadLocal.set(vo);
  14.  
  15.         SubmitOrderResponseVo responseVo = new SubmitOrderResponseVo();
  16.         //去创建、下订单、验令牌、验价格、锁定库存...
  17.  
  18.         //1.从拦截器中获取当前用户登录的信息
  19.         MemberResponseVo memberResponseVo = LoginUserInterceptor.loginUser.get();
  20.         responseVo.setCode(0);
  21.  
  22.         //2、验证令牌是否合法【令牌的对比和删除必须保证原子性】
  23.         String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
  24.         String orderToken = vo.getOrderToken();
  25.  
  26.         //通过lure脚本原子验证令牌和删除令牌
  27.         Long result = redisTemplate.execute(new DefaultRedisScript<Long>(script, Long.class),
  28.                 Arrays.asList(USER_ORDER_TOKEN_PREFIX + memberResponseVo.getId()),
  29.                 orderToken);
  30.  
  31.         if (result == 0L) {
  32.             //令牌验证失败
  33.             responseVo.setCode(1);
  34.             return responseVo;
  35.         } else {
  36.             //令牌验证成功
  37.             //1、创建订单、订单项等信息
  38.             OrderCreateTo order = createOrder();
  39.  
  40.             //2、验证价格
  41.             BigDecimal payAmount = order.getOrder().getPayAmount();
  42.             BigDecimal payPrice = vo.getPayPrice();
  43.  
  44.             if (Math.abs(payAmount.subtract(payPrice).doubleValue()) < 0.01) {
  45.                 //金额对比
  46.                 //TODO 3、保存订单
  47.                 saveOrder(order);
  48.  
  49.                 //4、库存锁定,只要有异常，回滚订单数据
  50.                 //订单号、所有订单项信息(skuId,skuNum,skuName)
  51.                 WareSkuLockVo lockVo = new WareSkuLockVo();
  52.                 lockVo.setOrderSn(order.getOrder().getOrderSn());
  53.  
  54.                 //获取出要锁定的商品数据信息
  55.                 List<OrderItemVo> orderItemVos = order.getOrderItems().stream().map((item) -> {
  56.                     OrderItemVo orderItemVo = new OrderItemVo();
  57.                     orderItemVo.setSkuId(item.getSkuId());
  58.                     orderItemVo.setCount(item.getSkuQuantity());
  59.                     orderItemVo.setTitle(item.getSkuName());
  60.                     return orderItemVo;
  61.                 }).collect(Collectors.toList());
  62.                 lockVo.setLocks(orderItemVos);
  63.  
  64.                 //TODO 调用远程锁定库存的方法
  65.                 //出现的问题：扣减库存成功了，但是由于网络原因超时，出现异常，导致订单事务回滚，库存事务不回滚(解决方案：seata)
  66.                 //为了保证高并发，不推荐使用seata，因为是加锁，并行化，提升不了效率,可以发消息给库存服务
  67.                 R r = wmsFeignService.orderLockStock(lockVo);
  68.                 if (r.getCode() == 0) {
  69.                     //锁定成功
  70.                     responseVo.setOrder(order.getOrder());
  71.                     // int i = 10/0;
  72.  
  73.                     //TODO 订单创建成功，发送消息给MQ
  74.                     rabbitTemplate.convertAndSend("order-event-exchange","order.create.order",order.getOrder());
  75.  
  76.                     //删除购物车里的数据
  77.                     redisTemplate.delete(CART_PREFIX+memberResponseVo.getId());
  78.                     return responseVo;
  79.                 } else {
  80.                     //锁定失败
  81.                     String msg = (String) r.get("msg");
  82.                     throw new NoStockException(msg);
  83.                     // responseVo.setCode(3);
  84.                     // return responseVo;
  85.                 }
  86.  
  87.             } else {
  88.                 responseVo.setCode(2);
  89.                 return responseVo;
  90.             }
  91.         }
  92.     }

7.2.2、创建订单、构建订单、计算价格等调用的方法

  1.     /**
  2.      * 创建订单、订单项等信息
  3.      * @return
  4.      */
  5.     private OrderCreateTo createOrder(){
  6.         OrderCreateTo createTo = new OrderCreateTo();
  7.         // 1、生成一个订单号
  8.         String orderSn = IdWorker.getTimeId();
  9.         // 2、构建一个订单
  10.         OrderEntity orderEntity = buildOrder(orderSn);
  11.         // 3、获取到所有的订单项
  12.         List<OrderItemEntity> itemEntities = buildOrderItems(orderSn);
  13.         // 4、计算价格、积分等相关信息
  14.         computePrice(orderEntity,itemEntities);
  15.  
  16.         createTo.setOrder(orderEntity);
  17.         createTo.setOrderItems(itemEntities);
  18.         return createTo;
  19.     }
  20.  
  21.  
  22.  
  23.     /**
  24.      * 构建订单
  25.      * @param orderSn
  26.      * @return
  27.      */
  28.     private OrderEntity buildOrder(String orderSn) {
  29.         MemberRespVo respVp = LoginUserInterceptor.loginUser.get();
  30.         OrderEntity entity = new OrderEntity();
  31.         entity.setOrderSn(orderSn);
  32.         entity.setMemberId(respVp.getId());
  33.  
  34.         OrderSubmitVo orderSubmitVo = confirmVoThreadLocal.get();
  35.         // 1、获取运费 和 收货信息
  36.         R fare = wareFeignService.getFare(orderSubmitVo.getAddrId());
  37.         FareVo fareResp = fare.getData(new TypeReference<FareVo>() {
  38.         });
  39.         // 2、设置运费
  40.         entity.setFreightAmount(fareResp.getFare());
  41.         // 3、设置收货人信息
  42.         entity.setReceiverPostCode(fareResp.getAddress().getPostCode());
  43.         entity.setReceiverProvince(fareResp.getAddress().getProvince());
  44.         entity.setReceiverRegion(fareResp.getAddress().getRegion());
  45.         entity.setReceiverCity(fareResp.getAddress().getCity());
  46.         entity.setReceiverDetailAddress(fareResp.getAddress().getDetailAddress());
  47.         entity.setReceiverName(fareResp.getAddress().getName());
  48.         entity.setReceiverPhone(fareResp.getAddress().getPhone());
  49.         // 4、设置订单的相关状态信息
  50.         entity.setStatus(OrderStatusEnum.CREATE_NEW.getCode());
  51.         // 5、默认取消信息
  52.         entity.setAutoConfirmDay(7);
  53.         return entity;
  54.     }
  55.  
  56.     /**
  57.      * 构建所有订单项数据
  58.      * @return
  59.      */
  60.     private  List<OrderItemEntity> buildOrderItems(String orderSn) {
  61.         // 最后确定每个购物项的价格
  62.         List<OrderItemVo> currentUserCartItems = cartFeignService.getCurrentUserCartItems();
  63.         if (currentUserCartItems != null && currentUserCartItems.size()>0){
  64.             List<OrderItemEntity> itemEntities = currentUserCartItems.stream().map(cartItem -> {
  65.                 OrderItemEntity itemEntity = buildOrderItem(cartItem);
  66.                 itemEntity.setOrderSn(orderSn);
  67.                 return itemEntity;
  68.             }).collect(Collectors.toList());
  69.             return itemEntities;
  70.         }
  71.         return null;
  72.     }
  73.  
  74.     /**
  75.      * 构建某一个订单项
  76.      * @param cartItem
  77.      * @return
  78.      */
  79.     private OrderItemEntity buildOrderItem(OrderItemVo cartItem) {
  80.         OrderItemEntity itemEntity = new OrderItemEntity();
  81.         // 1、订单信息：订单号 v
  82.         // 2、商品的spu信息
  83.         Long skuId = cartItem.getSkuId();
  84.         R r = productFeignService.getSpuInfoBySkuId(skuId);
  85.         SpuInfoVo data = r.getData(new TypeReference<SpuInfoVo>() {
  86.         });
  87.         itemEntity.setSpuId(data.getId());
  88.         itemEntity.setSpuBrand(data.getBrandId().toString());
  89.         itemEntity.setSpuName(data.getSpuName());
  90.         itemEntity.setCategoryId(data.getCatalogId());
  91.         // 3、商品的sku信息  v
  92.         itemEntity.setSkuId(cartItem.getSkuId());
  93.         itemEntity.setSkuName(cartItem.getTitle());
  94.         itemEntity.setSkuPic(cartItem.getImage());
  95.         itemEntity.setSkuPrice(cartItem.getPrice());
  96.         itemEntity.setSkuQuantity(cartItem.getCount());
  97.         itemEntity.setSkuAttrsVals(StringUtils.collectionToDelimitedString(cartItem.getSkuAttr(),";"));
  98.         // 4、优惠信息【不做】
  99.         // 5、积分信息
  100.         itemEntity.setGiftGrowth(cartItem.getPrice().multiply(new BigDecimal(cartItem.getCount().toString())).intValue());
  101.         itemEntity.setGiftIntegration(cartItem.getPrice().multiply(new BigDecimal(cartItem.getCount().toString())).intValue());
  102.         // 6、订单项的价格信息
  103.         itemEntity.setPromotionAmount(new BigDecimal("0"));
  104.         itemEntity.setCouponAmount(new BigDecimal("0"));
  105.         itemEntity.setIntegrationAmount(new BigDecimal("0"));
  106.         // 当前订单项的实际金额 总额-各种优惠
  107.         BigDecimal orign = itemEntity.getSkuPrice().multiply(new BigDecimal(itemEntity.getSkuQuantity().toString()));
  108.         BigDecimal subtract = orign.subtract(itemEntity.getCouponAmount()).
  109.                 subtract(itemEntity.getCouponAmount()).
  110.                 subtract(itemEntity.getIntegrationAmount());
  111.         itemEntity.setRealAmount(subtract);
  112.         return itemEntity;
  113.     }
  114.  
  115.     /**
  116.      * 计算价格
  117.      * @param orderEntity
  118.      * @param itemEntities
  119.      */
  120.     private void computePrice(OrderEntity orderEntity, List<OrderItemEntity> itemEntities) {
  121.         BigDecimal total = new BigDecimal("0.0");
  122.         BigDecimal coupon = new BigDecimal("0.0");
  123.         BigDecimal integration = new BigDecimal("0.0");
  124.         BigDecimal promotion = new BigDecimal("0.0");
  125.         BigDecimal gift = new BigDecimal("0.0");
  126.         BigDecimal growth = new BigDecimal("0.0");
  127.         // 1、订单的总额，叠加每一个订单项的总额信息
  128.         for (OrderItemEntity entity : itemEntities) {
  129.             total = total.add(entity.getRealAmount());
  130.             coupon = coupon.add(entity.getCouponAmount());
  131.             integration = integration.add(entity.getIntegrationAmount());
  132.             promotion = promotion.add(entity.getPromotionAmount());
  133.             gift = gift.add(new BigDecimal(entity.getGiftIntegration()));
  134.             growth = growth.add(new BigDecimal(entity.getGiftGrowth()));
  135.         }
  136.         // 订单总额
  137.         orderEntity.setTotalAmount(total);
  138.         // 应付总额
  139.         orderEntity.setPayAmount(total.add(orderEntity.getFreightAmount()));
  140.         orderEntity.setCouponAmount(coupon);
  141.         orderEntity.setIntegrationAmount(integration);
  142.         orderEntity.setPromotionAmount(promotion);
  143.         }

8、分布式事务优化

8.1、解决低并发场景的分布式事务

8.1.1 Seata的AT模式

回顾Seata：

SpringCloud基础6——分布式事务，Seata

AT模式： 

阶段一RM的工作：

  • 注册分支事务
  • 记录undo-log（数据快照）
  • 执行业务sql并提交
  • 报告事务状态

阶段二提交时RM的工作：

  • 删除undo-log即可

阶段二回滚时RM的工作：

  • 根据undo-log恢复数据到更新前

 image-20210724175327511

8.1.2【商品模块】保存spu信息业务设为分布式事务  

需求：AT模式实现低并发场景的分布式事务。

下面以保存商品业务为例：

保存商品业务是低并发，包装最终一致性即可，使用seata的AT模式。

 

因为这个业务里涉及到了远程调用，使用本地事务已经无法实现失败回滚，需要使用Seata分布式事务。

1.导入依赖

  1. <!--seata-->
  2. <dependency>
  3.     <groupId>com.alibaba.cloud</groupId>
  4.     <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  5. </dependency>

 2.对应数据库导入undo_log表

  1. -- 注意此处0.7.0+ 增加字段 context
  2. CREATE TABLE `undo_log` (
  3.   `id` bigint(20) NOT NULL AUTO_INCREMENT,
  4.   `branch_id` bigint(20) NOT NULL,
  5.   `xid` varchar(100) NOT NULL,
  6.   `context` varchar(128) NOT NULL,
  7.   `rollback_info` longblob NOT NULL,
  8.   `log_status` int(11) NOT NULL,
  9.   `log_created` datetime NOT NULL,
  10.   `log_modified` datetime NOT NULL,
  11.   PRIMARY KEY (`id`),
  12.   UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
  13. ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

 3.修改application.yml文件，将事务模式修改为AT模式即可：

  1. seata:
  2.   data-source-proxy-mode: AT # 默认就是AT

4.给发起全局事务的入口方法添加@GlobalTransactional注解:

  1. @GlobalTransactional
  2. @Transactional  // 本地事务，在分布式系统，只能控制住自己的回滚，控制不了其他服务的回滚。
  3. @Override
  4. public void saveSpuInfo(SpuSaveVo vo) {
  5.   //.....
  6. }

5.配置类注入seata代理数据源

  1. @Configuration
  2. public class DataSourceProxyConfig {
  3.  
  4.     @Bean
  5.     @ConfigurationProperties(prefix = "spring.datasource")
  6.     public DruidDataSource druidDataSource() {
  7.         return new DruidDataSource();
  8.     }
  9.  
  10.     @Primary
  11.     @Bean
  12.     public DataSourceProxy dataSource(DruidDataSource druidDataSource) {
  13.         return new DataSourceProxy(druidDataSource);
  14.     }
  15.  
  16. }

6.将file.conf和registry.conf两个配置文件移动到项目resources下：

seata-samples/springcloud-jpa-seata/account-service/src/main/resources at master · seata/seata-samples · GitHub

设置file.conf 的 service.vgroup_mapping 配置必须和spring.application.name一致
yml配置service.vgroup_mapping 的服务名：

8.2、解决低并发场景的分布式事务

8.2.1、可靠消息+最终一致性方案

业务处理服务在业务事务提交之前，向实时消息服务请求发送消息，实时消息服务只记录消息数据，而不是真正的发送。

业务处理服务在业务事务提交之后，向实时消息服务确认发送。只有在得到确认发送指令后，实时消息服务才会真正发送。

案例：

在商品下单业务的最后要锁定库存，我们设置在锁定库存后发RabbitMQ延迟队列消息，通知锁定库存成功，两分钟后消费消息，根据库存信息查询检查订单是否存在，若不存在代表下订单失败，此时要回滚，也就是解锁库存。

8.2.2、若订单失败，自动解锁库存

具体参考下一篇文章：谷粒商城笔记+踩坑（22）——库存自动解锁。RabbitMQ延迟队列_vincewm的博客-CSDN博客

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/很楠不爱3/article/detail/462382
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号