Spring Boot整合Redisson实现分布式锁

Szx

December 25, 2023

1637 views

No comments

3509 words

Spring Data

Redisson的分布式锁

解决的问题

并发控制：
- 在分布式系统中，多个节点可能同时操作同一个资源，引起数据不一致。分布式锁确保在任一时刻，只有一个节点可以操作该资源。
数据同步：
- 通过锁机制，可以同步不同节点间对共享资源的访问，保证数据的一致性。

避免死锁和减少阻塞

死锁问题：
- Redisson的分布式锁实现中，如果锁已被其他线程持有，当前线程会等待直到锁被释放。
- Redisson提供了锁的超时机制，可以防止永久等待，从而降低死锁发生的风险。
阻塞问题：
- 分布式锁可能会导致线程阻塞，特别是在高并发环境下。Redisson允许自定义等待和持锁时间，以此减少阻塞时间。
- Redisson还提供了tryLock方法，它可以在无法立即获取锁时返回，从而避免长时间阻塞。

环境准备

添加依赖：

在Spring Boot项目的pom.xml文件中添加Redisson依赖。

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.25.2</version> <!-- 使用最新版本 -->
</dependency>

配置Redisson

配置文件设置：

在application.yml或application.properties中配置Redisson。
示例application.yml配置：

spring:
  redis:
    host: 127.0.0.1 # Redis服务器地址
    port: 6379 # Redis服务器端口
    password: 12345678 # Redis密码，如果没有设置密码，则此项可以省略

使用Redisson

注入RedissonClient：

在Spring Boot应用中，可以直接注入RedissonClient。

/**
 * 自动注入RedissonClient
 */
@Autowired
private RedissonClient redissonClient;

操作Redis数据结构：

使用注入的RedissonClient操作Redis。

// 操作Redis中的Map
@GetMapping("/setValue")
public String setValue() {
     // 获取Redis Map
    RMap<String, String> map = redissonClient.getMap("myMap");
     // 向Map中添加数据
    map.put("key", "value");
    return "Value set";
}

@GetMapping("/getValue")
public String getValue() {
    // 获取Redis Map
    RMap<String, String> map = redissonClient.getMap("myMap");
    // 从Map中获取数据
    return "Value: " + map.get("key");
}

高级特性

分布式服务：

利用Redisson实现分布式锁、同步器等。

@GetMapping("/lock")
public String lockResource() {
    String orderId = "12345"; // 假设这是一个订单号
    RLock lock = redissonClient.getLock("orderLock:" + orderId); // 根据订单号动态生成锁名称
     // 加锁
    lock.lock();
    try {
        // 执行业务操作
    } finally {
        // 释放锁
        lock.unlock();
    }
    return "Resource locked and unlocked";
}

以上是Redisson与Spring Boot整合使用的基本方法和步骤。这种整合方式允许您在Spring Boot应用中轻松地利用Redisson提供的高级特性，如分布式数据结构和服务，特别是在处理分布式锁和并发控制方面。如果您在实践中遇到任何问题或有更多的疑问，欢迎随时提问和探讨。

锁的自动续租（Watchdog）机制

默认行为：
- 当一个服务获取锁之后，Redisson内部的watchdog会自动启动。
- 如果服务持续运行，watchdog会定期（默认每10秒）向Redis发送命令，以维持锁的持有时间。
- 如果锁的持有者服务宕机或无法续租锁（例如因为网络问题），锁会在最后一次成功续租后的30秒内自动释放。
自定义锁过期时间：
- 可以在获取锁时指定锁的过期时间，这会覆盖默认的30秒设置。

示例

以下是获取锁并设置自定义过期时间的示例：

RLock lock = redissonClient.getLock("someLock");
try {
    // 尝试获取锁，最多等待3秒，锁持有最长10秒
    if (lock.tryLock(3, 10, TimeUnit.SECONDS)) {
        try {
            // 执行业务操作
        } finally {
            lock.unlock();
        }
    }
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}