Spring整合Redis基本操作步骤

Spring 整合 Redis 操作步骤总结

1. 添加依赖

首先,在 pom.xml 文件中添加必要的 Maven 依赖。Redis 相关的依赖包括 Spring Boot 的 Redis 启动器和 fastjson(如果需要使用 Fastjson 作为序列化工具):

<!-- Spring Boot Redis Starter -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency><!-- Fastjson (用于 JSON 序列化和反序列化) -->
<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId>
</dependency>
2. 配置 Redis 连接信息

application.ymlapplication.properties 中配置 Redis 连接信息。以下是 application.yml 配置示例:

spring:redis:host: 127.0.0.1port: 6379database: 0jedis:pool:max-active: 20max-wait: -1max-idle: 10min-idle: 0timeout: 2000
3. 配置 Redis 数据源连接池

如果使用连接池(例如 HikariCP),你可以在 application.yml 中配置数据源连接池的参数。Spring Boot 默认会使用 HikariCP 连接池。

spring:datasource:url: jdbc:mysql://127.0.0.1:3306/easylive?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQueries=true&useSSL=falseusername: rootpassword: 123456driver-class-name: com.mysql.cj.jdbc.Driverhikari:pool-name: HikariCPDatasourceminimum-idle: 5idle-timeout: 180000maximum-pool-size: 10auto-commit: truemax-lifetime: 1800000connection-timeout: 30000connection-test-query: SELECT 1
4. 创建 Redis 配置类

在 Spring Boot 中配置 RedisTemplateRedisMessageListenerContainer。以下是一个基本的 RedisConfig 类,它用于配置 Redis 连接、序列化方式等。

@Configuration
public class RedisConfig<V> {private static final Logger logger = LoggerFactory.getLogger(RedisConfig.class);// 配置 RedisTemplate@Bean("redisTemplate")public RedisTemplate<String, V> redisTemplate(RedisConnectionFactory factory) {RedisTemplate<String, V> template = new RedisTemplate<>();template.setConnectionFactory(factory);// 设置 key 和 value 的序列化方式template.setKeySerializer(RedisSerializer.string());template.setValueSerializer(RedisSerializer.json());template.setHashKeySerializer(RedisSerializer.string());template.setHashValueSerializer(RedisSerializer.json());template.afterPropertiesSet();return template;}// 配置 Redis 消息监听容器@Beanpublic RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);return container;}
}
5. 使用 RedisTemplate 执行 Redis 操作

RedisTemplate 是 Spring Data Redis 提供的核心工具,用于执行 Redis 操作。以下是如何使用 RedisTemplate 进行 Redis 数据的基本操作。

@Service
public class RedisService {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;// 保存数据public void save(String key, Object value) {redisTemplate.opsForValue().set(key, value);}// 获取数据public Object get(String key) {return redisTemplate.opsForValue().get(key);}// 删除数据public void delete(String key) {redisTemplate.delete(key);}// 使用 Hash 存储数据public void saveHash(String hashKey, String key, Object value) {redisTemplate.opsForHash().put(hashKey, key, value);}public Object getHash(String hashKey, String key) {return redisTemplate.opsForHash().get(hashKey, key);}
}
6. Fastjson 作为序列化工具(可选)

如果你想使用 Fastjson 作为 Redis 数据的序列化和反序列化工具,可以在 RedisConfig 中配置:

@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(factory);// 使用 Fastjson 序列化template.setValueSerializer(new FastJsonRedisSerializer<>(Object.class));template.setHashValueSerializer(new FastJsonRedisSerializer<>(Object.class));template.afterPropertiesSet();return template;
}
7. 配置 Redis 消息监听器(可选)

如果你需要实现 Redis 发布/订阅功能,可以配置 RedisMessageListenerContainer 来监听 Redis 频道。

@Service
public class RedisListenerService {@Autowiredprivate RedisMessageListenerContainer container;public void subscribe(String channel) {MessageListener listener = message -> {String messageBody = new String(message.getBody());System.out.println("Received message: " + messageBody);};container.addMessageListener(listener, new ChannelTopic(channel));}
}
8. Redis 操作的示例

