使用 Spring Data Redis 实现 Redis 数据存储详解

使用 Spring Data Redis 实现 Redis 数据存储详解

Spring Data Redis 是 Spring 生态中操作 Redis 的核心模块，它封装了 Redis 客户端的底层细节（如 Jedis 或 Lettuce），提供了统一的 API 来操作 Redis 的数据结构。以下是详细实现步骤：

一、配置 Spring Data Redis

1. 引入依赖

在 pom.xml 中添加依赖（以 Spring Boot 3.x 为例）：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- 使用 Lettuce 客户端（默认） -->
<dependency><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId>
</dependency>
<!-- 可选：连接池（如使用 Jedis） -->
<dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId>
</dependency>
2. 配置 Redis 连接

在 application.yml 中配置 Redis 服务器信息：

spring:redis:host: localhost      # Redis 服务器地址port: 6379          # 默认端口password: 123456    # 密码（若无则省略）database: 0         # 默认数据库索引lettuce:pool:max-active: 8   # 最大连接数max-idle: 4     # 最大空闲连接min-idle: 1     # 最小空闲连接
3. 配置 RedisTemplate

自定义 RedisTemplate 序列化方式（避免二进制乱码）：

@Configuration
public class RedisConfig {@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(factory);// Key 统一使用字符串序列化template.setKeySerializer(RedisSerializer.string());template.setHashKeySerializer(RedisSerializer.string());// Value 统一使用 JSON 序列化Jackson2JsonRedisSerializer<Object> jsonSerializer = new Jackson2JsonRedisSerializer<>(Object.class);template.setValueSerializer(jsonSerializer);template.setHashValueSerializer(jsonSerializer);// 特殊数据结构的 Value 序列化（根据需求覆盖）// template.setDefaultSerializer(jsonSerializer); // 可选：全局默认序列化template.afterPropertiesSet();return template;}
}

二、操作 Redis 数据结构

在这里插入图片描述

1. String（字符串）
  • 用途：存储简单键值对（如缓存、计数器）。
  • 核心方法：opsForValue()
@Autowired
private RedisTemplate<String, Object> redisTemplate;// 写入值
redisTemplate.opsForValue().set("user:1:name", "Alice");// 读取值
String name = (String) redisTemplate.opsForValue().get("user:1:name");// 原子递增
Long count = redisTemplate.opsForValue().increment("article:100:views");
2. Hash（哈希表）
  • 用途：存储对象字段（如用户信息）。
  • 核心方法：opsForHash()
// 存储用户对象
Map<String, String> user = new HashMap<>();
user.put("name", "Bob");
user.put("age", "25");
redisTemplate.opsForHash().putAll("user:2", user);// 获取单个字段
String age = (String) redisTemplate.opsForHash().get("user:2", "age");// 更新字段
redisTemplate.opsForHash().put("user:2", "age", "26");// 获取所有字段
Map<Object, Object> userData = redisTemplate.opsForHash().entries("user:2");
3. List（列表）
  • 用途：实现队列、栈或消息列表。
  • 核心方法：opsForList()
// 左侧插入元素
redisTemplate.opsForList().leftPush("task:queue", "task1");// 右侧弹出元素（阻塞式）
String task = (String) redisTemplate.opsForList().rightPop("task:queue", 10, TimeUnit.SECONDS);// 获取列表范围
List<Object> tasks = redisTemplate.opsForList().range("task:queue", 0, -1);
4. Set（集合）
  • 用途：存储唯一值（如标签、共同好友）。
  • 核心方法：opsForSet()
// 添加元素
redisTemplate.opsForSet().add("article:100:tags", "tech", "java", "spring");// 判断元素是否存在
boolean exists = redisTemplate.opsForSet().isMember("article:100:tags", "java");// 求交集
Set<Object> commonTags = redisTemplate.opsForSet().intersect("article:100:tags", "article:101:tags");
5. Sorted Set（有序集合）
  • 用途：排行榜、优先级队列。
  • 核心方法：opsForZSet()
// 添加元素及分数
redisTemplate.opsForZSet().add("leaderboard", "player1", 100.0);
redisTemplate.opsForZSet().add("leaderboard", "player2", 85.5);// 获取前 10 名
Set<ZSetOperations.TypedTuple<Object>> topPlayers = redisTemplate.opsForZSet().reverseRangeWithScores("leaderboard", 0, 9);// 更新分数
redisTemplate.opsForZSet().incrementScore("leaderboard", "player1", 20.0);
6. HyperLogLog
  • 用途：近似统计独立用户数（UV）。
  • 核心方法：opsForHyperLogLog()
