Spring Boot 3 整合 Redisson 实现分布式锁

这篇博客详细介绍了如何在 Spring Boot 3 项目中使用 Redisson 实现分布式锁，包括依赖引入、Redis 配置、Redisson 配置、实现锁服务，以及测试控制器。希望对你有帮助！

介绍

在分布式系统中，多个服务实例可能会同时访问共享资源，导致数据不一致或竞争条件。使用分布式锁可以有效地解决这些问题。本文将介绍如何在 Spring Boot 3 项目中整合 Redisson 以实现分布式锁。

前提条件

Java Development Kit (JDK) 17 或更高版本
Maven 构建工具
Redis 服务器

引入依赖

首先，在你的 pom.xml 文件中引入 Redisson 的依赖：

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

配置 Redis

在 application.yml 文件中配置 Redis 的连接信息：

spring:data:redis:database: 0host: 127.0.0.1port: 6379password: 123456  # 如果没有密码，可以去掉这一行 去掉这一行

创建 RedisLockService 类

创建一个 RedisLockService 类来管理分布式锁的获取和释放：

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.concurrent.TimeUnit;@Service
public class RedisLockService {@Autowiredprivate RedissonClient redissonClient;/*** 获取锁的方法* @param lockKey 锁键* @param waitTime 等待时间* @param leaseTime 租约时间* @return 是否获取到锁*/public boolean acquireLock(String lockKey, long waitTime, long leaseTime) {// 获取指定锁键对应的 Redisson 锁RLock lock = redissonClient.getLock(lockKey);try {// 尝试以指定等待时间和租约时间获取锁return lock.tryLock(waitTime, leaseTime, TimeUnit.SECONDS);} catch (InterruptedException e) {// 当前线程中断Thread.currentThread().interrupt();// 返回获取锁失败return false;}}/*** 释放锁的方法* @param lockKey 锁键*/public void releaseLock(String lockKey) {// 获取指定锁键对应的 Redisson 锁RLock lock = redissonClient.getLock(lockKey);// 如果当前线程持有该锁if (lock.isHeldByCurrentThread()) {// 释放锁lock.unlock();}}}

创建控制器

创建一个控制器来测试分布式锁的功能：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class LockController {@Autowiredprivate RedisLockService redisLockService;@GetMapping("/doSomething")public String doSomething() {String lockKey = "myLock";boolean isLockAcquired = redisLockService.acquireLock(lockKey, 5, 10);if (isLockAcquired) {try {System.out.println("获取到锁！");// 在这里执行你的业务逻辑Thread.sleep(5000); // 模拟业务处理时间return "业务处理完成";} catch (InterruptedException e) {Thread.currentThread().interrupt();return "业务处理失败";} finally {redisLockService.releaseLock(lockKey);System.out.println("锁已释放！");}} else {System.out.println("未能获取到锁！");return "业务处理失败";}}
}