整合redission

### 整合 Redisson 分布式锁 Java Redis 客户端 #### Maven 依赖配置 要在项目中使用 Redisson，首先需要引入相应的 Maven 依赖： ```xml <dependency> <groupId>org.redisson</groupId> <artifactId>redisson-spring-boot-starter</artifactId> <version>3.17.6</version> </dependency> ``` 此版本兼容最新的 Spring Boot 版本并提供开箱即用的支持。 #### 配置文件设置 接着，在 `application.yml` 或者 `application.properties` 文件中添加 Redisson 的连接配置信息: 对于 YAML 格式的配置文件: ```yaml spring: redis: host: localhost port: 6379 data: redisson: config: classpath:redisson.yaml ``` 对应的 `redisson.yaml` 文件内容如下所示： ```yaml singleServerConfig: address: "redis://localhost:6379" threads: 0 nettyThreads: 0 codec: !<org.redisson.codec.JsonJacksonCodec> {} watcherMaxIdleInterval: 0 ``` 上述配置指定了单节点模式下的 Redis 地址以及其他必要的参数选项[^1]。 #### 使用 Redisson 实现分布式锁 下面是一个简单的例子来展示如何利用 Redisson 创建和管理分布式锁对象： ```java 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 DistributedLockService { @Autowired private RedissonClient redissonClient; public void performTaskWithLock() { RLock lock = redissonClient.getLock("myDistributedLock"); try { boolean isLocked = lock.tryLock(10, TimeUnit.SECONDS); if (isLocked) { System.out.println(Thread.currentThread().getName() + ": Acquired the distributed lock."); // 执行受保护的操作 Thread.sleep(5000); // Simulate work being done. System.out.println(Thread.currentThread().getName() + ": Released the distributed lock."); } else { System.err.println(Thread.currentThread().getName() + ": Failed to acquire the distributed lock."); } } catch (InterruptedException e) { throw new RuntimeException(e); } finally { if (lock.isHeldByCurrentThread()) { lock.unlock(); } } } } ``` 这段代码展示了怎样通过尝试获取名为 `"myDistributedLock"` 的锁来进行某些操作，并确保即使发生异常也能安全释放所持有的锁实例。