Spring Boot集成Apache Camel代理大文件：禁用StreamCache实现流式转发

针对你使用Spring Boot + Apache Camel 3.18.0实现大文件代理时遇到的StreamCacheConverter自动加载文件到内存的问题，可通过以下几种方式解决：

1. 全局禁用StreamCache自动转换 #

StreamCache默认会在需要重复读取流时自动启用，全局禁用后可避免所有路由触发内存缓存：

• Spring Boot配置文件方式：在application.properties或application.yml中添加：

  camel.context.stream-cache-enabled=false
  

• Java配置方式：通过CamelContextConfiguration手动禁用：

  @Bean
  public CamelContextConfiguration camelContextConfiguration() {
      return context -> {
          // 全局关闭StreamCache功能
          context.setStreamCache(false);
      };
  }
  

2. 针对特定路由禁用StreamCache #

如果不需要全局禁用，可仅在大文件传输的目标路由中关闭：

rest("/multipart")
    .tag("multipart")
    .post("")
    // 保留Swagger配置，但移除可能触发流读取的type()配置
    .consumes(MediaType.APPLICATION_OCTET_STREAM_VALUE)
    .produces(MediaType.APPLICATION_JSON_VALUE)
    .description("Upload large file")
    .responseMessage().responseModel(MultipartDocumentDTOResponse.class).code(HttpStatus.OK.value()).endResponseMessage()
    .responseMessage().message(HttpStatus.INTERNAL_SERVER_ERROR.getReasonPhrase()).code(HttpStatus.INTERNAL_SERVER_ERROR.value()).endResponseMessage()
    // 路由中显式禁用StreamCache
    .route()
        .streamCache(false)
        .to(documentEndpoint + MultipartService.MULTIPART_PATH + Util.BRIDGE_ENDPOINT + Util.THROW_EXCEPTION_OFF)
    .endRest();

3. 移除触发流预读取的配置 #

你的代码中.type(SaveDocumentDTORequest.class)会触发Camel将请求体反序列化为DTO，这会强制读取整个输入流到内存。如果该配置仅用于Swagger文档，可替换为不触发序列化的方式：

• 若无需严格的Swagger请求体类型定义，直接移除.type(SaveDocumentDTORequest.class)；
• 若需要保留Swagger文档，可使用@ApiImplicitParam注解标注请求体为二进制流，而非绑定DTO。

4. 确保HTTP组件支持分块传输 #

如果转发目标是HTTP服务，需确保Camel的HTTP组件（如camel-http4）启用分块传输，避免缓存整个请求体：

• 在端点URL中添加&chunked=true参数：

  .to(documentEndpoint + MultipartService.MULTIPART_PATH + Util.BRIDGE_ENDPOINT + Util.THROW_EXCEPTION_OFF + "&chunked=true")
  

• 或通过组件配置全局启用分块：

  @Bean
  public HttpComponent httpComponent() {
      HttpComponent component = new HttpComponent();
      component.setChunked(true);
      return component;
  }
  

原理说明 #

StreamCacheConverter会在Camel检测到流可能需要重复读取时自动触发，将输入流完整复制到内存或临时文件中。在代理场景下，我们只需要一次性转发流，无需重复读取，因此禁用StreamCache并确保组件支持流式分块传输，即可实现大文件的无内存加载转发。

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