blocks|key|5689861|text|我想这个问题是关于在Spring+Boot中添加一个新的spring.codec.max-+in+-memory-size配置属性。将其添加到属性中，如：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|5689862|spring:
++codec:
++++max-in-memory-size:+10MB|code-block|syntax|javascript|5689863|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

I suppose this issue is about adding a new spring.codec.max-in-memory-size configuration property in Spring Boot. Add it to the properties like:

<pre><code>spring:
 codec:
 max-in-memory-size: 10MB
</code></pre>

blocks|key|2160590|text|在spring+boot配置文件中设置maximum+bytes+(以+in+为单位)，如下所示：|type|unstyled|depth|inlineStyleRanges|offset|length|style|BOLD|entityRanges|data|2160591|spring.codec.max-in-memory-size=20MB|code-block|syntax|javascript|2160592|entityMap^0|1|B|R|5|Z|4|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@$9|N|A|O|B|C]|$9|P|A|Q|B|C]|$9|R|A|S|B|C]]|D|@]|E|$]]|$1|F|3|G|5|H|7|T|8|@]|D|@]|E|$I|J]]|$1|K|3|-4|5|6|7|U|8|@]|D|@]|E|$]]]|L|$]]

Set the maximum bytes (in megabytes) in you spring boot configuration file like below:

<pre><code>spring.codec.max-in-memory-size=20MB
</code></pre>

blocks|key|1700401|text|对于一个简单的RestController+(我发布了一个大的json字符串)，我得到了这个错误。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1700402|下面是我如何成功地更改maxInMemorySize|offset|length|style|CODE|1700403|import+org.springframework.context.annotation.Configuration;
import+org.springframework.http.codec.ServerCodecConfigurer;
import+org.springframework.web.reactive.config.ResourceHandlerRegistry;
import+org.springframework.web.reactive.config.WebFluxConfigurer;

@Configuration
public+class+WebfluxConfig+implements+WebFluxConfigurer+{

++++@Override
++++public+void+addResourceHandlers(ResourceHandlerRegistry+registry)+{

++++++++registry.addResourceHandler("/swagger-ui.html**")
++++++++++++.addResourceLocations("classpath:/META-INF/resources/");

++++++++registry.addResourceHandler("/webjars/**")
++++++++++++.addResourceLocations("classpath:/META-INF/resources/webjars/");
++++}

++++@Override
++++public+void+configureHttpMessageCodecs(ServerCodecConfigurer+configurer)+{
++++++++configurer.defaultCodecs().maxInMemorySize(16+*+1024+*+1024);
++++}
}|code-block|syntax|javascript|1700404|令人惊讶的是，这很难找到|1700405|entityMap^0|0|B|F|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|R|8|@$D|S|E|T|F|G]]|9|@]|A|$]]|$1|H|3|I|5|J|7|U|8|@]|9|@]|A|$K|L]]|$1|M|3|N|5|6|7|V|8|@]|9|@]|A|$]]|$1|O|3|-4|5|6|7|W|8|@]|9|@]|A|$]]]|P|$]]

i was getting this error for a simple RestController (i post a large json string).

here is how i successfully changed the <code>maxInMemorySize</code>

<pre><code>import org.springframework.context.annotation.Configuration;
import org.springframework.http.codec.ServerCodecConfigurer;
import org.springframework.web.reactive.config.ResourceHandlerRegistry;
import org.springframework.web.reactive.config.WebFluxConfigurer;

@Configuration
public class WebfluxConfig implements WebFluxConfigurer {

 @Override
 public void addResourceHandlers(ResourceHandlerRegistry registry) {

 registry.addResourceHandler("/swagger-ui.html**")
 .addResourceLocations("classpath:/META-INF/resources/");

 registry.addResourceHandler("/webjars/**")
 .addResourceLocations("classpath:/META-INF/resources/webjars/");
 }

 @Override
 public void configureHttpMessageCodecs(ServerCodecConfigurer configurer) {
 configurer.defaultCodecs().maxInMemorySize(16 * 1024 * 1024);
 }
}
</code></pre>

this was surprisingly hard to find