// 添加元素
redisTemplate.opsForHyperLogLog().add("uv:20231001", "user1", "user2", "user3");// 统计基数
Long uv = redisTemplate.opsForHyperLogLog().size("uv:20231001");
7. Bitmaps
  • 用途：位操作（如用户签到）。
  • 核心方法：opsForValue().setBit()
// 设置第 5 位为 1（表示用户 ID=5 已签到）
redisTemplate.opsForValue().setBit("sign:user:202310", 5, true);// 统计总签到数
Long count = redisTemplate.execute((RedisCallback<Long>) conn -> conn.bitCount("sign:user:202310".getBytes())
);
8. GEO（地理空间）
  • 用途：附近位置查询。
  • 核心方法：opsForGeo()
// 添加地理位置
redisTemplate.opsForGeo().add("cities", new Point(116.405285, 39.904989), "Beijing");// 查询距离
Distance distance = redisTemplate.opsForGeo().distance("cities", "Beijing", "Shanghai", Metrics.KILOMETERS);// 附近 100km 内的城市
GeoResults<GeoLocation<Object>> results = redisTemplate.opsForGeo().radius("cities", "Beijing", new Distance(100, Metrics.KILOMETERS));

三、高级功能

1. 事务支持
redisTemplate.execute(new SessionCallback<List<Object>>() {@Overridepublic List<Object> execute(RedisOperations operations) {operations.multi();  // 开启事务operations.opsForValue().set("key1", "value1");operations.opsForHash().put("hash1", "field", "value");return operations.exec();  // 提交事务}
});
2. 发布订阅
// 发布消息
redisTemplate.convertAndSend("news", "Breaking news: Spring 6 released!");// 订阅消息（需定义 MessageListener）
@Bean
public MessageListenerAdapter listenerAdapter(MessageReceiver receiver) {return new MessageListenerAdapter(receiver, "receiveMessage");
}@Bean
public RedisMessageListenerContainer container(RedisConnectionFactory factory,MessageListenerAdapter listener) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(factory);container.addMessageListener(listener, new ChannelTopic("news"));return container;
}
3. 管道操作（批量执行）
List<Object> results = redisTemplate.executePipelined((RedisCallback<Object>) connection -> {connection.stringCommands().set("key1".getBytes(), "value1".getBytes());connection.stringCommands().set("key2".getBytes(), "value2".getBytes());return null;
});

四、测试与验证

1. 注入 RedisTemplate
@SpringBootTest
public class RedisTest {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;@Testvoid testString() {redisTemplate.opsForValue().set("testKey", "Hello Redis");assertEquals("Hello Redis", redisTemplate.opsForValue().get("testKey"));}
}
2. 检查 Redis 连接
@Autowired
private RedisConnectionFactory redisConnectionFactory;@Test
void testConnection() {RedisConnection conn = redisConnectionFactory.getConnection();assertTrue(conn.ping().equals("PONG"));conn.close();
}

五、注意事项

  1. 序列化一致性
    确保所有操作的 Key/Value 序列化方式一致，避免出现乱码或类型错误。

  2. 连接泄漏
    使用 @Transactional 或手动关闭连接，避免未释放的连接耗尽资源。

  3. 数据淘汰策略
    在 Redis 配置中设置 maxmemory-policy（如 allkeys-lru），防止内存溢出。

  4. 集群模式
    若使用 Redis 集群，需在配置中指定所有节点地址：

    spring:redis:cluster:nodes: host1:6379,host2:6379,host3:6379

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

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

相关文章

Qt5与现代OpenGL学习（四）X轴方向旋转60度

Qt5与现代OpenGL学习（四）X轴方向旋转60度

把上面两张图像放到D盘1文件夹内&#xff1a; shader.h #ifndef SHADER_H #define SHADER_H#include <QDebug> #include <QOpenGLShader> #include <QOpenGLShaderProgram> #include <QString>class Shader { public:Shader(const QString& verte…
阅读更多...
【Machine Learning Q and AI 读书笔记】- 02 自监督学习

【Machine Learning Q and AI 读书笔记】- 02 自监督学习

Machine Learning Q and AI 中文译名 大模型技术30讲&#xff0c;主要总结了大模型相关的技术要点&#xff0c;结合学术和工程化&#xff0c;对LLM从业者来说&#xff0c;是一份非常好的学习实践技术地图. 本文是Machine Learning Q and AI 读书笔记的第2篇&#xff0c;对应原…
阅读更多...
using var connection = connectionFactory.CreateConnection()； using var 是什么意思

