Spring 整合 Redis 的三个简单步骤

news2025/1/20 20:04:16

一、导入 Redis 依赖

1、导入 Redis 客户端 jar 包依赖

导入 jar 包是需要注意,Redis 是属于 CS 架构模式,服务端需先启动,然后客户端主动去连它。但是客户端怎么去连接服务端呢?这里有两种方式:一种是 Jedis 客户端、另一种是 Lettuce 客户端可以 和 Redis 服务器通信。所以这里就需要导入客户端的 jar 包依赖。

提示:Jedis、Lettuce 都是 Redis 的 Java 客户端,通过它可以对 Redis 服务端进行操作。这个就是 Redis、和 Jedis 之间的亲密关系。Redis 目前不能离开这两个客户端。

以下两个客户端连接器依赖导入一个即可(就看你要使用哪种客户端操作 Redis 服务端):

提示:SpringBoot 默认使用的 Lettuce 客户端操作 Redis、连接池用的是 commons-pool2

  • Jedis 客户端依赖包如下:
	<dependency>
	    <groupId>redis.clients</groupId>
	    <artifactId>jedis</artifactId>
	    <version>3.3.0.RELEASE</version>
	</dependency>
  • Lettuce 客户端依赖包如下:
	<dependency>
	   	<groupId>io.lettuce</groupId>
	   	<artifactId>lettuce-core</artifactId>
	   	<version>5.3.0.RELEASE</version>
	</dependency>

2、导入 Spring 封装简单 API 的 jar 包依赖

但是直接使用上述客户端操作还是不太方便,所以 Spring 就对其进行封装,封装成更简单的 API 方便开发用,所以这里还需要导入封装 API 所在的 jar 包依赖。

导入 Spring 封装 Redis 客户端 API 的 jar 包如下:

	<dependency>
	   <groupId>org.springframework.data</groupId>
	   <artifactId>spring-data-redis</artifactId>
	   <version>2.3.0.RELEASE</version>
	</dependency>

3、导入连接池 jar 包依赖

另外还需要导入一个连接池的 jar 包依赖。如果不导入连接池,上面每次连接都需要重新创建连接对象,这样生成和释放连接太浪费时间,所以一般都会搭配连接池,提高性能。

导入连接池 jar 包依赖,可以看到是 apache 提供的连接池,而且还是 pool2,性能杠杠的。

   <dependency>
      <groupId>org.apache.commons</groupId>
      <artifactId>commons-pool2</artifactId>
      <version>2.8.0</version>
    </dependency>

总结以上需要 3 个 jar 包依赖,客户端 jar 包依赖、Spring API jar 包依赖、连接池 jar 包依赖。完整 maven 如下:

	<dependency>
	     <groupId>redis.clients</groupId>
	     <artifactId>jedis</artifactId>
	     <version>3.3.0.RELEASE</version>
	</dependency>
	
	<dependency>
	   <groupId>org.springframework.data</groupId>
	   <artifactId>spring-data-redis</artifactId>
	   <version>2.3.0.RELEASE</version>
	 </dependency>
	 
	<dependency>
	   <groupId>org.apache.commons</groupId>
	   <artifactId>commons-pool2</artifactId>
	   <version>2.8.0</version>
	</dependency>

gradle 配置如下:

dependencies {
	compile group: 'org.springframework.data', name: 'spring-data-redis', version: '2.3.0.RELEASE'
    compile group: 'redis.clients', name: 'jedis', version: '3.3.0'
    compile group: 'io.lettuce', name: 'lettuce-core', version: '5.3.0.RELEASE'
}

以上版本都是参照官方文档,不会爆 java.lang.NoClassDefFoundError: org/springframework/data/geo/Metric 版本异常。Spring-Data-Redis 官方文档点击链接 https://docs.spring.io/spring-data/redis/docs/2.3.0.RELEASE/reference/html/#reference 查看。其他版本的话点击官方 Github 链接https://github.com/redis/jedis/tree/jedis-3.0.1 查看对应版本。

