在运行时修改Spring Cloud网关路由

Question

我想在服务器运行时在运行时添加或删除SpringCloudGateway路由。我正在使用Fluent Java Routes API初始化网关路由。这是完美的工作。

但是，现在我想在SpringCloudGateway服务器运行时修改、添加和删除路由。我可以看到RouteLocator包含我的路由，但我看不到修改其内容的方法。

尽管我看到一些在执行器中创建新路由的能力，但我需要使用Java代码而不是REST调用来添加它们。在我的设置中，RoutedDefinitionRepository是空的，所以我没有看到在我的用例中使用它的任何方法。

是否可以在SpringCloudGateway中仅使用Java代码在运行时修改路由？

Answer 1

我做了一些类似于删除路由的事情，以隐藏网关的服务。尝试实例化自定义RouteLocator，如下面所示：

@Configuration
public class RouteConfiguration implements CommandLineRunner {

    final Logger LOGGER = LoggerFactory.getLogger(RouteConfiguration.class);

    @Value("${route.ignore.service-ids}")
    private String[] ignoreServiceIds;

    @Override
    public void run(String... args) throws Exception {

        if(ignoreServiceIds != null){
            for(String s: ignoreServiceIds){
                LOGGER.info("ServiceID ignored: {}",s);
            }
        }
    }

    @Bean
    @Primary
    @ConditionalOnMissingBean(name = "cachedCompositeRouteLocator")
    public RouteLocator cachedCompositeRouteLocator(List<RouteLocator> routeLocators) {

        return new CachingRouteLocator(new CustomCompositeRouteLocator(Flux.fromIterable(routeLocators), ignoreServiceIds));
    }
}

然后应用过滤器：

public class CustomCompositeRouteLocator implements RouteLocator {

    private final Flux<RouteLocator> delegates;
    private List<String> ignoredServiceIds;

    public CustomCompositeRouteLocator(Flux<RouteLocator> delegates, String[] ignoreServiceIds) {
        this.delegates = delegates;

        if(ignoreServiceIds != null && ignoreServiceIds.length>0)
            this.ignoredServiceIds = List.of(ignoreServiceIds);
    }

    @Override
    public Flux<Route> getRoutes() {

        if(ignoredServiceIds == null || ignoredServiceIds.isEmpty())
            return this.delegates.flatMapSequential(RouteLocator::getRoutes);
        return this.delegates.flatMapSequential(RouteLocator::getRoutes).filter(p->!ignoredServiceIds.contains(p.getUri().getHost()));
    }
}

在应用程序中。亚马尔

...
route:
  ignore:
    service-ids: MY_IGNORED_SERVICE_ID
...

Answer 2

改用Spring集成。您可以使用JavaDSL注册和删除集成流。https://docs.spring.io/spring-integration/docs/5.3.2.RELEASE/reference/html/dsl.html#java-dsl运行时流