使用ApacheCamel将文件上传到rest服务器

Question

我需要将文件从文件夹同步到restendpoint。因此，如果文件被放置在特定文件夹中，我需要将该文件发送到接受多部分文件的RESTendpoint。我正在使用ApacheCamel来实现这一点。

RESTendpoint在Spring中编写，如下所示：

@PostMapping("/")
public String handleFileUpload(@RequestParam("file") MultipartFile file,
                               RedirectAttributes redirectAttributes) {

    storageService.store(file);
    redirectAttributes.addFlashAttribute("message",
            "You successfully uploaded " + file.getOriginalFilename() + "!");

    return "redirect:/";
}

我是Camel的新手，并且已经弄清楚了如何通过构建路由并获取文件来轮询目录，但是我无法弄清楚如何使用此路由将此文件放入其余endpoint。这是我尝试过的：

@Component
public class SampleCamelRouter extends RouteBuilder {

    @Override
    public void configure() throws Exception {

        from("file://target/input?delay=4000")
        .process(new 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", filetoUpload);

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

                                }
                            })
        .setHeader(Exchange.CONTENT_TYPE, constant("multipart/form-data"))
        .setHeader(Exchange.HTTP_METHOD, constant("POST"))
        .to("http://localhost:9090/");
    }

}

但是当我运行这个时，我在rest服务器中得到以下异常：

org.apache.tomcat.util.http.fileupload.FileUploadException: the request was rejected because no multipart boundary was found

在camel端，请求失败，出现500错误。

任何线索都是值得赞赏的。

Answer 1

使用头="Content-Type=multipart/form-data"，到控制器中。

问题不在代码中，而是在请求中。多部分请求中缺少边界。正如在说明书中所述：

多部分实体的Content-Type字段需要一个参数“boundary”，用于指定封装边界。封装边界被定义为完全由两个连字符(“-”，十进制代码45)组成的一行，后跟Content-Type头字段中的边界参数值。这个和这个帖子应该也有帮助。