基于请求体内容的Spring云网关路由

Question

我需要创建一个反向代理，接收传入的请求，并基于请求正文的内容，将请求路由到特定的URI。

这是一个路由微服务，它类似于反向代理，根据来自每个请求主体的一些信息进行路由。这意味着对于每个请求，我需要解析请求正文并获得“username”字段，然后建立JDBC连接以从数据库中获取附加信息。根据数据库中的信息，它最终将请求重定向到正确的URI。

从我现在所拥有的，我有2个阻止方法。第一个是请求主体的解析，另一个是到数据库的JDBC连接。我明白我不应该在网关过滤器内放置任何阻塞调用。我只是不知道在这种情况下我该怎么办。我可以让两个操作都运行异步，但最终我仍然需要数据库的信息来进行路由。

    @Bean
    public RouteLocator apiLocator(RouteLocatorBuilder builder, XmlMapper xmlMapper) {
        return builder.routes()
            .route(r -> r
                .path("/test")
                .and()
                .readBody(String.class, s -> true)  // Read the request body, data will be cached as cachedRequestBodyObject
                .filters(f -> f.filter(new GatewayFilter() {
                    @Override
                    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
                        try {
                            // The following method is blocking and should not be put here
                            xmlMapper.readValue((String) exchange.getAttribute("cachedRequestBodyObject"), Map.class);
                        } catch (Exception e) {
                            //TODO
                        }
                        return chain.filter(exchange);
                    }
                }))
                .uri("http://localhost:8080"))
            .build();
    }

上面的示例只包括阻塞解析，因为我的请求体是基于XML的。我的IDE警告我那里有阻塞调用，我真的很感激。

非常感谢任何帮助。谢谢大家！

Answer 1

经过一些研究，Mono.FromCallable似乎很适合。然后我直接在github repo下问了同样的问题，结果发现使用servlet应用程序可能更好。对于任何有兴趣了解我的想法的人，请查看https://github.com/spring-cloud/spring-cloud-gateway/issues/1229