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

Spring Cloud Gateway 路由配置与动态管理详解

news 2026/6/15 0:08:45

摘要

本文详细探讨Spring Cloud Gateway的路由配置机制，包括静态路由配置、动态路由管理、路由刷新策略等内容。通过实际代码示例和架构分析，帮助开发者掌握路由配置的最佳实践方法。

1. 路由配置基础概念

1.1 路由核心组件

Spring Cloud Gateway的路由由以下几个核心组件构成：

ID：路由的唯一标识符
目标URI：路由的目标地址
谓词集合：用于匹配HTTP请求的断言
过滤器集合：用于处理请求和响应的过滤器

1.2 路由匹配原理

路由匹配基于谓词（Predicate）进行，当HTTP请求满足谓词条件时，请求将被路由到对应的目标服务。

2. 静态路由配置详解

2.1 YAML配置方式

spring:cloud:gateway:routes:# 用户服务路由-id:user-serviceuri:lb://user-servicepredicates:-Path=/user/**-Method=GET,POSTfilters:-StripPrefix=1-name:RequestRateLimiterargs:redis-rate-limiter.replenishRate:10redis-rate-limiter.burstCapacity:20key-resolver:"#{@userKeyResolver}"# 订单服务路由-id:order-serviceuri:lb://order-servicepredicates:-Path=/order/**-Header=X-Request-Id,\\d+filters:-RewritePath=/order/(?<segment>.*),/$\{segment}# 商品服务路由-id:product-serviceuri:lb://product-servicepredicates:-Path=/product/**-Query=tokenfilters:-AddRequestHeader=X-Request-Source,gateway

2.2 Java配置方式

@ConfigurationpublicclassRouteConfiguration{@BeanpublicRouteLocatorcustomRouteLocator(RouteLocatorBuilderbuilder){returnbuilder.routes().route("user-service",r->r.path("/user/**").filters(f->f.stripPrefix(1)).uri("lb://user-service")).route("order-service",r->r.path("/order/**").and().header("X-Request-Id","\\d+").filters(f->f.rewritePath("/order/(?<segment>.*)","/${segment}")).uri("lb://order-service")).build();}}

3. 动态路由实现机制

3.1 RouteDefinitionRepository接口

publicinterfaceRouteDefinitionRepository{Flux<RouteDefinition>getRouteDefinitions();Mono<Void>save(Mono<RouteDefinition>route);Mono<Void>delete(Mono<String>routeId);}

3.2 基于Redis的动态路由实现

@Component@Slf4jpublicclassRedisRouteDefinitionRepositoryimplementsRouteDefinitionRepository{@AutowiredprivateStringRedisTemplatestringRedisTemplate;privatestaticfinalStringGATEWAY_ROUTES="gateway_routes";@OverridepublicFlux<RouteDefinition>getRouteDefinitions(){returnFlux.fromIterable(loadRouteDefinitionsFromRedis());}@OverridepublicMono<Void>save(Mono<RouteDefinition>routeDefinitionMono){returnrouteDefinitionMono.flatMap(routeDefinition->{try{stringRedisTemplate.opsForHash().put(GATEWAY_ROUTES,routeDefinition.getId(),JSON.toJSONString(routeDefinition));log.info("保存路由:{}",routeDefinition);returnMono.empty();}catch(Exceptione){log.error("保存路由失败:{}",e.getMessage(),e);returnMono.error(e);}});}@OverridepublicMono<Void>delete(Mono<String>routeIdMono){returnrouteIdMono.flatMap(id->{try{stringRedisTemplate.opsForHash().delete(GATEWAY_ROUTES,id);log.info("删除路由:{}",id);returnMono.empty();}catch(Exceptione){log.error("删除路由失败:{}",e.getMessage(),e);returnMono.error(e);}});}privateList<RouteDefinition>loadRouteDefinitionsFromRedis(){List<RouteDefinition>routeDefinitions=newArrayList<>();Map<Object,Object>entries=stringRedisTemplate.opsForHash().entries(GATEWAY_ROUTES);for(Map.Entry<Object,Object>entry:entries.entrySet()){Stringjson=(String)entry.getValue();RouteDefinitionrouteDefinition=JSON.parseObject(json,RouteDefinition.class);routeDefinitions.add(routeDefinition);}returnrouteDefinitions;}}

3.3 路由刷新机制

@ComponentpublicclassRouteRefreshUtil{@AutowiredprivateApplicationEventPublisherpublisher;/** * 刷新路由 */publicvoidrefreshRoute(){this.publisher.publishEvent(newRefreshRoutesEvent(this));}}

4. 路由谓词详解

4.1 Path谓词

