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

发布于：2025-06-08 ⋅ 阅读:(15) ⋅ 点赞:(0)

文章目录

前言

       最近在搭建最新的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.1
      port: 6379
      password: 
      database: 0
      timeout: 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
    @ConditionalOnMissingBean
    public 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
    @ConditionalOnMissingBean
    public 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;
    }

    @Bean
    public RedisService redisService(RedisTemplate<Object, Object> redisTemplate) {
        return new RedisService(redisTemplate);
    }

    @Bean
    public 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);
    }

    @Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
        RedisTemplate<Object, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(connectionFactory);

        // 推荐的序列化方式：不需要设置 ObjectMapper
        GenericJackson2JsonRedisSerializer 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);
    }

}

       我也怕麻烦，个人认为RedisConfig更简单，无非就是要注意@DependsOn(“nacosConfigManager”)这个注解。

总结

       最近的事有点多，压力很大啊，关键是BOSS对软件没有认知，部门软件角色的人员也配备不全。主责的项目啥都没有，只有一个前端截图、一个Excel文档，根据Excel文档估的工时打骨折，难啊！

网站公告

今日签到

点亮在社区的每一天
去签到

热门文章

最新发布