一、概述
什么是分布式锁
在单机环境中，一般在多并发多线程场景下，出现多个线程去抢占一个资源，这个时候会出现线程同步问题，造成执行的结果没有达到预期。我们会用线程间加锁的方式，比如synchronized,lock,volatile,以及JVM并发包中提供的其他工具类去处理此问题。
但是随着技术的发展，分布式系统的出现，各个应用服务都部署在不同节点，由各自的JVM去操控，资源已经不是在 线程 之间的共享，而是变成了 进程 之间的共享，以上解决线程同步问题的办法已经无法满足。
因此，引入了分布式锁的概念。
分布式锁，既在分布式部署的环境下，通过在外部设置锁,让客户端之间互斥，当多应用发生对共享资源的抢占时，该资源同一时刻只能一个应用访问，从而保证数据一致性
分布式锁满足条件
- 互斥性：即同一时刻只能一个客户端获得锁，其他客户端必须等待获取锁的客户端主动释放锁或锁超时后再次对资源进行抢占。
- 避免死锁：这把锁在一段有限的时间之后，一定会被释放（正常释放或异常释放）,否则当一个客户端线程获得锁后没有主动释放，也没有设置超时时间，中途宕机等原因，其他线程就会一直获取不了锁
- 具备可重入特性：同一个线程可重复可递归调用的锁，在外层使用锁之后，在内层仍然可以使用，如果没有可重入锁的支持，在第二次尝试获得锁时将会进入死锁状态。
- 高可用：获取或释放锁的机制必须高可用且性能佳
分布式锁的重要性不言而喻，原因不在赘述，每一位菜鸟都有理由掌握它。提到分布式锁，解决方案更是乌泱乌泱的，如：
- 直接通过关系型数据库实现
- 基于Redission实现
- 基于Apache Curator实现
- …
本文暂时先介绍一种，基于Redission实现的方式
二、环境搭建
有一个简单的SpringBoot环境即可，便于测试：
依赖
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.6.5</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
配置
server:
port: 7077
spring:
redis:
host: 192.144.228.170
database: 0
启动及配置类
package com.ideax.distributed;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
@SpringBootApplication
public class DistributedApplication {
public static void main(String[] args) {
SpringApplication.run(DistributedApplication.class,args);
}
@Bean
public Redisson redisson(){
// 单机模式
Config config = new Config();
config.useSingleServer().setAddress("redis://192.144.228.170:6379").setDatabase(0);
return (Redisson) Redisson.create(config);
}
}
三、模拟一个库存扣减的场景
package com.ideax.distributed.controller;
import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Objects;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
@RequestMapping("/inventory")
@RestController
public class InventoryController {
@Autowired
private StringRedisTemplate redisTemplate;
@Autowired
private Redisson redisson;
@GetMapping("/minus")
public ResponseEntity<String> minusInventory(){
// 分布式高并发场景下，这样肯定不行
synchronized (this) {
int stock = Integer.parseInt(Objects.requireNonNull(redisTemplate.opsForValue().get("stock")));
if (stock > 0) {
int currentStock = stock - 1;
redisTemplate.opsForValue().set("stock", currentStock + "");
System.out.println("扣减成功，当前库存为" + currentStock);
} else {
System.out.println("库存不足，扣减失败！");
}
}
return ResponseEntity.ok("success");
}
@GetMapping("/minus1")
public ResponseEntity<String> minusInventory1(){
// 相当于setnx命令
String lockKey = "lockKey";
// 务必加try-finally，因为如果服务挂了，锁还得释放
String clientId = UUID.randomUUID().toString();
try {
// 相当于加锁
// Boolean absent = redisTemplate.opsForValue().setIfAbsent(lockKey, "zxs");
// 上下两行不能分开写，如果这中间报异常了，依然出现死锁
// redisTemplate.expire(lockKey,10, TimeUnit.SECONDS);
Boolean absent = redisTemplate.opsForValue().setIfAbsent(lockKey, clientId,30,TimeUnit.SECONDS);
if (!absent) {
return ResponseEntity.notFound().build();
}
int stock = Integer.parseInt(Objects.requireNonNull(redisTemplate.opsForValue().get("stock")));
if (stock > 0) {
int currentStock = stock - 1;
redisTemplate.opsForValue().set("stock", currentStock + "");
System.out.println("扣减成功，当前库存为" + currentStock);
} else {
System.out.println("库存不足，扣减失败！");
}
} finally {
// 如果系统挂了呢，finally也不起作用了，因此还需要设置超时时间
// 释放锁之前，判断一下，务必释放的锁是自己持有的锁
if (clientId.equals(redisTemplate.opsForValue().get(lockKey))) {
redisTemplate.delete(lockKey);
}
}
return ResponseEntity.ok("success");
}
@GetMapping("/minus2")
public ResponseEntity<String> minusInventory2(){
// redisson解决方案
String lockKey = "lockKey";
RLock lock = redisson.getLock(lockKey);
try {
// 加锁
lock.lock();
int stock = Integer.parseInt(Objects.requireNonNull(redisTemplate.opsForValue().get("stock")));
if (stock > 0) {
int currentStock = stock - 1;
redisTemplate.opsForValue().set("stock", currentStock + "");
System.out.println("扣减成功，当前库存为" + currentStock);
} else {
System.out.println("库存不足，扣减失败！");
}
} finally {
// 释放锁
lock.unlock();
}
return ResponseEntity.ok("success");
}
}
四、总结
- @GetMapping("/minus") public ResponseEntity<String> minusInventory()：初步实现方式，在单线程环境下可以使用，但是在分布式高并发场景下，毫无疑问是肯定不行的
- @GetMapping("/minus1") public ResponseEntity<String> minusInventory1()：进阶实现方式，在一般的不拘小节的公司，勉强够用，但是你需要考虑一下，锁过期时间，到底设置多少才能完美呢？
- @GetMapping("/minus2") public ResponseEntity<String> minusInventory2()：终极实现方式，redisson帮我们解决了上面的实现方式出现的尴尬情况
到此这篇关于SpringBoot基于Redis的分布式锁实现的文章就介绍到这了,更多相关SpringBoot基于Redis的分布式锁内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！
