前言
分布式锁，实在原理是就是多台机械，去争抢一个资源，谁争抢乐成，那么谁就持有了这把锁，然后去执行后续的营业逻辑，执行完毕后，把锁释放掉。
可以通过多种途径实现分布式锁，例如行使数据库(mysql等)，插入一条纪录(唯一索引)，谁插入乐成，谁就持有锁；还可通过zookeeper来实现分布式锁，谁建立节点乐成，谁就持有锁。本文先容通过redis来实现分布式锁。
本文使用springboot提供的RedisTemplate来操作redis。
实现分布式锁的步骤
第一步：通过redis的setnx方式(不存在则设置),往redis上设置一个带有过时时间的key，若是设置乐成，则获得了分布式锁。这里设置过时时间，是防止在释放锁的时刻出现异常导致锁释放不掉。
第二步：执行完营业操作之后，删除该锁。
实现
新建一个DistributedLock.class，注入StringRedisTemplate。
@Component public class DistributedLock { @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; }
setIfAbsent方式，就是当键不存在的时刻，设置，而且该方式可以设置键的过时时间。该方式对应到redis的原生下令就是：
SET lockId content PX millisecond NX
至于设置若干的过时时间合适，这个是没有定论的，需要凭据真是的营业场景来权衡。
释放锁
当处理完营业逻辑后，需要手动的把锁释放掉。
public void releaseLock(String lockId) { redisTemplate.delete(lockId); }
释放锁的操作比较简单，直接删除之前设置的键即可。实在，基于redis实现分布式锁的方式，在释放锁的时刻，是存在释放失败的风险的(好比网路发抖什么的)，这也是为什么在设置锁的时刻需要设置过时时间的缘故原由，可以防止在出现异常的时刻，锁会自动的消失掉。同时，我们也可以增添几回失败之后的重试机制。
测试
新建一个BusinessTask.java，代码如下：
@Component public class BusinessTask { private final static String LOCK_ID = "happyjava"; @Autowired DistributedLock distributedLock; @Scheduled(cron = "0/10 * * * * ? ") public void doSomething() { boolean lock = distributedLock.getLock(LOCK_ID, 10 * 1000); if (lock) { System.out.println("执行义务"); distributedLock.releaseLock(LOCK_ID); } else { System.out.println("没有抢到锁"); } } }
这里使用了springboot的Scheduled注解来实现准时义务，该cron表达式的意思是每10秒钟，执行一次义务，然后我们启动两次该项目，考察一段时间执行效果：
第一个springboot义务：
第二个springboot义务：
两个义务在交替的执行义务，证明了统一时刻只有一个应用持有了锁。
总结
本文主要先容了若何使用Java代码(springboot的restTemplate)实现Redis分布式锁，对于加锁和解锁也划分给出了示例代码。实在我们还可以实验使用Redisson实现分布式锁，这是Redis官方提供的Java组件，这个后续再先容吧。
原文链接：https://www.cnblogs.com/EarlyBridVic/p/12393827.html
本站声明:网站内容来源于网络,若有侵权,请联系我们,我们将及时处理。