java - 在 Apache Camel 中多播文件的问题

Question

伙计们。

我必须使用 apache Camel 并行处理 10 个文件，然后通过 FTP 命令发送。我做了一些研究，听说了“multicast()”命令。但它显然不起作用，因为我正在服务器中一一接收文件......:/

我的文件路径:

 fromF("file://%s?antInclude=**/*.sync&recursive=true&noop=true", configurationManager.getDestinationFilesFolderPath())
        .routeId("FTP_Snapshot_Fetcher")
        .setHeader("OriginalFileName", simple("${file:name.noext}"))
        .multicast()
        .parallelProcessing()
            .to(ftpRoutesForSameGroup.split(separator))
            .toD("file://" + configurationManager.getDestinationFilesFolderPath() + "?fileName=${in.header.OriginalFileName}" + DAConfigurations.FILE_EXTENSION);

我尝试将它与 pipeline 和 to 一起使用，但这两个选项都没有任何效果。

sftp组件有没有可能泄露？

看起来像:

.toD("sftp://"
                + ftpEndpoint.getUser() + "@"
                + ftpEndpoint.getUrl()  + ":"
                + ftpEndpoint.getPort() + "/ftp/${in.header.pathToFile}"
                + "?password=" + ftpEndpoint.getPassword()
                + "&autoCreate=true&passiveMode=true&binary=true&tempFileName=${file:name.noext}"
                + DAConfigurations.FILE_EXTENSION_ON_SYNC
            )

此ftpRoutesForSameGroup是一个字符串，其中包含所有分隔的路由列表(例如:“direct:r1;direct:r2;direct:r3”)。

有人知道如何以正确的方式修复它(发送所有文件，或并行发送最大可能的文件)？

Answer 1

根据 Camel 文档:

多播允许将相同的消息路由到多个端点并以不同的方式处理它们。

所以发生的情况是，文件内容被赋予四个路由，并且所有路由都处理相同的内容并执行相同的操作。

根据您的要求，尝试使用 SEDA 组件，该组件会分出一个新线程以进行进一步处理。

SEDA COMPONENT