spring cloud gateway 动态添加路由

Spring Cloud Gateway 是基于 Spring WebFlux 的 API 网关，它提供了动态路由、断路器、限流等功能。动态添加路由是指在运行时能够根据需要添加或修改路由规则，而不需要重启服务。

基础概念

路由（Route）：定义了请求如何被转发到目标服务的规则。每个路由包含一个 ID、一个目标 URI、一组断言（Predicates）和一组过滤器（Filters）。

断言（Predicate）：用于判断请求是否应该被路由到某个目标服务。常见的断言包括路径匹配、请求头匹配等。

过滤器（Filter）：在请求被路由之前或之后对请求和响应进行处理的组件。过滤器可以用于修改请求头、记录日志、限流等。

动态添加路由的优势

灵活性：可以在运行时根据需求动态调整路由规则，无需重启服务。
可扩展性：支持多种数据源和配置方式，便于集成不同的管理和监控系统。
高可用性：通过动态路由可以实现服务的自动切换和故障恢复。

类型

静态路由：在配置文件中预先定义好的路由规则。
动态路由：通过外部配置中心（如 Spring Cloud Config、Consul、Etcd 等）实时更新路由规则。

应用场景

微服务架构：作为 API 网关，统一管理和路由到各个微服务。
蓝绿部署：通过动态路由实现新旧版本的平滑切换。
A/B 测试：根据请求特征将流量分发到不同的服务实例。

实现动态添加路由的方法

使用 Spring Cloud Config

配置中心：将路由配置放在 Spring Cloud Config 服务器上。
刷新机制：通过 /actuator/refresh 端点触发配置刷新。

示例代码：

# application.yml
spring:
  cloud:
    gateway:
      routes:
        - id: service1
          uri: lb://service1
          predicates:
            - Path=/service1/**
          filters:
            - StripPrefix=1

@RestController
public class GatewayController {

    @Autowired
    private RouteDefinitionLocator routeDefinitionLocator;

    @Autowired
    private RouteDefinitionWriter routeDefinitionWriter;

    @PostMapping("/routes")
    public ResponseEntity<String> addRoute(@RequestBody RouteDefinition routeDefinition) {
        routeDefinitionWriter.save(Mono.just(routeDefinition)).subscribe();
        return ResponseEntity.ok("Route added successfully");
    }
}

使用数据库

存储路由配置：将路由规则存储在数据库中。
定时任务或事件驱动：定期从数据库读取路由配置并更新到 Gateway 中。

示例代码：

@Component
public class DatabaseRouteDefinitionLocator implements RouteDefinitionLocator {

    @Autowired
    private RouteRepository routeRepository;

    @Override
    public Flux<RouteDefinition> getRouteDefinitions() {
        return routeRepository.findAll().map(this::convertToRouteDefinition);
    }

    private RouteDefinition convertToRouteDefinition(RouteEntity entity) {
        RouteDefinition definition = new RouteDefinition();
        definition.setId(entity.getId());
        definition.setUri(URI.create(entity.getUri()));
        // 设置断言和过滤器
        return definition;
    }
}