-Path=/user/**

匹配所有以/user/开头的请求路径。

4.2 Method谓词

-Method=GET,POST,PUT

匹配指定的HTTP方法。

4.3 Header谓词

-Header=X-Request-Id,\\d+

匹配具有特定头部值的请求。

4.4 Query谓词

-Query=token-Query=username,abc

匹配具有特定查询参数的请求。

5. 路由过滤器详解

5.1 预置过滤器

Spring Cloud Gateway提供了多种预置过滤器：

filters:# 去除路径前缀-StripPrefix=1# 重写路径-RewritePath=/foo/(?<segment>.*),/$\{segment}# 添加请求头-AddRequestHeader=X-Request-Red,Blue# 添加响应头-AddResponseHeader=Result,Gold# 请求重试-name:Retryargs:retries:3statuses:BAD_GATEWAYmethods:GET,POST

5.2 自定义过滤器

@ComponentpublicclassCustomGatewayFilterFactoryextendsAbstractGatewayFilterFactory<CustomGatewayFilterFactory.Config>{publicCustomGatewayFilterFactory(){super(Config.class);}@OverridepublicGatewayFilterapply(Configconfig){return(exchange,chain)->{ServerHttpRequestrequest=exchange.getRequest().mutate().header("X-Custom-Request",config.getValue()).build();returnchain.filter(exchange.mutate().request(request).build());};}publicstaticclassConfig{privateStringvalue;publicStringgetValue(){returnvalue;}publicvoidsetValue(Stringvalue){this.value=value;}}}

6. 路由管理API设计

6.1 路由管理控制器

@RestController@RequestMapping("/routes")publicclassRouteManageController{@AutowiredprivateRouteDefinitionWriterrouteDefinitionWriter;@AutowiredprivateRedisRouteDefinitionRepositoryrouteDefinitionRepository;/** * 添加路由 */@PostMappingpublicResultaddRoute(@RequestBodyRouteDefinitionrouteDefinition){routeDefinitionWriter.save(Mono.just(routeDefinition)).subscribe();routeDefinitionRepository.save(Mono.just(routeDefinition));returnResult.success("添加路由成功");}/** * 删除路由 */@DeleteMapping("/{id}")publicResultdeleteRoute(@PathVariableStringid){routeDefinitionWriter.delete(Mono.just(id)).subscribe();routeDefinitionRepository.delete(Mono.just(id));returnResult.success("删除路由成功");}/** * 刷新路由 */@PostMapping("/refresh")publicResultrefreshRoutes(){// 触发路由刷新事件returnResult.success("刷新路由成功");}}

7. 路由性能优化

7.1 路由缓存策略

@ConfigurationpublicclassRouteCacheConfig{@BeanpublicCacheManagerrouteCacheManager(){CaffeineCacheManagercacheManager=newCaffeineCacheManager();cacheManager.setCaffeine(Caffeine.newBuilder().maximumSize(1000).expireAfterWrite(10,TimeUnit.MINUTES));returncacheManager;}}

7.2 路由匹配优化

@ComponentpublicclassOptimizedRouteMatcher{privatefinalMap<String,RouteDefinition>routeCache=newConcurrentHashMap<>();publicRouteDefinitionmatchRoute(Stringpath){// 优先从缓存中获取returnrouteCache.computeIfAbsent(path,this::findRouteDefinition);}privateRouteDefinitionfindRouteDefinition(Stringpath){// 实现高效的路由匹配算法returnnull;}}

8. 路由安全配置

8.1 路由权限控制

@ComponentpublicclassRoutePermissionFilterimplementsGlobalFilter,Ordered{@OverridepublicMono<Void>filter(ServerWebExchangeexchange,GatewayFilterChainchain){Stringpath=exchange.getRequest().getURI().getPath();if(isProtectedPath(path)){// 检查权限if(!hasPermission(exchange)){ServerHttpResponseresponse=exchange.getResponse();response.setStatusCode(HttpStatus.FORBIDDEN);returnresponse.setComplete();}}returnchain.filter(exchange);}privatebooleanisProtectedPath(Stringpath){returnpath.startsWith("/admin/")||path.startsWith("/secure/");}privatebooleanhasPermission(ServerWebExchangeexchange){// 实现权限检查逻辑returntrue;}@OverridepublicintgetOrder(){return-1000;// 高优先级}}

9. 路由监控与日志

9.1 路由访问日志

@ComponentpublicclassRouteAccessLogFilterimplementsGlobalFilter,Ordered{privatestaticfinalLoggerlogger=LoggerFactory.getLogger(RouteAccessLogFilter.class);@OverridepublicMono<Void>filter(ServerWebExchangeexchange,GatewayFilterChainchain){longstartTime=System.currentTimeMillis();returnchain.filter(exchange).doFinally(signalType->{longduration=System.currentTimeMillis()-startTime;Stringpath=exchange.getRequest().getURI().getPath();Stringmethod=exchange.getRequest().getMethodValue();intstatus=exchange.getResponse().getStatusCode()!=null?exchange.getResponse().getStatusCode().value():0;logger.info("路由访问: path={}, method={}, status={}, duration={}ms",path,method,status,duration);});}@OverridepublicintgetOrder(){returnOrdered.LOWEST_PRECEDENCE;}}