保存数据到 Redis

redisService.save("username", "john_doe");

获取 Redis 中的数据

String username = (String) redisService.get("username");

删除 Redis 中的数据

redisService.delete("username");
9. 总结

通过以上步骤,你已经成功将 Redis 集成到 Spring Boot 项目中,主要包括:

  • 配置 Redis 连接和连接池。
  • 配置 RedisTemplate 和使用序列化工具(如 Fastjson)。
  • 使用 RedisTemplate 执行常见的 Redis 操作(如 set/get)。
  • 配置 Redis 消息监听器实现发布/订阅功能(可选)。

此方案提供了高效的 Redis 集成方式,可以支持缓存、消息队列、发布/订阅等常见使用场景。

封装工具类

package com.easylive.redis;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;import javax.annotation.Resource;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;@Component("redisUtils")
public class RedisUtils<V> {@Resourceprivate RedisTemplate<String, V> redisTemplate;private static final Logger logger = LoggerFactory.getLogger(RedisUtils.class);/*** 删除缓存** @param key 可以传一个值 或多个*/public void delete(String... key) {if (key != null && key.length > 0) {if (key.length == 1) {redisTemplate.delete(key[0]);} else {redisTemplate.delete((Collection<String>) CollectionUtils.arrayToList(key));}}}public V get(String key) {return key == null ? null : redisTemplate.opsForValue().get(key);}/*** 普通缓存放入** @param key   键* @param value 值* @return true成功 false失败*/public boolean set(String key, V value) {try {redisTemplate.opsForValue().set(key, value);return true;} catch (Exception e) {logger.error("设置redisKey:{},value:{}失败", key, value);return false;}}public boolean keyExists(String key) {return redisTemplate.hasKey(key);}/*** 普通缓存放入并设置时间** @param key   键* @param value 值* @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期* @return true成功 false 失败*/public boolean setex(String key, V value, long time) {try {if (time > 0) {redisTemplate.opsForValue().set(key, value, time, TimeUnit.MILLISECONDS);} else {set(key, value);}return true;} catch (Exception e) {logger.error("设置redisKey:{},value:{}失败", key, value);return false;}}public boolean expire(String key, long time) {try {if (time > 0) {redisTemplate.expire(key, time, TimeUnit.MILLISECONDS);}return true;} catch (Exception e) {e.printStackTrace();return false;}}public List<V> getQueueList(String key) {return redisTemplate.opsForList().range(key, 0, -1);}public boolean lpush(String key, V value, Long time) {try {redisTemplate.opsForList().leftPush(key, value);if (time != null && time > 0) {expire(key, time);}return true;} catch (Exception e) {e.printStackTrace();return false;}}public long remove(String key, Object value) {try {Long remove = redisTemplate.opsForList().remove(key, 1, value);return remove;} catch (Exception e) {e.printStackTrace();return 0;}}public boolean lpushAll(String key, List<V> values, long time) {try {redisTemplate.opsForList().leftPushAll(key, values);if (time > 0) {expire(key, time);}return true;} catch (Exception e) {e.printStackTrace();return false;}}public V rpop(String key) {try {return redisTemplate.opsForList().rightPop(key);} catch (Exception e) {e.printStackTrace();return null;}}public Long increment(String key) {Long count = redisTemplate.opsForValue().increment(key, 1);return count;}public Long incrementex(String key, long milliseconds) {Long count = redisTemplate.opsForValue().increment(key, 1);if (count == 1) {//设置过期时间1天expire(key, milliseconds);}return count;}public Long decrement(String key) {Long count = redisTemplate.opsForValue().increment(key, -1);if (count <= 0) {redisTemplate.delete(key);}logger.info("key:{},减少数量{}", key, count);return count;}public Set<String> getByKeyPrefix(String keyPrifix) {Set<String> keyList = redisTemplate.keys(keyPrifix + "*");return keyList;}public Map<String, V> getBatch(String keyPrifix) {Set<String> keySet = redisTemplate.keys(keyPrifix + "*");List<String> keyList = new ArrayList<>(keySet);List<V> keyValueList = redisTemplate.opsForValue().multiGet(keyList);Map<String, V> resultMap = keyList.stream().collect(Collectors.toMap(key -> key, value -> keyValueList.get(keyList.indexOf(value))));return resultMap;}public void zaddCount(String key, V v) {redisTemplate.opsForZSet().incrementScore(key, v, 1);}public List<V> getZSetList(String key, Integer count) {Set<V> topElements = redisTemplate.opsForZSet().reverseRange(key, 0, count);List<V> list = new ArrayList<>(topElements);return list;}}

这个 RedisUtils 类是一个通用的 Redis 工具类,封装了对 Redis 的常见操作,方便在项目中进行缓存处理、队列操作等。下面详细解释每个方法的功能。

1. delete 方法

public void delete(String... key) {if (key != null && key.length > 0) {if (key.length == 1) {redisTemplate.delete(key[0]);} else {redisTemplate.delete((Collection<String>) CollectionUtils.arrayToList(key));}}
}
  • 功能:删除指定的 Redis 键,可以一次删除一个或多个键。
  • 参数key:一个或多个 Redis 键名。
  • 实现
    • 如果只有一个键,调用 redisTemplate.delete(key[0]) 删除该键。
    • 如果有多个键,先将它们转换成一个 List,然后调用 redisTemplate.delete() 删除多个键。

2. get 方法

public V get(String key) {return key == null ? null : redisTemplate.opsForValue().get(key);
}
  • 功能:从 Redis 中获取指定键的值。
  • 参数key:Redis 键名。
  • 返回:键对应的值,如果键为空则返回 null
  • 实现:调用 redisTemplate.opsForValue().get(key) 获取 Redis 中保存的值。

3. set 方法

public boolean set(String key, V value) {try {redisTemplate.opsForValue().set(key, value);return true;} catch (Exception e) {logger.error("设置redisKey:{},value:{}失败", key, value);return false;}
}
  • 功能:将数据保存到 Redis 中,使用键值对存储。
  • 参数key:Redis 键名,value:要保存的值。
  • 返回:如果成功保存,返回 true,否则返回 false
  • 实现:调用 redisTemplate.opsForValue().set(key, value) 保存数据,如果发生异常则返回 false 并记录日志。

4. keyExists 方法

public boolean keyExists(String key) {return redisTemplate.hasKey(key);
}
  • 功能:检查 Redis 中是否存在指定的键。
  • 参数key:Redis 键名。
  • 返回:如果键存在返回 true,否则返回 false
  • 实现:调用 redisTemplate.hasKey(key) 检查键是否存在。

5. setex 方法

public boolean setex(String key, V value, long time) {try {if (time > 0) {redisTemplate.opsForValue().set(key, value, time, TimeUnit.MILLISECONDS);} else {set(key, value);}return true;} catch (Exception e) {logger.error("设置redisKey:{},value:{}失败", key, value);return false;}
}
  • 功能:将数据保存到 Redis 中,并设置过期时间。
  • 参数key:Redis 键名,value:要保存的值,time:过期时间,单位为毫秒。
  • 返回:保存成功返回 true,否则返回 false
  • 实现
    • 如果 time > 0,调用 redisTemplate.opsForValue().set(key, value, time, TimeUnit.MILLISECONDS) 保存数据并设置过期时间。
    • 如果 time <= 0,直接调用 set() 方法保存数据。

6. expire 方法

public boolean expire(String key, long time) {try {if (time > 0) {redisTemplate.expire(key, time, TimeUnit.MILLISECONDS);}return true;} catch (Exception e) {e.printStackTrace();return false;}
}
  • 功能:设置 Redis 键的过期时间。
  • 参数key:Redis 键名,time:过期时间,单位为毫秒。
  • 返回:设置成功返回 true,否则返回 false
  • 实现:调用 redisTemplate.expire(key, time, TimeUnit.MILLISECONDS) 设置过期时间。

7. getQueueList 方法

public List<V> getQueueList(String key) {return redisTemplate.opsForList().range(key, 0, -1);
}
  • 功能:获取 Redis 列表(队列)的所有元素。
  • 参数key:Redis 键名。
  • 返回:Redis 列表的所有元素,返回类型是 List<V>
  • 实现:调用 redisTemplate.opsForList().range(key, 0, -1) 获取整个列表。

8. lpush 方法

public boolean lpush(String key, V value, Long time) {try {redisTemplate.opsForList().leftPush(key, value);if (time != null && time > 0) {expire(key, time);}return true;} catch (Exception e) {e.printStackTrace();return false;}
}
  • 功能:将元素插入到 Redis 列表的头部。
  • 参数key:Redis 键名,value:要插入的值,time:可选的过期时间,单位为秒。
  • 返回:插入成功返回 true,否则返回 false
  • 实现
    • 调用 redisTemplate.opsForList().leftPush(key, value) 将元素添加到列表头部。
    • 如果 time > 0,则调用 expire() 方法设置过期时间。

9. remove 方法

public long remove(String key, Object value) {try {Long remove = redisTemplate.opsForList().remove(key, 1, value);return remove;} catch (Exception e) {e.printStackTrace();return 0;}
}
  • 功能:从 Redis 列表中删除指定元素。
  • 参数key:Redis 键名,value:要删除的值。
  • 返回:删除成功返回被删除的元素数量,失败返回 0
  • 实现:调用 redisTemplate.opsForList().remove(key, 1, value) 删除元素。

10. lpushAll 方法

public boolean lpushAll(String key, List<V> values, long time) {try {redisTemplate.opsForList().leftPushAll(key, values);if (time > 0) {expire(key, time);}return true;} catch (Exception e) {e.printStackTrace();return false;}
}
  • 功能:将多个元素插入到 Redis 列表的头部。
  • 参数key:Redis 键名,values:要插入的值列表,time:可选的过期时间,单位为秒。
  • 返回:插入成功返回 true,否则返回 false
  • 实现
    • 调用 redisTemplate.opsForList().leftPushAll(key, values) 将多个元素插入到列表头部。
    • 如果 time > 0,则调用 expire() 方法设置过期时间。

11. rpop 方法

public V rpop(String key) {try {return redisTemplate.opsForList().rightPop(key);} catch (Exception e) {e.printStackTrace();return null;}
}
  • 功能:从 Redis 列表的尾部弹出一个元素。
  • 参数key:Redis 键名。
  • 返回:弹出的元素,如果发生异常则返回 null
  • 实现:调用 redisTemplate.opsForList().rightPop(key) 弹出列表尾部元素。

12. increment 方法

public Long increment(String key) {Long count = redisTemplate.opsForValue().increment(key, 1);return count;
}
  • 功能:将指定键的值增加 1(如果键不存在,则创建并设置为 1)。
  • 参数key:Redis 键名。
  • 返回:增加后的值。
  • 实现:调用 redisTemplate.opsForValue().increment(key, 1) 增加值。

13. incrementex 方法

public Long incrementex(String key, long milliseconds) {Long count = redisTemplate.opsForValue().increment(key, 1);if (count == 1) {expire(key, milliseconds);}return count;
}
  • 功能:将指定键的值增加 1,并在首次设置时设置过期时间。
  • 参数key:Redis 键名,`milliseconds

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

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

相关文章

电商项目-网站首页高可用(二)

一、LUA基本语法 lua有交互式编程和脚本式编程。 交互式编程就是直接输入语法&#xff0c;就能执行。 脚本式编程需要编写脚本文件&#xff0c;然后再执行。 一般采用脚本式编程。&#xff08;例如&#xff1a;编写一个hello.lua的文件&#xff0c;输入文件内容&#xff0c;并执…

flink实现复杂kafka数据读取

接上文&#xff1a;一文说清flink从编码到部署上线 环境说明&#xff1a;MySQL&#xff1a;5.7&#xff1b;flink&#xff1a;1.14.0&#xff1b;hadoop&#xff1a;3.0.0&#xff1b;操作系统&#xff1a;CentOS 7.6&#xff1b;JDK&#xff1a;1.8.0_401。 常见的文章中&…

第十五届蓝桥杯Scratch01月stema选拔赛—排序

排序 具体要求&#xff1a; 1). 点击绿旗&#xff0c;在舞台上出现4张点数不同的扑克牌&#xff0c;牌上的点数是随机的&#xff08;4-9点&#xff09;&#xff0c;如图所示&#xff1b; 完整题目可点击下方链接查看&#xff1a; 排序_scratch_嗨信奥-玩嗨信息奥林匹克竞赛-…

图形学笔记 - 5. 光线追踪2 - 加速结构

目录 使用AABB加速光线追踪 Uniform Spatial Partitions (Grids) 均匀空间划分 空间划分 KD树预处理 KD-Tree数据结构 遍历kd树 对象划分 & Bounding Volume Hierarchy 层次包围盒 BVH BVH遍历 空间划分与物体划分呢 GTC news: DLSS、RTXGI 实时光线追踪 使用AAB…

计算机毕业设计原创定制(免费送源码):NodeJS+MVVM+MySQL 樱花在线视频网站

目 录 摘要 1 1 绪论 1 1.1研究背景 1 1.2系统设计思想 1 1.3B/S体系工作原理 1 1.4node.js主要功能 2 1.5论文结构与章节安排 3 2 樱花在线视频网站分析 4 2.1 可行性分析 4 2.2 系统流程分析 4 2.2.1数据增加流程 5 2.3.2数据修改流程 5 2.3.3数据删除流程 5 …

SpringBoot 启动类 SpringApplication 二 run方法

配置 在Program arguments配置2个参数&#xff1a;--server.port8081 --spring.profiles.activedev。 run方法 run方法执行结束代表SpringBoot启动完成&#xff0c;即完成加载bean。 // ConfigurableApplicationContext 是IOC容器 public ConfigurableApplicationContext ru…

如何调大unity软件的字体

一、解决的问题&#xff1a; unity软件的字体太小&#xff0c;怎么调大点&#xff1f;二、解决方法&#xff1a; 1.操作步骤&#xff1a; 打开Unity编辑器> Edit>preferences> UI Scaling>Use custom scaling value&#xff08;取消勾选“使用默认桌面设置”&…

SYD881X RTC定时器事件在调用timeAppClockSet后会出现比较大的延迟

RTC定时器事件在调用timeAppClockSet后会出现比较大的延迟 这里RTC做了两个定时器一个是12秒,一个是185秒: #define RTCEVT_NUM ((uint8_t) 0x02)//当前定时器事件数#define RTCEVT_12S ((uint32_t) 0x0000002)//定时器1s事件 /*整分钟定时器事件&#xff0c;因为其余的…

内置函数.

日期函数 current_date/time() 日期/时间 获得年月日&#xff1a; 获得时分秒&#xff1a; 获得时间戳&#xff1a;日期时间 now()函数 体会date(datetime)的用法&#xff1a;只显示日期 在日期的基础上加日期&#xff1a;按照日历自动计算 关键字为 intervalinterval 后的数值…

PHP 微信棋牌开发全解析:高级教程

PHP - 多维数组详解 多维数组是 PHP 中一种强大的数据结构&#xff0c;指的是一个数组的元素中可以包含一个或多个数组。它常用于存储复杂的嵌套数据&#xff0c;如表格数据或多层次关系的数据结构。 注释&#xff1a; 数组的维度表示您需要指定索引的层级数&#xff0c;以访问…

【Java】递归算法

递归的本质&#xff1a; 方法调用自身。 案例1. 斐波那契数列 1 1 2 3 5 8 13 21 .. f(n)f(n-1)f(n-2) 方法的返回值&#xff1a; 只要涉及到加减乘除&#xff0c;就是int,其他的就是void。 案例2. 青蛙跳台 青蛙一次可以跳一级台阶&#xff0c;也可以跳两级台阶&#xff…

JVM简介—1.Java内存区域

大纲 1.运行时数据区的介绍 2.运行时数据区各区域的作用 3.各个版本内存区域的变化 4.直接内存的使用和作用 5.站在线程的角度看Java内存区域 6.深入分析堆和栈的区别 7.方法的出入栈和栈上分配、逃逸分析及TLAB 8.虚拟机中的对象创建步骤 9.对象的内存布局 10.对象的…

大腾智能CAD:国产云原生三维设计新选择

在快速发展的工业设计领域&#xff0c;CAD软件已成为不可或缺的核心工具。它通过强大的建模、分析、优化等功能&#xff0c;不仅显著提升了设计效率与精度&#xff0c;还促进了设计思维的创新与拓展&#xff0c;为产品从概念构想到实体制造的全过程提供了强有力的技术支持。然而…

设计模式の享元模板代理模式

文章目录 前言一、享元模式二、模板方法模式三、代理模式3.1、静态代理3.2、JDK动态代理3.3、Cglib动态代理3.4、小结 前言 本篇是关于设计模式中享元模式、模板模式、以及代理模式的学习笔记。 一、享元模式 享元模式是一种结构型设计模式&#xff0c;目的是为了相似对象的复用…

Linux网络功能 - 服务和客户端程序CS架构和简单web服务示例

By: fulinux E-mail: fulinux@sina.com Blog: https://blog.csdn.net/fulinus 喜欢的盆友欢迎点赞和订阅! 你的喜欢就是我写作的动力! 目录 概述准备工作扫描服务端有那些开放端口创建客户端-服务器设置启动服务器和客户端进程双向发送数据保持服务器进程处于活动状态设置最小…

用人话讲计算机:Python篇!(十五)迭代器、生成器、装饰器

一、迭代器 &#xff08;1&#xff09;定义 标准解释&#xff1a;迭代器是 Python 中实现了迭代协议的对象&#xff0c;即提供__iter__()和 __next__()方法&#xff0c;任何实现了这两个方法的对象都可以被称为迭代器。 所谓__iter__()&#xff0c;即返回迭代器自身 所谓__…

小程序快速实现大模型聊天机器人

需求分析&#xff1a; 基于大模型&#xff0c;打造一个聊天机器人&#xff1b;使用开放API快速搭建&#xff0c;例如&#xff1a;讯飞星火&#xff1b;先实现UI展示&#xff0c;在接入API。 最终实现效果如下&#xff1a; 一.聊天机器人UI部分 1. 创建微信小程序&#xff0c…

【Android】unzip aar删除冲突classes再zip

# 解压JAR文件 jar xf your-library.jar # 解压AAR文件&#xff08;AAR实际上是ZIP格式&#xff09; unzip your-library.aar # 删除不需要的类 rm -rf path/to/com/example/unwanted/ # 对于JAR打包 jar cf your-library-modified.jar -C path/to/unzipped/ . # 对于AAR打包…

使用C语言编写UDP循环接收并打印消息的程序

使用C语言编写UDP循环接收并打印消息的程序 前提条件程序概述伪代码C语言实现编译和运行C改进之自由设定端口注意事项在本文中,我们将展示如何使用C语言编写一个简单的UDP服务器程序,该程序将循环接收来自指定端口的UDP消息,并将接收到的消息打印到控制台。我们将使用POSIX套…

你的第一个博客-第一弹

使用 Flask 开发博客 Flask 是一个轻量级的 Web 框架&#xff0c;适合小型应用和学习项目。我们将通过 Flask 开发一个简单的博客系统&#xff0c;支持用户注册、登录、发布文章等功能。 步骤&#xff1a; 安装 Flask 和其他必要库&#xff1a; 在开发博客之前&#xff0c;首…