分布式锁【基于synchronized锁解决超卖问题、分布式锁解决方案、悲观锁实现的分布式锁】(二)-全面详解（学习总结---从入门到深化）

太过爱你忘了你带给我的痛 2023-10-13 16:56 47阅读 0赞

### ![66279e7ebb4545598673ec058d044a10.gif][] ###

![d5d80957689647648fbf7b287895e801.png][]

**目录**

分布式锁问题\_演示问题

基于synchronized锁解决超卖问题

分布式锁解决方案

分布式锁实现方案

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

项目中使用for update

--------------------

### 分布式锁问题\_演示问题 ###

![f8652357d7da4ed59b581959b25fd025.png][]

**启动订单服务9090**

![338a6612ef5e4f89a3be6f4cbdd663f3.png][]

**启动订单服务9091**

![121edb0312584b25b52d69e6507ef19d.png][]

**创建两个SpringBoot服务**

![b425038c164245d5b34e82b911750144.png][]

**启动Nginx服务**

> 下载Nginx windows服务，官网http://nginx.org/en/download.html

![4b652f6187f24ee98a8ee0c470d1a6a8.png][]

**配置负载均衡**

编辑nginx.conf文件添加负载均衡的配置。

upstream test{
          server localhost:9090 ;
          server localhost:9091 ;
       }
        
    server {
            listen       80;
            server_name localhost;
        
            location / {
                proxy_pass http://test;
           }
    }

**启动Nginx服务**

在nginx目录下面

![897a7ea14a414bd3b123623e4e424b1c.png][]

**启动JMeter压测工具**

添加线程组 -> HTTP请求 -> 察看结果树 -> 聚合报告

![670dcb73820c4b3984931ab39335aa67.png][]

**设置Http请求参数**

![b5c3910cc75d4f4d8150e90693ada12a.png][]

**查看库存数据**

![91089bca58bd4d9a9b65157f05fa4153.png][]

**查看订单数据**

![d5c819828f4941d1a75323d35f083fea.png][]

### 基于synchronized锁解决超卖问题 ###

![acbb68d1d2be41c38e509eb9d0b8a07a.png][]

> Spring进行了统一的抽象，形成了 PlatformTransactionManager事务管理器接口 ， 事务的 提交、回滚等操作 全部交给它来实现。

**事务功能的总体接口设计**

三个接口功能一句话总的来说事务管理器基于事务基础信息在操作 事务时候对事务状态进行更新。

![2b6911e0634648c891da2d372a9dc14c.png][]

**方法加锁**

public synchronized String createOrder(Integer produceId, Integer purchaseNum) { }

**声明事务管理器**

@Autowired
    private PlatformTransactionManager platformTransactionManager;
    @Autowired
    private TransactionDefinition transactionDefinition;

**手动创建事务**

TransactionStatus transaction = platformTransactionManager.getTransaction(transactionDefinition);

**手动提交事务**

/**
         * 创建订单
         *
         * @param produceId   商品id
         * @param purchaseNum 购买数量
         * @return
         */
        @Override
        public synchronized String createOrder(Integer produceId, Integer purchaseNum) {
            TransactionStatus transaction = platformTransactionManager.getTransaction(trans
    actionDefinition);
            // 1、根据商品id获取商品信息
            Product product = productMapper.selectById(produceId);
            // 2、判断商品是否存在
            if (product == null) {
              platformTransactionManager.rollback(transaction);
                throw new RuntimeException("购买商品不存在");
           }
             log.info(Thread.currentThread().getName() + "库存数量" + product.getCount());
            // 3、校验库存
            if (purchaseNum > product.getCount()) {
               platformTransactionManager.rollback(transaction);
                throw new RuntimeException("库存不足");
           }
            // 4、更新库存操作
            int count = product.getCount() - purchaseNum;
            product.setCount(count);
            productMapper.updateById(product);
            // 5、创建订单
            TOrder order = new TOrder();
            order.setOrderStatus(1);//订单状态
            order.setReceiverName("张三");
            order.setReceiverMobile("18587781058");
          order.setOrderAmount(product.getPrice().multiply(new BigDecimal(purchaseNum)));//订单价格
            baseMapper.insert(order);
            // 6、创建订单和商品关联
            OrderItem orderItem = new OrderItem();
            orderItem.setOrderId(order.getId());//订单id
            orderItem.setProduceId(product.getId());// 商品id
            orderItem.setPurchasePrice(product.getPrice());// 购买价格
            orderItem.setPurchaseNum(purchaseNum);// 购买数量
            orderItemMapper.insert(orderItem);
            //提交事务
            platformTransactionManager.commit(transaction);
            return order.getId();
       }

