Apache骆驼多部分路由

Question

我试图通过Apache Camel将文件路由到HTTP文件上传API。但我得到以下例外

org.apache.camel.InvalidPayloadException: No body available of type: java.io.InputStream but has value: [email protected] of type: org.apache.http.entity.mime.MultipartFormEntity on: [email protected] Caused by: No type converter available to convert from type: org.apache.http.entity.mime.MultipartFormEntity to the required type: java.io.InputStream with value [email protected] Exchange[[email protected]]. Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: org.apache.http.entity.mime.MultipartFormEntity to the required type: java.io.InputStream with value [email protected]] 

任何人都可以在这里帮助吗？ 以下是我试过到目前为止

我的文件上传控制方法与URL映射的API /文件上传需要一个MultipartHttpServletRequest

MyCamelRouter.java

public class MyCamelRouter extends RouteBuilder { 

@Override 
public void configure() throws Exception { 
    from("file:C:/src") 
     .process(new MyProcessor()) 
     .log("POST ${header.CamelFileName} to /upload") 
     .setHeader(Exchange.CONTENT_TYPE, constant("multipart/form-data")) 
     .setHeader(Exchange.HTTP_METHOD, constant("POST")) 
     .to("http:localhost:8080/sampleUploader/api/fileupload") 
     .log("HTTP response status: ${header.CamelHttpResponseCode}") 
     .log(LoggingLevel.DEBUG, "HTTP response body:\n${body}"); 
} 

}

和MyProcessor.java

public class MyProcessor implements Processor { 
    public void process(Exchange exchange) throws Exception { 

     File filetoUpload = exchange.getIn().getBody(File.class); 
     String fileName = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class); 

     MultipartEntityBuilder entity = MultipartEntityBuilder.create(); 
     entity.addTextBody("fileName", fileName); 
     entity.addBinaryBody("file", new File(filePath)); 

     exchange.getOut().setBody(entity.build()); 
    } 

}

This是我跟着链接，这个（斯卡拉DSL）

Answer 1

的信息是明确的，当它说，你需要一个InputStream

的方法构建返回HttpEntity。

http://hc.apache.org/httpcomponents-client-ga/httpmime/apidocs/org/apache/http/entity/mime/MultipartEntityBuilder.html

您可以用该方法的getContent（）尝试

http://hc.apache.org/httpcomponents-core-ga/httpcore/apidocs/org/apache/http/HttpEntity.html?is-external=true

试图改变自己：

exchange.getOut().setBody(entity.build()); 

到：

exchange.getOut().setBody(entity.build().getContent()); 

UPDATE

您的评论，你可以做其他的事情以后是：

ByteArrayOutputStream out = new ByteArrayOutputStream(); 
entity.build().writeTo(out); 
InputStream inputStream = new ByteArrayInputStream(out.toByteArray()); 
exchange.getOut().setBody(inputStream);