blocks|key|1697976|text|这个工作台很适合我|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1697977|1697978|在某个配置类或主Springbootapplication类中创建bean|ordered-list-item|1697979|1697980|@Bean+public+WebClient+getWebClientBuilder(){+return+WebClient.builder().exchangeStrategies(ExchangeStrategies.builder()+.codecs(configurer+->+configurer+.defaultCodecs()+.maxInMemorySize(16+*+1024+*+1024))+.build())+.build()；}|1697981|1697982|下一步，转到要使用the客户端的所需类|1697983|1697984|@RestController+/+@Bean/+@服务公共类PaySharpGatewayController+{+@Autowired+webClient；public+void+test(){+String+out+=+webClient+.get()+.uri(“API的端点”)+.retrieve()+.bodyToMono(String.class)+.block()；sysout(out)+}|1697985|entityMap^0|0|0|0|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@]|A|$]]|$1|B|3|-4|5|6|7|R|8|@]|9|@]|A|$]]|$1|C|3|D|5|E|7|S|8|@]|9|@]|A|$]]|$1|F|3|-4|5|6|7|T|8|@]|9|@]|A|$]]|$1|G|3|H|5|6|7|U|8|@]|9|@]|A|$]]|$1|I|3|-4|5|6|7|V|8|@]|9|@]|A|$]]|$1|J|3|K|5|E|7|W|8|@]|9|@]|A|$]]|$1|L|3|-4|5|6|7|X|8|@]|9|@]|A|$]]|$1|M|3|N|5|6|7|Y|8|@]|9|@]|A|$]]|$1|O|3|-4|5|6|7|Z|8|@]|9|@]|A|$]]]|P|$]]

This workerd for me
<ol>
<li>Create a bean in your one of the configuration class or the main Springbootapplication class
<pre><code>@Bean
public WebClient getWebClientBuilder(){
 return WebClient.builder().exchangeStrategies(ExchangeStrategies.builder()
 .codecs(configurer -&gt; configurer
 .defaultCodecs()
 .maxInMemorySize(16 * 1024 * 1024))
 .build())
 .build();
}
</code></pre>
</li>
<li>Next go to your desired class where you want to use the webclient
<pre><code> @RestController / @Bean/ @Service
 public class PaySharpGatewayController {
 @Autowired
 WebClient webClient;

 public void test(){
 String out = webClient
 .get()
 .uri(&quot;end point of an API&quot;)
 .retrieve()
 .bodyToMono(String.class)
 .block();

 sysout(out)
 }
</code></pre>
</li>
</ol>

blocks|key|5689978|text|你可以流式传输，而不是一次检索数据：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|5689979|Mono<String>+string+=+webClient.get()
++++.uri("end+point+of+an+API")
++++.retrieve()
++++.bodyToFlux(DataBuffer.class)
++++.map(buffer+->+{
++++++++String+string+=+buffer.toString(Charset.forName("UTF-8"));
++++++++DataBufferUtils.release(buffer);
++++++++return+string;
++++});|code-block|syntax|javascript|5689980|或者，转换为stream：|5689981|++++.map(b+->+b.asInputStream(true))
++++.reduce(SequenceInputStream::new)
++++.map(stream+->+{
++++++++//+consume+stream
++++++++stream.close();
++++++++return+string;
++++});|5689982|在大多数情况下，您不希望真正聚合流，而不是直接处理它。需要在内存中加载大量数据，这主要是将方法改变为更具反应性的方法。JSON和XML解析器都有流接口。|5689983|entityMap^0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|P|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|Q|8|@]|9|@]|A|$]]|$1|I|3|J|5|D|7|R|8|@]|9|@]|A|$E|F]]|$1|K|3|L|5|6|7|S|8|@]|9|@]|A|$]]|$1|M|3|-4|5|6|7|T|8|@]|9|@]|A|$]]]|N|$]]

Instead of retrieving data at once, you can stream:
<pre><code>Mono&lt;String&gt; string = webClient.get()
 .uri(&quot;end point of an API&quot;)
 .retrieve()
 .bodyToFlux(DataBuffer.class)
 .map(buffer -&gt; {
 String string = buffer.toString(Charset.forName(&quot;UTF-8&quot;));
 DataBufferUtils.release(buffer);
 return string;
 });
</code></pre>
Alternatively convert to stream:
<pre><code> .map(b -&gt; b.asInputStream(true))
 .reduce(SequenceInputStream::new)
 .map(stream -&gt; {
 // consume stream
 stream.close();
 return string;
 });
</code></pre>
In most cases you don't want to really aggregate the stream, rather than processing it directly. The need to load huge amount of data in memory is mostly a sign to change the approach to more reactive one. JSON- and XML-Parsers have streaming interfaces.

