[Java实战]Spring Boot 整合 Redis（十八）

[Java实战]Spring Boot 整合 Redis（十八）

在现代的分布式应用开发中，Redis 作为一种高性能的键值存储数据库，被广泛用于缓存、消息队列、排行榜等多种场景。Spring Boot 提供了强大的支持，使得整合 Redis 变得非常简单。本文将详细介绍如何在 Spring Boot 项目中整合 Redis，从基础配置到高级用法，帮助你快速上手并深入掌握。

一、Redis 简介

Redis（Remote Dictionary Server，远程字典服务）是一个开源的键值存储数据库，通常用作数据库、缓存或消息代理。它支持多种数据结构，如字符串（strings）、哈希（hashes）、列表（lists）、集合（sets）、有序集合（sorted sets）等。

Redis 的主要特点

  • 高性能：每秒可处理数十万次读写操作。
  • 支持丰富的数据类型：不仅支持简单的 key-value 类型，还支持 list、set、zset（sorted set）等复杂数据类型。
  • 原子操作：所有操作都是原子性的，保证了数据的一致性。
  • 持久化：支持 RDB（快照）和 AOF（追加文件）两种持久化方式。

二、Spring Boot 整合 Redis

1. 添加依赖

在 Spring Boot 项目中，整合 Redis 非常简单。首先，需要在 pom.xml 文件中添加 Redis 相关的依赖。

<dependencies><!-- Spring Boot Starter Data Redis --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>
</dependencies>

2. 配置 Redis

在 application.yml 或 application.properties 文件中配置 Redis 的连接信息。

application.yml
spring:redis:host: localhostport: 6379password: your_password # 如果有密码database: 0 # 数据库编号（默认为 0）timeout: 5000ms # 连接超时时间
application.properties
spring.redis.host=localhost
spring.redis.port=6379
spring.redis.password=your_password # 如果有密码
spring.redis.database=0 # 数据库编号（默认为 0）
spring.redis.timeout=5000ms # 连接超时时间

3. 配置 RedisTemplate

RedisTemplate 是 Spring 提供的用于操作 Redis 的模板类，它封装了底层的 Jedis 或 Lettuce 客户端，提供了丰富的 API。

配置 RedisTemplate
@Configuration
public class RedisConfig {@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(redisConnectionFactory);// 设置序列化器Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);template.setDefaultSerializer(serializer);return template;}
}

4. 使用 RedisTemplate

存储和获取数据
@Service
public class RedisService {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;public void set(String key, Object value) {redisTemplate.opsForValue().set(key, value);}public Object get(String key) {return redisTemplate.opsForValue().get(key);}
}
示例：缓存用户信息
@RestController
@RequestMapping("/user")
public class UserController {@Autowiredprivate RedisService redisService;@PostMapping("/saveUser")public void saveUserInfo(User User){User u =  new User();u.setId("3");u.setAge(25);u.setEmail("alice@example.com");u.setName("Alice");userService.saveUserToRedis(u);}
}

在这里插入图片描述
在这里插入图片描述

三、高级用法

1. Redis 消息订阅与发布

Redis 支持发布/订阅模式，可以用于实现简单的消息队列。

配置消息监听器
@Component
public class RedisMessageListener implements MessageListener {@Overridepublic void onMessage(Message message, byte[] pattern) {String messageStr = new String(message.getBody());System.out.println("Received message: " + messageStr);}
}
配置订阅
@Configuration
public class RedisMessageConfig {@Beanpublic RedisMessageListenerAdapter messageListener(RedisMessageListener listener) {return new RedisMessageListenerAdapter(listener);}@Beanpublic StringRedisTemplate template(RedisConnectionFactory connectionFactory) {return new StringRedisTemplate(connectionFactory);}@Beanpublic RedisPubSubListener redisPubSubListener() {return new RedisPubSubListener();}@Beanpublic RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,RedisMessageListenerAdapter listenerAdapter) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);container.addMessageListener(listenerAdapter, new PatternTopic("chat"));return container;}
}
发布消息
@Service
public class RedisPubSubService {@Autowiredprivate StringRedisTemplate template;public void sendMessage(String channel, String message) {template.convertAndSend(channel, message);}
}

2. Redis 分布式锁

