Camel Rest DSL 检索 HTTP POST 多部分文件

Question

我的路由器类如下所示，我正在尝试上传视频文件并将其存储到文件位置。

SpringBootRouter.java

package com.camelrest;

import java.util.HashMap;
import java.util.Map;

import org.apache.camel.component.restlet.RestletComponent;
import org.apache.camel.spring.boot.FatJarRouter;
import org.restlet.Component;
import org.restlet.ext.spring.SpringServerServlet;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.embedded.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class MySpringBootRouter extends FatJarRouter {

    @Autowired
    private MultipartProcessor multipartProcessor;

    @Override
    public void configure() {

        restConfiguration().component("restlet");

        rest("/upload").post().to("direct:upload");

        from("direct:upload")
        .to("file://E:/RestTest");

    }

    @Bean
    public ServletRegistrationBean servletRegistrationBean() {

        SpringServerServlet serverServlet = new SpringServerServlet();
        ServletRegistrationBean regBean = new ServletRegistrationBean(
                serverServlet, "/rest/*");

        Map<String, String> params = new HashMap<String, String>();

        params.put("org.restlet.component", "restletComponent");

        regBean.setInitParameters(params);

        return regBean;
    }

    @Bean
    public Component restletComponent() {
        return new Component();
    }

    @Bean
    public RestletComponent restletComponentService() {
        return new RestletComponent(restletComponent());
    }    
}

我正在尝试使用邮递员上传视频文件，如下图所示：

我上传的文件内容保存的文件名带有由camel生成的一些随机camel ID

但是我想要在正文中传递的文件名

示例视频_1280x720_10mb.mp4

作为文件名并从正文中删除以下内容

----------------------------948281627232093197119960
Content-Disposition: form-data; name="file"; filename="SampleVideo_1280x720_10mb.mp4"
Content-Type: video/mp4

所以最终输出可以是使用postman上传时使用的文件名上传的视频

Answer 1

您可以使用

MimeMultipartDataFormat

来解组多部分请求。使用此功能，将准备附件，以

Exchange

。

之后，您需要以某种方式将

Attachment

转换为

InputStream

并填充

CamelFileName

标题。有了这个任务可以帮助你小

Processor

.

路线：

from("direct:upload")
        .unmarshal().mimeMultipart().split().attachments()
        .process(new PrepareFileFromAttachment())
        .to("file://C:/RestTest");

处理器：

class PrepareFileFromAttachment implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        DataHandler dataHandler = exchange.getIn().getBody(Attachment.class).getDataHandler();
        exchange.getIn().setHeader(Exchange.FILE_NAME, dataHandler.getName());
        exchange.getIn().setBody(dataHandler.getInputStream());
    }
}

---

如果您的表单仅包含单个输入，则上述方法不起作用。这是因为

MimeMultipartDataFormat

将第一个表单输入编组到正文（不存储文件名），并将其他输入编组到存储文件名的附件。 在这种情况下，您需要直接创建

Processor

阅读

InputStream

：

路线：

from("direct:upload")
        .process(new ProcessMultipartRequest())
        .to("file:c://RestTest");

处理器

public class ProcessMultipartRequest implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        InputStream is = exchange.getIn().getBody(InputStream.class);
        MimeBodyPart mimeMessage = new MimeBodyPart(is);
        DataHandler dh = mimeMessage.getDataHandler();
        exchange.getIn().setBody(dh.getInputStream());
        exchange.getIn().setHeader(Exchange.FILE_NAME, dh.getName());
    }
}

Answer 2

在多部分/表单数据请求中，字段顺序很重要。提交时，文件字段应按顺序排在第一位。 Apache Camel 创建除请求中第一个字段之外的所有字段的附件对象。 例如。

其他领域：

• var1 和 var2 成为附件对象

  从（路线） .unmarshal().mimeMultipart().split().attachments() .log("进程") 。结尾（） .process(新的MyProcessor()) .end();

  公共类 MyProcessor 实现处理器 { @覆盖 public void process(Exchange交换)抛出异常{ // 其他字段值 集合附件 = Exchange.getIn().getAttachmentObjects().values(); for(附件附件：附件){ // 附件值 附件.getDataHandler().getInputStream(); } // 请求文件内容正文 输入流 = Exchange.getIn().getBody(InputStream.class); } }