blocks|key|4272726|text|另一种选择是创建一个自定义的CodecCustomizer，它将同时应用于WebFlux和WebClient：|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|4272727|@Configuration
class+MyAppConfiguration+{

++++companion+object+{
++++++++private+const+val+MAX_MEMORY_SIZE+=+50+*+1024+*+1024+//+50+MB
++++}

++++@Bean
++++fun+codecCustomizer():+CodecCustomizer+{
++++++++return+CodecCustomizer+{
++++++++++++it.defaultCodecs()
++++++++++++++++.maxInMemorySize(MAX_MEMORY_SIZE)
++++++++}
++++}
}|code-block|syntax|javascript|4272728|entityMap^0|E|F|11|7|19|9|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@$9|N|A|O|B|C]|$9|P|A|Q|B|C]|$9|R|A|S|B|C]]|D|@]|E|$]]|$1|F|3|G|5|H|7|T|8|@]|D|@]|E|$I|J]]|$1|K|3|-4|5|6|7|U|8|@]|D|@]|E|$]]]|L|$]]

Another alternative could be creating a custom <code>CodecCustomizer</code>, which is going to be applied to both <code>WebFlux</code> and <code>WebClient</code> at the same time:
<pre class="lang-kotlin prettyprint-override"><code>@Configuration
class MyAppConfiguration {

 companion object {
 private const val MAX_MEMORY_SIZE = 50 * 1024 * 1024 // 50 MB
 }

 @Bean
 fun codecCustomizer(): CodecCustomizer {
 return CodecCustomizer {
 it.defaultCodecs()
 .maxInMemorySize(MAX_MEMORY_SIZE)
 }
 }
}
</code></pre>

blocks|key|4272733|text|这对我很有效|type|unstyled|depth|inlineStyleRanges|entityRanges|data|4272734|val+exchangeStrategies+=+ExchangeStrategies.builder()
++++++++++++++++.codecs+{+configurer:+ClientCodecConfigurer+->+configurer.defaultCodecs().maxInMemorySize(16+*+1024+*+1024)+}.build()
++++++++return+WebClient.builder().exchangeStrategies(exchangeStrategies).build()|code-block|syntax|javascript|4272735|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

This worked for me
<pre><code>val exchangeStrategies = ExchangeStrategies.builder()
 .codecs { configurer: ClientCodecConfigurer -&gt; configurer.defaultCodecs().maxInMemorySize(16 * 1024 * 1024) }.build()
 return WebClient.builder().exchangeStrategies(exchangeStrategies).build()
</code></pre>

blocks|key|5690026|text|对我很管用|type|unstyled|depth|inlineStyleRanges|entityRanges|data|5690027|webTestClient.mutate().codecs(configurer+->+configurer
++.defaultCodecs()
++.maxInMemorySize(16+*+1024+*+1024)).build().get()
++.uri("/u/r/l")
++.exchange()
++.expectStatus()
++.isOk()|code-block|syntax|javascript|5690028|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

worked for me
<pre><code>webTestClient.mutate().codecs(configurer -&gt; configurer
 .defaultCodecs()
 .maxInMemorySize(16 * 1024 * 1024)).build().get()
 .uri(&quot;/u/r/l&quot;)
 .exchange()
 .expectStatus()
 .isOk()
</code></pre>

blocks|key|1700441|text|从Spring+Boot+2.3.0开始，反应式Elasticsearch+REST客户端有了一个专用的配置属性。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1700442|可以使用以下配置属性为客户端设置特定的内存限制。|1700443|spring.data.elasticsearch.client.reactive.max-in-memory-size=已经存在的spring.codec.max-+in+-memory-size属性是独立的，并且只影响应用程序中的其他WebClient实例。|1700444|entityMap^0|0|0|0^^$0|@$1|2|3|4|5|6|7|H|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|I|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|J|8|@]|9|@]|A|$]]|$1|F|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|G|$]]

As of Spring Boot 2.3.0, there is now a dedicated configuration property for the Reactive Elasticsearch REST client.
You can use the following configuration property to set a specific memory limit for the client.
spring.data.elasticsearch.client.reactive.max-in-memory-size=
The already existing spring.codec.max-in-memory-size property is separate and only affects other WebClient instances in the application.

While sending a file I receive an array of bytes. I always have a problem with webflux to receive an array.
the error thrown as below :
<pre><code>org.springframework.core.io.buffer.DataBufferLimitException: Exceeded limit on max bytes to buffer : 262144
 at org.springframework.core.io.buffer.LimitedDataBufferList.raiseLimitException(LimitedDataBufferList.java:101)
 Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException
</code></pre>
Do you now how to resolve that in webflux ?

DataBufferLimitException: Exceeded limit on max bytes to buffer webflux error

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

在发送文件时，我收到一个字节数组。我总是在webflux接收数组时遇到问题。抛出的错误如下：org.springframework.core.io.buffer.DataBufferLimitException: Exceeded limit on max bytes to buffer : 262144    at ...

问DataBufferLimitException:超出缓冲webflux错误的最大字节数限制
EN

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问DataBufferLimitException:超出缓冲webflux错误的最大字节数限制EN