Spring Boot 3.3 【八】整合实现高可用 Redis 集群

一、引言

在当今快速发展的软件开发领域，系统的性能和可靠性至关重要。Springboot 3 整合 Redis 7 集群具有多方面的重大意义。

首先，随着业务的不断发展，数据量呈爆炸式增长，单个 Redis 服务器往往难以满足存储和处理需求。Redis 7 集群通过将数据分布在多个节点上，实现了数据的 横向扩展，能够轻松应对大规模数据的存储和访问。

对于高并发的应用场景，性能是关键考量因素。Springboot 3 与 Redis 7 集群整合后，可以充分利用 Redis 的高性能缓存特性。Redis 以其快速的读写速度著称，能够极大地减少数据库的访问压力，提高系统的响应速度。例如，在电商平台中，商品信息、用户购物车等数据可以缓存到 Redis 集群中，当用户查询或操作这些数据时，直接从 Redis 中获取，响应时间可以从几百毫秒降低到几毫秒，大大提升用户体验。

可靠性方面，Redis 7 集群提供了高可用性。如果其中一个 Redis 节点出现故障，其他节点仍然可以继续提供服务，确保系统的稳定运行。在金融交易系统、在线游戏等对稳定性要求极高的场景中，这种高可用性至关重要。数据会在多个节点之间进行复制，即使某个节点发生故障，数据也不会丢失，保证了数据的一致性和可用性。

此外，Springboot 3 的强大框架特性与 Redis 7 集群的结合，使得开发人员能够更加便捷地进行开发和维护。Springboot 提供了简洁的配置和开发模式，而 Redis 7 集群则提供了高效的数据存储和访问方式，两者相辅相成，为开发高质量的应用程序奠定了坚实的基础。

二、准备工作

（一）Redis 集群安装，请参照下文链接：

CentOS 7 环境搭建 redis 最新版 7.4 分布式集群完整版详解

三、整合步骤

（一）依赖添加

在 Springboot 3 项目中，要整合 Redis 7 集群，首先需要在项目的pom.xml文件中添加必要的依赖。

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

（二）配置文件编写

接下来是编写 application.yml 文件，下面配置了 Redis 7 集群的节点、超时时间以及连接池的相关参数。

server:
  port=8080
  
spring:application:name: redis
  data:redis:password: 123456abc
      cluster:timeout:1000max-redirects:3nodes: 192.168.117.128:7400,192.168.117.128:7401,192.168.117.129:7402,192.168.117.129:7403,192.168.117.131:7404,192.168.117.131:7405lettuce:pool:max-active:8# 连接池中的最大空闲连接max-wait:500# 连接池最大阻塞等待时间（使用负值表示没有限制）max-idle:8# 连接池最大连接数（使用负值表示没有限制）min-idle:0# 连接池中的最小空闲连接

（三）缓存工具类

这个缓存工具类可以更灵活地进行缓存操作，提供了设置和获取缓存的方法，并支持设置过期时间。

packagecom.jsglxx.redis;importjava.util.concurrent.TimeUnit;importorg.springframework.data.redis.core.RedisTemplate;importorg.springframework.stereotype.Component;@ComponentpublicclassCacheUtil{privatefinalRedisTemplate<String,Object> redisTemplate;publicCacheUtil(RedisTemplate<String,Object> redisTemplate){this.redisTemplate = redisTemplate;}publicvoidset(String key,Object value,long timeout,TimeUnit unit){
        redisTemplate.opsForValue().set(key, value, timeout, unit);}publicObjectget(String key){return redisTemplate.opsForValue().get(key);}}

• 缓存工具类 CacheUtil 通过构造函数注入 RedisTemplate。set 方法用于设置缓存，接收键、值、过期时间和时间单位作为参数。get 方法用于获取缓存，根据键从 Redis 中获取对应的值。

（四）实体类

