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

Question

在发送文件时，我收到一个字节数组。我总是遇到 webflux 接收数组的问题。抛出的错误如下：

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

你现在如何在 webflux 中解决这个问题？

Answer 1

这为我工作

1. 在您的配置类或主 Springbootapplication 类之一中创建一个 bean

   @Bean
   public WebClient getWebClientBuilder(){
       return   WebClient.builder().exchangeStrategies(ExchangeStrategies.builder()
               .codecs(configurer -> configurer
                         .defaultCodecs()
                         .maxInMemorySize(16 * 1024 * 1024))
                       .build())
                     .build();
   }
   

2. 接下来转到您想要使用 webclient 的所需类

     @RestController / @Bean/ @Service
      public class PaySharpGatewayController {
           @Autowired
           WebClient webClient;
   
           public void test(){
            String out = webClient
                         .get()
                         .uri("end point of an API")
                         .retrieve()
                         .bodyToMono(String.class)
                        .block();
   
            sysout(out)
           }
   

Answer 2

我想这个问题是关于在 Spring Boot 中添加一个新的 spring.codec.max-in-memory-size 配置属性。将其添加到如下属性中：

spring:
  codec:
    max-in-memory-size: 10MB

Answer 3

这是摆脱异常的官方方法（请参阅文档）：

webTestClient.mutate()
  .codecs(configurer -> configurer
          .defaultCodecs()
          .maxInMemorySize(16 * 1024 * 1024))
  .build().get()
  .uri("/u/r/l")
  .exchange()
  .expectStatus()
  .isOk()

Answer 4

对于一个简单的 RestController，我收到了这个错误（我发布了一个大的 json 字符串）。

这是我如何成功更改 maxInMemorySize

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);
    }
}

这出奇地难找

Answer 5

在spring boot配置文件中设置最大字节（以兆字节为单位），如下所示：

spring.codec.max-in-memory-size=20MB

Answer 6

您可以流式传输，而不是立即检索数据：

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;
    });

或者转换为流：

    .map(b -> b.asInputStream(true))
    .reduce(SequenceInputStream::new)
    .map(stream -> {
        // consume stream
        stream.close();
        return string;
    });

在大多数情况下，您不想真正聚合流，而不是直接处理它。需要在内存中加载大量数据主要是改变方法的一种标志。JSON 和 XML 解析器具有流接口。

Answer 7

这对我有用

val exchangeStrategies = ExchangeStrategies.builder()
                .codecs { configurer: ClientCodecConfigurer -> configurer.defaultCodecs().maxInMemorySize(16 * 1024 * 1024) }.build()
        return WebClient.builder().exchangeStrategies(exchangeStrategies).build()