【征服redis5】redis的Redisson客户端

2024-01-17 02:20

本文主要是介绍【征服redis5】redis的Redisson客户端,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

1 Redisson介绍

2. 与其他Java Redis客户端的比较

3.基本的配置与连接池

3.1 依赖和SDK

3.2 配置内容解析

4 实战案例:优雅的让Hash的某个Field过期

5 Redisson的强大功能


1 Redisson介绍

Redisson 最初由 GitHub 用户 “mrniko” 创建,并在 Apache 2.0 许可证下发布。它的目标是提供一组强大的工具和 API,帮助开发人员在分布式环境中处理数据,并解决并发和一致性的问题。

Redisson 是一款在 Redis 的基础上实现的 Java 驻内存数据网格(In-Memory Data Grid)。它提供了很多分布式的java对象并直接映射到Redis服务器的数据结构。


Redisson 提供了一系列丰富的 Redis 对象供用户使用,比如:Bucket, Deque, Set, SortedSet, Map, Lock, AtomicLong, CountDownLatch,Publish / Subscribe,Bloom filter, HyperLogLog 等等。它能使开发者可以直接在代码中操纵这些对象,而不是维护细节,提高了开发的效率。
Redisson 具有以下优势和特点:

  1. 简单易用:Redisson 提供了简单、一致的 API,使得开发人员可以像使用本地对象一样使用分布式对象。
  2. 高性能:Redisson 使用了异步和无锁的设计,以最大程度地提高性能和吞吐量。
  3. 分布式数据结构:Redisson 提供了一系列分布式数据结构,如分布式集合、分布式映射、分布式列表等,使得处理大规模数据变得更加高效。
  4. 分布式锁:Redisson 提供了可重入的分布式锁,帮助开发人员解决并发访问的问题。
  5. 分布式队列:Redisson 提供了分布式队列,支持先进先出和优先级队列,适用于任务调度和消息传递等场景。
  6. 高可用和故障恢复:Redisson 支持主从复制和哨兵模式,确保系统的高可用性和故障恢复能力。


2. 与其他Java Redis客户端的比较

和Jedis以及Lettuce等其他Redis Java客户端比较,Redisson提供了更丰富的分布式对象模型,以及更强大的并发处理和故障恢复特性。
Redisson的高级特性,包括高级Java对象、故障转移、母子复制支持、公平锁支持和分布式服务等,使它成为Java环境中最强大、最灵活的Redis客户端之一。
Redisson与其他Java Redis客户端(Jedis和Lettuce)的比较,足以看出来他的天下无敌。

项目RedissonJedisLettuce
Redis数据类型支持支持全部(包括流)支持全部支持全部
高级Java对象多班并发和分布式Java对象没有没有
连接池
集群支持
故障转移没有
母子复制支持没有
SSL支持
LUA scripting有(只读)有(只读)
响应式API没有
事务支持
分布式锁有(包括公平锁)没有没有
公平锁支持没有没有
发布和订阅
异步API没有
分布式服务有(例如BloomFilter,BitSet,AtomicLong等)没有没有

3.基本的配置与连接池

3.1 依赖和SDK

通过在Maven或Gradle中添加以下依赖来使用Redisson

   <dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.13.6</version></dependency>

3.2 配置内容解析

Redisson的配置功能就就比较强大了,我们通过下面的文件看一个配置示例:

