diff --git a/spring/webflux/webclient.md b/spring/webflux/webclient.md index 6f9a1ca..59af3fb 100644 --- a/spring/webflux/webclient.md +++ b/spring/webflux/webclient.md @@ -38,3 +38,59 @@ WebClient client2 = client1.mutate() // client2 has filterA, filterB, filterC, filterD ``` +### MaxInMemorySize +Codecs对于缓存在内存中的数据大小存在限制,避免导致应用的内存问题。默认情况下,该值被设置为`256KB`,如果该大小不够,那么将会见到如下报错: +``` +org.springframework.core.io.buffer.DataBufferLimitException: Exceeded limit on max bytes to buffer +``` +如果想要修改该默认的codecs限制,可以使用如下配置: +```java +WebClient webClient = WebClient.builder() + .codecs(configurer -> configurer.defaultCodecs().maxInMemorySize(2 * 1024 * 1024)) + .build(); +``` + +### reactor netty +为了自定义reactor netty配置,可以提供一个预先定义的`HttpClient` +```java +HttpClient httpClient = HttpClient.create().secure(sslSpec -> ...); + +WebClient webClient = WebClient.builder() + .clientConnector(new ReactorClientHttpConnector(httpClient)) + .build(); +``` +#### Resources +默认情况下,`HttpClient`将会参与使用`reactor.netty.http.HttpResources`中保存的全局reactor netty resources。 + +`HttpResources`中包含event loop threads和connection pool,HttpClient会使用这些共享的资源。对于基于event loop的并发,更倾向使用固定、共享的资源,直到进程退出时这些全局资源才会被释放。 + +如果server的生命周期和进程相同,那么对全局资源无需手动释放。但若server在进程的生命周期中可能会启动和停止,那么可以声明一个`ReactorResourceFactory`类型的bean,并设置`globalResources=true`(默认),从而确保reactor netty的global resource在`ApplicationContext`关闭时被释放,示例如下所示: +```java +@Bean +public ReactorResourceFactory reactorResourceFactory() { + return new ReactorResourceFactory(); +} +``` + +也可以不使用global reactor netty resources,但是,在该模式下,你需要确保所有reactor netty client and server使用共享的资源,示例如下所示: +```java +@Bean +public ReactorResourceFactory resourceFactory() { + ReactorResourceFactory factory = new ReactorResourceFactory(); + factory.setUseGlobalResources(false); + return factory; +} + +@Bean +public WebClient webClient() { + + Function mapper = client -> { + // Further customizations... + }; + + ClientHttpConnector connector = + new ReactorClientHttpConnector(resourceFactory(), mapper); + + return WebClient.builder().clientConnector(connector).build(); +} +```