Springboot利用Redis实现分布式锁
1、利用场景和实现方案：利用场景：本地锁如Lock和Syncronized只能锁住本地进程，在分布式应用中，必要利用分布式锁来更好实现特定的业务。
实现方案：有多种，比如利用mysql、zookeeper、redis，各种方案有其优缺点，利用哪种方式需结合具体业务来选择。下面先容一下利用redis实现分布式锁。
实现方式：如下图所示
https://i-blog.csdnimg.cn/direct/3c65e514e8544596be4011fae2b2e00a.png
具体实现代码：
2.1 利用redisTemplate：
public Map<String,List<Catelog2Vo>> getCatelogJsonFromDbWithRedisLock(){
//使用redis分布式锁，防止缓存击穿
String uuid = UUID.randomUUID().toString();
Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock", uuid,300,TimeUnit.SECONDS);
Map<String, List<Catelog2Vo>>map;
if(lock){
//如果加锁成功，执行业务
System.out.println("获取分布式锁成功...........");
map = getDataFromDb();
try {
} finally {
//执行完业务，要释放锁,使用delete解锁，非原子性，存在缺陷
// 获取值对比+对比成功删除=原子操作
// String lockValue = redisTemplate.opsForValue().get("lock");
// if (uuid.equals(lockValue)) {
// redisTemplate.delete("lock");
// }
// 使用lua脚本解锁，保证原子性
String script = "if redis.call('get',KEYS) == ARGV then return redis.call('del',KEYS) else return 0 end";
Long unlock = redisTemplate.execute(new DefaultRedisScript<Long>(script, Long.class), Arrays.asList("lock"), uuid);
}
return map;
}else{
//加锁失败，重试，执行类似syncronized方法，自旋锁，等待->重试
System.out.println("获取分布式锁失败........等待重试");
//可以添加休眠时间
try {
Thread.sleep(100);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
return this.getCatelogJsonFromDbWithRedisLock();
}
} 2.2 利用Redisson 实现分布式锁：
Redisson 是架设在 Redis 底子上的一个 Java 驻内存数据网格（In-Memory Data Grid） 。 充分的利用了 Redis 键值数据库提供的一系列上风， 基于 Java 实用工具包中常用接口， 为利用者提供了一系列具有分布式特性的常用工具类。 使得原来作为协调单机多线程并发程序的工具包得到了协调分布式多机多线程并发体系的能力， 大大降低了设计和研发大规模分布式体系的难度。 同时结合各富特色的分布式服务， 更进一步简化了分布式环境中程序相互之间的协作。
官方文档： https://github.com/redisson/redisson/wiki/%E7%9B%AE%E5%BD%95
利用方法：
1、maven引入依靠
<!--使用redisson作为所有分布式锁，分布式对象等功能框架-->
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.12.0</version>
</dependency>2、 配置：
// 默认连接地址 127.0.0.1:6379
RedissonClient redisson = Redisson.create();
Config config = new Config(); //redis://127.0.0.1:7181
//可以用"rediss://"来启用 SSL 连接
config.useSingleServer().setAddress("redis://192.168.56.10:6379");
RedissonClient redisson = Redisson.create(config);
3、 利用分布式锁
RLock lock = redisson.getLock("anyLock");// 最常见的使用方法
lock.lock();
// 加锁以后 10 秒钟自动解锁// 无需调用 unlock 方法手动解锁
lock.lock(10, TimeUnit.SECONDS);
// 尝试加锁， 最多等待 100 秒， 上锁以后 10 秒自动解锁
boolean res = lock.tryLock(100,10, TimeUnit.SECONDS);
if (res) {
try {
...
} finally {
lock.unlock();
}
}
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]