# Redisson 配置文件# Redisson 服务器地址
# 可以是单个服务器或多个服务器
# 多个服务器之间使用逗号分隔
redisson.address = "redis://127.0.0.1:6379,redis://127.0.0.2:6379"# Redisson 连接超时时间(毫秒)
redisson.connectionTimeout = 3000# Redisson 密码
redisson.password = "password"# Redisson 连接池配置# 最小空闲连接数
redisson.connectionPool.minIdle = 10# 最大连接数
redisson.connectionPool.maxSize = 100# 连接空闲超时时间(毫秒)
redisson.connectionPool.idleTimeout = 10000# 连接最大空闲时间(毫秒)
redisson.connectionPool.maxIdleTime = 60000# Redisson 重试配置# 重试次数
redisson.retryAttempts = 3# 重试间隔时间(毫秒)
redisson.retryInterval = 1000# Redisson 序列化配置
# 可以选择不同的序列化方式,如 JSON、Jackson、Kryo 等
redisson.codec = org.redisson.codec.JsonJacksonCodec# Redisson 事件监听器配置# 是否启用事件监听器
redisson.listener.enable = true# 事件监听器线程池大小
redisson.listener.threadPoolSize = 10# Redisson 集群配置# 是否启用集群模式
redisson.cluster.enabled = false# 集群节点地址
redisson.cluster.nodes = "redis://127.0.0.1:6379,redis://127.0.0.2:6379"# 集群扫描间隔时间(毫秒)
redisson.cluster.scanInterval = 2000

通过在配置中设置 connectionMinimumIdleSize 和 connectionPoolSize 参数,可以进行Redisson的连接池配置。

  1. connectionMinimumIdleSize:最小空闲连接数,表示即使没有数据库连接时依然维持的空闲连接数量。默认值:32
  2. connectionPoolSize:最大连接池数量,对所有ROUTER节点来说,都是公用的。默认值:64

注意配置中的其它参数也会影响Redisson的性能和行为,比如timeout, retryAttempts, retryInterval等等。应根据实际应用需要来调整这些参数。
当然,我们可以为每个配置项添加注释,以方便理解每个参数的作用。下面是带注释的YAML配置文件:

singleServerConfig:idleConnectionTimeout: 10000 # 空闲连接超时,单位:毫秒connectTimeout: 10000 # 连接超时,单位:毫秒timeout: 3000 # 命令等待超时,单位:毫秒retryAttempts: 3 # 命令失败重试次数retryInterval: 1500 # 命令重试发送间隔,单位:毫秒password: null # Redis 服务器密码subscriptionsPerConnection: 5 # 每个连接的最大订阅数量clientName: null # Redis 客户端名称address: "redis://127.0.0.1:6379" # Redis 服务器地址subscriptionConnectionMinimumIdleSize: 1 # 订阅连接的最小空闲数量subscriptionConnectionPoolSize: 50 # 订阅连接的最大连接数量connectionMinimumIdleSize: 10 # 正常连接的最小空闲数量,至少保持10个空闲连接connectionPoolSize: 50 # 正常连接的最大连接数量,最多可以创建50个连接database: 0 # 连接的数据库编号,默认是0dnsMonitoringInterval: 5000 # DNS监控间隔,单位:毫秒

4 实战案例:优雅的让Hash的某个Field过期

为了感受 redisson 的强大,我们写一个redis其他客户端不具备的能力。
使用redisson 设置 hash结构的二级key过期。也就是设置hash 结构的 field 设置过期时间。我们使用redisson优雅的使Hash的某个Field过期。

 redisson.yaml 示例:

singleServerConfig:idleConnectionTimeout: 10000connectTimeout: 10000timeout: 3000retryAttempts: 3retryInterval: 1500password: nullsubscriptionsPerConnection: 5clientName: nulladdress: "redis://127.0.0.1:6379"subscriptionConnectionMinimumIdleSize: 1subscriptionConnectionPoolSize: 50connectionMinimumIdleSize: 10connectionPoolSize: 50database: 0dnsMonitoringInterval: 5000

测试:

