Apache Camel FTP无法捕获远程FTP文件夹上的文件创建事件

Question

我正在尝试使用Apache Camel FTP来使用被推送到FTP文件夹的文件。路由和连接到FTP服务器的骆驼上下文是好的，但我不能得到文件创建事件处理时，文件被推到FTP文件夹。下面是我的代码和日志：首先是我的pom.xml for camel（我使用的是camel 3.0.1版本）的一部分：

<!-- Listen FTP folder -->
        <!-- https://mvnrepository.com/artifact/org.apache.camel.springboot/camel-spring-boot-starter -->
        <dependency>
            <groupId>org.apache.camel.springboot</groupId>
            <artifactId>camel-spring-boot-starter</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.camel/camel-core-starter -->
        <dependency>
            <groupId>org.apache.camel.springboot</groupId>
            <artifactId>camel-core-starter</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.camel.springboot/camel-ftp-starter -->
        <dependency>
            <groupId>org.apache.camel.springboot</groupId>
            <artifactId>camel-ftp-starter</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.camel.springboot/camel-jacksonxml-starter -->
        <dependency>
            <groupId>org.apache.camel.springboot</groupId>
            <artifactId>camel-jacksonxml-starter</artifactId>
            <version>3.0.0</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.camel.springboot/camel-jackson-starter -->
        <dependency>
            <groupId>org.apache.camel.springboot</groupId>
            <artifactId>camel-jackson-starter</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.camel.springboot/camel-rabbitmq-starter -->
        <dependency>
            <groupId>org.apache.camel.springboot</groupId>
            <artifactId>camel-rabbitmq-starter</artifactId>
            <version>${camel.version}</version>
        </dependency>

初始化camel的RouteBuilder消耗：

package xx.listener.route;

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

import xx.listener.common.model.ddXMLModel;

@Component
public class DataRouter extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        System.out.println("Initialize camel route...");
        JacksonDataFormat jacksonDataFormat = new JacksonDataFormat();
        jacksonDataFormat.setInclude("NON_NULL");
        jacksonDataFormat.setPrettyPrint(true);

        from("ftp://user@localhost:21/ftp/files?password=abc@123&move=.done&moveFailed=.error")
                .log("${body}")
                .unmarshal().jacksonxml(ddXMLModel.class)
                .marshal(jacksonDataFormat)
                .log("${body}")
                .to("rabbitmq://localhost:5672/test_camel?username=root&password=123456&queue=camel.queue&autoDelete=false").end();
    }
}

启动应用程序时的日志：

Initialize camel route...
[INFO ] 2020-12-22 14:21:24.522 [main] SpringBootRoutesCollector - Loading additional Camel XML routes from: classpath:camel/*.xml
[INFO ] 2020-12-22 14:21:24.522 [main] SpringBootRoutesCollector - Loading additional Camel XML rests from: classpath:camel-rest/*.xml
[INFO ] 2020-12-22 14:21:24.530 [main] SpringBootCamelContext - Apache Camel 3.0.1 (CamelContext: camel-1) is starting
[INFO ] 2020-12-22 14:21:24.531 [main] JmxManagementStrategy - JMX is enabled
[WARN ] 2020-12-22 14:21:24.747 [main] RabbitMQComponent - The old syntax rabbitmq://hostname:port/exchangeName is deprecated. You should configure the hostname on the component or ConnectionFactory
[INFO ] 2020-12-22 14:21:24.755 [main] SpringBootCamelContext - StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
[WARN ] 2020-12-22 14:21:24.772 [main] JacksonDataFormat - The option autoDiscoverObjectMapper is set to false, Camel won't search in the registry
[INFO ] 2020-12-22 14:21:24.897 [main] SpringBootCamelContext - Route: route1 started and consuming from: ftp://user@localhost:21/ftp/files?move=.done&moveFailed=.error&password=xxxxxx
[INFO ] 2020-12-22 14:21:24.902 [main] SpringBootCamelContext - Total 1 routes, of which 1 are started
[INFO ] 2020-12-22 14:21:24.904 [main] SpringBootCamelContext - Apache Camel 3.0.1 (CamelContext: camel-1) started in 0.372 seconds
[INFO ] 2020-12-22 14:21:24.908 [main] ListenerApplication - Started ListenerApplication in 2.979 seconds (JVM running for 4.169)

CamelContext camelContext = new DefaultCamelContext();
        try {
            camelContext.addRoutes(new DataRouter());
            camelContext.start();
        }
        catch (Exception e){
            e.printStackTrace();
            camelContext.stop();
        }

我的代码出了什么问题。谢谢

Answer 1

只有2个想法，因为没有发生任何事情（没有文件读取，没有错误）

• 是否具有查看文件的用户权限？
• 文件是否在[userHome]/ftp/files下？

第二点是因为骆驼FTP路径总是相对的。因此，用户的主路径（即用户在ftp登录后登陆的目录）是路径的起点。