springboot集成redission

Spring Boot 集成 Redis Sentinel 模式主要是为了实现高可用的分布式 Redis 存储。Sentinel 是 Redis 官方提供的一个用于监控集群健康状态和选举主节点的工具。以下是集成 Spring Boot 和 Redis Sentinel 的一般步骤： 1. 添加依赖：在你的 Maven 或者 Gradle 项目中添加 Spring Data Redis 和 Spring Cloud Config 的 Sentinel 版本依赖。 ```xml <!-- Maven --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>sentinel-spring-boot-starter</artifactId> </dependency> // 或者 Gradle implementation 'org.springframework.boot:spring-boot-starter-data-redis' implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-client' implementation 'com.alibaba:sentinel-spring-boot-starter' ``` 2. 配置 Sentinel 信息：在 `application.properties` 或者 `application.yml` 中，添加 Sentinel 的地址、集群名、服务实例名等信息。 ```yaml spring.redis.sentinel.master=your-cluster-name spring.redis.sentinel.nodes=senode1:26379,senode2:26379,etc. spring.redis.sentinel.service-instance-name=your-service-instance-name ``` 3. 配置客户端：启用 Sentinel 配置，这会自动切换到 Sentinel 选择的主节点。 ```yaml spring.redis.sentinel.use-strict-hostname=true spring.redis.pool.max-active=8 ``` 4. 事务管理：如果需要支持 Redis 事务，记得启用 Spring Data Redis 的事务支持： ```yaml spring.redis.transaction.type=RETRY_ON_FAILURE ``` 5. Eureka 配置：如果你使用的是 Netflix Eureka 作为服务注册中心，确保它也配置了 Sentinel 集群地址。 6. 高级配置：可以根据实际需求调整连接池参数、超时时间等。

### Spring Boot 整合 Redisson 实现分布式锁 #### 1. 添加依赖项 为了在 Spring Boot 中使用 Redisson 来实现分布式锁，首先需要引入相应的 Maven 或 Gradle 依赖。 对于 Maven 用户，在 `pom.xml` 文件中加入如下配置： ```xml <dependency> <groupId>org.redisson</groupId> <artifactId>redisson-spring-boot-starter</artifactId> <version>3.17.6</version> </dependency> ``` Gradle 用户可以在 `build.gradle` 文件里添加下面的内容: ```groovy implementation 'org.redisson:redisson-spring-boot-starter:3.17.6' ``` #### 2. 配置 Redisson 客户端连接参数 创建名为 `application.yml` 的配置文件，并按照以下方式定义 Redisson 连接属性： ```yaml spring: redisson: config: classpath:redisson.yaml ``` 接着在同一目录下新建 `redisson.yaml` 文件用于指定具体的 Redis 地址和其他选项： ```yaml singleServerConfig: address: "redis://127.0.0.1:6379" threads: 0 nettyThreads: 0 codec: !<org.redisson.codec.JsonJacksonCodec> {} watcherExecutorThreadPoolSize: 0 ``` 以上设置指定了单服务器模式下的 Redis 访问地址以及 JSON 编解码器的选择[^1]。 #### 3. 使用 Redisson 分布式锁 通过注入 `RedissonClient` 对象并调用其提供的 API 方法即可轻松获取和释放锁实例。这里给出一段简单的 Java 示例代码展示如何操作 Lock 接口： ```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 doSomethingWithDistributedLock() { RLock lock = redissonClient.getLock("my-distributed-lock"); try { boolean isLocked = lock.tryLock(10, TimeUnit.SECONDS); if (isLocked) { System.out.println(Thread.currentThread().getName() + ": Acquired the distributed lock."); // 执行受保护的操作 Thread.sleep(5000); // Simulate some work being done. System.out.println(Thread.currentThread().getName() + ": Released the distributed lock after completing task."); } else { System.out.println(Thread.currentThread().getName() + ": Failed to acquire the distributed lock."); } } catch (InterruptedException e) { throw new RuntimeException(e); } finally { if (lock.isHeldByCurrentThread()) { lock.unlock(); } } } } ``` 这段程序展示了怎样安全地尝试获得一个带有超时机制的分布式锁，并确保即使发生异常也能正确解锁[^2]。 #### 4. 测试功能 编写单元测试验证上述逻辑是否正常工作。可以通过启动多个线程模拟不同客户端竞争同一把锁的情况来进行压力测试。 ```java @SpringBootTest(classes = Application.class) class DistributedLockTest { @Autowired private DistributedLockService service; @Test void testConcurrentAccessControlledByDistributedLocks() throws InterruptedException { ExecutorService executor = Executors.newFixedThreadPool(10); List<Future<?>> futures = IntStream.rangeClosed(1, 10).boxed() .map(i -> executor.submit(service::doSomethingWithDistributedLock)) .collect(Collectors.toList()); for (Future<?> future : futures) { future.get(); // Wait until all threads finish their tasks. } executor.shutdownNow(); } } ``` 此段 JUnit 测试会开启十个线程同时请求锁定相同名称的资源，以此检验系统的健壮性和可靠性[^3]。