小编Ant*_* Tb的帖子

我不明白反应式 webclient 的工作原理。它说spring webclient是非阻塞客户端，但是这个webclient似乎在等待来自远程api的onComplete()信号，然后它可以处理从远程api发出的每个项目。我期望当 onNext() 从目标 api 被触发时，webclient 可以处理每个项目

我是春季 webflux 世界的新手。我读到它，它说它使用 netty 作为默认服务器。而这个 netty 使用 eventloop。所以为了理解它是如何工作的，我尝试创建 2 个小应用程序，客户端和服务器。服务器应用程序只返回简单的通量，每个项目延迟 1 秒。客户端应用程序使用 webclient 调用远程 api。

服务器：

@GetMapping(ITEM_END_POINT_V1)
public Flux<Item> getAllItems(){
        return Flux.just(new Item(null, "Samsung TV", 399.99),
                new Item(null, "LG TV", 329.99),
                new Item(null, "Apple Watch", 349.99),
                new Item("ABC", "Beats HeadPhones", 
      149.99)).delayElements(Duration.ofSeconds(1)).log("Item : ");
}

客户：

WebClient webClient = WebClient.create("http://localhost:8080");

@GetMapping("/client/retrieve")
public Flux<Item> getAllItemsUsingRetrieve() {
        return webClient.get().uri("/v1/items")
                .retrieve()
                .bodyToFlux(Item.class).log();
}

从服务器登录：

2019-05-01 22:44:20.121  INFO 19644 --- [ctor-http-nio-2] Item :                                   : onSubscribe(FluxConcatMap.ConcatMapImmediate)
2019-05-01 …

有人可以帮助我了解Mono.defer（），Mono.create（）和Mono.just（）之间的区别吗？如何正确使用？