using var connection = connectionFactory.CreateConnection()； using var 是什么意思

在 .NET 中&#xff0c;​​垃圾回收&#xff08;Garbage Collection, GC&#xff09;​​ 确实是自动管理内存的机制&#xff0c;但它 ​​仅适用于托管资源&#xff08;Managed Resources&#xff09;​​&#xff08;如类实例、数组等&#xff09;。然而&#xff0c;对于 ​…
阅读更多...
Multicore-TSNE

Multicore-TSNE

文章目录 TSNE使用scikit-learn库使用Multicore-TSNE库安装方法基本使用方法采用不同的距离度量 其他资料 TSNE t-Distributed Stochastic Neighbor Embedding (t-SNE) 是一种高维数据的降维方法&#xff0c;由Laurens van der Maaten和Geoffrey Hinton于2008年提出&#xff0…
阅读更多...
SI5338-EVB Usage Guide（LVPECL、LVDS、HCSL、CMOS、SSTL、HSTL）

SI5338-EVB Usage Guide（LVPECL、LVDS、HCSL、CMOS、SSTL、HSTL）

目录 1. 简介 1.1 EVB 介绍 1.2 Si5338 Block Diagram 2. EVB 详解 2.1 实物图 2.2 基本配置 2.2.1 Universal Pin 2.2.2 IIC I/F 2.2.3 Input Clocks 2.2.4 Output Frequencies 2.2.5 Output Driver 2.2.6 Freq and Phase Offset 2.2.7 Spread Spectrum 2.2.8 快…
阅读更多...
Spring AI应用系列——基于OpenTelemetry实现大模型调用的可观测性实践

Spring AI应用系列——基于OpenTelemetry实现大模型调用的可观测性实践

一、项目背景与目标 在AI应用日益复杂的今天&#xff0c;大模型服务&#xff08;如语言理解和生成&#xff09;的性能监控和问题排查变得尤为关键。为了实现对大模型调用链路的可观测性&#xff08;Observability&#xff09;管理&#xff0c;我们基于 Spring Boot Spring AI…
阅读更多...
Spyglass：官方Hands-on Training（一）

Spyglass：官方Hands-on Training（一）

相关阅读 Spyglasshttps://blog.csdn.net/weixin_45791458/category_12828934.html?spm1001.2014.3001.5482 本文是对Spyglass Hands-on Training中第一个实验的翻译&#xff08;有删改&#xff09;&#xff0c;Lab文件可以从以下链接获取。Spyglass Hands-on Traininghttps:…
阅读更多...
PCB设计工艺规范（三）走线要求

PCB设计工艺规范（三）走线要求

走线要求 1.走线要求2.固定孔、安装孔、过孔要求3.基准点要求4.丝印要求 1.走线要求 印制板距板边距离:V-CUT 边大于 0.75mm&#xff0c;铣槽边大于0.3mm。为了保证 PCB 加工时不出现露铜的缺陷&#xff0c;要求所有的走线及铜箔距离板边:V-CUT边大于 0.75mm&#xff0c;铣槽边…
阅读更多...
抓取工具Charles配置教程（mac电脑+ios手机）

抓取工具Charles配置教程（mac电脑+ios手机）

mac电脑上的配置 1. 下载最新版本的Charles 2. 按照以下截图进行配置 2.1 端口号配置&#xff1a; 2.2 https配置 3. mac端证书配置 4. IOS手机端网络配置 4.1 先查看电脑上的配置 4.2 配置手机网络 连接和电脑同一个wifi&#xff0c;然后按照以下截图进行配置 5. 手机端证书…
阅读更多...
【CSS】精通Flex布局（全）

【CSS】精通Flex布局（全）

目录 1. flex布局体验 1.1 传统布局 与 flex布局 1.2 初体验 2. flex布局原理 2.1 布局原理 3. flex布局父项常见属性 3.1 常见父项属性 3.2 属性值 3.3 justify-content 设置主轴上的子元素排列方式 3.4 flex-wrap设置子元素是否换行 3.5 align-items 设置侧轴上的…
阅读更多...
力扣第447场周赛

力扣第447场周赛

这次终于赶上力扣的周赛了, 赛时成绩如下(依旧还是三题 )&#xff1a; 1. 统计被覆盖的建筑 给你一个正整数 n&#xff0c;表示一个 n x n 的城市&#xff0c;同时给定一个二维数组 buildings&#xff0c;其中 buildings[i] [x, y] 表示位于坐标 [x, y] 的一个 唯一 建筑。 如…
阅读更多...
AI中常用概念的理解

