Spring reactive reading web客户端响应

Question

import org.springframework.web.reactive.function.client.WebClient;
// other imports etc

@Slf4j
class WebClientTests {
  private static String baseUrl = "http://localhost:8080";
  private static WebClient client = WebClient.create(baseUrl);
  @Test
  void testWebClient() {
    Instant start = Instant.now();
    Flux.just(1,2,3)
      .map(i -> client.get().uri("/person/{id}", i).retrieve().bodyToFlux(Person.class))
      .subscribe(s -> {
        log.info("subscribed: {}", s);
      });
    log.info("Elapsed time: " + Duration.between(start, Instant.now()).toMillis() + "ms");
  }
}

20:32:55.251 [main] DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetection.targetRecords: 4
20:32:55.652 [main] INFO com.example.reactive.reactivedemo.WebClientTests - subscribed: MonoFlatMap
20:32:55.652 [main] INFO com.example.reactive.reactivedemo.WebClientTests - subscribed: MonoFlatMap
20:32:55.652 [main] INFO com.example.reactive.reactivedemo.WebClientTests - subscribed: MonoFlatMap
20:32:55.668 [main] INFO com.example.reactive.reactivedemo.WebClientTests - Elapsed time: 84ms

但是，我不确定为什么它不输出get请求的值？它实际上并不触发endpoint。

Answer 1

您几乎肯定希望在.map(i->client.get().uri...行上使用FlatMap()，而不是Map()。

map()用于同步转换，返回要映射到的实际值。您不是返回一个实际值--您是从map方法返回一个publisher，因此publisher只是原样返回--它从未被订阅，而且由于在您订阅之前什么都不会发生，所以您的web请求永远不会执行。

flatmap()用于非阻塞转换，在此转换中，您返回一个发布者，该发布者发出要映射到的一个或多个值。该发布服务器作为您的反应链的一部分被订阅，并且该发布服务器发出的值沿着该链传递给下一个操作员。