Redisson

1 什么是Redisson
2.SpringBoot整合Redisson
3.使用Redisson实现分布式锁
- 3.1 Redisson是如何解决这两个问题的呢?
- 3.2 Redisson是怎么保证自己加的锁, 自己释放锁?

1 什么是Redisson

Redisson是一个基于Redis的java框架, 用于简化Redis的操作. 它提供了丰富的功能, 包括: 分布式集合、分布式对象、分布式锁、分布式调度器等等

2.SpringBoot整合Redisson

步骤一: 添加依赖

<dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>{redisson-version}</version>
</dependency>

步骤二: 在application.properties文件中配置Redisson连接信息

# Redisson连接信息
spring.redis.redisson.config=classpath:/redisson.yaml

步骤三: 在这个示例中，我们通过redisson.yaml文件配置Redisson连接信息，你可以根据实际情况选择其他方式，如直接在application.properties中配置Redisson的连接信息。
Springboot-Redisson - 1.简介和配置

# 单一 Redis 服务器模式
singleServerConfig:# Redis 服务器的地址address: "redis://127.0.0.1:6379"# 连接池的大小connectionPoolSize: 64# Redis 服务器的密码password: "your_password"# Redis 数据库索引database: 0# 客户端名称clientName: "your_client_name"# 超时时间，单位为毫秒timeout: 3000# Redis 命令失败重试次数retryAttempts: 3# 两次命令之间重试的时间间隔，单位为毫秒retryInterval: 1500# 发布和订阅的连接的最小数量subscriptionConnectionMinimumIdleSize: 1# 发布和订阅的连接池的大小subscriptionConnectionPoolSize: 50# 当前处理 Redis 命令的线程共享的联接connectionMinimumIdleSize: 10# 集群模式的配置 (需要注释或删除 singleServerConfig 当使用此模式)
#clusterServersConfig:
#  scanInterval: 2000
#  slaveConnectionPoolSize: 64
#  slaveConnectionMinimumIdleSize: 24
#  masterConnectionPoolSize: 64
#  masterConnectionMinimumIdleSize: 24
#  readMode: "SLAVE"
#  nodeAddresses:
#    - "redis://127.0.0.1:7001"
#    - "redis://127.0.0.1:7002"
#    - "redis://127.0.0.1:7003"
#  password: "your_password"# 其他模式，如 sentinel, masterSlave, replicated 可以在这里配置，但确保只有一个模式处于未注释状态# 线程工厂配置
threads: 16
nettyThreads: 32# 编解码器配置，默认是 Jackson
codec: !<org.redisson.codec.JsonJacksonCodec> {}# 传输模式，默认是 NIO
transportMode: "NIO"

步骤四: 注入RedissonClient, 使用RedissonClient

@Autowired
private RedissonClient redissonClient;

3.使用Redisson实现分布式锁

1小时掌握Redisson实现Redis分布式锁以及Redlock分布式锁

@Service
public class RedissonService {@Autowiredprivate RedissonClient redissonClient;public void lock() {RLock lock = redissonClient.getLock("lock");try {if (lock.tryLock()) {   // 尝试获取锁// 执行业务逻辑}} finally {lock.unlock();  // 释放锁}}}

这个代码比之前使用Redis实现分布式锁更简单, 也解决了过期时间设置、原子性等等这些问题, 其原理图如下:

在这里插入图片描述

使用Redis实现分布式锁, 主要存在两个问题很难解决

锁的过期时间很难设置
- 设置的太短吧, 可能会导致在执行耗时长的业务时, 提前释放锁
- 设置的太长吧, 如果服务宕机了, 锁的生命周期就很长, 即使服务重启好了, 也要等锁释放了才能执行业务
为了保证"自己加的锁, 自己释放", 就需要进行两步操作, 先根据value判断是不是自己加的锁, 然后释放锁, 这个过程不是原子性的