分布式锁解决方案_数据库乐观锁实现的分布式锁-【官方】百战程序员_IT在线教育培训机构


xxxxxxxxxx
    <update id="decreaseStockForVersion" parameterType="int" >
        UPDATE product SET count = count - #{count}, version = version + 1 WHERE id = #{id} AND count > 0 AND version = #{version}
    </update>

编写创建订单业务层


xxxxxxxxxx
 /**
     * 创建订单  乐观锁
     *
     * @return
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public String createOrder(Integer productId, Integer count) throws Exception {
        int retryCount = 0;
        int update = 0;
        // 1、根据商品id查询商品信息
        Product product = productMapper.selectById(productId);
        // 2、判断商品是否存在
        if (product == null) {
            throw new RuntimeException("购买商品不存在:" + productId + "不存在");
        }
        // 3、校验库存
        if (count > product.getCount()) {
            throw new Exception("库存不够");
        }
        // 乐观锁更新库存
        // 更新失败，说明其他线程已经修改过数据，本次扣减库存失败，可以重试一定次数或者返回
        // 最多重试3次
        while(retryCount < 3 && update == 0){
            update = this.reduceStock(product.getId(),count);
            retryCount++;
        }
        if (update == 0){
            throw new Exception("库存不够");
        }
        // 6、 创建订单
        TOrder order = new TOrder();
        order.setOrderStatus(1);//待处理
        order.setReceiverName("张三");
        order.setReceiverMobile("18587781068");
        order.setOrderAmount(product.getPrice().multiply(new BigDecimal(count)));//订单价格
        baseMapper.insert(order);

        // 7、 创建订单和商品关系数据
        OrderItem orderItem = new OrderItem();
        orderItem.setOrderId(order.getId());
        orderItem.setProduceId(product.getId());
        orderItem.setPurchasePrice(product.getPrice());
        orderItem.setPurchaseNum(count);
        orderItemMapper.insert(orderItem);
        return order.getId();
    }
 /**
     * 减库存
     * <p>
     * 由于默认的事务隔离级别是可重复读，produce.findById()
     * 得到的数据始终是相同的，所以需要提取reduceStock方法。每次循环都启动新的事务尝试扣减库存操作。
     */
    @Transactional(rollbackFor = Exception.class)
    public int reduceStock(int gid,int count) {
        int result = 0;
        //1、查询商品库存
        Product product = productMapper.selectById(gid);
        //2、判断库存是否充足
        if (product.getCount() >= count) {
            //3、减库存
            // 乐观锁更新库存
            result = productMapper.decreaseStockForVersion(gid,count, product.getVersion());
        }
        return result;
    }

实时效果反馈

1.基于数据库如何实现乐观锁_______。

A for update

B 表加version字段

C synchronized

D 以上都是错误

2.乐观锁适用于__的应用类型，这样可以提高吞吐量。

A 多读

B 写多

C 删多

D 以上都是错误

答案

1=>B 2=>A

分布式锁解决方案_数据库悲观锁实现的分布式锁分布式锁解决方案_Redis实现的分布式锁原理

北京市昌平区回龙观镇南店村综合商业楼2楼226室