当前位置：首页 > article >正文

springCloud2025+springBoot3.5.0+Nacos集成redis从nacos拉配置起服务

article 2025/8/17 14:05:32

文章目录

前言
一、网关gateway选型
- 1. 响应式编程模型
- 2. 网关的特定需求
- 3. 技术栈一致性
- 4. 性能对比
- 5. 实际应用场景优势
二、redis的集成
- 1.引入库
- 2.配置类
- - A、自定义配置类RedisAfterNacosAutoConfiguration
  - B、自定义配置类RedisConfig
总结

前言

       最近在搭建最新的springCloud + springboot3 + nacos微服务框架，有个新项目要启动了，做完二期公司都可以上市的，所以基础得搭建牢固。有建议找开源的，之前呆过的一家公司居然还花钱买框架，真是。。。。。。
       以上2种方式我都不喜欢，要搞就搞最新的，就跟找朋友样，要找就找年轻的，所以我就算是今天周六也在家搞搞呗。因为都是最新的，参考真的很少啊，踩几个坑了，但是没有太多时间复盘，今天就先简单说下gateway网关用redis的事情。
       这里是redis的配置也放nacos，那么问题就来了，自动配置的RedisProperties怎么在服务还在启动过程中就去nacos哪配置呢？

一、网关gateway选型

gateway选择基于 WebFlux 而非传统的 Servlet 栈（如 Spring MVC）呢？就是因为这个原因，gateway的redis我不能直接引入通用的common，因为我把数据库连接、异常统一处理、redis等都放在了common包，但是异常统一处理是基于starter-web写的，所以最后我gateway单独引入redis。
为什么我不把gateway也换成基于starter-web呢？原因如下：

1. 响应式编程模型

核心优势：

非阻塞 I/O：WebFlux 基于 Reactor 实现非阻塞异步处理，特别适合网关这种 I/O 密集型场景
高并发能力：用少量线程处理大量并发连接（相比线程池模型的 Servlet 容器）
资源高效：避免线程上下文切换开销，减少内存消耗

2. 网关的特定需求

功能性考量：

请求转发：网关需要高效处理大量 HTTP 请求转发
过滤器链：WebFlux 的函数式编程模型更适合实现灵活的过滤器管道
背压支持：内置响应式流背压机制，防止下游服务过载

3. 技术栈一致性

架构匹配：

Spring 5+ 生态：Gateway 作为 Spring Cloud 新一代组件，自然采用 Spring 5 的响应式体系
Netty 集成：默认使用 Netty 作为服务器，与 WebFlux 深度集成
函数式路由：支持 lambda 表达式定义路由规则，更简洁的 API 设计

4. 性能对比

指标	WebFlux (Netty)	Servlet (Tomcat)
线程模型	事件循环	线程池
并发连接处理能力	更高	受限于线程池大小
内存占用	更低	更高
长连接支持	更优	一般

5. 实际应用场景优势

典型用例：

微服务架构中的边缘服务
需要处理大量并发连接（如 IoT 场景）
需要低延迟的请求转发
需要灵活的自定义过滤逻辑

二、redis的集成

1.引入库

引库没啥可说的，无非就是现在最新的redis的starter的配置项前缀发生了改变，不再是“spring.redis”了，而是“spring.data.redis”。

<!-- Spring Boot 3 Redis 依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>${redisson.version}</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency>

2.配置类

这里因为是要先加载完nacos，再从nacos拉取redis，最后启动服务。正因为这个服务启动顺序，又涉及到最新的springboot、cloud，所以就出现了2种写法，写在这里也是笔记也是分享。
redis在nacos的配置

spring:data:redis:host: 127.0.0.1port: 6379password: database: 0timeout: 5000ms

A、自定义配置类RedisAfterNacosAutoConfiguration


import com.alibaba.cloud.nacos.NacosConfigAutoConfiguration;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisPassword;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.util.StringUtils;/*** @author zwmac*/
@AutoConfiguration(after = NacosConfigAutoConfiguration.class)
@ConditionalOnProperty(name = "spring.cloud.nacos.config.enabled", havingValue = "true", matchIfMissing = true)
public class RedisAfterNacosAutoConfiguration {@Bean@ConditionalOnMissingBeanpublic RedisConnectionFactory redisConnectionFactory(ConfigurableEnvironment env) {String host = env.getProperty("spring.data.redis.host");Integer port = env.getProperty("spring.data.redis.port", Integer.class, 6379);String password = env.getProperty("spring.data.redis.password");if (host == null) {throw new IllegalStateException("Redis配置未从Nacos加载，请检查 redis-config.yaml 是否加载成功");}RedisStandaloneConfiguration config = new RedisStandaloneConfiguration(host, port);if (StringUtils.hasText(password)) {config.setPassword(RedisPassword.of(password));}return new LettuceConnectionFactory(config);}@Bean@ConditionalOnMissingBeanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory factory) {RedisTemplate<Object, Object> template = new RedisTemplate<>();template.setConnectionFactory(factory);GenericJackson2JsonRedisSerializer serializer = new GenericJackson2JsonRedisSerializer();template.setDefaultSerializer(serializer);template.setKeySerializer(new StringRedisSerializer());template.setHashKeySerializer(new StringRedisSerializer());template.setValueSerializer(serializer);template.setHashValueSerializer(serializer);template.afterPropertiesSet();return template;}
}

注意这种方式需要在启动类上加@Import(RedisAfterNacosAutoConfiguration.class)，否则无效。

B、自定义配置类RedisConfig

import com.rs.gov.govgateway.service.redis.RedisService;
import org.apache.commons.lang3.StringUtils;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.SingleServerConfig;
import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.DependsOn;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisPassword;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;/*** @author zwmac*/
@Configuration
@DependsOn("nacosConfigManager")
@EnableConfigurationProperties(RedisProperties.class)
public class RedisConfig {private final RedisProperties redisProperties;public RedisConfig(RedisProperties redisProperties) {this.redisProperties = redisProperties;}@Beanpublic RedisService redisService(RedisTemplate<Object, Object> redisTemplate) {return new RedisService(redisTemplate);}@Beanpublic LettuceConnectionFactory redisConnectionFactory(RedisProperties redisProperties) {RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();config.setHostName(redisProperties.getHost());config.setPort(redisProperties.getPort());config.setPassword(RedisPassword.of(redisProperties.getPassword()));return new LettuceConnectionFactory(config);}@Beanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) {RedisTemplate<Object, Object> template = new RedisTemplate<>();template.setConnectionFactory(connectionFactory);// 推荐的序列化方式：不需要设置 ObjectMapperGenericJackson2JsonRedisSerializer jackson2JsonRedisSerializer = new GenericJackson2JsonRedisSerializer();template.setDefaultSerializer(jackson2JsonRedisSerializer);template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(jackson2JsonRedisSerializer);template.setHashKeySerializer(new StringRedisSerializer());template.setHashValueSerializer(jackson2JsonRedisSerializer);template.afterPropertiesSet();return template;}// 可选：注册 RedissonClient@Bean(destroyMethod = "shutdown")public RedissonClient redissonClient() {Config config = new Config();SingleServerConfig singleServerConfig = config.useSingleServer();singleServerConfig.setAddress("redis://" + redisProperties.getHost() + ":" + redisProperties.getPort());if (StringUtils.isNotBlank(redisProperties.getPassword())) {singleServerConfig.setPassword(redisProperties.getPassword());}return Redisson.create(config);}}