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.mzph.cn/news/889966.shtml

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

相关文章

底层理论基础(单片机)

计算机基础 IO逻辑 计算机系统中的高低电平逻辑1和0&#xff0c;数据在计算机中的存储、传输、运算都是以二进制形式进行的。 数据的传输通过总线真正传递的是电信号&#xff0c;高低电平&#xff08;0、1&#xff09;。运算在电路中进行&#xff0c;集成电路中运算。 计算机的…

B站bilibili视频转文字字幕下载方法

本文将讲述介绍一种使用本地工具如何快速的下载B站的字幕为本地文本文件的方法。 通常获取B站字幕需要在浏览器中安装第三方插件&#xff0c;通过插件获取字幕。随着大模型&#xff0c;生成式AI&#xff0c;ChatGPT的应用&#xff0c;B站也提供了AI小助手对视频的内容进行总结…

ROS+PX4+Gazebo仿真环境配置全流程解析

上一期文章介绍了我们即将发布的仿真平台&#xff0c;并提到后续需要在Ubuntu系统上进行PX4软件在环仿真。本期文章将为大家详细介绍如何配置Ubuntu环境以及安装ROS和PX4仿真环境。具体配置包括&#xff1a;Ubuntu 20.04 ROS Noetic PX4 Python3。 需要注意的是&#xff0c…

基础入门-APP应用微信小程序原生态开发H5+Vue技术WEB封装打包反编译抓包点

知识点&#xff1a; 1、基础入门-APP应用-开发架构安全问题 2、基础入门-小程序应用-开发架构安全问题 通用&#xff1a; 1、反编译-得到源码-源码提取资产&#xff08;泄漏的配置信息&#xff09;-安全测试 2、抓包-资产-安全测试 一、演示案例-移动App-开发架构-原生&H…

Elasticsearch:使用 Open Crawler 和 semantic text 进行语义搜索

作者&#xff1a;来自 Elastic Jeff Vestal 了解如何使用开放爬虫与 semantic text 字段结合来轻松抓取网站并使其可进行语义搜索。 Elastic Open Crawler 演练 我们在这里要做什么&#xff1f; Elastic Open Crawler 是 Elastic 托管爬虫的后继者。 Semantic text 是 Elasti…

Qt之自定义标题栏拓展(十)

Qt开发 系列文章 - user-defined-titlebars&#xff08;十&#xff09; 目录 前言 一、方式一 1.效果演示 2.创建标题栏类 3.可视化UI设计 4.定义相关函数 5.使用标题栏类 二、方式二 1.效果演示 2.创建标题栏类 3.定义相关函数 4.使用标题栏类 总结 前言 Qt自带…

vue3前端组件库的搭建与发布(一)

前言&#xff1a; 最近在做公司项目中&#xff0c;有这么一件事情&#xff0c;很是头疼&#xff0c;就是同一套代码&#xff0c;不同项目&#xff0c;要改相同bug&#xff0c;改好多遍&#xff0c;改的都想吐&#xff0c;于是就想做一个组件库&#xff0c;这样更新一下就全都可…

学技术学英文:代码中的锁:悲观锁和乐观锁

本文导读&#xff1a; 1. 举例说明加锁的场景&#xff1a; 多线程并发情况下有资源竞争的时候&#xff0c;如果不加锁&#xff0c;会出现数据错误&#xff0c;举例说明&#xff1a; 业务需求&#xff1a;账户余额>取款金额&#xff0c;才能取钱。 时间线 两人共有账户 …

Qt编译MySQL数据库驱动

目录 Qt编译MySQL数据库驱动 测试程序 Qt编译MySQL数据库驱动 &#xff08;1&#xff09;先找到MySQL安装路径以及Qt安装路径 C:\Program Files\MySQL\MySQL Server 8.0 D:\qt\5.12.12 &#xff08;2&#xff09;在D:\qt\5.12.12\Src\qtbase\src\plugins\sqldrivers\mysql下…

CTFHUB-web(SSRF)

内网访问 点击进入环境&#xff0c;输入 http://127.0.0.1/flag.php 伪协议读取文件 /?urlfile:///var/www/html/flag.php 右击查看页面源代码 端口扫描 1.根据题目提示我们知道端口号在8000-9000之间,使用bp抓包并进行爆破 POST请求 点击环境&#xff0c;访问flag.php 查看页…

