如何在Spring Webflux/Reactor Netty web应用程序中执行阻塞调用

Question

在我的用例中，我有一个带有Reactor Netty的Spring Webflux微服务，我有以下依赖项：

null

由于reactor-core（版本0.7.6版）已包含在最新的spring-boot-dependencies（版本2.0.1版）中，因此不能再使用:block()/blockfirst()/blocklast（）are blocking（线程xxx不支持），请参阅->https://github.com/reactor/reactor-netty/issues/312

我的代码段：

java prettyprint-override">public Mono<FooBar> getFooBar(Foo foo) {
    MultiValueMap<String, String> parameters = new LinkedMultiValueMap<>();
    parameters.add("size", foo.getSize());
    parameters.addAll("bars", barReactiveCrudRepository.findAllByIdentifierIn(foo.getBarIdentifiers()) // This obviously returns a Flux
        .map(Bar::toString)
        .collectList()
        .block());

    String url = UriComponentsBuilder.fromHttpUrl("https://base-url/")
        .port(8081)
        .path("/foo-bar")
        .queryParams(parameters)
        .build()
        .toString();

    return webClient.get()
        .uri(url)
        .retrieve()
        .bodyToMono(FooBar.class);
}

这适用于spring-boot版本2.0.0.release，但由于升级到版本2.0.1.release，因此从ractor-core升级到版本0.7.6.release，因此不允许再这样做了。

我看到的唯一真正的解决方案是包括一个块（非反应的）存储库/mongo客户机，但我不确定是否鼓励这样做。有什么建议吗？

Answer 1

webclient不接受其请求URL的publisher类型，但没有什么可以阻止您执行以下操作：

public Mono<FooBar> getFooBar(Foo foo) {

    Mono<List<String>> bars = barReactiveCrudRepository
        .findAllByIdentifierIn(foo.getBarIdentifiers())
        .map(Bar::toString)
        .collectList();

    Mono<FooBar> foobar = bars.flatMap(b -> {

        MultiValueMap<String, String> parameters = new LinkedMultiValueMap<>();
        parameters.add("size", foo.getSize());
        parameters.addAll("bars", b);

        String url = UriComponentsBuilder.fromHttpUrl("https://base-url/")
            .port(8081)
            .path("/foo-bar")
            .queryParams(parameters)
            .build()
            .toString();

        return webClient.get()
            .uri(url)
            .retrieve()
            .bodyToMono(FooBar.class);
    });
    return foobar;         
}

如果有的话，这个新的Reactor核心检查使您避免了在WebFlux处理程序中间使用这个阻塞调用而使整个应用程序崩溃。