二、编写 Redis 配置类

1、使用 Jedis 作为客户端连接器

JedisConfig 类如下:

@Configuration
public class JedisConfig {

	@Bean
	public RedisTemplate<String,String> restTemplate() {
		// 配置连接池
		JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
		// 最大空闲数
		jedisPoolConfig.setMaxIdle(50);
		// 最大连接数
		jedisPoolConfig.setMaxTotal(100);
		// 最大等待亳秒数
		jedisPoolConfig.setMaxWaitMillis(20000);


		// Redis 连接服务器配置
		RedisStandaloneConfiguration redisConfig = new RedisStandaloneConfiguration();
		redisConfig.setHostName("127.0.0.1");
		redisConfig.setPort(6379);
		redisConfig.setPassword("");
		redisConfig.setDatabase(0);


		// 修改 Redis 的连接器 Jedis 的默认连接池
		JedisClientConfiguration.JedisPoolingClientConfigurationBuilder builder =
				(JedisClientConfiguration.JedisPoolingClientConfigurationBuilder) JedisClientConfiguration.builder();
		JedisClientConfiguration jedisClientConfiguration = builder.poolConfig(jedisPoolConfig).build();


		// 采用 Jedis 作为 Redis 客户端,可用用 JedisConnectionFactory 工厂初始化连接池配置
		JedisConnectionFactory connectionFactory = new JedisConnectionFactory(redisConfig,jedisClientConfiguration);
		// 调用后初始化方法,没有它将抛出异常
		connectionFactory.afterPropertiesSet();

		// 定义 RedisTemplate,并设置连接工程
		RedisTemplate<String,String> redisTemplate = new RedisTemplate<String,String>();
		redisTemplate.setConnectionFactory(connectionFactory);


		// 设置自定 Redis 序列化器
		RedisSerializer<Object> jdkSerializationRedisSerializer = new JdkSerializationRedisSerializer();
		RedisSerializer<String> stringRedisSerializer = new StringRedisSerializer();
		// 默认使用 StringRedisSerializer 作为 K,V 序列化存储
		redisTemplate.setDefaultSerializer(stringRedisSerializer);
		// 对于普通类型 K 使用 StringRedisSerializer 序列化存储
		redisTemplate.setKeySerializer(stringRedisSerializer);
		// 对于普通类型 V 使用 JdkSerializationRedisSerializer 序列化存储(不推荐存储占用空间大)
		redisTemplate.setValueSerializer(jdkSerializationRedisSerializer);
		// 对于 Hash 类型 K 使用 StringRedisSerializer 序列化存储
		redisTemplate.setHashKeySerializer(stringRedisSerializer);
		// 对于 Hash 类型 V 使用 JdkSerializationRedisSerializer 序列化存储(不推荐存储占用空间大)
		redisTemplate.setHashValueSerializer(jdkSerializationRedisSerializer);
		return redisTemplate;
	}
}

主要还是借助 spring-data-redis 包下的 RedisTemplate 来操作 Redis 服务端。这个类是 Spring 对 Jedis、Lettuce 客户端的包装,提供更方便 API。现在对上面代码进行拆分分析。

2、JedisPoolConfig 类—配置连接池

Jedis、Lettuce 都有对应的连接池标准 API ,Jedis 对应的是 JedisPoolConfig、Lettuce 对应的是 GenericObjectPoolConfig 配置类。下面这段是 JedisPoolConfig 连接池的配置。

	// 配置连接池
	JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
	// 最大空闲数
	jedisPoolConfig.setMaxIdle(50);
	// 最大连接数
	jedisPoolConfig.setMaxTotal(100);
	// 最大等待亳秒数
	jedisPoolConfig.setMaxWaitMillis(20000);

连接池配置好之后,现在准备去连接 Redis 服务端,之前代码是通过 JedisConnectionFactory 类来去连接,但是现在这个类提供的 API 都已经过期,如下图示:

在这里插入图片描述

3、RedisStandaloneConfiguration 类—配置 Redis 连接和连接池对象

