Redis学习2——SpringBoot整合Redis，Redis工具类

依赖和配置

pom.xml

SpringBoot整合Redis，需要引入spring-boot-starter-data-redis依赖

  <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>

当我们需要配置redis的连接池时，还需要引入commons-pool2依赖

 <dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency>
application.yml配置
spring:redis:host: 127.0.0.1port: 6379database: 0jedis:pool:max-idle: 8max-active: 8min-idle: 0

这里的jedis指的是使用jedis客户端，这里也可以将jedis改为lettuce，表示使用lettuce客户端，客户端下面的pool表示的是连接池的相关配置。
上述的配置针对的是单机redis配置，如果使用的是集群，配置如下：

spring:redis:password: 123456cluster:nodes: 10.255.144.115:7001,10.255.144.115:7002,10.255.144.115:7003,10.255.144.115:7004,10.255.144.115:7005,10.255.144.115:7006max-redirects: 3

RedisTemplate

上述的配置完毕后，我们就可以在项目中操作redis了，操作的时候，可以直接使用spring-boot-starter-data-redis为我们提供的RedisTemplate这个类，也可以使用StringRedisTemplate，两者的方法基本一致，后者可以看作RedisTemplate<String, String> 。
在上一节中，提到，Redis有多种数据类型，比如string、list、hash、set、zset等，这些类型的操作在RedisTemplate分别对应opsForValue(), opsForList(), opsForHash(), opsForSet(), opsForZSet()。
具体的操作演示如下：


@SpringBootTest
public class RedisAppTest {@Autowiredprivate RedisTemplate<String, String> redisTemplate;@Testpublic void testGet() {System.out.println("字符串操作=================");redisTemplate.opsForValue().set("name", "cxy");System.out.println(redisTemplate.opsForValue().get("name"));System.out.println("列表操作");redisTemplate.opsForList().leftPush("school", "华南理工大学");redisTemplate.opsForList().leftPush("school", "中山大学");redisTemplate.opsForList().leftPush("school", "华南农业大学");List<String> school = redisTemplate.opsForList().range("school", 0, 5);for (String s : school) {System.out.print(s + " ");}System.out.println();System.out.println("hash操作");redisTemplate.opsForHash().put("student", "name", "cxy");redisTemplate.opsForHash().put("student", "age", "21");redisTemplate.opsForHash().put("student", "sex", "male");System.out.println(redisTemplate.opsForHash().get("student", "name"));System.out.println(redisTemplate.opsForHash().get("student", "age"));System.out.println(redisTemplate.opsForHash().get("student", "sex"));System.out.println("set操作");redisTemplate.opsForSet().add("project", "软件工程", "计算机技术", "通信工程", "软件工程");Set<String> project = redisTemplate.opsForSet().members("project");for (String s : project) {System.out.print(s + " ");}System.out.println();System.out.println("zset操作");redisTemplate.opsForZSet().add("movie", "热辣滚烫", 2.7d);redisTemplate.opsForZSet().add("movie", "飞驰人生", 9.1d);redisTemplate.opsForZSet().add("movie", "熊出没之逆转时空", 9.3d);redisTemplate.opsForZSet().add("movie", "二十一条", 8.2d);Set<String> movie = redisTemplate.opsForZSet().rangeByScore("movie", 3.0d, 9.3d);for (String s : movie) {System.out.print(s + " ");}System.out.println();System.out.println("基数操作");redisTemplate.opsForHyperLogLog().add("accessIp", "127.0.0.1");redisTemplate.opsForHyperLogLog().add("accessIp", "192.168.10.1");redisTemplate.opsForHyperLogLog().add("accessIp", "192.168.0.1");redisTemplate.opsForHyperLogLog().add("accessIp", "33.45.23.1");System.out.println(redisTemplate.opsForHyperLogLog().size("accessIp"));}}

运行结果如下：
image.png

RedisUtils工具类

虽然RedisTemplate提供的redis操作很全面，但对于不了解redis的开发同学来说，直接看RedisTemplate的方法不够见名知义，因此一般情况下，我们都会单独封装一个工具类，将常用的一些方法进行抽象，以方便后续使用。
创建Redis配置类，配置RedisTemplate