在分布式系统中，分布式锁是一个常见的需求。Redis 提供了基于 SETNX 命令的锁机制。

实现分布式锁
@Service
public class RedisLockService {@Autowiredprivate StringRedisTemplate template;public boolean tryLock(String key, String value, long expireTime) {Boolean result = template.opsForValue().setIfAbsent(key, value, expireTime, TimeUnit.MILLISECONDS);return result != null && result;}public void releaseLock(String key, String value) {String currentValue = template.opsForValue().get(key);if (value.equals(currentValue)) {template.delete(key);}}
}
使用分布式锁
@RestController
@RequestMapping("/order")
public class OrderController {@Autowiredprivate RedisLockService redisLockService;@PostMapping("/create")public ResponseEntity<?> createOrder(@RequestBody Order order) {String lockKey = "order:lock";String lockValue = UUID.randomUUID().toString();if (redisLockService.tryLock(lockKey, lockValue, 30000)) {try {// 处理订单逻辑orderService.createOrder(order);} finally {redisLockService.releaseLock(lockKey, lockValue);}} else {return ResponseEntity.status(HttpStatus.TOO_MANY_REQUESTS).body("Too many requests");}return ResponseEntity.ok("Order created successfully");}
}

四、常见问题与解决方案

1. Redis 连接超时

原因：Redis 服务器响应慢或网络问题。

解决方案：

  • 增加连接超时时间：
    spring:redis:timeout: 10000ms
  • 检查 Redis 服务器性能，优化配置。

2. 序列化问题

原因：默认的序列化方式可能导致存储的数据难以理解。

解决方案：

  • 使用自定义的序列化器，如 Jackson2JsonRedisSerializer：
    Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
template.setDefaultSerializer(serializer);

3. 数据丢失

原因：Redis 默认不开启持久化。

解决方案：