查看源码现在换成了 RedisStandaloneConfiguration 类。

在这里插入图片描述

4、JedisPoolingClientConfigurationBuilder 内部类—设置连接池对象

但是这个类在设置连接池对象的时候比较麻烦,需要通过一个内部类操作。然后通过调用内部类的 poolConfig() 方法才可以将连接池对象封装到 Jedis 客户端配置中,代码如下:

	// 修改 Redis 的连接器 Jedis 的默认连接池
	JedisClientConfiguration.JedisPoolingClientConfigurationBuilder builder =
			(JedisClientConfiguration.JedisPoolingClientConfigurationBuilder) JedisClientConfiguration.builder();
			
	JedisClientConfiguration jedisClientConfiguration = builder.poolConfig(jedisPoolConfig).build();
	

5、JedisConnectionFactory 类—Jedis 连接工厂

现在 redisConfig 封装着 Redis 连接服务端的 url 地址,jedisClientConfiguration 封装着客户端连接池信息,将这两个全部交给 JedisConnectionFactory 类。调用 afterPropertiesSet() 方法,就位初始化客户端和连接池。代码如下:

	// 采用 Jedis 作为 Redis 客户端,可用用 JedisConnectionFactory 工厂初始化连接池配置
	JedisConnectionFactory connectionFactory = new JedisConnectionFactory(redisConfig,jedisClientConfiguration);

	// 调用后初始化方法,没有它将抛出异常
	connectionFactory.afterPropertiesSet();

6、RedisTemplate 类—Spring 封装操作 Redis 的工具类

在 RedisTemplate 类中,我们需要将 JedisConnectionFactory 传给它,毕竟它封装的 API 底层都是通过 JedisConnectionFactory 工厂中的 Jedis 客户端操作的。代码如下:

	// 定义 RedisTemplate,并设置连接工程
	RedisTemplate<String,String> redisTemplate = new RedisTemplate<String,String>();
	redisTemplate.setConnectionFactory(connectionFactory);

7、K,V 序列化设置

最后就是设置 K,V 的序列化,序列化算法好的话,可以节省很多存储空间。传统的 JdkSerializationRedisSerializer 序列化不算好,序列化可以借鉴 Google 提供的包。

	// 设置自定 Redis 序列化器
	RedisSerializer<Object> jdkSerializationRedisSerializer = new JdkSerializationRedisSerializer();
	RedisSerializer<String> stringRedisSerializer = new StringRedisSerializer();
	// 默认使用 StringRedisSerializer 作为 K,V 序列化存储
	redisTemplate.setDefaultSerializer(stringRedisSerializer);
	// 对于普通类型 K 使用 StringRedisSerializer 序列化存储
	redisTemplate.setKeySerializer(stringRedisSerializer);
	// 对于普通类型 V 使用 JdkSerializationRedisSerializer 序列化存储(不推荐存储占用空间大)
	redisTemplate.setValueSerializer(jdkSerializationRedisSerializer);
	// 对于 Hash 类型 K 使用 StringRedisSerializer 序列化存储
	redisTemplate.setHashKeySerializer(stringRedisSerializer);
	// 对于 Hash 类型 V 使用 JdkSerializationRedisSerializer 序列化存储(不推荐存储占用空间大)
	redisTemplate.setHashValueSerializer(jdkSerializationRedisSerializer);
	

上面直接引入那三个 jar 包依赖,然后把 JedisConfig 配置类拷贝到项目中就可以使用。下面用 Lettuce 作为客户端,基本上一模一样,只是换了几个模板类。在这里不过多描述,直接拷贝代码即可。

8、使用 Lettuce 作为客户端连接器

就是将上面的 Jedis 包换成 Lettuce 包就可以,完整的 xml 如下:

    <dependency>
      <groupId>io.lettuce</groupId>
      <artifactId>lettuce-core</artifactId>
      <version>5.3.0.RELEASE</version>
    </dependency>
	
	<dependency>
	   <groupId>org.springframework.data</groupId>
	   <artifactId>spring-data-redis</artifactId>
	   <version>2.3.0.RELEASE</version>
	 </dependency>
	 
	<dependency>
	   <groupId>org.apache.commons</groupId>
	   <artifactId>commons-pool2</artifactId>
	   <version>2.8.0</version>
	</dependency>