AI中常用概念的理解

1. RAG&#xff08;检索增强生成&#xff09; 通俗理解&#xff1a;就像你写作业时&#xff0c;先查课本 / 百度找资料&#xff0c;再根据资料写答案&#xff0c;而不是纯靠记忆瞎编。 AI 模型&#xff08;比如 ChatGPT&#xff09;回答问题时&#xff0c;先去 “数据库 / 互联…
阅读更多...
SQLServer多版本兼容Java方案和数据采集

SQLServer多版本兼容Java方案和数据采集

Maven引入 <dependency><groupId>com.microsoft.sqlserver</groupId><artifactId>sqljdbc4</artifactId><version>4.0</version></dependency><dependency><groupId>net.sourceforge.jtds</groupId><ar…
阅读更多...
【每日八股】复习 Redis Day4：线程模型

【每日八股】复习 Redis Day4：线程模型

文章目录 复习 Redis Day4&#xff1a;线程模型介绍一下 Redis 的线程模型核心线程模型&#xff08;Redis 6.0 之前&#xff09;Redis 6.0 的多线程改进Redis 真的是单线程吗&#xff1f;Redis 的线程模型剖析 上一篇 Redis 的应用我今天才完成&#xff0c;因此明天一并复习 Re…
阅读更多...
树莓派智能摄像头实战指南：基于TensorFlow Lite的端到端AI部署

树莓派智能摄像头实战指南：基于TensorFlow Lite的端到端AI部署

引言&#xff1a;嵌入式AI的革新力量 在物联网与人工智能深度融合的今天&#xff0c;树莓派这一信用卡大小的计算机正在成为边缘计算的核心载体。本文将手把手教你打造一款基于TensorFlow Lite的低功耗智能监控设备&#xff0c;通过MobileNetV2模型实现实时物体检测&#xff0…
阅读更多...
vs2019编译occ7.9.0时，出现fatal error C1060: compiler is out of heap space

vs2019编译occ7.9.0时，出现fatal error C1060: compiler is out of heap space

问题描述 visual studio 2019编译opencascade 7.9.0时&#xff0c;出现编译错误 fatal error C1060: compiler is out of heap space 解决方案 修改vs2019并行编译的线程个数&#xff0c;默认是12个&#xff0c;我改成了4个&#xff0c;问题解决 Tools > Project and Sol…
阅读更多...
vue跨域问题总结笔记

vue跨域问题总结笔记

目录 一、Websocket跨域问题 1.nginx配置 2.VUE CLI代理 3.env.development配置 4.nginx日志 5.解决 一、解决跨域的几种常用方法 1.Vue CLI代理 2.JSONP 3.WebSocket 4.NGINX解决跨域问题 6.Java解决跨域 二、Vue跨域问题详解 1. 什么是跨域 2. 跨域的例子 3.…
阅读更多...
数据结构篇：线性表的另一表达—链表之单链表(下篇)

数据结构篇：线性表的另一表达—链表之单链表(下篇)

目录 1.前言 2.是否使用二级指针 3.插入/删除 3.1 pos位置前/后插入 3.2 查找函数 3.3 pos位置删除 3.4 pos位置后面删除 3.5 函数的销毁 4.断言问题 4.1 断言pphead 4.2 断言*pphead 5.三个文件的代码 5.1 头文件 5.2 具体函数实现 5.3 测试用例 1.前言 之前是讲…
阅读更多...
完美解决react-native文件直传阿里云oss问题一

完美解决react-native文件直传阿里云oss问题一

前言 通常情况下&#xff0c;作为前后端分离的项目来说&#xff0c;文件上传是最寻常的功能之一。虽然每个公司选择的文件管理云库各不相同&#xff0c;但实现思路基本一致。我所在公司使用阿里云oss文件管理&#xff0c;之前服务端做了透传&#xff0c;但是由于每个测试环境的…
阅读更多...
5.运输层

5.运输层

5. 运输层 1. 概述 第2~4章依次介绍了计算机网络体系结构中的物理层、数据链路层和网络层&#xff0c;它们共同解决了将主机通过异构网络互联起来所面临的问题&#xff0c;实现了主机到主机的通信然而在计算机网络中实际进行通信的真正实体&#xff0c;是位于通信两端主机中的…
阅读更多...
最新文章

Copyright @ 2022~2023