Redis实战之Redisson使用技巧详解,干活!

时间:2025-11-04 19:29:48来源:极客码头作者:数据库

一、干活摘要

什么是实使用 Redisson?来自于官网上的描述内容如下!

Redisson 是技巧一个在 Redis 的基础上实现的 Java 驻内存数据网格客户端(In-Memory Data Grid)。它不仅提供了一系列的详解 redis 常用数据结构命令服务,还提供了许多分布式服务,干活例如分布式锁、实使用分布式对象、技巧分布式集合、详解分布式远程服务、干活分布式调度任务服务等等。实使用

Redis实战之Redisson使用技巧详解,干活!

相比于 Jedis、技巧Lettuce 等基于 redis 命令封装的详解客户端,Redisson 提供的干活功能更加高端和抽象,逼格高!实使用

更多功能特性和开发文档说明,技巧可用移步github进行获取,访问地址如下:

复制https://github.com/redisson/redisson/wiki/目录1.

接下来,我们就一起来聊一下,如何使用 Redisson 操作 Redis 中的字符串、哈希、列表、集合、有序集合,以及布隆过滤器和分布式锁等功能。

二、b2b信息网Redisson

2.1、基本使用

跟过去一样,首先创建一个 maven 项目,添加​​Redisson​​依赖包。

复制<dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.13.6</version></dependency>1.2.3.4.5.

单机环境下,简单样例如下!

