如何修复Camel 3.16.0版本中camel-rest破坏性变更引发的Multipart流解析问题

这个问题的核心原因是Camel 3.16.0移除REST嵌入式路由后，默认会自动消费并读取REST请求的请求体，导致HttpServletRequest的InputStream被提前关闭，后续你用ServletFileUpload解析时自然会抛出异常。针对超大文件的流式处理需求，最直接的解决方案是禁用Camel自动消费请求体，让你自己的代码完全掌控流的读取。

具体实现方式 #

1. Java DSL配置REST端点

在定义REST接口时，添加consumeRequestBody(false)配置，阻止Camel提前读取请求流：

rest("/your-upload-endpoint")
    .post()
    .consumes("multipart/form-data")
    .consumeRequestBody(false) // 关键配置：禁用自动消费请求体
    .route()
    .process(exchange -> {
        // 你的原有解析逻辑可以正常复用了
        Message message = exchange.getMessage();
        HttpServletRequest request = message.getBody(HttpServletRequest.class);
        ServletFileUpload servletFileUpload = new ServletFileUpload(new DiskFileItemFactory());
        List<FileItem> items = servletFileUpload.parseRequest(request);
        
        // 遍历项、流式保存文件、解析元数据等操作
        for (FileItem item : items) {
            if (!item.isFormField()) {
                // 流式写入文件，避免内存溢出
                try (OutputStream os = new FileOutputStream("/temp/" + item.getName())) {
                    os.write(item.get());
                }
            } else {
                // 解析元数据字段
                String metaValue = item.getString();
                // ... 处理元数据
            }
        }
    });

2. XML配置方式

如果用XML定义路由，对应设置consumeRequestBody="false"属性：

<rest path="/your-upload-endpoint">
    <post consumes="multipart/form-data" consumeRequestBody="false">
        <route>
            <process ref="yourUploadProcessorBean"/>
        </route>
    </post>
</rest>

注意事项 #

• 禁用自动消费后，需要确保你的代码完全处理请求流；如果后续路由还需要访问请求体，建议使用CachedOutputStream做流式缓存（但超大文件场景下不推荐，避免内存压力）。
• 保持DiskFileItemFactory的合理配置，比如设置合适的临时文件阈值，确保大文件直接写入磁盘而非内存，避免OOM问题。

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