小菜鸟

java菜鸟号正在起航

0%

发表于 更新于 分类于 阅读次数： Valine：
本文字数： 4k 阅读时长 ≈ 4 分钟

Spring Cloud Bus：基于消息总线的分布式配置动态刷新

Spring Cloud Bus（消息总线）通过整合消息中间件（如 RabbitMQ、Kafka），将分布式系统中的所有微服务节点连接到一个共享的消息主题，实现配置变更的广播通知。当配置中心的配置更新后，只需触发一次刷新请求，所有相关服务即可自动感知并应用新配置，极大简化了分布式环境下的配置管理。

消息总线实现动态刷新的核心原理

  1. 消息主题共享：所有微服务（包括配置中心和客户端）都监听同一个消息主题（默认springCloudBus）。
  2. 事件驱动：当配置发生变更时，通过触发配置中心的/actuator/bus-refresh端点，将刷新事件发布到消息主题。
  3. 广播通知：所有监听该主题的服务接收到事件后，自动从配置中心拉取最新配置并更新本地状态。

有两种实现方式

第一种

利用消息总线触发一个客户端/bus/refresh，从而刷新所有客户端的配置

第二种

利用消息总线触发Config服务端的/bus/refresh端点，从而刷新所有客户端的配置，选用该方式比较合适

流程示意图：

1
Git仓库配置变更 → 触发配置中心/bus-refresh → 配置中心发布刷新事件到MQ → 所有客户端接收事件 → 客户端拉取新配置

基于 Kafka 的消息总线配置（第二种方案推荐）

推荐采用 “触发配置中心刷新所有客户端” 的方案，只需在配置中心暴露总线端点，客户端被动接收通知，无需单独配置刷新逻辑。

1. 环境准备

  • 安装并启动 Kafka（默认端口 9092），创建默认主题（或使用自动创建）。
  • 确保配置中心（Config Server）和所有客户端已集成 Spring Cloud Config。

2. 配置中心服务端（Config Server）配置

（1）引入依赖
阅读全文 »

发表于 更新于 分类于 阅读次数： Valine：
本文字数： 2.5k 阅读时长 ≈ 2 分钟

Nacos 简介：一站式服务发现与配置管理平台

Nacos（Dynamic Naming and Configuration Service）是阿里巴巴开源的微服务基础设施，集服务注册发现与配置管理于一体，旨在简化微服务架构中的服务治理和配置管理流程。作为 Spring Cloud Alibaba 生态的核心组件，Nacos 可无缝替代 Eureka（注册中心）和 Spring Cloud Config（配置中心），提供更高效、更灵活的解决方案。

Nacos 的核心功能

Nacos 的核心价值在于 “一站式” 能力，同时支持两大核心功能：

  1. 服务发现与健康检查
    • 支持基于 DNS 和 HTTP 的服务发现，兼容 Spring Cloud、Dubbo 等主流微服务框架；
    • 内置健康检查机制，自动剔除不健康服务实例，保证服务调用的可靠性。
  2. 动态配置管理
    • 集中管理不同环境、不同服务的配置，支持配置的动态更新（无需重启服务）；
    • 支持配置版本控制、灰度发布、配置回滚等高级特性。

Nacos 的显著优势

相比传统组件（如 Eureka、Spring Cloud Config），Nacos 具有以下优势：

阅读全文 »

发表于 更新于 分类于 阅读次数： Valine：
本文字数： 5.9k 阅读时长 ≈ 5 分钟

Spring Cloud Gateway 过滤器：请求处理的拦截与增强机制

Spring Cloud Gateway 的过滤器（Filter）用于在请求路由前后对请求 / 响应进行拦截、修改或增强，是实现权限校验、日志记录、限流熔断等功能的核心组件。过滤器分为内置过滤器（官方提供）和自定义过滤器（按需扩展），按作用范围又可分为全局过滤器（对所有路由生效）和路由过滤器（仅对指定路由生效）。

