Spring Cloud Gateway实战：微服务API网关从零到一

前言

Spring Cloud Gateway 是 Spring 官方推出的 API 网关，基于 WebFlux 实现，性能卓越。本文带你从零搭建一个生产级的微服务 API 网关。
一、核心概念

• Route（路由）：网关的基本构建块，包含 ID、目标 URI、Predicate、Filter
  
• Predicate（断言）：匹配请求条件（路径、Header、参数等）
  
• Filter（过滤器）：对请求进行前置/后置处理（鉴权、限流、日志等）
  

二、快速搭建

1. <dependency>
2.     <groupId>org.springframework.cloud</groupId>
3.     spring-cloud-starter-gateway</artifactId>
4. </dependency>
6. # application.yml
7. server:
8.   port: 8080
10. spring:
11.   application:
12.     name: api-gateway
13.   cloud:
14.     gateway:
15.       routes:
16.         - id: user-service
17.           uri: lb://user-service
18.           predicates:
19.             - Path=/api/users/**
20.           filters:
21.             - StripPrefix=1
22.         - id: order-service
23.           uri: lb://order-service
24.           predicates:
25.             - Path=/api/orders/**
26.           filters:
27.             - StripPrefix=1
29.       discovery:
30.         locator:
31.           enabled: true  # 自动发现服务

复制代码

三、自定义全局过滤器（JWT 鉴权）

1. @Component
2. public class AuthGlobalFilter implements GlobalFilter, Ordered {
4.     @Override
5.     public Mono<Void> filter(ServerWebExchange exchange,
6.                               GatewayFilterChain chain) {
7.         String path = exchange.getRequest().getPath().value();
8.         // 白名单路径跳过鉴权
9.         if (path.startsWith("/api/auth/login") ||
10.             path.startsWith("/api/auth/register")) {
11.             return chain.filter(exchange);
12.         }
13.         String token = exchange.getRequest()
14.             .getHeaders().getFirst("Authorization");
15.         if (token == null || !token.startsWith("Bearer ")) {
16.             exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
17.             return exchange.getResponse().setComplete();
18.         }
19.         // 验证 JWT（简化示例）
20.         try {
21.             String jwt = token.substring(7);
22.             Claims claims = Jwts.parser()
23.                 .setSigningKey("secret-key").parseClaimsJws(jwt).getBody();
24.             String userId = claims.getSubject();
25.             ServerHttpRequest request = exchange.getRequest()
26.                 .mutate().header("X-User-Id", userId).build();
27.             return chain.filter(exchange.mutate().request(request).build());
28.         } catch (Exception e) {
29.             exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
30.             return exchange.getResponse().setComplete();
31.         }
32.     }
34.     @Override
35.     public int getOrder() { return -100; }
36. }

复制代码

四、自定义 GatewayFilter（限流）

1. @Component
2. public class RateLimitFilter implements GatewayFilter, Ordered {
4.     private final RateLimiter rateLimiter = RateLimiter.create(100);
6.     @Override
7.     public Mono<Void> filter(ServerWebExchange exchange,
8.                               GatewayFilterChain chain) {
9.         if (!rateLimiter.tryAcquire()) {
10.             exchange.getResponse().setStatusCode(HttpStatus.TOO_MANY_REQUESTS);
11.             return exchange.getResponse().setComplete();
12.         }
13.         return chain.filter(exchange);
14.     }
16.     @Override
17.     public int getOrder() { return 0; }
18. }
20. # 在路由中使用自定义过滤器
21. spring.cloud.gateway.routes[0].filters:
22.   - name: RateLimit
23.     args:
24.       redis-rate-limiter.replenishRate: 10
25.       redis-rate-limiter.burstCapacity: 20

复制代码

五、跨域配置

1. @Configuration
2. public class CorsConfig {
3.     @Bean
4.     public CorsWebFilter corsWebFilter() {
5.         CorsConfiguration config = new CorsConfiguration();
6.         config.addAllowedOrigin("*");
7.         config.addAllowedHeader("*");
8.         config.addAllowedMethod("*");
9.         config.setAllowCredentials(true);
11.         UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
12.         source.registerCorsConfiguration("/**", config);
13.         return new CorsWebFilter(source);
14.     }
15. }

复制代码

六、网关 vs Nginx

1. # Nginx：反向代理 + 负载均衡
2. # 适合：静态资源、SSL 终止、四层/七层负载均衡
4. # Spring Cloud Gateway：业务网关
5. # 适合：动态路由、JWT 鉴权、限流、熔断、灰度发布
7. # 生产推荐：Nginx（前置）+ Gateway（后置）
8. # 请求链路：Client → Nginx → Gateway → Microservice

复制代码

总结

Spring Cloud Gateway 是微服务架构的统一入口。核心要点：基于 WebFlux 高性能非阻塞、断言灵活匹配路由、全局过滤器实现统一鉴权、配合 Nginx 构建多层网关架构。

觉得有帮助请点赞收藏！有问题欢迎评论区交流
来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！