使用Apache Camel文件组件传输文件

Question

package com.example.demo.controller;

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

import org.apache.camel.ProducerTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/camel")
public class FileTransferController {

    @Autowired private ProducerTemplate producerTemplate;

    @RequestMapping(value="/file", method=RequestMethod.GET)
    public String callCamelRoute() {
        String fileName = "input2.txt";

        Map<String, Object> headerMap = new HashMap<String, Object>();
        headerMap.put("fileName", fileName);

        producerTemplate.sendBodyAndHeaders("direct:transferFile", null, headerMap);

        return "Route invoked";
    }

}

package com.example.demo.route;

import org.apache.camel.LoggingLevel;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;

@Component
public class FileTransferRoute extends RouteBuilder {

    @SuppressWarnings("deprecation")
    @Override
    public void configure() {
        errorHandler(defaultErrorHandler()
            .maximumRedeliveries(3)
            .redeliverDelay(1000)
            .retryAttemptedLogLevel(LoggingLevel.WARN));

        from("direct:transferFile")
            .log("Route reached")
            .log("file:C:\\CamelDemo\\inputFolder?fileName=${in.headers.fileName}&noop=true")
            .pollEnrich("file://C:/CamelDemo/inputFolder?fileName=${in.headers.fileName}&noop=true")
            .to("file://C:/CamelDemo/outputFolder?autoCreate=false")
        .end();
    }

}

但是，当我第一次调用此路由时，即使指定了fileName参数，文件input1.txt也会被传输。请帮忙。

Answer 1

我认为问题在于没有设置文件名，因为您没有告诉Camel您使用的是一个简单的表达式，而不是一个固定的URI。

查看手册(https://camel.apache.org/manual/latest/pollencric-eip.html#_using_dynamic_uris)，它暗示您需要

.pollEnrich().simple("file://C:/CamelDemo/inputFolder?fileName=${in.headers.fileName}&noop=true")

以便能够使用动态终结点。