Spring Cloud Gateway 微服务统一入口实战

启动类非常简单，无需额外配置：

@SpringBootApplication
public class GatewayApplication {
    public static void main(String[] args) {
        SpringApplication.run(GatewayApplication.class, args);
    }
}

路由配置

在 application.yml 中配置路由规则。这里以对接 Nacos 为例：

server:
  port: 10030

spring:
  application:
    name: gateway
  cloud:
    nacos:
      discovery:
        server-addr: 110.41.51.65:10020
    gateway:
      routes:
        - id: product-service
          uri: lb://product-service
          predicates:
            - Path=/product/**
        - id: order-service
          uri: lb://order-service
          predicates:
            - Path=/order/**

配置说明：

• id：路由唯一标识。
• uri：目标服务地址。使用 lb:// 前缀表示从注册中心获取服务列表并进行负载均衡。
• predicates：路由断言，匹配符合规则的请求才会被转发。

访问网关地址 http://127.0.0.1:10030/order/1 即可触发路由转发。

Route Predicate Factories（路由断言工厂）

Predicate 是 Java 8 提供的函数式接口，用于条件过滤。在 Spring Cloud Gateway 中，Route Predicate Factory 负责解析配置文件中的字符串规则，将其转换为具体的判断逻辑。

例如配置 Path=/product/**，实际是由 PathRoutePredicateFactory 实现 URL 前缀匹配。Gateway 默认提供了丰富的断言工厂，支持 HTTP 请求的不同属性匹配，且可以通过 and 逻辑组合。

更多内置断言可参考 Spring Cloud Gateway 文档。

断言示例

在配置中添加时间限制：

predicates:
  - Path=/product/**
  - After=2026-01-01T00:00:00.000+08:00[Asia/Shanghai]

这样配置后，只有在指定时间之后的请求才能通过该路由。

Gateway Filter Factories（过滤器工厂）

Predicate 决定请求由哪个路由处理，而 Filter 则负责在请求处理前后执行特定逻辑。Filter 分为 Pre（前置）和 Post（后置）类型。

• Pre 类型：路由转发之前执行，常用于鉴权、限流。
• Post 类型：响应返回给客户端之前执行，常用于日志记录、响应修改。

根据作用范围，Filter 分为两类：

1. GatewayFilter：仅对单个或分组路由生效。
2. GlobalFilter：对所有路由生效，适用于全局性需求（如安全、监控）。

GatewayFilter 使用

GatewayFilter 通常在配置文件中针对特定路由声明。例如为 product-service 添加请求参数：

filters:
  - AddRequestParameter=userName,bite

这会在转发给 product-service 的请求头中增加 userName=bite 参数。接收端控制器即可获取该值：

@RequestMapping("/{productId}")
public ProductInfo getProductById(@PathVariable Integer productId, String userName) {
    System.out.println("收到请求，Id:" + productId);
    System.out.println("userName:" + userName);
    return productService.selectProductById(productId);
}

若希望对所有路由生效，可使用 default-filters 配置：

default-filters:
  - AddResponseHeader=X-Response-Default-Red,Default-Blue
  - PrefixPath=/httpbin

GlobalFilter 使用

GlobalFilter 作用于所有请求。Spring Cloud Gateway 内置了多个全局过滤器，如 LoadBalancerClientFilter（负载均衡）、GatewayMetricsFilter（指标监控）等。

启用监控通常需要添加 Actuator 依赖并配置暴露端点：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

management:
  endpoints:
    web:
      exposure:
        include: "*"

访问 http://127.0.0.1:10030/actuator 即可查看网关运行指标。

过滤器执行顺序

当项目中同时存在 GatewayFilter 和 GlobalFilter 时，它们会被合并到一个过滤器链中排序执行。每个过滤器必须指定 order 值（整数），值越小优先级越高。

• 自定义过滤器可通过实现 Ordered 接口或添加 @Order 注解指定顺序。
• 当 order 值相同时，执行顺序通常为：defaultFilter > GatewayFilter > GlobalFilter。

自定义过滤器

Spring Cloud Gateway 允许开发者扩展过滤器功能，支持自定义 GatewayFilter 和 GlobalFilter。

自定义 GatewayFilter

实现 AbstractGatewayFilterFactory 抽象类较为便捷。注意类名后缀应为 GatewayFilterFactory，以便系统识别。

@Slf4j
@Service
public class CustomGatewayFilterFactory extends AbstractGatewayFilterFactory<CustomConfig> implements Ordered {

    public CustomGatewayFilterFactory() {
        super(CustomConfig.class);
    }

    @Override
    public GatewayFilter apply(CustomConfig config) {
        return ((exchange, chain) -> {
            log.info("[Pre] Filter Request, name: {}", config.getName());
            // 执行后续过滤器链
            return chain.filter(exchange).then(Mono.fromRunnable(() -> {
                log.info("[Post] Response Filter");
            }));
        });
    }

    @Override
    public int getOrder() {
        return Ordered.LOWEST_PRECEDENCE;
    }

    @Data
    public static class CustomConfig {
        private String name;
    }
}

在配置文件中引用：

filters:
  - name: Custom
    args:
      name: custom_filter

自定义 GlobalFilter

GlobalFilter 实现相对简单，只需实现 GlobalFilter 接口，无需额外配置，会自动应用到所有路由。

@Slf4j
@Service
public class CustomGlobalFilter implements GlobalFilter, Ordered {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        log.info("[Pre] CustomGlobalFilter enter...");
        return chain.filter(exchange).then(Mono.fromRunnable(() -> {
            log.info("[Post] CustomGlobalFilter return...");
        }));
    }

    @Override
    public int getOrder() {
        return Ordered.LOWEST_PRECEDENCE;
    }
}

总结

Spring Cloud Gateway 凭借其高性能和非阻塞特性，已成为微服务架构中统一入口的首选方案。通过合理配置路由断言与过滤器，我们可以灵活地实现鉴权、限流、日志追踪等横切逻辑，有效降低微服务间的耦合度。在实际开发中，建议优先使用内置过滤器满足通用需求，仅在特殊场景下自定义过滤器，并注意控制过滤器的执行顺序以避免逻辑冲突。