如何在Spring的服务调用中获取Mono-QS-param值

Question

我对反应性非常陌生，所以在范式转变中有点挣扎，但是也许有人能帮我克服这个问题？

我的控制器将Mono（称为“limit”）作为服务参数传递给我的服务。Mono在subscribe上发出一个整数，服务使用该整数执行其工作，该整数返回一个流量。

在我的服务方法中，我需要订阅mono，但我需要在我的服务方法（对其他endpoint进行web客户端REST调用）之前订阅mono，因为REST调用中需要限制值。现在，我知道订阅将在某个点完成，但它是在主线程继续完成方法之后完成的。我的代码：

public Flux<User> getUserdata(Mono<Integer> limit) {

        return
                Flux.from(WebClient.create()
                        .get()
                        .uri(uriBase, uri -> {
                            uri.queryParam("_limit", limit.subscribe(k -> String.valueOf(k)));
                        })
                        .accept(MediaType.APPLICATION_JSON)
                        .retrieve()
                        .bodyToFlux(User.class));
}

如果我硬编码limit参数，这就行了。我需要有人确保订阅已完成。我知道我仍然对sync/async有点混淆，所以关于如何反应性地/正确地做到这一点，有什么想法/建议吗？

蒂亚，

彼得

Answer 1

Mono和Flux是制作人。订阅的用户称为消费者。在您的情况下，最终的消费者可能就是发起呼叫的消费者。很可能是一个网页，或另一个调用您的服务的服务。

我的意思是，既然你是制作人，你就不应该打电话给订阅，因为你不是最终的消费者。一旦你看到自己在做这件事，你就会知道这是一种代码气味。

我在下面重写了您提供的示例，并提供了一些注释。

public Flux<User> getUserdata(Mono<Integer> limit) {

    // Should be created in a @Configuration annotated, as a 
    // @Bean WebClient is quite a large class and can affect performance.
    final WebClient webclient = WebClient.create();

    // We flatMap incoming mono to get the value, and then
    // call webClient, bodyToFlux returns a Flux for us.
    return limit.flatMap(l -> webClient.get()
                        .uri(uriBase, uri -> {
                            uri.queryParam("_limit", String.valueOf(l))
                               .build());
                        })
                        .accept(MediaType.APPLICATION_JSON)
                        .retrieve()
                        .bodyToFlux(User.class));
}