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

【Redis实践篇】使用Redisson 优雅实现项目实践过程中的5种场景

news 2025/7/9 2:08:00

文章目录

1.前言
2.使用方式
- 1. 添加Redisson依赖：
- 2. 配置Redis连接信息
- 3. 使用场景
- - 3.1. 分布式锁
  - 3.2. 限流器（Rate Limiter）
  - 3.3. 可过期的对象（Expirable Object）
  - 3.4. 信号量（Semaphore）
  - 3.5. 分布式调度器（Distributed Scheduler）
5. 源码地址
6. Redis从入门到精通系列文章
7.参考文档

1.前言

Redisson是一个基于Redis的分布式Java对象和数据结构库，它提供了丰富的功能和易于使用的API，使开发人员能够轻松地在分布式环境中操作和管理数据。

作为一个分布式对象和数据结构库，Redisson提供了许多常见的数据结构和算法的实现，包括通用对象桶、二进制流、地理空间对象桶、BitSet、原子长整型、原子双精度浮点数、话题（订阅分发）、布隆过滤器和基数估计算法。这些数据结构和算法为开发人员提供了处理分布式数据的工具，从而简化了复杂性，提高了效率。简直就是一个Redis的最佳实践框架和最牛X的Redis客户端工具宝箱，基本上覆盖了所有场景。

通过Redisson，开发人员可以使用简单而一致的API来存储和检索对象，处理二进制数据，管理地理位置信息，操作位集合，进行原子操作，进行发布-订阅消息传递，实现布隆过滤器和基数估计等功能。Redisson还提供了许多附加功能，如分布式锁、分布式信号量、分布式队列和分布式限流器等，进一步增强了分布式应用的能力。

Redisson的设计目标是提供高性能、可扩展和可靠的分布式数据操作解决方案。它与Redis数据库紧密集成，并利用Redis的特性来实现分布式对象和数据结构的存储和管理。Redisson还支持与Spring框架的无缝集成，使开发人员能够更方便地在Spring应用程序中使用Redisson功能。

所以我们本篇文章了解一下Redisson 在项目实践中最常用的5种场景，分别搞了一个示例方便大家理解。
在这里插入图片描述

2.使用方式

1. 添加Redisson依赖：

在Spring Boot项目的pom.xml文件中添加Redisson的依赖。

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

2. 配置Redis连接信息

在Spring Boot项目的application.properties或application.yml文件中配置Redis连接信息，包括主机地址、端口、密码等。例如：

spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=

3. 使用场景

3.1. 分布式锁

例如，你可以在Spring Boot的Service类中注入RedissonClient并使用它进行操作：

import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class MyService {@Autowiredprivate RedissonClient redissonClient;public void myMethod() {// 获取分布式锁RLock lock = redissonClient.getLock("myLock");try {// 尝试加锁，如果加锁成功，则执行加锁后的逻辑if (lock.tryLock()) {// 执行加锁后的逻辑// ...}} finally {// 释放锁lock.unlock();}}}

3.2. 限流器（Rate Limiter）

import org.redisson.api.RRateLimiter;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
public class MyService {@Autowiredprivate   RedissonClient redissonClient;public void myMethod() {// 获取限流器RRateLimiter limiter = redissonClient.getRateLimiter("myLimiter");// 定义限流速率，例如每秒最多允许10个操作limiter.trySetRate(RateType.OVERALL, 10, 1, RateIntervalUnit.SECONDS);// 尝试获取许可boolean acquired = limiter.tryAcquire();if (acquired) {// 执行需要限流的操作// ...} else {// 限流逻辑，例如返回错误信息或执行降级处理// ...}}
}

3.3. 可过期的对象（Expirable Object）

在Redis中，Hash结构是一种用于存储键值对的数据结构。每个Hash结构都可以包含多个字段（field）和对应的值（value）。而要为Hash结构中的二级key设置过期时间，可以使用Redisson的RMapCache接口。如果使用Redisson 来实现对Hash结构中二级key的值设置过期时间，其实很简单了。

我们使用redissonClient.getMapCache("myHash")获取一个名为"myHash"的可过期对象的Hash结构。然后，我们可以使用put()方法将具有过期时间的二级键值对存储到Hash结构中，并指定过期时间和时间单位。存储的二级键值对将会在指定的过期时间后自动过期。

在setHashValueWithExpiration()方法中，我们传入Hash结构的一级键（hashKey）、二级键（fieldKey）、值（value）、过期时间和时间单位，将值存储到Hash结构中的二级键，并为其设置过期时间。

在getHashValue()方法中，我们根据Hash结构的一级键和二级键从Hash结构中获取对应的值。

通过使用Redisson的RMapCache接口，你可以方便地为Hash结构中的二级键值对设置过期时间，并且无需手动处理过期逻辑。Redisson会自动管理过期和清理操作，简化了在分布式环境中使用可过期的Hash结构的开发工作。

import org.redisson.api.RMapCache;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.util.concurrent.TimeUnit;@Component
public class HashService {@Autowiredprivate  RedissonClient redissonClient;public void setHashValueWithExpiration(String hashKey, String fieldKey, Object value, long expirationTime, TimeUnit timeUnit) {RMapCache<String, Object> hash = redissonClient.getMapCache("myHash");hash.put(hashKey, fieldKey, value, expirationTime, timeUnit);}public Object getHashValue(String hashKey, String fieldKey) {RMapCache<String, Object> hash = redissonClient.getMapCache("myHash");return hash.get(hashKey, fieldKey);}
}

3.4. 信号量（Semaphore）

redissonClient.getSemaphore(“mySemaphore”)获取一个名为"mySemaphore"的信号量。然后，使用trySetPermits()方法设置信号量的初始数量，例如设置为10个。在myMethod()方法中，我们使用acquire()方法尝试获取信号量，如果获取到信号量，则执行需要受信号量限制的操作。在操作完成后，使用release()方法释放信号量。

通过使用Redisson的信号量功能，你可以控制在分布式环境中对某个资源的并发访问数量，限制并发访问的能力，从而保护资源的稳定性和可用性。

import org.redisson.api.RSemaphore;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
public class ResourceService {private final RedissonClient redissonClient;@Autowiredpublic ResourceService(RedissonClient redissonClient) {this.redissonClient = redissonClient;}public void accessResource() {RSemaphore resourceSemaphore = redissonClient.getSemaphore("resourceSemaphore");resourceSemaphore.trySetPermits(10);try {resourceSemaphore.acquire();// 执行需要受信号量限制的操作，访问资源// ...} catch (InterruptedException e) {// 处理中断异常// ...} finally {resourceSemaphore.release();}}
}

3.5. 分布式调度器（Distributed Scheduler）