然后配置 LettuceConfig 类,代码如下:

@Configuration
public class LettuceConfig {

	@Bean
	public RedisTemplate<String,String> restTemplate() {
		// 配置连接池
		GenericObjectPoolConfig<Object> lettucePoolConfig = new GenericObjectPoolConfig<Object>();
		// 最小空闲数
		lettucePoolConfig.setMinIdle(10);
		// 最大空闲数
		lettucePoolConfig.setMaxIdle(50);
		// 最大连接数
		lettucePoolConfig.setMaxTotal(100);
		// 最大等待时间
		lettucePoolConfig.setMaxWaitMillis(3000);

		// Redis 连接服务器配置
		RedisStandaloneConfiguration redisConnectConfig = new RedisStandaloneConfiguration();
		redisConnectConfig.setHostName("127.0.0.1");
		redisConnectConfig.setPort(6379);
		redisConnectConfig.setPassword("");
		redisConnectConfig.setDatabase(0);

		// 修改 Redis 的连接器 Lettuce 默认连接池
		LettuceClientConfiguration lettucePoolConfiguration = LettucePoolingClientConfiguration.builder()
				.commandTimeout(Duration.ofMillis(5000))
				.poolConfig(lettucePoolConfig)
				.build();

		// 采用 Lettuce 作为 Redis 客户端,可用用 LettuceConnectionFactory 工厂初始化连接池配置
		LettuceConnectionFactory connectionFactory = new LettuceConnectionFactory(redisConnectConfig,lettucePoolConfiguration);

		// 调用后初始化方法,没有它将抛出异常
		connectionFactory.afterPropertiesSet();

		// 定义 RedisTemplate,并设置连接工程
		RedisTemplate<String,String> redisTemplate = new RedisTemplate<String,String>();
		redisTemplate.setConnectionFactory(connectionFactory);

		// 设置自定 Redis 序列化器
		RedisSerializer<Object> jdkSerializationRedisSerializer = new JdkSerializationRedisSerializer();
		RedisSerializer<String> stringRedisSerializer = new StringRedisSerializer();
		// 默认使用 StringRedisSerializer 作为 K,V 序列化存储
		redisTemplate.setDefaultSerializer(stringRedisSerializer);
		// 对于普通类型 K 使用 StringRedisSerializer 序列化存储
		redisTemplate.setKeySerializer(stringRedisSerializer);
		// 对于普通类型 V 使用 JdkSerializationRedisSerializer 序列化存储(不推荐存储占用空间大)
		redisTemplate.setValueSerializer(jdkSerializationRedisSerializer);
		// 对于 Hash 类型 K 使用 StringRedisSerializer 序列化存储
		redisTemplate.setHashKeySerializer(stringRedisSerializer);
		// 对于 Hash 类型 V 使用 JdkSerializationRedisSerializer 序列化存储(不推荐存储占用空间大)
		redisTemplate.setHashValueSerializer(jdkSerializationRedisSerializer);
		return redisTemplate;
	}
}

三、JedisPool 的使用

最后补充一个用法,不使用 Spring 封装的 API RedisTemplate 操作 Redis,通过 JedisPool 直接获取 Jedis 客户端,然后通过 Jedis 向 Redis 服务端发送指令。代码如下:

	JedisPool jedisPool = new JedisPool(poolConfig, "localhost", Integer.parseInt("6379"), 1800);
	Jedis jedisClient = jedisPool.getResource();

看到这里了应该知道 RedisJedisLettuce 他们三有啥不可告人的关系了吧!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/161305.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

糖果(差分约束+找最小值)

