[type: feat] body maxInMemorySize (#3640)

* "feat body maxInMemorySize"

* fix ci error

* fix ci error

Author: impactCn

shenyu-bootstrap/src/main/resources/application.yml

@@ -121,6 +121,7 @@ shenyu:
 #    writeTimeout: 3000
 #    wiretap: false
 #    keepAlive: false
+#    maxInMemorySize: 16 * 1024 * 1024
 #    pool:
 #      type: ELASTIC
 #      name: proxy

shenyu-plugin/shenyu-plugin-httpclient/src/main/java/org/apache/shenyu/plugin/httpclient/config/HttpClientProperties.java

@@ -116,6 +116,11 @@ public class HttpClientProperties {
      */
     private boolean keepAlive;
 
+    /**
+     * body max memory size, unit byte.
+     */
+    private int maxInMemorySize;
+
     /**
      * Gets strategy.
      *
@@ -369,6 +374,22 @@ public void setKeepAlive(final boolean keepAlive) {
         this.keepAlive = keepAlive;
     }
 
+    /**
+     * get maxInMemorySize.
+     * @return maxInMemorySize
+     */
+    public int getMaxInMemorySize() {
+        return maxInMemorySize;
+    }
+
+    /**
+     * set maxInMemorySize.
+     * @param maxInMemorySize maxInMemorySize
+     */
+    public void setMaxInMemorySize(final int maxInMemorySize) {
+        this.maxInMemorySize = maxInMemorySize;
+    }
+
     /**
      * The type Pool.
      */

shenyu-spring-boot-starter/shenyu-spring-boot-starter-plugin/shenyu-spring-boot-starter-plugin-httpclient/src/main/java/org/apache/shenyu/springboot/starter/plugin/httpclient/HttpClientPluginConfiguration.java

@@ -35,6 +35,7 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.http.client.reactive.ReactorClientHttpConnector;
+import org.springframework.web.reactive.function.client.ExchangeStrategies;
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.netty.http.client.HttpClient;
 import reactor.netty.resources.ConnectionProvider;
@@ -233,8 +234,20 @@ static class WebClientConfiguration {
          * @return the shenyu plugin
          */
         @Bean
-        public ShenyuPlugin webClientPlugin(final ObjectProvider<HttpClient> httpClient) {
-            WebClient webClient = WebClient.builder()
+        public ShenyuPlugin webClientPlugin(
+                final HttpClientProperties properties,
+                final ObjectProvider<HttpClient> httpClient) {
+            WebClient.Builder builder = WebClient.builder();
+            if (properties.getMaxInMemorySize() != 0) {
+                // fix Exceeded limit on max bytes to buffer
+                // detail see https://stackoverflow.com/questions/59326351/configure-spring-codec-max-in-memory-size-when-using-reactiveelasticsearchclient
+                ExchangeStrategies strategies = ExchangeStrategies.builder()
+                        .codecs(codecs -> codecs.defaultCodecs().maxInMemorySize(properties.getMaxInMemorySize()))
+                        .build();
+                builder = builder.exchangeStrategies(strategies);
+            }
+
+            WebClient webClient = builder
                     .clientConnector(new ReactorClientHttpConnector(Objects.requireNonNull(httpClient.getIfAvailable())))
                     .build();
             return new WebClientPlugin(webClient);