在发送文件时，我会收到一个字节数组。但是使用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中解决这个问题吗？
这对我有用：
在你的配置类或主要的 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配置。 - Georgios Syngouroglou我认为这个问题是关于在Spring Boot中添加一个新的spring.codec.max-in-memory-size配置属性。 将其添加到application.yml文件中，如下所示：
spring:
codec:
max-in-memory-size: 10MB
请按以下方式在您的 Spring Boot application.properties 配置文件中设置最大字节数（以兆为单位）：
spring.codec.max-in-memory-size=20MB
webTestClient.mutate()
.codecs(configurer -> configurer
.defaultCodecs()
.maxInMemorySize(16 * 1024 * 1024))
.build().get()
.uri("/u/r/l")
.exchange()
.expectStatus()
.isOk()
在一个简单的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);
}
}
这个竟然很难找到。
不需要一次性检索数据，你可以使用流式传输：
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 定义在哪里？ - Ashok KoyiDataBufferUtils.release(buffer)的调用。这似乎像是手动内存管理，而这与 Java 的通常做法相左。 - Krzysztof Tomaszewski这对我有效
val exchangeStrategies = ExchangeStrategies.builder()
.codecs { configurer: ClientCodecConfigurer -> configurer.defaultCodecs().maxInMemorySize(16 * 1024 * 1024) }.build()
return WebClient.builder().exchangeStrategies(exchangeStrategies).build()
另一个选择是创建自定义的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)
}
}
}
从Spring Boot 2.3.0开始，现在有一个专门的配置属性用于Reactive Elasticsearch REST客户端。
您可以使用以下配置属性来为客户端设置特定的内存限制。
spring.data.elasticsearch.client.reactive.max-in-memory-size= 已经存在的spring.codec.max-in-memory-size属性是独立的，并且仅影响应用程序中的其他WebClient实例。
Integer CODEC_20_MB_SIZE = 20 * 1024 * 1024;
WebClient.builder()
.codecs(clientCodecConfigurer -> {
var codec = new Jackson2JsonDecoder();
codec.setMaxInMemorySize(CODEC_20_MB_SIZE);
clientCodecConfigurer.customCodecs().register(codec);
clientCodecConfigurer.customCodecs().register(new Jackson2JsonEncoder());
});