糖果 题目描述 幼儿园里有 n 个小朋友&#xff0c; lxhgww 老师现在想要给这些小朋友们分配糖果&#xff0c;要求每个小朋友都要分到糖果。 但是小朋友们也有嫉妒心&#xff0c;总是会提出一些要求&#xff0c;比如小明不希望小红分到的糖果比他的多&#xff0c;于是在分配糖果…

区块链技术相关概述

第一节区块链技术相关概述一、区块链定义区块链其实就相当于一个去中介化的数据库&#xff0c;是由一串数据块组成的。狭义&#xff1a;区块链是就是一种按照时间顺序来将数据区块以顺序相连的方式组合成的一种链式数据结构&#xff0c;并以密码学方式保证的不可篡改和不可伪造…

WebDAV之葫芦儿·派盘+MiXplorer

MiXplorer 支持WebDAV方式连接葫芦儿派盘。 手机内存不够用了?东西太多清理不过来?快来试试这款MiXplorer。 MiXplorer是一款非常强大实用的手机文档管理器,能给用户提供了一系列的文档处理功能,包括本地文件浏览、文件排序、文件筛选、切换视图、新建文件、添

SSH免密登录配置

情况 服务器A: 192.168.0.101 服务器B: 192.168.0.102 在服务器A上 可以使用 ssh root192.168.0.102 无需密码登录到192.168.0.102 配置 服务器A: 192.168.0.101 上查看是否有ssh公钥 1.进入.ssh目录&#xff1a; cd ~/.ssh 2.找到id_rsa.pub文件&#xff1a; ls 3.查看公钥…

ucos3+emwin+appwizard控制硬件LED

1.新建appwizard项目2.AppWizard 设计器导出代码&#xff0c;点击 File→Export&Save 3.移植代码到keil其中&#xff0c;Soure 和Resource 中的C文件&#xff0c;添加到项目代码Simulation和Soure 和Resource 中的h文件,添加到编译器的include path。修改Source\Generated下…

Docker容器管理常用

Docker容器管理常用docker容器管理命令创建容器进入容器Attach和exec暂停容器删除容器创建容器并在停止时销毁容器查看容器查看容器的详细信息查看容器执行的完整命令查看容器日志查看已退出容器的日志查看容器指定日期的日志修改容器名指定容器实例的主机名容器特权privileged…

从零开始学习Redis

非关系型数据库简述 关系型数据库(SQL)&#xff1a;Mysql,oracle 特点&#xff1a;数据和数据之间、表和字段之间&#xff0c;表和表之间是存在关系的。 优点&#xff1a;数据之间有关系、进行数据的增删改查时非常方便、关系型数据库有事务操作&#xff0c;保证数据的完整性…

离散数学与组合数学-02二元关系

文章目录离散数学与组合数学-02二元关系上2.1 序偶和笛卡尔积2.1.1 有序组的定义2.1.2 笛卡儿积笛卡儿积的性质2.2 关系的定义2.2.1 二元关系定义与案例2.2.2 二元关系的数学符号定义案例枚举二元关系2.2.3 定义域和值域2.2.4 二元关系概念的推广2.3 关系的表示2.3.1 集合表示法…

Swift(1)

前段时间在忙着考试&#xff0c;今天终于线上考试结束了&#xff0c;最后一场考试被安排到开学。 今天来看一下Swift&#xff1a; 首先&#xff0c;Swift是苹果于2014年WWDC苹果开发者大会发布的新开发语言&#xff0c;可与Objective-C共同运行于macOS和iOS平台&#xff0c;用…

CadSoftTools Web CAD SDK 14.1.0.51184 Crack

Web CAD SDK是一个 ASP.NET 控件&#xff0c;用于在Internet、Intranet、SharePoint、Office 365 和其他支持 HTML5 的在线技术上 查看DWG和其他CAD 文件。该产品不需要安装AutoCAD或其他第三方应用程序或组件&#xff0c;并随 C# 示例一起提供。 格式 CAD 格式&#xff1a; A…

克里金法学习笔记