@Configuration
public class RedisConfiguration {@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);return redisTemplate;}
}

工具类代码如下：

package org.example.util;import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.stereotype.Component;import java.util.*;
import java.util.concurrent.TimeUnit;@Component
public class RedisUtils {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;public boolean removeKey(String key) {return redisTemplate.delete(key);}public boolean hasKey(String key) {if (StringUtils.isEmpty(key)) {return false;}return redisTemplate.hasKey(key);}public boolean expire(String key, long time) {return expire(key, time, TimeUnit.SECONDS);}public boolean expire(String key, long time, TimeUnit timeUnit) {if (StringUtils.isEmpty(key)) {return false;}return redisTemplate.expire(key, time, timeUnit);}public void addKey(String key, Object value, long time) {addKey(key, value, time, TimeUnit.SECONDS);}public void addKey(String key, Object value, long time, TimeUnit timeUnit) {if (StringUtils.isEmpty(key)) {return;}redisTemplate.opsForValue().set(key, value, time, timeUnit);}public void addKey(String key, Object value) {redisTemplate.opsForValue().set(key, value);}public Object getKey(String key) {if (StringUtils.isEmpty(key)) {return null;}return redisTemplate.opsForValue().get(key);}public void increment(String key) {increment(key, 1L);}public void increment(String key, long delta) {if (StringUtils.isEmpty(key)) {return;}redisTemplate.opsForValue().increment(key, delta);}public void decrement(String key) {decrement(key, 1L);}public void decrement(String key, long delta) {if (StringUtils.isEmpty(key)) {return;}redisTemplate.opsForValue().decrement(key, delta);}public void leftPush(String key, List<Object> values) {if (StringUtils.isEmpty(key)) {return;}redisTemplate.opsForList().leftPushAll(key, values);}public void leftPush(String key, Object... value) {if (StringUtils.isEmpty(key)) {return;}redisTemplate.opsForList().leftPushAll(key, value);}public Object leftPop(String key) {if (StringUtils.isEmpty(key)) {return null;}return redisTemplate.opsForList().leftPop(key);}public List<Object> range(String key, long start, long end) {if (StringUtils.isEmpty(key)) {return new ArrayList<>();}return redisTemplate.opsForList().range(key, start, end);}public Object indexOfList(String key, int index) {if (StringUtils.isEmpty(key)) {return null;}return redisTemplate.opsForList().index(key, index);}public void addHash(String key, Map<String, Object> map) {if (StringUtils.isEmpty(key)) {return;}if (map == null || map.isEmpty()) {return;}map.forEach((field, value) -> {redisTemplate.opsForHash().put(key, field, value);});}public void addField(String key, String field, Object value) {if (StringUtils.isEmpty(key) || StringUtils.isEmpty(field)) {return;}redisTemplate.opsForHash().put(key, field, value);}public void removeField(String key, String field) {if (StringUtils.isEmpty(key) || StringUtils.isEmpty(field)) {return;}redisTemplate.opsForHash().delete(key, field);}public Map<String, Object> getEntries(String key) {if (StringUtils.isEmpty(key)) {return new HashMap<>();}Map<Object, Object> entries = redisTemplate.opsForHash().entries(key);Map<String, Object> result = new HashMap<>();entries.forEach((k, v) -> {result.put(k.toString(), v);});return result;}public Object getField(String key, String field) {if (StringUtils.isEmpty(key) || StringUtils.isEmpty(field)) {return null;}return redisTemplate.opsForHash().get(key, field);}public Boolean hasField(String key, String field) {if (StringUtils.isEmpty(key) || StringUtils.isEmpty(field)) {return false;}return redisTemplate.opsForHash().hasKey(key, field);}public void addSet(String key, String... value) {if (StringUtils.isEmpty(key)) {return;}redisTemplate.opsForSet().add(key, value);}public Set<Object> members(String key) {if (StringUtils.isEmpty(key)) {return new HashSet<>();}return redisTemplate.opsForSet().members(key);}public Boolean isMember(String key, Object value) {if (StringUtils.isEmpty(key)) {return false;}return redisTemplate.opsForSet().isMember(key, value);}public void addZSet(String key, Object value, Double score) {if (StringUtils.isEmpty(key)) {return;}redisTemplate.opsForZSet().add(key, value, score);}public Set<Object> rangeByScore(String key, Double min, Double max) {if (StringUtils.isEmpty(key)) {return new HashSet<>();}return redisTemplate.opsForZSet().rangeByScore(key, min, max);}public Set<ZSetOperations.TypedTuple<Object>> rangeByScoreWithScore(String key, Double min, Double max) {if (StringUtils.isEmpty(key)) {return new HashSet<>();}return redisTemplate.opsForZSet().rangeByScoreWithScores(key, min, max);}public void addHyperLogLog(String key, Object... value) {if (StringUtils.isEmpty(key)) {return;}redisTemplate.opsForHyperLogLog().add(key, value);}public void addHyperLogLog(String key, List value) {if (StringUtils.isEmpty(key)) {return;}redisTemplate.opsForHyperLogLog().add(key, value);}public Long countHyperLogLog(String key) {if (StringUtils.isEmpty(key)) {return 0L;}return redisTemplate.opsForHyperLogLog().size(key);}
}