游戏引擎学习第43天

仓库 https://gitee.com/mrxiao_com/2d_game 介绍运动方程 今天我们将更进一步&#xff0c;探索运动方程&#xff0c;了解真实世界中的物理&#xff0c;并调整它们&#xff0c;以创建一种让玩家感觉愉悦的控制体验。这并不是在做一个完美的物理模拟&#xff0c;而是找到最有趣…

YashanDB共享集群产品能力观测:细节足见功底

本文基于前泽塔数科研发总监-王若楠2024年11月在“2024年国产数据库创新生态大会”-“根”技术专场的演讲整理形成&#xff0c;主要对崖山共享集群YAC的架构、功能、高可用性、性能四大方面进行全面测试&#xff0c;并分享了测试环境和测试结论。 年初&#xff0c;基于某些商业…

VMware ubuntu16.04怎么设置静态IP联网

1.将VMware桥接到当前电脑使用的网络上面&#xff1b; 2.点击网络符号&#xff0c;编辑连接&#xff1b; 3.双击有线连接1&#xff1b; 4.选择IPv4设置&#xff0c;将地址&#xff0c;子网掩码&#xff0c;网关&#xff0c;DNS服务器设置好&#xff0c;保存&#xff1b; 5.在终…

ElasticSearch的自动补全功能(拼音分词器、自定义分词器、DSL实现自动补全查询、RestAPI实现自动补全查询)

文章目录 1. 什么是自动补全2. 拼音分词器2.1 初识拼音分词器2.2 下载拼音分词器2.3 安装拼音分词器2.4 测试拼音分词器 3. 自定义分词器3.1 拼音分词器存在的问题3.2 分词器&#xff08;analyzer&#xff09;的组成3.3 如何自定义分词器3.4 拼音分词器的可选参数3.5 配置自定义…

Windows环境 (Ubuntu 24.04.1 LTS ) 国内镜像,用apt-get命令安装RabbitMQ,java代码样例

一、环境 Windows11 WSL(Ubuntu 24.04.1) 二、思路 1 用Windows中的Ubuntu安装RabbitMQ&#xff0c;贴近Linux的线上环境&#xff1b; 2 RabbitMQ用erlang语言编写的&#xff0c;先安装erlang的运行环境&#xff1b; 2 用Linux的apt-get命令安装&#xff0c;解决软件依赖…

医学预测模型的网页应用必要模块设计(重制版)

医学预测模型的网页应用必要模块设计&#xff08;重制版&#xff09; 刘岳鹏 摘要&#xff1a; 网页应用&#xff08;Web APP&#xff09;承载医学临床预测模型并在临床实践中实现与用户的互动&#xff0c;必要的功能模块设计将有助于Web APP更好地在临床实践中发挥其功能。在此…

【他山之石】Leading-Trim: The Future of Digital Typesetting:数字排版的未来 —— Leading-Trim

文章目录 【他山之石】Leading-Trim: The Future of Digital Typesetting&#xff1a;数字排版的未来 —— Leading-TrimHow an emerging CSS standard can fix old problems and raise the bar for web apps1. The problem with text boxes today2. How we got here: a histor…

【k8s集群应用】Kubernetes 容器编排系统

文章目录 Kubernetes 容器编排系统背景与发展Kubernetes 基本概念Kubernetes 集群架构与组件Kubernetes 核心组件Master 组件配置存储中心Node 组件 Kubernetes核心概念1. Pod2. Pod控制器3. Label与Label选择器4. Service5. Ingress6. Volume7. Name与Namespace K8S创建Pod资源…

梳理你的思路(从OOP到架构设计)_简介EIT造形

目录 1、 复习<基类 /子类>的扩充(extends)结构 典型的<基类/子类>代码结构 <基类/子类>代码结构的变形 2、 从<基类/子类>结构到EIT造形 3、 EIT造形的基本形与变形 1、 复习<基类 /子类>的扩充(extends)结构 典型的<基类/子类>代码…

Rust vs C: PNG解码器性能之争的启示

在系统编程领域,C语言一直是性能标杆。但最近一个现象引发了广泛讨论:用 Rust 实现的 PNG 解码器性能竟然超越了 C 语言版本。这个看似反直觉的结果背后,折射出现代编程语言发展的新趋势。 让我们深入解析这个有趣的技术现象。PNG解码本质上是把压缩的图像数据还原成像素数据的…