发送文件时，我收到一个字节数组。我总是遇到 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 中解决这个问题？
【问题讨论】：
标签： java spring webclient spring-webflux
我想这个问题是关于在 Spring Boot 中添加一个新的spring.codec.max-in-memory-size 配置属性。将其添加到 application.yml 文件中，例如：
spring:
codec:
max-in-memory-size: 10MB
【讨论】：
在 Spring Boot application.properties 配置文件中设置最大 bytes（以 megabytes 为单位，如下所示：
spring.codec.max-in-memory-size=20MB
【讨论】：
我在一个简单的 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);
}
}
这出奇地难找
【讨论】：
这对我有用：
在您的配置类之一或主SpringBootApplication 类中创建@Bean：
@Bean
public WebClient webClient() {
final int size = 16 * 1024 * 1024;
final ExchangeStrategies strategies = ExchangeStrategies.builder()
.codecs(codecs -> codecs.defaultCodecs().maxInMemorySize(size))
.build();
return WebClient.builder()
.exchangeStrategies(strategies)
.build();
}
接下来，转到您想要使用WebClient 的所需课程：
@Service
public class TestService {
@Autowired
private WebClient webClient;
public void test() {
String out = webClient
.get()
.uri("/my/api/endpoint")
.retrieve()
.bodyToMono(String.class)
.block();
System.out.println(out);
}
}
【讨论】：
maxInMemorySize属性，你直接配置你的webclient，绕过spring-boot的Web配置。
您可以流式传输，而不是立即检索数据：
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 解析器具有流式接口。
【讨论】：
buffer 定义在哪里？
另一种选择是创建自定义CodecCustomizer，它将同时应用于WebFlux 和WebClient：
@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)
}
}
}
【讨论】：
这对我有用
val exchangeStrategies = ExchangeStrategies.builder()
.codecs { configurer: ClientCodecConfigurer -> configurer.defaultCodecs().maxInMemorySize(16 * 1024 * 1024) }.build()
return WebClient.builder().exchangeStrategies(exchangeStrategies).build()
【讨论】：
为我工作
webTestClient.mutate().codecs(configurer -> configurer
.defaultCodecs()
.maxInMemorySize(16 * 1024 * 1024)).build().get()
.uri("/u/r/l")
.exchange()
.expectStatus()
.isOk()
【讨论】：
从 Spring Boot 2.3.0 开始，现在有一个专门用于 Reactive Elasticsearch REST 客户端的配置属性。
您可以使用以下配置属性为客户端设置特定的内存限制。
spring.data.elasticsearch.client.reactive.max-in-memory-size= 已经存在的 spring.codec.max-in-memory-size 属性是独立的，只影响应用程序中的其他 WebClient 实例。
【讨论】：