当前位置：首页 > news >正文

Redisson实现分布式锁

news 来源：原创 2024/7/3 14:58:23

在Spring Cloud项目中使用Redisson实现分布式锁可以帮助你在分布式系统中安全地管理共享资源。以下是一个详细的步骤，包括配置Redisson、集成到Spring Cloud项目中，以及使用分布式锁的示例代码。

1. 添加依赖

在你的Spring Cloud项目的pom.xml文件中添加Redisson的依赖：

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

2. 配置Redisson

在Spring Cloud项目的application.yml文件中配置Redisson：

spring:redis:host: localhostport: 6379redisson:singleServerConfig:address: "redis://${spring.redis.host}:${spring.redis.port}"password: nulldatabase: 0

3. 配置Redisson客户端

创建一个Redisson配置类：

import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.spring.starter.RedissonAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RedissonConfig {@Beanpublic RedissonClient redissonClient() {Config config = new Config();config.useSingleServer().setAddress("redis://" + spring.redis.host + ":" + spring.redis.port);return Redisson.create(config);}
}

4. 使用Redisson分布式锁

在需要使用分布式锁的地方，可以通过注入RedissonClient来获取锁并使用它。以下是一个示例：

示例服务类

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 DistributedLockService {@Autowiredprivate RedissonClient redissonClient;public void executeWithLock() {RLock lock = redissonClient.getLock("myDistributedLock");boolean isLocked = false;try {// 尝试加锁，等待时间为10秒，上锁后10秒自动解锁isLocked = lock.tryLock(10, 10, TimeUnit.SECONDS);if (isLocked) {// 执行需要同步的操作System.out.println("Lock acquired, executing protected code");// 模拟业务逻辑处理Thread.sleep(5000);} else {System.out.println("Unable to acquire lock");}} catch (InterruptedException e) {e.printStackTrace();} finally {if (isLocked) {lock.unlock();System.out.println("Lock released");}}}
}

示例控制器类

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 DistributedLockService distributedLockService;@GetMapping("/executeWithLock")public String executeWithLock() {distributedLockService.executeWithLock();return "Lock execution finished";}
}