修改之前的测试代码，将redisTemplate，改为我们的工具类

@Autowiredprivate RedisUtils redisUtils;@Testpublic void testRedisUtils() {System.out.println("字符串操作=================");redisUtils.addKey("name", "cxy");System.out.println(redisUtils.getKey("name"));System.out.println("列表操作");redisUtils.leftPush("school", "华南理工大学");redisUtils.leftPush("school", "中山大学");redisUtils.leftPush("school", "华南农业大学");List<Object> school = redisUtils.range("school", 0, 5);for (Object s : school) {System.out.print(s + " ");}System.out.println();System.out.println("hash操作");redisUtils.addField("student", "name", "cxy");redisUtils.addField("student", "age", "21");redisUtils.addField("student", "sex", "male");System.out.println(redisUtils.getField("student", "name"));System.out.println(redisUtils.getField("student", "age"));System.out.println(redisUtils.getField("student", "sex"));System.out.println("set操作");redisUtils.addSet("project", "软件工程", "计算机技术", "通信工程", "软件工程");Set<Object> project = redisUtils.members("project");for (Object s : project) {System.out.print(s + " ");}System.out.println();System.out.println("zset操作");redisUtils.addZSet("movie", "热辣滚烫", 2.7d);redisUtils.addZSet("movie", "飞驰人生", 9.1d);redisUtils.addZSet("movie", "熊出没之逆转时空", 9.3d);redisUtils.addZSet("movie", "二十一条", 8.2d);Set<Object> movie = redisUtils.rangeByScore("movie", 3.0d, 9.3d);for (Object s : movie) {System.out.print(s + " ");}System.out.println();System.out.println("基数操作");redisUtils.addHyperLogLog("accessIp", "127.0.0.1");redisUtils.addHyperLogLog("accessIp", "192.168.10.1");redisUtils.addHyperLogLog("accessIp", "192.168.0.1");redisUtils.addHyperLogLog("accessIp", "33.45.23.1");System.out.println(redisUtils.countHyperLogLog("accessIp"));}

在测试之前，先删除之前添加的数据
image.png
测试结果如下：
image.png

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

stm32_RTC_2_HAL——stm32CudeMX

stm32_RTC_2_HAL——stm32CudeMX

介绍 RTC&#xff08;实时时钟&#xff09;不仅仅提供计数功能&#xff0c;它是一个完整的时钟和日历模块&#xff0c;用于提供日期和时间信息。RTC 能够提供年、月、日、星期、时、分、秒等时间信息&#xff0c;并且通常具有闹钟功能&#xff0c;可以用于定时唤醒或触发事件。…
阅读更多...
C++学习第十二天（继承）

C++学习第十二天（继承）

1、继承的概念以及定义 继承的概念 继承机制是面向对象程序设计使代码可以复用的最重要的手段&#xff0c;它允许程序员在保持原有类特性的基础上进行拓展&#xff0c;增加功能&#xff0c;这样产生新的类&#xff0c;称派生类。继承呈现了面向对象程序设计的层次结构&#x…
阅读更多...
STM32F103学习笔记 | 报错界面及解决方案 | 1.keil5中文注释的横竖（正与斜）问题

