Redis高并发锁（二）乐观锁

拼搏现实的明天。 2024-03-30 10:19 76阅读 0赞

#### 文章目录 ####

*  redis乐观锁
 *   *  1. watch 监控key
     *  2. multi 开启事务
     *  3. exec 执行事务
     *  4. 演示
     *   *  1) 先用两个连接AB访问redis
         *  2) A监控key,此时库存是4501
         *  3) A开启事务，并且将库存-1,事务进入队列等待执行
         *  4）此时B更新库存为2001
         *  5）A开始执行事务
 *  业务改造
 *   *  1. StockService
 *  测试
 *  问题

## redis乐观锁 ##

由watch multi exec配合实现乐观锁

### 1. watch 监控key ###

可以监控一个或者多个key的值，若在事务执行(exec)之前，key的值发生变化则取消事务执行

### 2. multi 开启事务 ###

### 3. exec 执行事务 ###

### 4. 演示 ###

#### 1) 先用两个连接AB访问redis ####

#### 2) A监控key,此时库存是4501 ####

![在这里插入图片描述][1bc94e5ea3e647e09eac649e8f08dd20.png]

#### 3) A开启事务，并且将库存-1,事务进入队列等待执行 ####

![在这里插入图片描述][2b25ebd99bee495b801999206ba02450.png]

#### 4）此时B更新库存为2001 ####

![在这里插入图片描述][18c2acda9ca0464c9adec2bd23dfeedf.png]

#### 5）A开始执行事务 ####

![在这里插入图片描述][6a7b3916da9c4a5d9531b699e23600ed.png]

执行为空，即执行失败,且库存已被B更新为了2001

6）若事务执行过程中没有被B执行呢  
![在这里插入图片描述][45222f2acff64fb6bbec2b711e497e01.png]  
执行成功！！！

## 业务改造 ##

### 1. StockService ###

@Service
    public class StockService {
        
    
        @Autowired
        private StockMapper stockMapper;
    
    
        @Autowired
        private StringRedisTemplate redisTemplate;
    
        public void deduct() {
        
    
            redisTemplate.execute(new SessionCallback<Object>() {
        
                @Override
                public <K, V> Object execute(RedisOperations<K, V> redisOperations) throws DataAccessException {
        
                    // watch 监控key
                    redisOperations.watch((K) "stock");
    
                    // 1。 查询库存
                    String stockStr = redisTemplate.opsForValue().get("stock");
                    if (!StringUtil.isNullOrEmpty(stockStr)) {
        
                        int stock = Integer.parseInt(stockStr);
                        // 2。 判断条件是否满足
                        if (stock > 0) {
        
    
                            // multi 开启事务
                            redisOperations.multi();
                            // 3 更新redis
                            redisTemplate.opsForValue().set("stock", String.valueOf(stock - 1));
                            // exec 执行事务
                            List<Object> list = redisOperations.exec();
                            // 如果执行事务返回结果为空，则重试
                            if (CollectionUtils.isEmpty(list)) {
        
                                try {
        
                                    Thread.sleep(20);
                                } catch (InterruptedException e) {
        
                                    throw new RuntimeException(e);
                                }
                                deduct();
                            }
    
                        }
                    }
                    return null;
                }
            });
    
        }
    }

需要在redisTemplate.execute(new SessionCallback() \{\})的匿名内部类中实现redis事务。

而RedisOperations  
![在这里插入图片描述][d8a672646c684a05a94d1128baf2a7c1.png]  
其实就是我们使用的StringRedisTemplate，所以直接用它调用即可。

## 测试 ##

![在这里插入图片描述][4deda6af1a1a4592850ee44b570811a3.png]  
性能太差了，吞吐量只有6

![在这里插入图片描述][b93e9e13f2b046b6b4847f66e8473de5.png]  
但库存成功清0了，问题解决

## 问题 ##

性能太差

[1bc94e5ea3e647e09eac649e8f08dd20.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/bef4ffe6148a497fb4123337ec645150.png
[2b25ebd99bee495b801999206ba02450.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/59f8a9fd772d4947b70988714fcf4a7f.png
[18c2acda9ca0464c9adec2bd23dfeedf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/687d43991ad64e87a9f0e138efe20d11.png
[6a7b3916da9c4a5d9531b699e23600ed.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/806421d25e9c4011926ced86afdf1b9c.png
[45222f2acff64fb6bbec2b711e497e01.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/18a41b8bfc5b41c6846ba7d9e6a09a6a.png
[d8a672646c684a05a94d1128baf2a7c1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/1f399be937d947cf8d0bbedb477e5153.png
[4deda6af1a1a4592850ee44b570811a3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/600164af30804d9992f01dd1ce10a843.png
[b93e9e13f2b046b6b4847f66e8473de5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/a401d473ab834c1ab17ea35bb05b6c33.png