package com.icepip,redisson.example;import org.redisson.Redisson;
import org.redisson.api.RBucket;
import org.redisson.api.RMap;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;import java.util.concurrent.TimeUnit;public class Main {public static void main(String[] args) {Config config = Config.fromYAML(Main.class.getClassLoader().getResource("redisson.yaml"));RedissonClient redisson = Redisson.create(config);// 设置Hash的key和valueRMap<String, String> map = redisson.getMap("hash");map.put("field", "value");// 对于相应的key设置过期时间RBucket<String> bucket = redisson.getBucket("hash:field:expire");bucket.set("dummyValue", 5, TimeUnit.MINUTES);}
}

5 Redisson的强大功能

在网上能看到这么一张图,这些都是使用redisson+redis可以实现的功能, 由此可见其功能只强大。

这部分内容可以参考:

redission分布式锁的实战案例

redisson使用全解——redisson官方文档+注释


 

这篇关于【征服redis5】redis的Redisson客户端的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/614638

相关文章

Redis Cluster模式配置

《RedisCluster模式配置》:本文主要介绍RedisCluster模式配置,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录分片 一、分片的本质与核心价值二、分片实现方案对比 ‌三、分片算法详解1. ‌范围分片(顺序分片)‌2. ‌哈希分片3. ‌虚

Springboot整合Redis主从实践

《Springboot整合Redis主从实践》:本文主要介绍Springboot整合Redis主从的实例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言原配置现配置测试LettuceConnectionFactory.setShareNativeConnect

MYSQL查询结果实现发送给客户端

《MYSQL查询结果实现发送给客户端》:本文主要介绍MYSQL查询结果实现发送给客户端方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录mysql取数据和发数据的流程(边读边发)Sending to clientSending DataLRU(Least Rec

Redis过期删除机制与内存淘汰策略的解析指南

《Redis过期删除机制与内存淘汰策略的解析指南》在使用Redis构建缓存系统时,很多开发者只设置了EXPIRE但却忽略了背后Redis的过期删除机制与内存淘汰策略,下面小编就来和大家详细介绍一下... 目录1、简述2、Redis http://www.chinasem.cn的过期删除策略(Key Expir

Python FastMCP构建MCP服务端与客户端的详细步骤

《PythonFastMCP构建MCP服务端与客户端的详细步骤》MCP(Multi-ClientProtocol)是一种用于构建可扩展服务的通信协议框架,本文将使用FastMCP搭建一个支持St... 目录简介环境准备服务端实现(server.py)客户端实现(client.py)运行效果扩展方向常见问题结

Redis指南及6.2.x版本安装过程

《Redis指南及6.2.x版本安装过程》Redis是完全开源免费的,遵守BSD协议,是一个高性能(NOSQL)的key-value数据库,Redis是一个开源的使用ANSIC语言编写、支持网络、... 目录概述Redis特点Redis应用场景缓存缓存分布式会话分布式锁社交网络最新列表Redis各版本介绍旧

Java如何从Redis中批量读取数据

《Java如何从Redis中批量读取数据》:本文主要介绍Java如何从Redis中批量读取数据的情况,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一.背景概述二.分析与实现三.发现问题与屡次改进3.1.QPS过高而且波动很大3.2.程序中断,抛异常3.3.内存消

Redis中的Lettuce使用详解

《Redis中的Lettuce使用详解》Lettuce是一个高级的、线程安全的Redis客户端,用于与Redis数据库交互,Lettuce是一个功能强大、使用方便的Redis客户端,适用于各种规模的J... 目录简介特点连接池连接池特点连接池管理连接池优势连接池配置参数监控常用监控工具通过JMX监控通过Pr

python操作redis基础

《python操作redis基础》Redis(RemoteDictionaryServer)是一个开源的、基于内存的键值对(Key-Value)存储系统,它通常用作数据库、缓存和消息代理,这篇文章... 目录1. Redis 简介2. 前提条件3. 安装 python Redis 客户端库4. 连接到 Re

Redis迷你版微信抢红包实战

《Redis迷你版微信抢红包实战》本文主要介绍了Redis迷你版微信抢红包实战... 目录1 思路分析1.1hCckRX 流程1.2 注意点①拆红包:二倍均值算法②发红包:list③抢红包&记录:hset2 代码实现2.1 拆红包splitRedPacket2.2 发红包sendRedPacket2.3 抢