STM32F103学习笔记 | 报错界面及解决方案 | 1.keil5中文注释的横竖（正与斜）问题

文章目录 一、报错界面二、解决方案参考文献 一、报错界面 二、解决方案 打开设置 在打开的设置选项卡中&#xff0c;图中Font显示的是这个软件当前设置的字体&#xff0c;可以看到字体是仿宋&#xff0c;这就是问题出现的原因&#xff0c;将之改成没有的字体就行了。 可以看…
阅读更多...
用FPGA+DAC输出“心”形波

用FPGA+DAC输出“心”形波

1.前言 之前在做信号处理的时候整了一下活&#xff0c;用FPGADAC&#xff08;数模转换器&#xff09;&#xff0c;输出了一个爱心形状的波形&#xff0c;今天整理资料的时候偶然发现了他&#xff0c;现在把他分享出来。当时将DAC的输出接在示波器上显示如下图所示&#xff1a; …
阅读更多...
Docker使用进阶篇

Docker使用进阶篇

文章目录 1 前言2 使用Docker安装常用镜像示例2.1 Docker安装RabbitMQ2.2 Docker安装Nacos2.3 Docker安装xxl-job&#xff08;推荐该方式构建&#xff09;2.4 Docker安装redis2.5 Docker安装mysql 3 Docker自定义镜像3.1 Dockerfile的基本结构3.2 Dockerfile指令3.3 自定义JDK镜…
阅读更多...
Flutter笔记：手动配置VSCode中Dart代码自动格式化

Flutter笔记：手动配置VSCode中Dart代码自动格式化

Flutter笔记 手动配置VSCode中Dart代码自动格式化 - 文章信息 - Author: 李俊才 (jcLee95) Visit me at CSDN: https://jclee95.blog.csdn.netMy WebSite&#xff1a;http://thispage.tech/Email: 291148484163.com. Shenzhen ChinaAddress of this article:https://blog.csd…
阅读更多...
数据结构学习——线性表、顺序表

数据结构学习——线性表、顺序表

1.线性表 线性表 &#xff08; linear list &#xff09; 是n个具有相同特性的数据元素的有限序列。 线性表是一种在实际中广泛使 用的数据结构&#xff0c;常见的线性表&#xff1a;顺序表、链表、栈、队列、字符串… 线性表在逻辑上是线性结构&#xff0c;也就说是连续的一…
阅读更多...
在WPS表格（Excel）中，每10行增加一个特定的值

在WPS表格（Excel）中，每10行增加一个特定的值

注&#xff1a;如下为WPS表格操作演示 例如1&#xff0d;15的数值是1&#xff0c;16-30就变为2&#xff0c;31-45就变为3&#xff0c;类推&#xff01; 1、在B1单元格输入一个起始值&#xff0c;B2单元格输入公式IF(MOD(ROW(),15)0,B11,B1) 然后鼠标放到B2单元格右下角小点处&…
阅读更多...
利用生成式AI重新构想ITSM的未来

利用生成式AI重新构想ITSM的未来

对注入 AI 的生成式 ITSM 的需求&#xff0c;在 2023 年 Gartner AI 炒作周期中&#xff0c;生成式 AI 达到预期值达到顶峰后&#xff0c;三分之二的企业已经将生成式 AI 集成到其流程中。 你问为什么这种追求&#xff1f;在预定义算法的驱动下&#xff0c;IT 服务交付和管理中…
阅读更多...
第七届机电、机器人与自动化国际会议（ICMRA 2024）即将召开！

第七届机电、机器人与自动化国际会议（ICMRA 2024）即将召开！

第七届机电、机器人与自动化国际会议&#xff08;ICMRA 2024&#xff09;将于2024年9月20日-22日在中国武汉举行。ICMRA 2024为各国专家学者提供一个学术交流的平台&#xff0c;讨论机电、机器人和自动化领域的最新研究成果和未来的研究方向&#xff0c;旨在能够建立起国家间&a…
阅读更多...
Ansible剧本playbook之--------Templates 模块、roles角色详细解读

Ansible剧本playbook之--------Templates 模块、roles角色详细解读

