Spring Boot 3实战：Redisson分布式锁详解与代码示例

Spring Boot 3实战：Redisson分布式锁详解与代码示例

在分布式系统中，数据一致性是一个核心挑战。当多个节点需要访问和修改共享资源时，如何确保操作的顺序性和原子性？这就需要用到分布式锁。Redisson作为Redis的Java客户端，提供了强大而易用的分布式锁功能，让开发者能够轻松应对这一挑战。

Redisson是一个基于Redis的Java客户端，提供了丰富的分布式特性，包括分布式锁、队列、发布/订阅等功能。其分布式锁功能具有以下优势：

• 可重入性：支持同一个节点的线程重复获取锁
• 锁续期：自动延长锁的有效期，防止锁过期
• 看门狗机制：默认在锁快要过期时自动续期到30秒
• 公平锁支持：保证请求锁的先后顺序

Redisson的分布式锁（RLock）基于Redis实现，使用了以下关键技术：

1. Pub/Sub机制：当锁被占用时，其他请求锁的线程会订阅一个特定的频道。锁释放时，会发布消息通知订阅者重新尝试获取锁。

2. Lua脚本：保证锁的操作在Redis中具有原子性，防止竞态条件。

3. 看门狗机制：默认情况下，如果业务执行时间超过锁的有效期，Redisson会自动续期锁，避免死锁。

接下来，我们将在Spring Boot 3项目中实现Redisson分布式锁。

1. 项目搭建

使用Spring Initializr创建一个名为redisson-lock-demo的Spring Boot项目。

2. 添加依赖

在pom.xml中添加以下依赖：

<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.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.40.2</version>
</dependency>

3. 配置Redis连接

在application.yml中添加Redis配置：

spring:
  data:
    redis:
      host: 127.0.0.1
      port: 6379
      password: your_password

4. 创建Redisson配置类

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;

@Configuration
public class RedissonConfig {

    @Value("${spring.redis.host}")
    private String redisHost;

    @Value("${spring.redis.port}")
    private int redisPort;

    @Value("${spring.redis.password}")
    private String password;

    @Bean
    public RedissonClient redissonClient() {
        Config config = new Config();
        config.useSingleServer()
                .setAddress("redis://" + redisHost + ":" + redisPort)
                .setPassword(password);
        return Redisson.create(config);
    }
}

5. 实现锁服务

创建一个锁服务类LockService：

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class LockService {

    @Autowired
    private RedissonClient redissonClient;

    public void doBusinessWithLock(String lockName) {
        RLock lock = redissonClient.getLock(lockName);
        try {
            // 尝试加锁，最多等待10秒，上锁后30秒自动解锁
            boolean isLocked = lock.tryLock(10, 30, TimeUnit.SECONDS);
            if (isLocked) {
                // 执行业务逻辑
                System.out.println("Lock acquired, handling business logic.");
                Thread.sleep(2000);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放锁
            lock.unlock();
            System.out.println("Lock released.");
        }
    }
}

6. 测试控制器

创建一个测试控制器LockController：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/lock")
public class LockController {

    @Autowired
    private LockService lockService;

    @GetMapping("/test")
    public String testLock() {
        lockService.doBusinessWithLock("testLock");
        return "Lock test completed.";
    }
}

启动应用，访问http://localhost:8080/lock/test，可以看到控制台输出锁的获取和释放日志。

1. 锁的释放：确保在finally块中释放锁，防止资源泄露。
2. 锁超时时间：设置合理的锁超时时间（leaseTime），避免死锁。
3. 性能优化：使用连接池管理Redis连接，提高性能。

Redisson分布式锁为开发者提供了一个强大而易用的工具，用于解决分布式环境下的并发控制问题。通过本教程，你已经掌握了在Spring Boot 3中使用Redisson实现分布式锁的基本方法。无论是秒杀活动、优惠券领取，还是接口幂等性校验，Redisson都能帮助你轻松应对高并发场景下的数据一致性挑战。