目录1.Arcmap克里金法的工作原理&#xff1a;2.Kriging From Wikipedia:[https://en.wikipedia.org/wiki/Kriging](https://en.wikipedia.org/wiki/Kriging)3.实例分析4.代码部分5.较好的案例1.Arcmap克里金法的工作原理&#xff1a; https://desktop.arcgis.com/zh-cn/arcmap…

Android so库开发——使用addr2line查看so异常信息(四)

在NDK开发中经常会出现应用Crash的情况&#xff0c;而JNI层的报错信息&#xff0c;不像Java层报错信息那样可以直接在日志中看到错误的行数&#xff0c;JNI层中出现的错误直接看根本定位不到错误的位置。通常来说&#xff0c;JNI报的基本都是堆栈信息&#xff0c;需要NDK的一些…

时序数据库TDengine建模思路

一、时序数据库基本概念 基本属性 1.采集量 采集量是指传感器、设备或其他类型采集点采集的物理量&#xff0c;比如电流、电压、温度、压力、GPS 位置等&#xff0c;是随时间变化的参数 2.标签 标签是指传感器、设备或其他类型采集点的静态属性&#xff0c;不是随时间变化的…

纯 CSS3 卡通小火车行驶动画

自从CSS3流行以来&#xff0c;基于纯CSS3的动画就层出不穷&#xff0c;有纯CSS3的人物动画、纯CSS3按钮动画等。这次&#xff0c;我们给大家分享一个很不错的CSS3卡通火车沿轨道行驶动画&#xff0c;一辆卡通样式的火车缓缓驰过&#xff0c;特别是火车头的动画设计&#xff0c;…

二叉树21:合并二叉树

主要是我自己刷题的一些记录过程。如果有错可以指出哦&#xff0c;大家一起进步。 转载代码随想录 原文链接&#xff1a; 代码随想录 leetcode链接&#xff1a;617. 合并二叉树 题目&#xff1a; 给你两棵二叉树&#xff1a; root1 和 root2 。 想象一下&#xff0c;当你将其…

Vuex状态管理

Vuex&#xff1a;管理组件中共用的一些状态&#xff0c;并能够做一些操作 一、准备工作 安装Vuex ① 默认安装vuex4版本&#xff1a;执行命令 npm install vuex ② 指定安装vuex3版本&#xff1a;执行命令 npm install vuex3 引入Vuex 在src目录下新建名称为store的文件夹&am…

微信小程序wxss相关介绍、全局配置和tabbar知识以及发送数据请求(post,get)

wxss相关介绍 什么是wxss??? wxss (WeiXin Style Sheets)是一套样式语言&#xff0c;用于美化WXML的组件样式&#xff0c;类似于网页开发中的CSS。 WXSS 具有CSS大部分特性&#xff0c;同时&#xff0c;WXSS还对CSS进行了扩充以及修改&#xff0c;以适应微信小程序的开发。 …

数据探索性分析(EDA)——不平衡样本处理

1、何为不平衡样本&#xff1f; 样本不平衡是指分类任务中不同类别的训练样例数目差别很大的情况。在实际的分类任务中&#xff0c;我们经常会遇到类别不平衡&#xff0c;例如广告点击率预测、情感分类、异常检测等。而机器学习算法通常假设不同类别的样本数量大致相似&#x…

【4】k8s_NameSpacePod

目录 一、NameSpace 二、Pod 【1】命令式对象管理: 直接使用命令去操作kubernetes资源 【2】命令式对象配置: 通过命令配置和配置文件去操作作kubernetes资源 1、写一个ymal文件 2、然后运行yaml文件&#xff08;提前创建好了命名空间string&#xff09; 3、用bashboard创…

案例分享|方形锂电池铝壳外观缺陷检测

SNE Research最新披露的数据显示&#xff0c;2022年1-11月&#xff0c;宁德时代、比亚迪和中航锂电三家中国企业合计占全球动力电池市场份额的54.7%&#xff0c;排名前十的动力电池企业中&#xff0c;中国企业占据6席&#xff0c;合计市场份额达到64.5%。随着动力电池企业的强势…