SpringBoot 3 WebFlux处理Multipart请求遇415媒体类型错误求助

1. 修复路由配置的语法错误 #

你提供的路由代码存在语法错误，多余的闭合括号会导致路由匹配逻辑失效，直接触发415错误。

原错误代码：

POST("api/v1/slides",accept(MediaType.MULTIPART_FORM_DATA).and(contentType(MediaType.MULTIPART_FORM_DATA))),(sliderHandler::addNewSlide))

修正后代码：

POST("api/v1/slides", accept(MediaType.MULTIPART_FORM_DATA).and(contentType(MediaType.MULTIPART_FORM_DATA)), sliderHandler::addNewSlide)

2. 配置Multipart消息解析器 #

Spring WebFlux默认不会自动将multipart表单绑定到包含FilePart的DTO，需手动注册对应的消息解析器：

@Configuration
public class WebFluxConfig implements WebFluxConfigurer {
    @Override
    public void configureHttpMessageCodecs(ServerCodecConfigurer configurer) {
        configurer.defaultCodecs().multipartReader(new MultipartHttpMessageReader());
    }
}

同时确保项目依赖中包含spring-boot-starter-webflux，它会自动引入multipart处理的核心依赖。

3. 验证请求发送的正确性 #

检查请求头 #

• 必须携带Content-Type: multipart/form-data; boundary=xxx，其中boundary由客户端自动生成，禁止手动指定固定值
• 不要手动设置Content-Length，交由客户端自动计算

检查表单字段名 #

表单字段名必须与CreateSlideRequest的属性名完全一致，比如用curl测试的正确命令：

curl -X POST -F "buttonTitle=测试按钮标题" -F "title=测试幻灯片标题" -F "buttonUrl=https://example.com" -F "imageFile=@/本地图片路径.jpg" http://localhost:8080/api/v1/slides

4. 确认DTO注解的正确性 #

• 确保@NotNull、@Size等校验注解来自jakarta.validation.constraints（Spring Boot 3+）或javax.validation.constraints（Spring Boot 2.x）
• Record类型无需实现Serializable接口，WebFlux的multipart绑定不依赖该接口

5. 手动提取Multipart数据（自动绑定失效时的替代方案） #

如果自动绑定到CreateSlideRequest仍失败，可以手动解析multipart数据：

public Mono<ServerResponse> addNewSlide(ServerRequest serverRequest) {
    return serverRequest.multipartData()
            .flatMap(multipartData -> {
                // 提取普通表单字段
                String buttonTitle = multipartData.getFirst("buttonTitle").value();
                String title = multipartData.getFirst("title").value();
                String buttonUrl = multipartData.getFirst("buttonUrl").value();
                // 提取文件字段
                FilePart imageFile = (FilePart) multipartData.getFirst("imageFile");
                
                // 构造请求对象并校验
                CreateSlideRequest request = new CreateSlideRequest(buttonTitle, title, buttonUrl, imageFile);
                this.validationUtils.validateRequest(request);
                
                // 后续文件保存与数据入库逻辑
                return DataBufferUtils.join(imageFile.content())
                        .publishOn(Schedulers.boundedElastic())
                        .flatMap(dataBuffer -> {
                            byte[] bytes = new byte[dataBuffer.readableByteCount()];
                            String imageName = imageFile.filename() + UUID.randomUUID();
                            dataBuffer.read(bytes);
                            Path path = Path.of(uploadDir + "/" + imageName);
                            try {
                                Files.write(path, bytes);
                            } catch (IOException e) {
                                return Mono.error(new SlideException("Fail to save slide image!"));
                            }
                            return Mono.just(imageName);
                        })
                        .flatMap(imageName -> {
                            Slide slide = slideMapper.slideRequestToSlide(request);
                            slide.setImage(imageName);
                            return slideRepository.save(slide);
                        })
                        .flatMap(ServerResponse.status(HttpStatus.CREATED)::bodyValue);
            });
}

内容的提问来源于stack exchange，提问作者boris dimitrijevic