问题描述 #

当前端向我的Java Spring后端发送请求时，返回了PayloadTooLargeException: 413 PAYLOAD_TOO_LARGE，堆栈信息如下：

Caused by: org.springframework.core.io.buffer.DataBufferLimitException: Exceeded limit on max bytes to buffer : 262144
at org.springframework.core.io.buffer.LimitedDataBufferList.raiseLimitException(LimitedDataBufferList.java:99)
at org.springframework.core.io.buffer.LimitedDataBufferList.updateCount(LimitedDataBufferList.java:92)
at org.springframework.core.io.buffer.LimitedDataBufferList.add(LimitedDataBufferList.java:58)
at reactor.core.publisher.MonoCollect$CollectSubscriber.onNext(MonoCollect.java:103)

我想知道有没有办法只给某个特定接口增大缓冲区大小？我知道可以全局调整，但希望其他接口保持原有设置，只给需要的接口扩容。

当然可以实现这种精细化控制！从堆栈信息来看你用的是Spring WebFlux，下面给你两种实用的方案：

方案一：单个接口手动控制缓冲区大小 #

这种方式适合只需要给某一个接口调整的场景，直接在接口方法里手动处理请求体，指定自定义的缓冲区上限：

import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.http.server.reactive.ServerHttpRequest;
import reactor.core.publisher.Mono;

@RestController
public class LargePayloadController {

    @PostMapping("/your-specific-endpoint")
    public Mono<ResponseEntity<Void>> handleLargePayloadRequest(ServerHttpRequest request) {
        // 设置你需要的缓冲区大小，比如这里设为5MB（可根据需求调整）
        int customMaxBufferSize = 5 * 1024 * 1024;

        return DataBufferUtils.join(request.getBody(), customMaxBufferSize)
                .flatMap(dataBuffer -> {
                    // 这里写你的业务逻辑，比如解析请求体、处理数据等
                    // 记得用完释放缓冲区
                    DataBufferUtils.release(dataBuffer);
                    return Mono.just(ResponseEntity.ok().build());
                })
                .onErrorResume(DataBufferLimitException.class, e -> {
                    // 捕获缓冲区超限的异常，返回413
                    return Mono.just(ResponseEntity.status(HttpStatus.PAYLOAD_TOO_LARGE).build());
                });
    }
}

这种方式完全不会影响其他接口的缓冲区设置，只针对当前接口生效。

方案二：针对特定路径批量配置解码器 #

如果你有多个接口需要调整缓冲区，可以通过WebFlux配置类，给匹配特定路径的请求设置自定义的消息解码器，从而修改缓冲区大小：

import org.springframework.context.annotation.Configuration;
import org.springframework.http.codec.json.Jackson2JsonDecoder;
import org.springframework.web.reactive.config.WebFluxConfigurer;
import org.springframework.http.codec.ServerCodecConfigurer;
import org.springframework.http.server.reactive.ServerHttpRequest;

@Configuration
public class CustomWebFluxConfig implements WebFluxConfigurer {

    @Override
    public void configureHttpMessageCodecs(ServerCodecConfigurer configurer) {
        // 创建自定义的Jackson解码器，设置更大的内存缓冲区
        Jackson2JsonDecoder customJsonDecoder = new Jackson2JsonDecoder();
        // 这里设置为5MB，可按需调整
        customJsonDecoder.setMaxInMemorySize(5 * 1024 * 1024);

        // 注册解码器，并指定仅对匹配特定路径的请求生效
        configurer.codecConfigurer().registerCodec(customJsonDecoder,
                serverHttpRequest -> serverHttpRequest.getPath().matches("/large-payload/**")
        );
    }
}

这样所有路径匹配/large-payload/**的接口都会使用这个自定义的解码器，缓冲区大小设为你指定的值，其他接口依然使用全局默认的256KB（262144字节）。

注意事项 #

• 如果你的接口原本使用@RequestBody注解，默认会走全局的解码器配置。如果要保留@RequestBody的便捷性，推荐使用方案二；如果只需要单个接口调整，方案一更灵活。
• 缓冲区大小不要设置过大，避免内存溢出风险，根据实际业务的最大请求体大小来设定即可。

备注：内容来源于stack exchange，提问作者Morales