  • 开启 RDB 或 AOF 持久化：
    appendonly yes
save 900 1
save 300 10
save 60 10000

五、总结

本文详细介绍了 Spring Boot 整合 Redis 的过程，从基础配置到高级用法，包括消息订阅与发布、分布式锁等。通过合理使用 Redis，可以显著提升应用的性能和扩展性。希望本文能帮助你更好地理解和使用 Spring Boot 整合 Redis。

如果你在使用过程中遇到任何问题，欢迎在评论区留言交流。感谢你的阅读，希望这篇文章对你有所帮助！

OF 持久化：

appendonly yes
save 900 1
save 300 10
save 60 10000

五、总结

本文详细介绍了 Spring Boot 整合 Redis 的过程，从基础配置到高级用法，包括消息订阅与发布、分布式锁等。通过合理使用 Redis，可以显著提升应用的性能和扩展性。希望本文能帮助你更好地理解和使用 Spring Boot 整合 Redis。

如果你在使用过程中遇到任何问题，欢迎在评论区留言交流。感谢你的阅读，希望这篇文章对你有所帮助！

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

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

相关文章

【氮化镓】GaN在不同电子能量损失的SHI辐射下的损伤

【氮化镓】GaN在不同电子能量损失的SHI辐射下的损伤

该文的主要发现和结论如下： GaN的再结晶特性 ：GaN在离子撞击区域具有较高的再结晶倾向，这导致其形成永久损伤的阈值较高。在所有研究的电子能量损失 regime 下，GaN都表现出这种倾向，但在电子能量损失增加时，其效率会降低，尤其是在材料发生解离并形成N₂气泡时。 能量损失…
阅读更多...
R语言实战第5章（1）

R语言实战第5章（1）

第一部分&#xff1a;数学、统计和字符处理函数 数学和统计函数&#xff1a;R提供了丰富的数学和统计函数&#xff0c;用于执行各种计算和分析。这些函数可以帮助用户快速完成复杂的数学运算、统计分析等任务&#xff0c;例如计算均值、方差、相关系数、进行假设检验等。字符处…
阅读更多...
k8s术语之Horizontal Pod Autoscaling

k8s术语之Horizontal Pod Autoscaling

应用的资源使用率通常都有高峰和低谷的时候&#xff0c;如何削峰填谷&#xff0c;提高整体的整体资源利用率&#xff0c;让service中的Pod个数自动调整呢&#xff1f;Horizontal Pod Autoscaling:使pod水平自动缩放。这个Object也是最能体现kubernetes之于传统运维价值的地方&a…
阅读更多...
Linux复习笔记（三） 网络服务配置（web)

Linux复习笔记（三） 网络服务配置（web)

遇到的问题&#xff0c;都有解决方案&#xff0c;希望我的博客能为你提供一点帮助。 二、网络服务配置 2.3 web服务配置 2.3.1通信基础&#xff1a;HTTP协议与C/S架构&#xff08;了解&#xff09; ​​HTTP协议的核心作用​​ Web服务基于HTTP/HTTPS协议实现客户端&#xff…
阅读更多...
9.1.领域驱动设计

9.1.领域驱动设计

目录 一、领域驱动设计核心哲学 战略设计与战术设计的分野 • 战略设计&#xff1a;限界上下文&#xff08;Bounded Context&#xff09;与上下文映射&#xff08;Context Mapping&#xff09; • 战术设计&#xff1a;实体、值对象、聚合根、领域服务的构建原则 统一语言&am…
阅读更多...
CSS Layer 详解

CSS Layer 详解

CSS Layer 详解 前言 最近在整理CSS知识体系时&#xff0c;发现Layer这个特性特别有意思。它就像是给样式规则提供了一个专属的「VIP通道」&#xff0c;让我们能更优雅地解决样式冲突问题。今天我就用最通俗的语言&#xff0c;带大家全面了解这个CSS新特性。 什么是CSS Laye…
阅读更多...
【Dv3Admin】工具视图配置文件解析

【Dv3Admin】工具视图配置文件解析

在开发后台管理系统时，处理复杂的 CRUD 操作是常见的需求。Django Rest Framework（DRF）通过 ModelViewSet 提供了基础的增删改查功能，但在实际应用中，往往需要扩展更多的功能，如批量操作、权限控制、查询优化等。dvadmin/utils/viewset.py 模块通过继承并扩展 ModelViewS…
阅读更多...
‌云原生CAE软件

‌云原生CAE软件

‌云原生CAE软件‌是一种在设计和实现时就充分考虑了云环境特点的软件&#xff0c;能够充分利用云资源&#xff0c;实现高效、可扩展和灵活的仿真分析。 定义和特点 云原生CAE软件是一种在云端构建和运行的CAE&#xff08;Computer Aided Engineering&#xff0c;计算机辅助工…
阅读更多...
若依定制pdf生成实战

若依定制pdf生成实战

一、介绍 使用 Java Apache POI 将文字渲染到 Word 模板是一种常见的文档自动化技术&#xff0c;广泛应用于批量生成或定制 Word 文档的场景。使用aspose可以将word转成pdf从而达到定制化pdf的目的。 参考文档&#xff1a;java实现Word转Pdf&#xff08;Windows、Linux通用&a…
阅读更多...
Redis再次开源！reids8.0.0一键安装脚本分享

Redis再次开源！reids8.0.0一键安装脚本分享

准备工作 1. 下载 Redis 8 安装包 # Redis 8.0.0 示例&#xff08;请替换为实际版本&#xff09; http://download.redis.io/releases/redis-8.0.0.tar.gz一、脚本内容&#xff1a; #!/usr/bin/python # -*- coding: UTF-8 -*-import os import time import shutil import s…
阅读更多...
stm32之BKP备份寄存器和RTC时钟

stm32之BKP备份寄存器和RTC时钟

目录 1.时间戳1.1 Unix时间戳1.2 UTC/GMT1.3 时间戳转换**1.** time_t time(time_t*)**2.** struct tm* gmtime(const time_t*)**3.** struct tm* localtime(const time_t*)**4.** time_t mktime(struct tm*)**5.** char* ctime(const time_t*)**6.** char* asctime(const stru…
阅读更多...
Android学习总结之算法篇八（二叉树和数组）

Android学习总结之算法篇八（二叉树和数组）

路径总和 import java.util.ArrayList; import java.util.List;// 定义二叉树节点类 class TreeNode {int val;TreeNode left;TreeNode right;// 构造函数&#xff0c;用于初始化节点值TreeNode(int x) {val x;} }public class PathSumProblems {// 路径总和 I&#xff1a;判…
阅读更多...
Scala和Spark的介绍

Scala和Spark的介绍

Scala 1. Slaca的发展过程 由洛桑联邦理工学院的马丁 奥德斯在 2001 年基于 Funnel 的工作开始设计&#xff0c;设计初衷是想集成面向对象编程和函数式编程的各种特性。 Scala 是一种纯粹的面向对象的语言&#xff0c;每个值都是对象。 Scala 也是一种函数式语言&#xff0…
阅读更多...
配置Hadoop集群环境-使用脚本命令实现集群文件同步

配置Hadoop集群环境-使用脚本命令实现集群文件同步

在 Hadoop 集群环境中&#xff0c;确保各节点配置文件一致至关重要。以下是使用 rsync 结合 SSH 实现集群文件同步的脚本方案&#xff0c;支持批量同步文件到所有节点&#xff1a; 1. 前提条件 所有节点已配置 SSH 免密登录主节点&#xff08;NameNode&#xff09;能通过主机…
阅读更多...
Redis能保证数据不丢失吗之RDB

Redis能保证数据不丢失吗之RDB

有了AOF为什么还需要RDB？ 上一篇我们介绍了Redis AOF持久化策略。Redis能保证数据不丢失吗之AOF AOF虽然能实现持久化，但由于AOF恢复数据的时候是一条一条命令重新执行的，但数据量大的时候，Redis数据恢复的时间就会很久，这会导致Redis在重启的时候，有一大段时间的不可用…
阅读更多...
AI浪潮下的艺术突围战：对话《名人百科数据库》执行主编刘鑫炜

AI浪潮下的艺术突围战：对话《名人百科数据库》执行主编刘鑫炜

当AI生成的画作在国际赛事中摘冠&#xff0c;当算法推荐主导艺术传播路径&#xff0c;技术革命正以前所未有的速度重塑艺术生态。我们独家专访深耕艺术推广领域的刘鑫炜主编&#xff0c;探讨当代艺术家在智能时代的生存法则。 图为《名人百科数据库》执行主编刘鑫炜 技术重构创…
阅读更多...
Python 实现失败重试功能的几种方法

Python 实现失败重试功能的几种方法

更多内容请见： python3案例和总结-专栏介绍和目录 文章目录 方法 1：手动 `while` 循环 + 异常捕获方法 2：使用 `tenacity` 库（推荐）方法 3：使用 `retrying` 库（旧版，已停止维护）方法 4：`requests` 自带重试（适用于 HTTP 请求）方法 5：自定义装饰器（灵活控制）方法…
阅读更多...
2025年渗透测试面试题总结-渗透测试红队面试七（题目+回答）

2025年渗透测试面试题总结-渗透测试红队面试七（题目+回答）

网络安全领域各种资源&#xff0c;学习文档&#xff0c;以及工具分享、前沿信息分享、POC、EXP分享。不定期分享各种好玩的项目及好用的工具&#xff0c;欢迎关注。 目录 渗透测试红队面试七 一百八十一、Shiro漏洞类型&#xff0c;721原理&#xff0c;721利用要注意什么&am…
阅读更多...
Unity动画系统使用整理 --- Playable

Unity动画系统使用整理 --- Playable

​​Playable API​​ 是一个强大的工具&#xff0c;用于更灵活地控制动画、音频、脚本等时间轴内容的播放和混合。它提供了比传统 Animator 更底层、更可控的方式管理时间轴行为&#xff0c;尤其适合复杂动画逻辑或动态内容组合的场景。 优点&#xff1a; 1.Playables API 支…
阅读更多...
基于STM32、HAL库的BMP390L气压传感器 驱动程序设计

基于STM32、HAL库的BMP390L气压传感器 驱动程序设计

一、简介： BMP390L 是 Bosch Sensortec 生产的一款高精度气压传感器，专为需要精确测量气压和海拔高度的应用场景设计。BMP390L 具有更低的功耗、更高的精度和更快的响应速度。 二、硬件接口： BMP390L 引脚STM32L4XX 引脚说明VDD3.3V电源GNDGND地SCLPB6 (I2C1 SCL)I2C 时钟线…
阅读更多...
最新文章

Copyright @ 2022~2023