### 分布式锁解决方案 ###

![551dab23175344c28e0ab46cbb946dfc.png][]

> 分布式的CAP理论告诉我们“任何一个分布式系统都无法同时满足一 致性（Consistency）、可用性（Availability）和分区容错性 （Partition tolerance），最多只能同时满足两项。”所以，很多系 统在设计之初就要对这三者做出取舍。在互联网领域的绝大多数的 场景中，都需要牺牲强一致性来换取系统的高可用性，系统往往只 需要保证“最终一致性”，只要这个最终时间是在用户可以接受的范围内即可。

### 分布式锁实现方案 ###

**基于数据库实现的分布式锁**

![2ccca5404f75498fa6ee28f9955cd770.png][]

> 基于数据库实现分布式锁主要是利用数据库的唯一索引来实现，唯 一索引天然具有排他性，这刚好符合我们对锁的要求：同一时刻只能允许一个竞争者获取锁。

**基于 Redis 实现的分布式锁**

![79abf3641cb347c3844eb5d1b80814af.png][]

> 使用Redis来实现分布式锁的效率最高，加锁速度最快，因为Redis 几乎都是纯内存操作，而基于数据库的方案和基于Zookeeper的方 案都会涉及到磁盘文件IO，效率相对低下。一般使用Redis来实现分 布式锁都是利用Redis的 SETNX key value 这个命令，只有当key不存在时 才会执行成功，如果key已经存在则命令执行失败。

**基于 Zookeeper 实现的分布式锁**

![9225f7a434d54534a3a70e3be30a6a1d.png][]

Zookeeper一般用作配置中心，其实现分布式锁的原理和Redis类 似，我们在Zookeeper中创建临时顺序节点，利用节点不能重复创建的特性来保证排他性。

![0d776aa755a54294b43453e28e9fbf08.png][]

### 分布式锁解决方案\_数据库悲观锁实现的分布式锁 ###

![be461a517351443ab7de6df4dd3cc7c3.png][]

什么是悲观锁

顾名思义，就是比较悲观的锁，总是假设最坏的情况，每次去拿数 据的时候都认为别人会修改，所以每次在拿数据的时候都会上锁， 这样别人想拿这个数据就会阻塞直到它拿到锁。

**演示for update**

开启2个命令行界面

![f863aa35937a401b87c1baa06536d1be.png][]

**测试for update**

![17903166b1c2465f9f4677d3e25487b0.png][]

### 项目中使用for update ###

**配置文件添加配置**