过滤器的核心作用

  • 请求预处理：路由前修改请求头、参数、路径（如添加认证信息、统一前缀）；
  • 响应后处理：路由后修改响应头、状态码（如添加跟踪 ID、统一响应格式）；
  • 业务管控：实现限流、熔断、日志记录、权限校验等（如拦截未登录请求）；
  • 异常处理：捕获路由过程中的异常，返回友好提示。

内置过滤器详解

Gateway 内置了数十种过滤器，按功能可分为以下类别，覆盖大部分常见场景：

1. 请求头 / 响应头过滤器

用于修改请求头或响应头信息，常见过滤器包括：

过滤器名称 作用说明 配置示例
AddRequestHeader 为请求添加指定头信息。 - AddRequestHeader=X-Request-Source, gateway（添加X-Request-Source: gateway）
AddResponseHeader 为响应添加指定头信息。 - AddResponseHeader=X-Response-Time, {now}（添加响应时间头）
RemoveRequestHeader 移除请求中的指定头信息（如敏感信息）。 - RemoveRequestHeader=Authorization（移除 Authorization 头）
RemoveResponseHeader 移除响应中的指定头信息。 - RemoveResponseHeader=X-Powered-By（移除服务器标识头）
DedupeResponseHeader 处理重复的响应头（如 CORS 跨域头），支持RETAIN_FIRST（保留第一个）、RETAIN_LAST（保留最后一个）、RETAIN_UNIQUE（去重）策略。 - DedupeResponseHeader=Access-Control-Allow-Credentials, RETAIN_LAST

2. 请求参数过滤器

用于修改请求参数：

阅读全文 »

发表于 更新于 分类于 阅读次数： Valine：
本文字数： 3.5k 阅读时长 ≈ 3 分钟

Spring Cloud Gateway 断言（Predicate）详解：精准匹配请求的核心机制

Spring Cloud Gateway 的断言（Predicate）是路由匹配的核心，它通过匹配 HTTP 请求的各种属性（如路径、方法、头信息、时间等），决定是否将请求转发到目标服务。Gateway 内置了多种断言工厂，满足不同场景的路由匹配需求。

断言的本质

断言（Predicate）本质是请求匹配规则，基于 Java 8 的Predicate函数式接口实现。当请求到达网关时，Gateway 会依次执行路由中定义的断言：

  • 若所有断言均返回true，则请求匹配该路由，执行转发；
  • 若任一断言返回false，则跳过该路由，继续匹配其他路由。

断言的配置方式有两种：

  1. 简短配置：- 断言名=参数1,参数2（适合简单场景）；
  2. 全面配置：通过name和args显式指定参数（适合复杂场景）。

示例（Cookie 断言的两种配置）：

阅读全文 »

发表于 更新于 分类于 阅读次数： Valine：
本文字数： 3.5k 阅读时长 ≈ 3 分钟

分布式配置动态刷新：从手动触发到自动感知

在分布式系统中，配置中心的核心价值不仅在于集中管理配置，更在于支持配置的动态刷新—— 即配置修改后无需重启服务即可生效。Spring Cloud 提供了多种实现方式，从手动触发到自动感知，满足不同场景的需求。

基于 @RefreshScope + Actuator 的手动刷新

这是 Spring Cloud Config 中最基础的动态刷新方式，通过注解标记需要刷新的组件，并结合 Actuator 端点手动触发刷新。

1. 实现步骤

（1）引入依赖

添加 spring-boot-starter-actuator 依赖，用于暴露刷新端点：

1
2
3
4
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
（2）配置刷新端点

在客户端的 application.yml 中暴露 refresh 端点（或使用 * 暴露所有端点）：

1
2
3
4
5
6
management:
  endpoints:
    web:
      exposure:
        include: refresh  # 仅暴露refresh端点（推荐）
        # include: "*"   # 暴露所有端点（开发环境可用）
（3）标记需要刷新的组件

在使用配置的类上添加 @RefreshScope 注解，Spring 会为该类创建代理对象，在配置刷新时重新初始化：

阅读全文 »