redis简单的分布式锁

小咪咪 2022-12-23 06:56 167阅读 0赞

转自：[https://www.cnblogs.com/happy4java/p/11205993.html][https_www.cnblogs.com_happy4java_p_11205993.html]  感谢楼主分享

一、前言

分布式锁，其实原理是就是多台机器，去争抢一个资源，谁争抢成功，那么谁就持有了这把锁，然后去执行后续的业务逻辑，执行完毕后，把锁释放掉。

可以通过多种途径实现分布式锁，例如利用数据库（mysql等）乐观锁和悲观锁；还可通过zookeeper来实现分布式锁，创建顺序节点轮到谁就是谁。本文介绍通过redis来实现分布式锁。

本文使用springboot提供的RedisTemplate来操作redis，这里对使用RedisTemplate来操作redis做了介绍。当然也可以直接使用jedis来操作redis，大家可以参考下jedis的文档，使用上都是大同小异的。

二、实现分布式锁的步骤

第一步：通过redis的setnx方式（不存在则设置）,往redis上设置一个带有过期时间的key，如果设置成功，则获得了分布式锁。这里设置过期时间，是防止在释放锁的时候出现异常导致锁释放不掉。

第二步：执行完业务操作之后，删除该锁。

三、编写工具类

@Component
    public class RedisLockUtils {
    
        @Autowired
        private StringRedisTemplate redisTemplate;
    
        public boolean getLock(String lockId, long millisecond) {
            Boolean success = redisTemplate.opsForValue().setIfAbsent(lockId, "lock",millisecond, TimeUnit.MILLISECONDS);
            return success != null && success;
        }
        public boolean delLock(String lockId) {
            Boolean success = redisTemplate.delete(lockId);
            return success != null && success;
        }
    }

setIfAbsent方法，就是当键不存在的时候，设置，并且该方法可以设置键的过期时间。该方法对应到redis的原生命令就是：

SET lockId content PX millisecond NX

至于设置多少的过期时间合适，这个是没有定论的，需要根据真是的业务场景来衡量。

**释放锁**

当处理完业务逻辑后，需要手动的把锁释放掉。

释放锁的操作比较简单，直接删除之前设置的键即可。其实，基于redis实现分布式锁的方式，在释放锁的时候，是存在释放失败的风险的（比如网路抖动什么的），这也是为什么在设置锁的时候需要设置过期时间的原因，可以防止在出现异常的时候，锁会自动的消失掉。同时，我们也可以增加几次失败之后的重试机制。

四、测试

flag=redisLockUtils.getLock("redisLock",5*60*1000);
                log.info("发送邮件开始获取锁{}",flag);
                if(!flag){
                    return;
                }
                //执行业务
                flag=redisLockUtils.delLock("redisLock");

如果没有得到锁等待则可以写个while循环直到获得为止

五、总结

本文主要介绍了如何使用Java代码（springboot的restTemplate）实现Redis分布式锁，对于加锁和解锁也分别给出了示例代码。其实我们还可以尝试使用Redisson实现分布式锁，这是Redis官方提供的Java组件。请看本人上一篇文章

[https_www.cnblogs.com_happy4java_p_11205993.html]: https://www.cnblogs.com/happy4java/p/11205993.html