目录 一、Templates 模块 1.1准备模板文件并设置引用的变量 1.2修改主机清单文件&#xff0c;使用主机变量定义一个变量名相同&#xff0c;而值不同的变量 1.3编写 playbook 1.4ansible主机远程查看修改参数 1.5验证 二、tags 模块 always应用 三、Roles 模块 3.1ro…
阅读更多...
在国企分公司做信息宣传新闻投稿的经验分享

在国企分公司做信息宣传新闻投稿的经验分享

作为一名国企分公司的信息宣传工作者,我亲历了从传统投稿方式到数字化转型的全过程,这段经历既充满了挑战,也收获了成长。回首最初的日子,那些用邮箱投稿的时光,至今仍让我感慨万千。 初尝辛酸,邮箱投稿的艰难岁月 刚接手信息宣传工作时,我满腔热情,却很快被现实的冷水浇了个透…
阅读更多...
RabbitMQ的五种模式

RabbitMQ的五种模式

一、简单模式 简单模式&#xff08;Simple&#xff09;&#xff1a;一个生产者&#xff0c;一个消费者 package com.qiangesoft.rabbitmq.mode.simple;import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.annotation.Queue; import org.springframe…
阅读更多...
事业单位向媒体投稿发文章上级领导交给了我投稿方法

事业单位向媒体投稿发文章上级领导交给了我投稿方法

作为一名事业单位的普通职员,负责信息宣传工作,我见证了从传统投稿方式到智能化转型的全过程,这段旅程既是一次挑战,也是一次宝贵的成长。回想起初涉此领域的日子,那些通过邮箱投稿的时光,至今仍然历历在目,其中的酸甜苦辣,构成了我职业生涯中一段难忘的经历。 邮箱投稿:费时费…
阅读更多...
C++从入门到精通---模版

C++从入门到精通---模版

文章目录 泛型编程函数模版模版参数的匹配原则类模版类模版的定义格式类模版的实例化 总结 泛型编程 泛型编程是一种编程范式&#xff0c;旨在实现通用性和灵活性。它允许在编写代码时使用参数化类型&#xff0c;而不是具体的类型&#xff0c;从而使代码更加灵活和可重用。 在…
阅读更多...
spring ioc 容器加载过程 refresh() 方法详解

spring ioc 容器加载过程 refresh() 方法详解

IOC 加载过程 从 new ClassPathXmlApplicationContext开始 ApplicationContext context new ClassPathXmlApplicationContext("classpath:application.xml");ClassPathXmlApplicationContext类构造方法 public ClassPathXmlApplicationContext(String[] configLo…
阅读更多...
Redis集群分片

Redis集群分片

什么是集群 集群是由多个复制集组成的,能提供在多个redis节点间共享数据的程序集 简而言之就是将原来的单master主机拆分为多个master主机,将整个数据集分配到各主机上 集群的作用 集群中可以存在多个master,而每个master可以挂载多个slave自带哨兵的故障转移机制,不需要再去…
阅读更多...
Python解释器3.8.2版本安装详细教程

Python解释器3.8.2版本安装详细教程

Python解释器提取链接链接&#xff1a; https://pan.baidu.com/s/1eDvwYmUJ4l7kIBXewtN4EA?pwd1111 提取码&#xff1a;1111 演示版本为3.6.8&#xff0c;链接安装包为3.8.2版&#xff0c;包中附加pytharm安装包。 1.双击提取好的python-exe安装文件&#xff0c;会…
阅读更多...
外企接受大龄程序员吗？

外企接受大龄程序员吗？

本人知乎账号同公众号&#xff1a;老胡聊Java&#xff0c;欢迎留言并咨询 亲身体会外企经历所见所闻&#xff0c;外企能接受大龄程序员。 1 大概是10年的时候&#xff0c;进一家知名外企&#xff0c;和我一起进的一位manager&#xff0c;后来听下来&#xff0c;年龄35&#xf…
阅读更多...
0508_IO3

0508_IO3

练习1&#xff1a; 1&#xff1a;使用 dup2 实现错误日志功能 使用 write 和 read 实现文件的拷贝功能&#xff0c;注意&#xff0c;代码中所有函数后面&#xff0c;紧跟perror输出错误信息&#xff0c;要求这些错误信息重定向到错误日志 err.txt 中去 1 #include <stdio.h…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023