【谷粒商城】缓存使用之进程锁和分布式锁

梦里梦外; 2022-09-05 12:49 154阅读 0赞

### 文章目录 ###

*  \#进程锁（本地锁）
 *   *  在本地锁的基础上实现分布式锁
     *   *  获取分布式锁
         *  执行逻辑
     *  没有解锁怎么办（死锁）
     *  如果业务还没执行完，锁已过期怎么办
     *  分布式锁提前过期怎么办？
 *  \#分布式锁

# \#进程锁（本地锁） #

[https://www.bilibili.com/video/BV1np4y1C7Yf?p=156&spm\_id\_from=pageDriver][https_www.bilibili.com_video_BV1np4y1C7Yf_p_156_spm_id_from_pageDriver]  
缺点：分布式情况下，锁不住所有的服务。  
在当前方法上加`synchroized` 或者 在方法内部写上同步代码块。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70]  
首先，我们要知道，在springboot项目中所有组件在容器中都是单例的。  
加锁加的是this，当前实例对象。当前实例作为锁，容器中是单实例，但是一个项目是一个容器。  
但是如果商品服务有8台机器，那就是8个锁。一个锁同一时间只能放进来一条数据，8个锁，放进来8条数据。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70 1]

## 在本地锁的基础上实现分布式锁 ##

[https://www.bilibili.com/video/BV1np4y1C7Yf?p=158&spm\_id\_from=pageDriver][https_www.bilibili.com_video_BV1np4y1C7Yf_p_158_spm_id_from_pageDriver]  
上面的单体应用的锁已经实现了，要在它的基础上实现分布式锁的话，需要用到nx。  
整体逻辑就是在本地锁的上面再加一层锁。

### 获取分布式锁 ###

比如有8个商品服务，每个服务查询商品前要加锁。这时候需要先去获取到分布式锁。 我们可以通过`redisTemplate.opsForValue().setIfAbsent("lock","111");` 先占锁。  
这个方法比较特殊。 几个服务通过nx的方式存储数据，最终只会有一个成功。  
这个示例可以看上方视频。  
而返回成功的那个，就是获取到分布式的锁了。

### 执行逻辑 ###

获取到锁了之后，就可以通过本地锁，继续执行代码了。  
而没有获取到锁的，可以休眠一下，然后继续调用当前方法获取锁。  
最后，执行完逻辑，删掉当前服务获取到的分布式锁。然后返回数据（删除掉后，其他服务，就可以继续获取到了）。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70 2]

## 没有解锁怎么办（死锁） ##

可以加过期时间  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70 3]  
为了防止加锁和过期时间一起成功，保持原子性，所以这里锁和过期时间一起设置  
![在这里插入图片描述][616231d584554ed7b3ee05125a6c3771.png]

## 如果业务还没执行完，锁已过期怎么办 ##

如果业务逻辑比较长，代码还没执行完毕，锁就过期了。这时候不能直接删锁（因为有可能删的是别人的锁）。  
因为当前线程的锁已经自己过期了，所以删锁的时候要做个判断。 在获取锁的时候，可以放一个uuid或者其他东西。删的时候获取一下锁，如果当前锁的值和放进去的一样，才能删。  
但是，在查当前锁的时候，有可能查的时候还在，但是等这边收到返回结果，执行删除之前，锁其实已经变成别人的锁了。  
所以，这样查询所和删除锁也要保持原子性。  
这里要使用redis + Lua脚本  
参考官方文档：[http://redis.cn/commands/set.html][http_redis.cn_commands_set.html]  
脚本：

if redis.call("get",KEYS[1]) == ARGV[1]
    then
        return redis.call("del",KEYS[1])
    else
        return 0
    end

使用脚本

String redisScript = "if redis.call('get',KEYS[1]) == ARGV[1] then return redis.call('del',KEYS[1]) else return 0 end";
    // 比较：如果redis查询到我们传入的key和value是一致的，那么会执行删除。成功返回1，失败返回0
    redisTemplate.execute(new DefaultRedisScript<>(redisScript, Integer.class), Arrays.asList("lock"), uuid);

## 分布式锁提前过期怎么办？ ##

把事件设置的长一点，然后业务处理完，在final里面执行释放锁  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70 4]

# \#分布式锁 #

缺点：性能比较慢

[https_www.bilibili.com_video_BV1np4y1C7Yf_p_156_spm_id_from_pageDriver]: https://www.bilibili.com/video/BV1np4y1C7Yf?p=156&spm_id_from=pageDriver
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70]: /images/20220829/0ddc6dea150e4953b34c0f670770f541.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70 1]: /images/20220829/6a53be43b499445295d296186026dc16.png
[https_www.bilibili.com_video_BV1np4y1C7Yf_p_158_spm_id_from_pageDriver]: https://www.bilibili.com/video/BV1np4y1C7Yf?p=158&spm_id_from=pageDriver
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70 2]: /images/20220829/972f7664f43c4fd89aadb16637e871d3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70 3]: /images/20220829/ad6d5c0a6e0b4cce945623e1e48852eb.png
[616231d584554ed7b3ee05125a6c3771.png]: /images/20220829/c6a6719f8c8543fa9cf0a651380a679a.png
[http_redis.cn_commands_set.html]: http://redis.cn/commands/set.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3MxNDQxMTAxMjY1_size_16_color_FFFFFF_t_70 4]: /images/20220829/0c0f5940dee64c92a9c6dc1f38b53bb5.png