复制public class RedissonMain { public static void main(String[] args){ Config config = new Config(); config.useSingleServer() .setAddress("redis://127.0.0.1:6379") .setPassword("123456") .setDatabase(0); //

获取客户端

RedissonClient redissonClient = Redisson.create(config); //

获取所有的key

redissonClient.getKeys().getKeys().forEach(key -> System.out.println(key)); //

关闭客户端

redissonClient.shutdown(); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.

ps:创建 RedissonClient 对象实例的方式多钟多样,可以直接通过在代码中设置 Redis 服务的相关参数创建,也可以通过加载 JSON 格式、 YAML 格式或者 Spring XML 配置文件来创建,详细的参数配置可用移步上文提到的 Redisson 开发文档。

2.2、字符串操作

Redisson 支持通过RBucket对象来操作字符串数据结构,通过RBucket实例可以设置value或设置value和有效期,简单样例如下!

复制//

字符串操作

RBucket<String> rBucket = redissonClient.getBucket("strKey");//

设置value和key的有效期

rBucket.set("张三", 30, TimeUnit.SECONDS);//

通过key获取value

System.out.println(redissonClient.getBucket("strKey").get());1.2.3.4.5.6. 2.3、对象操作

Redisson 支持将对象作为value存入redis,被存储的对象事先必须要实现序列化接口Serializable,否则会报错,简单样例如下!

复制public class Student implements Serializable { private Long id; private String name; private Integer age; //set

、get...

@Override

public String toString(){ return "Student{" + "id=" + id + ", name=" + name + + ", age=" + age +}; }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.

复制//Student对象

Student student = new Student();

student.setId(1L);

student.setName("张三");

student.setAge(18);

//对象操作

RBucketrBucket = redissonClient.getBucket("objKey");

// 设置value和key的有效期

rBucket.set(student, 30, TimeUnit.SECONDS);

// 通过key获取value

System.out.println(redissonClient.getBucket("objKey").get());1.2.3.4.5.6.7.8.9.10.11.12. 2.4、哈希操作

Redisson 支持通过RMap​对象来操作哈希数据结构,简单样例如下!

复制//

哈希操作

RMap<String, String> rMap = redissonClient.getMap("mapkey");// 设置map中key-

value

rMap.put("id", "123");rMap.put("name", "赵四");rMap.put("age", "50");//

设置过期时间

rMap.expire(30, TimeUnit.SECONDS);//

通过key获取value

System.out.println(redissonClient.getMap("mapkey").get("name"));1.2.3.4.5.6.7.8.9.10.11. 2.5、IT技术网列表操作

Redisson 支持通过RList对象来操作列表数据结构,简单样例如下!

复制//

字符串操作

RList<Student> rList = redissonClient.getList("listkey");Student student1 = new Student();student1.setId(1L);student1.setName("张三");student1.setAge(18);rList.add(student1);Student student2 = new Student();student2.setId(2L);student2.setName("李四");student2.setAge(19);rList.add(student2);//

设置过期时间

rList.expire(30, TimeUnit.SECONDS);//

通过key获取value

System.out.println(redissonClient.getList("listkey"));1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19. 2.6、集合操作

Redisson 支持通过RSet对象来操作集合数据结构,简单样例如下!

复制//

字符串操作

RSet<Student> rSet = redissonClient.getSet("setkey");Student student1 = new Student();student1.setId(1L);student1.setName("张三");student1.setAge(18);rSet.add(student1);Student student2 = new Student();student2.setId(2L);student2.setName("李四");student2.setAge(19);rSet.add(student2);//

设置过期时间

rSet.expire(30, TimeUnit.SECONDS);//

通过key获取value

System.out.println(redissonClient.getSet("setkey"));1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19. 2.6、有序集合操作

Redisson 支持通过RSortedSet对象来操作有序集合数据结构,在使用对象来存储之前,实体对象必须先实现Comparable接口,并重写比较逻辑,否则会报错,简单样例如下!

复制public class Student implements Serializable, Comparable<Student> { private Long id; private String name; private Integer age; //

get、set.....

@Override

public String toString(){ return "Student{" + "id=" + id + ", name=" + name + + ", age=" + age +}; }

@Override

public int compareTo(Student obj){ return this.getId().compareTo(obj.getId()); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24. 复制//

有序集合操作

RSortedSet<Student> sortSetkey = redissonClient.getSortedSet("sortSetkey");Student student1 = new Student();student1.setId(1L);student1.setName("张三");student1.setAge(18);sortSetkey.add(student1);Student student2 = new Student();student2.setId(2L);student2.setName("李四");student2.setAge(19);sortSetkey.add(student2);//

通过key获取value

System.out.println(redissonClient.getSortedSet("sortSetkey"));1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17. 2.7、布隆过滤器

布隆过滤器(Bloom Filter)是 1970 年由布隆提出的。它实际上是一个很长的二进制向量和一系列随机映射函数。

布隆过滤器可以用于检索一个元素是否在一个集合中。它的优点是空间效率和查询时间都比一般的算法要好的多,缺点是有一定的误识别率和删除困难。

Redisson 支持通过RBloomFilter对象来操作布隆过滤器,简单样例如下!

复制RBloomFilter rBloomFilter = redissonClient.getBloomFilter("seqId");// 初始化预期插入的WordPress模板数据量为10000和期望误差率为0.01rBloomFilter.tryInit(10000, 0.01);//

插入部分数据

rBloomFilter.add("100");rBloomFilter.add("200");rBloomFilter.add("300");//

设置过期时间

rBloomFilter.expire(30, TimeUnit.SECONDS);//

判断是否存在

System.out.println(rBloomFilter.contains("300"));System.out.println(rBloomFilter.contains("200"));System.out.println(rBloomFilter.contains("999"));1.2.3.4.5.6.7.8.9.10.11.12.13. 2.8、分布式自增ID

ID 是数据的唯一标识,传统的做法是利用 UUID 和数据库的自增 ID。

但由于 UUID 是无序的,不能附带一些其他信息,因此实际作用有限。

随着业务的发展,数据量会越来越大,需要对数据进行分表,甚至分库。分表后每个表的数据会按自己的节奏来自增,这样会造成 ID 冲突,因此这时就需要一个单独的机制来负责生成唯一 ID,redis 原生支持生成全局唯一的 ID。

简单样例如下!

复制final String lockKey = "aaaa";//

通过redis的自增获取序号

RAtomicLong atomicLong = redissonClient.getAtomicLong(lockKey);//

设置过期时间

atomicLong.expire(30, TimeUnit.SECONDS);//

获取值

System.out.println(atomicLong.incrementAndGet());1.2.3.4.5.6.7. 2.9、分布式锁

Redisson 最大的亮点,也是使用最多的功能,就是提供了强大的分布式锁实现,特点是:使用简单、安全!

简单使用样例如下!

复制Config config = new Config();config.useSingleServer() .setAddress("redis://127.0.0.1:6379") .setPassword("123456") .setDatabase(0);RedissonClient redissonClient = Redisson.create(config);//

获取锁对象实例

final String lockKey = "abc";RLock rLock = redissonClient.getLock(lockKey);try { //

尝试5秒内获取锁,如果获取到了,最长60秒自动释放

boolean res = rLock.tryLock(5L, 60L, TimeUnit.SECONDS); if (res) { //

成功获得锁,在这里处理业务

System.out.println("获取锁成功"); }} catch (Exception e) { System.out.println("获取锁失败,失败原因:" + e.getMessage());} finally { //无论如何,

最后都要解锁

rLock.unlock();}//

关闭客户端

redissonClient.shutdown();1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.

以上是单机环境下的分布式锁实现逻辑,如果是集群环境下,应该如何处理呢?

Redisson 提供RedissonRedLock操作类,也被称为红锁,实现原理简单的总结有以下几点:

如果有多个 redis 集群的时候,当且仅当从大多数(N/2+1,比如有3个 redis 节点,那么至少有2个节点)的 Redis 节点都取到锁,并且获取锁使用的总耗时小于锁失效时间时,锁才算获取成功如果获取失败,客户端会在所有的 Redis 实例上进行解锁操作集群环境下,redis 服务器直接不存在任何复制或者其他隐含的分布式协调机制,否则会存在实效的可能

RedissonRedLock简单使用样例如下!

复制Config config1 = new Config();config1.useSingleServer().setAddress("redis://192.168.3.111:6379").setPassword("a123456").setDatabase(0);RedissonClient redissonClient1 = Redisson.create(config1);Config config2 = new Config();config2.useSingleServer().setAddress("redis://192.168.3.112:6379").setPassword("a123456").setDatabase(0);RedissonClient redissonClient2 = Redisson.create(config2);Config config3 = new Config();config3.useSingleServer().setAddress("redis://192.168.3.113:6379").setPassword("a123456").setDatabase(0);RedissonClient redissonClient3 = Redisson.create(config3);//

获取多个 RLock 对象

final String lockKey = "abc";RLock lock1 = redissonClient1.getLock(lockKey);RLock lock2 = redissonClient2.getLock(lockKey);RLock lock3 = redissonClient3.getLock(lockKey);//

根据多个 RLock 对象构建 RedissonRedLock (最核心的差别就在这里)

RedissonRedLock redLock = new RedissonRedLock(lock1, lock2, lock3);try { //

尝试5秒内获取锁,如果获取到了,最长60秒自动释放

boolean res = redLock.tryLock(5L, 60L, TimeUnit.SECONDS); if (res) { //

成功获得锁,在这里处理业务

System.out.println("获取锁成功"); }} catch (Exception e) { System.out.println("获取锁失败,失败原因:" + e.getMessage());} finally { //无论如何,

最后都要解锁

redLock.unlock();}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.

更加详细的分布式锁实现原理分析,可以移步到这个地址查阅。

复制https://blog.csdn.net/asd051377305/article/details/1083844901. 2.10、集群模式

以上介绍的都是单机模式,如果是集群环境,我们可以采用如下方式进行配置:

复制Config config = new Config();config.useClusterServers() .setScanInterval(2000) //

集群状态扫描间隔时间,单位是毫秒

//可以用"rediss://"

来启用SSL连接

.addNodeAddress("redis://127.0.0.1:7000", "redis://127.0.0.1:7001") .addNodeAddress("redis://127.0.0.1:7002");RedissonClient redisson = Redisson.create(config);1.2.3.4.5.6.7.8. 2.11、哨兵模式

哨兵模式,参数配置方式如下:

复制Config config = new Config();config.useSentinelServers() .setMasterName("mymaster") //可以用"rediss://"

来启用SSL连接

.addSentinelAddress("127.0.0.1:26389", "127.0.0.1:26379") .addSentinelAddress("127.0.0.1:26319");RedissonClient redisson = Redisson.create(config);1.2.3.4.5.6.7.8. 2.12、主从模式

主从模式,参数配置方式如下:

复制Config config = new Config();config.useMasterSlaveServers() //可以用"rediss://"

来启用SSL连接

.setMasterAddress("redis://127.0.0.1:6379") .addSlaveAddress("redis://127.0.0.1:6389", "redis://127.0.0.1:6332", "redis://127.0.0.1:6419") .addSlaveAddress("redis://127.0.0.1:6399");RedissonClient redisson = Redisson.create(config);1.2.3.4.5.6.7.8.

三、小结

在前几篇文章中,我们详细的介绍了 Jedis、Lettuce,我们不禁会发出一个疑问:Redisson和Jedis、Lettuce有什么区别?

现在我们再回头来总结一番!

Jedis:Redis 官方推出的用于通过 Java 连接 Redis 客户端的一个工具包,它提供了全面的类似于 Redis 原生命令的支持,是目前使用最广的一款 java 客户端。Lettuce:一个可扩展的线程安全的 Redis 客户端,通讯框架基于 Netty 开发,支持高级的 Redis 特性,比如哨兵,集群,管道,自动重新连接等特性。从 Spring Boot 2.x 开始, Lettuce 已取代 Jedis 成为首选 Redis 的客户端。Redisson:一款架设在 Redis 基础上,通讯基于 Netty 的综合的、新型的中间件,是企业级开发中使用 Redis 的最佳范本。

总结下来,Jedis 把 Redis 命令封装的非常全面,Lettuce 则进一步丰富了 Api,支持 Redis 各种高级特性。

但是两者并没有进一步深化,只给了你操作 Redis 数据库的工具,而 Redisson 则是基于 Redis、Lua 和 Netty 建立起了一套的分布式解决方案,比如分布式锁的实现,分布式对象的操作等等。

在实际使用过程中,Lettuce​ + Redisson组合使用的比较多,两者相铺相成。

关于分布式锁实现的应用,生产环境推荐尽量采用单点环境来实现,基本上解决绝大部分的分布式锁问题,如果当前服务的环境确实很复杂,可以采用RedissonRedLock来实现。

四、参考

1、Redisson 开发文档

2、王同学 - 聊一聊Redis官方置顶推荐的Java客户端Redisson

3、Venlenter - Redis分布式锁-这一篇全了解(Redission实现分布式锁完美方案)

相关内容
热点内容