阿帕奇骆驼多路线 [英] Apache Camel multipart route

问题描述

我正在尝试通过Apache Camel将文件路由到HTTP文件上传API.但是我正在追随异常

I'm trying to route a file to HTTP file upload API via Apache Camel. But I'm getting following exception

org.apache.camel.InvalidPayloadException: No body available of type: java.io.InputStream but has value: org.apache.http.entity.mime.MultipartFormEntity@71ef4d4f of type: org.apache.http.entity.mime.MultipartFormEntity on: org.apache.camel.component.file.GenericFileMessage@7e693963. 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 org.apache.http.entity.mime.MultipartFormEntity@71ef4d4f. Exchange[org.apache.camel.component.file.GenericFileMessage@7e693963]. 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 org.apache.http.entity.mime.MultipartFormEntity@71ef4d4f]

有人可以在这里帮忙吗? 以下是我到目前为止尝试过的

Can anyone help here? Following is what I tried so far

与URL api/fileupload映射的我的fileupload控制器方法期望MultipartHttpServletRequest

My fileupload controller method mapped with the URL api/fileupload expects a MultipartHttpServletRequest

MyCamelRouter.java

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

and in 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());  
    }

}

这是我遵循的此链接(Scala DSL)

This is the link I followed for this(Scala DSL)

推荐答案

该消息表明您需要InputStream时，该消息很清楚

The message is clear when it say that you need an InputStream

方法构建返回一个HttpEntity.

The method build returns an HttpEntity.

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

您可以尝试使用getContent()方法

You can try with the method 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());  

更新

发表评论后，您可以做的另一件事是

After your comment the other thing you can do is:

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

这篇关于阿帕奇骆驼多路线的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！