mybatis-plus:
     mapper-locations: classpath:mapper/*.xml

**mapper添加方法**

public interface ProductMapper extends BaseMapper<Product> {
        Product  findById(@Param("id")Integer id);
    }

**mapper编写语句**

<select id="findById" parameterType="int" resultType="com.tong.lock.entity.Product">
           select * from product where id = #{id} for update
    </select>

**修改订单接口实现类**

@Transactional(rollbackFor = Exception.class)
        @Override
        public  String createOrder(Integer productId, Integer count) {
            // 1、根据商品id查询商品信息
            Product product = productMapper.findById(productId);
            // 2、判断商品是否存在
            if (product == null) {
                throw new RuntimeException("购买商品不存在:" + productId + "不存在");
           }
            // 3、校验库存
            if (count > product.getCount()) {
                throw new RuntimeException("商品" +productId + "仅剩" + product.getCount() + "件,无法购买");
           }
            // 4、计算库存
            Integer leftCount = product.getCount() - count;
            // 5、更新库存
            product.setCount(leftCount);
            productMapper.updateById(product);
            // 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();
       }

**压测吞吐量**

![3e1e682e25624092bf0c49f366cf3d09.png][]

[66279e7ebb4545598673ec058d044a10.gif]: https://img-blog.csdnimg.cn/66279e7ebb4545598673ec058d044a10.gif
[d5d80957689647648fbf7b287895e801.png]: https://img-blog.csdnimg.cn/d5d80957689647648fbf7b287895e801.png
[f8652357d7da4ed59b581959b25fd025.png]: https://img-blog.csdnimg.cn/f8652357d7da4ed59b581959b25fd025.png
[338a6612ef5e4f89a3be6f4cbdd663f3.png]: https://img-blog.csdnimg.cn/338a6612ef5e4f89a3be6f4cbdd663f3.png
[121edb0312584b25b52d69e6507ef19d.png]: https://img-blog.csdnimg.cn/121edb0312584b25b52d69e6507ef19d.png
[b425038c164245d5b34e82b911750144.png]: https://img-blog.csdnimg.cn/b425038c164245d5b34e82b911750144.png
[4b652f6187f24ee98a8ee0c470d1a6a8.png]: https://img-blog.csdnimg.cn/4b652f6187f24ee98a8ee0c470d1a6a8.png
[897a7ea14a414bd3b123623e4e424b1c.png]: https://img-blog.csdnimg.cn/897a7ea14a414bd3b123623e4e424b1c.png
[670dcb73820c4b3984931ab39335aa67.png]: https://img-blog.csdnimg.cn/670dcb73820c4b3984931ab39335aa67.png
[b5c3910cc75d4f4d8150e90693ada12a.png]: https://img-blog.csdnimg.cn/b5c3910cc75d4f4d8150e90693ada12a.png
[91089bca58bd4d9a9b65157f05fa4153.png]: https://img-blog.csdnimg.cn/91089bca58bd4d9a9b65157f05fa4153.png
[d5c819828f4941d1a75323d35f083fea.png]: https://img-blog.csdnimg.cn/d5c819828f4941d1a75323d35f083fea.png
[acbb68d1d2be41c38e509eb9d0b8a07a.png]: https://img-blog.csdnimg.cn/acbb68d1d2be41c38e509eb9d0b8a07a.png
[2b6911e0634648c891da2d372a9dc14c.png]: https://img-blog.csdnimg.cn/2b6911e0634648c891da2d372a9dc14c.png
[551dab23175344c28e0ab46cbb946dfc.png]: https://img-blog.csdnimg.cn/551dab23175344c28e0ab46cbb946dfc.png
[2ccca5404f75498fa6ee28f9955cd770.png]: https://img-blog.csdnimg.cn/2ccca5404f75498fa6ee28f9955cd770.png
[79abf3641cb347c3844eb5d1b80814af.png]: https://img-blog.csdnimg.cn/79abf3641cb347c3844eb5d1b80814af.png
[9225f7a434d54534a3a70e3be30a6a1d.png]: https://img-blog.csdnimg.cn/9225f7a434d54534a3a70e3be30a6a1d.png
[0d776aa755a54294b43453e28e9fbf08.png]: https://img-blog.csdnimg.cn/0d776aa755a54294b43453e28e9fbf08.png
[be461a517351443ab7de6df4dd3cc7c3.png]: https://img-blog.csdnimg.cn/be461a517351443ab7de6df4dd3cc7c3.png
[f863aa35937a401b87c1baa06536d1be.png]: https://img-blog.csdnimg.cn/f863aa35937a401b87c1baa06536d1be.png
[17903166b1c2465f9f4677d3e25487b0.png]: https://img-blog.csdnimg.cn/17903166b1c2465f9f4677d3e25487b0.png
[3e1e682e25624092bf0c49f366cf3d09.png]: https://img-blog.csdnimg.cn/3e1e682e25624092bf0c49f366cf3d09.png