0

我正在尝试在我的要求中实现并发/并行处理，但在这方面的多次尝试中我没有得到适当的帮助。

我有 5 个包含日志文件的远程目录（可以添加或删除），我想每 15 分钟将它们加载到我的本地目录，并希望在完成 ftp 传输作业后执行 Lucene 索引，我想添加路由器动态的。

由于所有这些远程机器都是不同的端点和不同的路线。我没有任何特定的终点来启动所有这些。

Start 
<parallel>
        <download remote dir from: sftp1>
       <download remote dir from: sftp2>
          .... 
</parallel>
<After above task complete>
<start Lucene indexing>
<end>

每15分钟重复一次以上，

我想并行下载所有文件夹，如果有人处理类似要求，请提出解决方案。

我想知道当我没有起始端点时，应该如何启动/启动这些多条路由（例如多个远程目录）。我想并行启动所有 ftp 操作并完成那些然后索引。感谢您花时间阅读这篇文章，非常感谢您的帮助。

我试过这样

from (bean:foo? Method=start).multicast ().to (direct:a).to (direct:b)... 

From (direct:a) .from (sftp:xxx).to (localdir) 
from (direct:b).from (sftp:xxx).to (localdir)
4

1 回答 1

0
  • camel-ftp 支持通过 consumer.delay 属性进行定期轮询
  • 如本单元测试所示，为每个服务器动态添加 camel-ftp 消费者路由
  • 然后，您可以根据大小或超时值聚合结果以启动 Lucene 索引等

[todo - 整理一个例子]

于 2013-10-10T06:12:46.817 回答