Spring Cloud Gateway自定义过滤器：webclient.create（）.post（）在测试时导致挂起

Question

因此，我创建了一个自定义过滤器，当被访问时，它将创建一个webflux客户机并发送到预定的URL。这在运行时似乎很好，但在测试这段代码时，测试就挂起了（直到我取消测试）。因此，我觉得除了无法完成测试以确保此路由正常工作之外，还可能存在内存泄漏。如果我将WebClient方法切换为get()，那么筛选器的结果测试工作正常。带有post()的东西我不确定缺少什么。

@Component
class ProxyGatewayFilterFactory: AbstractGatewayFilterFactory<ProxyGatewayFilterFactory.Params>(Params::class.java) {
    override fun apply(params: Params): GatewayFilter {
        return OrderedGatewayFilter(
                GatewayFilter { exchange, chain ->
                    exchange.request.mutate().header("test","test1").build()
                    WebClient.create().post()
                            .uri(params.proxyBasePath)
                            .body(BodyInserters.fromDataBuffers(exchange.request.body))
                            .headers { it.addAll(exchange.request.headers) }
                            .exchange()
                            .flatMap {
                                println("the POST statusCode is "+it.statusCode())
                                Mono.just(it.statusCode().is2xxSuccessful)
                            }
                            .map {
                                exchange.request.mutate().header("test", "test2").build()
                                println("exchange request uri is " + exchange.request.uri)
                                println("exchange response statusCode is "+ exchange.response.statusCode)
                                exchange
                            }
                            .flatMap(chain::filter)
                }, params.order)
}

Answer 1

摘自文档，如果使用exchange，您有义务使用正文。

与retrieve（）不同，在使用exchange（）时，应用程序负责使用任何响应内容，而不管场景如何（成功、错误、意外数据等）。不这样做会导致内存泄漏。用于ClientResponse的Javadoc列出了消费主体的所有可用选项。通常更喜欢使用retrieve()，除非您有充分的理由使用exchange()，它允许在决定如何或是否使用响应之前检查响应状态和头。

Spring framework 5.2.9 Webclient

这个api在spring framework 5.3.0的最新版本中已经改变，现在spring将强制您使用主体，因为开发人员实际上并没有阅读文档。