问题描述
我不理解被动式Web客户端的工作原理。它说Spring Web客户端是非阻塞客户端，但这个Web客户端似乎在等待来自远程API的信号onComplete()，然后它可以处理从远程API发出的每一项。我希望当从目标API激发onNext()时，WebClient可以处理每一项
我是春季网络流量世界的新手。我读到过它，上面说它使用Netty作为默认服务器。而这个网络使用的是Eventloop。因此，为了了解它是如何工作的，我尝试创建了两个小应用程序，客户端和服务器。服务器应用程序只返回简单的流量，每项延迟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 22:44:20.122 INFO 19644 --- [ctor-http-nio-2] Item : : request(unbounded)
2019-05-01 22:44:21.126 INFO 19644 --- [ parallel-1] Item : : onNext(Item(id=null, description=Samsung TV, price=399.99))
2019-05-01 22:44:22.129 INFO 19644 --- [ parallel-2] Item : : onNext(Item(id=null, description=LG TV, price=329.99))
2019-05-01 22:44:23.130 INFO 19644 --- [ parallel-3] Item : : onNext(Item(id=null, description=Apple Watch, price=349.99))
2019-05-01 22:44:24.131 INFO 19644 --- [ parallel-4] Item : : onNext(Item(id=ABC, description=Beats HeadPhones, price=149.99))
2019-05-01 22:44:24.132 INFO 19644 --- [ parallel-4] Item : : onComplete()
来自客户端的日志：
2019-05-01 22:44:19.934 INFO 24164 --- [ctor-http-nio-2] reactor.Flux.MonoFlatMapMany.1 : onSubscribe(MonoFlatMapMany.FlatMapManyMain)
2019-05-01 22:44:19.936 INFO 24164 --- [ctor-http-nio-2] reactor.Flux.MonoFlatMapMany.1 : request(unbounded)
2019-05-01 22:44:19.940 TRACE 24164 --- [ctor-http-nio-2] o.s.w.r.f.client.ExchangeFunctions : [7e73de5c] HTTP GET http://localhost:8080/v1/items, headers={}
2019-05-01 22:44:24.159 TRACE 24164 --- [ctor-http-nio-6] o.s.w.r.f.client.ExchangeFunctions : [7e73de5c] Response 200 OK, headers={masked}
2019-05-01 22:44:24.204 INFO 24164 --- [ctor-http-nio-6] reactor.Flux.MonoFlatMapMany.1 : onNext(Item(id=null, description=Samsung TV, price=399.99))
2019-05-01 22:44:24.204 INFO 24164 --- [ctor-http-nio-6] reactor.Flux.MonoFlatMapMany.1 : onNext(Item(id=null, description=LG TV, price=329.99))
2019-05-01 22:44:24.204 INFO 24164 --- [ctor-http-nio-6] reactor.Flux.MonoFlatMapMany.1 : onNext(Item(id=null, description=Apple Watch, price=349.99))
2019-05-01 22:44:24.204 INFO 24164 --- [ctor-http-nio-6] reactor.Flux.MonoFlatMapMany.1 : onNext(Item(id=ABC, description=Beats HeadPhones, price=149.99))
2019-05-01 22:44:24.205 INFO 24164 --- [ctor-http-nio-6] reactor.Flux.MonoFlatMapMany.1 : onComplete()
我希望客户端不会等4秒就能得到实际结果。如您所见，服务器在22：44：21.126开始发出onNext()，而客户端在22：44：24.159获得结果。所以我不明白为什么WebClient会被称为非阻塞客户端，如果它有这种行为的话。
推荐答案
WebClient是非阻塞的，通过WebClient发送Http请求的线程不会被IO操作阻塞。当响应可用时，Netty将通知其中一个工作线程，并将根据您定义的反应流操作处理响应。
在您的示例中，服务器将等待，直到Flux中的所有元素都可用(4秒)，将它们序列化为JSON数组，然后在单个HTTP响应中将其发回。
客户端等待此单个响应，但在此期间它的所有线程都未被阻止。
如果您想要达到流媒体效果，您需要利用不同的内容类型或底层协议，如WebSockets。查看以下有关application/stream+json内容类型的SO帖子：Spring WebFlux Flux behavior with non streaming application/json
这篇关于Spring WebClient是否是非阻塞客户端？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！