redis分布式锁之redisson可重入锁_xr不经意_redisson可重入锁

网络 02-07 7708

1.上篇讲了java里使用setNX实现redis分布式锁，可是这种方法还是有很多弊端的，追求完美的做法可以使用redisson来实现分布式锁，如下:

2.Redisson 是 java 的 Redis 客户端之一，是 Redis 官网推荐的 java 语言实现分布式锁的项目。

它提供了一些 api 方便操作 Redis。因为本文主要以锁为主，所以接下来我们主要关注锁相关的类，以下是 Redisson 中提供的多样化的锁：

可重入锁（Reentrant Lock）公平锁（Fair Lock）联锁（MultiLock）红锁（RedLock）读写锁（ReadWriteLock）信号量（Semaphore）

3.本文中 Redisson 分布式锁的实现是基于 RLock 接口，而 RLock 锁接口实现源码主要是 RedissonLock 这个类，而源码中加锁、释放锁等操作都是使用 Lua 脚本来完成的，并且封装的非常完善，开箱即用。

接下来主要以 Redisson 实现 RLock (用的最多)可重入锁为主。

4.Maven 依赖 pom.xml，Redisson、MySQL 等相关依赖。

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.2.2.RELEASE</version> <relativePath/>  </parent> <groupId>com.example</groupId> <artifactId>redis-redlock</artifactId> <version>0.0.1-SNAPSHOT</version> <name>redis-redlock</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency>  <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>  <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>1.18.10</version> </dependency>  <dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.11.1</version> </dependency>  <dependency> <groupId>com.google.code.gson</groupId> <artifactId>gson</artifactId> <version>2.8.6</version> </dependency>  <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.48</version> </dependency>  <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.20</version> </dependency>  <dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>4.6.8</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>

5.application.yml 配置文件

server: port: 8888 servlet: context-path: / spring: # 数据源 datasource: url: jdbc:mysql://127.0.0.1:3306/redisson_demo?useUnicode=true&characterEncoding=utf-8&useSSL=false username: xxxx password: xxxx type: com.alibaba.druid.pool.DruidDataSource driverClassName: com.mysql.jdbc.Driver logSlowSql: true redis: password: xxxx clusters: 10.211.55.4:6379, 10.211.55.4:6380, 10.211.55.4:6381 lettuce: pool: min-idle: 0 max-idle: 8 max-active: 20 # 日志 logging: # 输出级别 level: root: info file: # 指定路径 path: redis-logs # 最大保存天数 max-history: 7 # 每个文件最大大小 max-size: 5MB

6.Redisson配置类

import java.io.IOException; import org.redisson.Redisson; import org.redisson.api.RedissonClient; import org.redisson.config.Config; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * redisson配置 */ @Configuration public class RedissonManager { @Value("${spring.redis.clusters}") private String cluster; @Value("${spring.redis.password}") private String password; @Bean public RedissonClient getRedisson(){ String[] nodes = cluster.split(","); //redisson版本是3.5，集群的ip前面要加上“redis://”，不然会报错，3.2版本可不加 List<String> collect = Stream.of(nodes).map(x->"redis://"+x).collect(Collectors.toList()); Config config = new Config(); config.setThread(4); config.setNettyThreads(4); config.useClusterServers() //这是用的集群server .setScanInterval(2000) //设置集群状态扫描时间 .addNodeAddress(collect) .setPassword(password); //可通过打印redisson.getConfig().toJSON().toString()来检测是否配置成功 return Redisson.create(config); } }

7.加锁实现

@Slf4j @Service @Transactional public class OrderServerImpl implements OrderServer { @Resource private RedissonClient redissonClient; @Override @Transactional(rollbackFor = Exception.class) public boolean createOrder(String userId, String productId) { /** 加锁 **/ RLock lock = redissonClient.getLock("stock:" + productId); try { if(!lock.tryLock(10,30, TimeUnit.SECONDS)){ throw new RuntimeException("获取锁失败"); } 　　　　　　　/** 减库存操作 **/ return true; } catch (Exception ex) { log.error("下单失败", ex); } finally { if(lock.isHeldByCurrentThread()){ lock.unlock(); } } return false; } }

8.lock() 方法

RLock lock = redissonClient.getLock("xxx"); /*最常见的使用方法*/ lock.lock(); /*支持过期解锁，30秒之后自动释放锁，无须调用unlock方法手动解锁*/ lock.lock(30, TimeUnit.SECONDS);

9.tryLock() 方法

RLock lock = redissonClient.getLock("xxx"); /*尝试加锁，最多等待10秒，上锁以后10秒自动解锁，返回true表示加锁成功*/ if(lock.tryLock(10,10, TimeUnit.SECONDS)){ xxx }

10.RedLock 中的方法

RLock 本身继承自 Lock 接口，如下分为两部分展示：

public interface RLock extends Lock, RLockAsync { //----------------------Lock接口方法----------------------- /** * 加锁锁的有效期默认30秒 */ void lock(); /** * tryLock()方法是有返回值的，它表示用来尝试获取锁，如果获取成功，则返回true，如果获取失败（即锁已被其他线程获取），则返回false . */ boolean tryLock(); /** * tryLock(long time, TimeUnit unit)方法和tryLock()方法是类似的，只不过区别在于这个方法在拿不到锁时会等待一定的时间， * 在时间期限之内如果还拿不到锁，就返回false。如果如果一开始拿到锁或者在等待期间内拿到了锁，则返回true。 * * @param time 等待时间 * @param unit 时间单位小时、分、秒、毫秒等 */ boolean tryLock(long time, TimeUnit unit) throws InterruptedException; /** * 解锁 */ void unlock(); /** * 中断锁表示该锁可以被中断假如A和B同时调这个方法，A获取锁，B为获取锁，那么B线程可以通过 * Thread.currentThread().interrupt(); 方法真正中断该线程 */ void lockInterruptibly(); //----------------------RLock接口方法----------------------- /** * 加锁上面是默认30秒这里可以手动设置锁的有效时间 * * @param leaseTime 锁有效时间 * @param unit 时间单位小时、分、秒、毫秒等 */ void lock(long leaseTime, TimeUnit unit); /** * 这里比上面多一个参数，多添加一个锁的有效时间 * * @param waitTime 等待时间 * @param leaseTime 锁有效时间 * @param unit 时间单位小时、分、秒、毫秒等 */ boolean tryLock(long waitTime, long leaseTime, TimeUnit unit) throws InterruptedException; /** * 检验该锁是否被线程使用，如果被使用返回True */ boolean isLocked(); /** * 检查当前线程是否获得此锁（这个和上面的区别就是该方法可以判断是否当前线程获得此锁，而不是此锁是否被线程占有） * 这个比上面那个实用 */ boolean isHeldByCurrentThread(); /** * 中断锁和上面中断锁差不多，只是这里如果获得锁成功,添加锁的有效时间 * @param leaseTime 锁有效时间 * @param unit 时间单位小时、分、秒、毫秒等 */ void lockInterruptibly(long leaseTime, TimeUnit unit); }

下一篇锁续期