packagecom.jsglxx.redis.Entity;publicclassUser{privateLong id;privateString name;publicUser(){super();// TODO Auto-generated constructor stub}publicUser(Long id,String name){super();this.id = id;this.name = name;}publicLonggetId(){return id;}publicvoidsetId(Long id){this.id = id;}publicStringgetName(){return name;}publicvoidsetName(String name){this.name = name;}}

（五）Service 层

packagecom.jsglxx.redis.service;importorg.springframework.data.redis.core.RedisTemplate;importorg.springframework.stereotype.Service;importcom.jsglxx.redis.Entity.User;@ServicepublicclassUserService{privatefinalRedisTemplate<String,Object> redisTemplate;publicUserService(RedisTemplate<String,Object> redisTemplate){this.redisTemplate = redisTemplate;}publicvoidsaveUser(User user){
        redisTemplate.opsForValue().set("user:"+ user.getId(), user);}publicObjectgetUser(Long id){return(User) redisTemplate.opsForValue().get("user:"+ id);}}

• 这里通过构造函数注入 RedisTemplate，然后使用它的opsForValue()方法进行对值类型的操作。在saveUser方法中，将用户对象以键值对的形式存入 Redis，键为"user:" + user.getId()，值为用户对象。在getUser方法中，根据用户 ID 从 Redis 中获取对应的用户对象。

（六）Controller 层

packagecom.jsglxx.redis.controller;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.PathVariable;importorg.springframework.web.bind.annotation.PostMapping;importorg.springframework.web.bind.annotation.RequestBody;importorg.springframework.web.bind.annotation.RestController;importcom.jsglxx.redis.Entity.User;importcom.jsglxx.redis.service.UserService;@RestControllerpublicclassUserController{privatefinalUserService userService;publicUserController(UserService userService){this.userService = userService;}@PostMapping("/users")publicvoidsaveUser(@RequestBodyUser user){
        userService.saveUser(user);}@GetMapping("/users/{id}")publicObjectgetUser(@PathVariableLong id){return userService.getUser(id);}}

• UserController 提供了两个接口，**/users** 用于保存用户，**/users/{id}** 用于获取用户。
• UserController 接收 UserService 的实例，通过 @PostMapping 和 @GetMapping 注解定义了两个接口。在 saveUser 方法中，调用 userService 的 saveUser 方法保存用户。在 getUser 方法中，调用 userService 的 getUser 方法获取用户。

(七）配置类

importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.data.redis.connection.RedisConnectionFactory;importorg.springframework.data.redis.core.RedisTemplate;importorg.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;importorg.springframework.data.redis.serializer.StringRedisSerializer;@ConfigurationpublicclassRedisConfig{@BeanpublicRedisTemplate<String,Object>redisTemplate(RedisConnectionFactory redisConnectionFactory){RedisTemplate<String,Object> template =newRedisTemplate<>();
        template.setConnectionFactory(redisConnectionFactory);
        template.setKeySerializer(newStringRedisSerializer());
        template.setValueSerializer(newJackson2JsonRedisSerializer<>(Object.class));return template;}}

四、测试保存用户接口（POST 请求）

1. 选择 POST 请求方法。
2. 在 URL 输入栏中输入你的应用的地址加上 /users，http://localhost:8080/users。
3. 在 Headers 选项卡中，可以添加 Content-Type 为 application/json，表示请求体是 JSON 格式的数据。
4. 在 Body 选项卡中，选择 raw 和 JSON 格式。
5. 输入一个 JSON 对象来表示用户数据：

{"id":1,"name":"小明"}

1. 点击 Send 按钮发送请求。
2. 检查响应状态码，应该是 200 OK 表示请求成功，并且你的应用应该已经将用户数据保存到 Redis 中。

五、测试获取用户接口（GET 请求）

1. 选择 GET 请求方法。
2. 在 URL 输入栏中输入你的应用的地址加上 **/users/{id}**，将 {id} 替换为你要查询的用户 ID，例如 http://localhost:8080/users/1。

3. 点击 Send 按钮发送请求。

结束语

在本次探索中，我们成功地将 Spring Boot 3.3 与 Redis 7.4 进行了整合，实现了高效的缓存管理。通过利用 Redis 7.4 的强大功能和集群模式，我们为应用程序带来了显著的性能提升和高可用性保障。

如果觉得本文能够帮到您，请关注🌟、点赞👍、收藏📚，让这份美好延续下去！

🌟 对技术管理感兴趣 请关注下方 ⬇ 【 技术管理修行】
过来人的建议：学习技术的同时学一点管理小知识，您不升职谁升职！~~