Spring Cloud Gateway异步响应式路由断言实现方案咨询

原生断言的设计现状 #

Spring Cloud Gateway 原生RoutePredicate SPI为同步设计，test()方法直接返回boolean类型，官方未提供返回Mono<Boolean>的异步断言接口。若直接在断言逻辑中使用block()调用异步API，会占用Netty事件循环线程，破坏全链路非阻塞特性，不推荐使用。

无阻塞实现异步判定的适配方案 #

不需要修改网关核心源码，通过请求上下文预加载的方式即可实现全非阻塞的异步断言逻辑，实现步骤如下：

• 定义最高优先级的WebFilter，在路由匹配逻辑执行前完成异步API调用
  WebFilter执行时机早于路由匹配的HandlerMapping，支持返回Mono<Void>实现全异步逻辑。在过滤器中完成目标服务判定后，将结果写入ServerWebExchange的属性上下文即可，示例代码：

  @Component
  @Order(Ordered.HIGHEST_PRECEDENCE)
  public class TargetServiceJudgeFilter implements WebFilter {
      // 注入你的异步API调用客户端
      private final AsyncRouteApiClient asyncRouteApiClient;
  
      @Override
      public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
          return asyncRouteApiClient.getTargetService(exchange.getRequest())
                  .doOnNext(targetServiceId -> {
                      // 将异步判定结果存入请求上下文
                      exchange.getAttributes().put("attr-target-service", targetServiceId);
                  })
                  .then(chain.filter(exchange));
      }
  }
  

• 自定义路由断言实现，直接读取预计算的上下文结果
  断言执行时异步判定已经完成，直接从上下文读取结果返回布尔值即可，全程无阻塞：

  @Component
  public class MyRoutePredicateFactory extends AbstractRoutePredicateFactory<MyRoutePredicateFactory.Config> {
      public MyRoutePredicateFactory() {
          super(Config.class);
      }
  
      @Override
      public Predicate<ServerWebExchange> apply(Config config) {
          return exchange -> {
              String targetService = exchange.getAttribute("attr-target-service");
              // 匹配当前路由绑定的服务ID和预计算的目标服务
              return config.getServiceId().equals(targetService);
          };
      }
  
      // 配置类，接收当前路由绑定的服务ID
      @Data
      public static class Config {
          private String serviceId;
      }
  }
  

配合Consul服务发现自动生成路由的逻辑，每个服务实例生成的路由会自动绑定自身服务ID到断言配置，即可实现「API返回哪个服务，哪个服务的路由断言命中」的逻辑，全程无阻塞调用。

更轻量的替代实现方案 #

如果不想自定义断言，也可以通过以下两种方式实现相同的路由选择需求，适配成本更低：

• 自定义响应式负载均衡规则：配置一个通配路由统一承接/MyService/**的请求，自定义ReactorServiceInstanceLoadBalancer实现，在服务实例筛选阶段发起异步API调用，直接选中目标服务对应的实例返回，全程使用SCG原生的响应式负载均衡API，不需要改动路由断言逻辑。
• 全局过滤器动态改写URI：配置兜底路由承接所有匹配/MyService/**的请求，在优先级足够高的全局过滤器中完成异步判定，直接改写请求的目标URI为对应服务的地址，再交由后续转发过滤器处理，不需要依赖自动生成的服务路由。

不建议通过修改网关核心源码的方式将断言返回值改为Mono<Boolean>，该改动会重构整个路由遍历匹配的核心链路，后续版本升级兼容性成本极高。

内容的提问来源于stack exchange，提问作者ATrubka