当前位置: 首页 > 知识库问答 >
问题:

自定义骆驼组件-在FTP使用者中调用FTP

轩辕翰
2023-03-14

然后我需要做的是创建另一个FTP连接--技术上是到同一台机器,但路径不同。在我的实验中,我使用了一个带有构造URI的使用者模板来获取另一个文件(基于轮询文件的内容)。

这已经在一个高级别工作,并获取我需要的文件。谁能证实这是不是一件危险的事?

根据文档:

当然,我想要的文件确实会被检索到,而且我可以将它进一步传递到骆驼路由中,然而,当我处理FTP流文件时,我看到了字节级处理(按位计算等)的问题,我想知道这是否与它有关。

所以我想我的主要问题是,在单个消费者中调用多个FTP命令的安全骆驼方式是什么?

如果我正在做的应该可以工作,那么也许我需要一个关于我对这个数据的按位操作的新问题(基本上,只要只做了一个FTP get,它们总是可以正常工作--也就是说,使用者在轮询的文件上运行进程。但是如果我轮询一个文件,然后用它来获取另一个文件,该文件处理会在低级别失败--就好像存在内存/线程问题一样)。

共有1个答案

华甫
2023-03-14

要建立另一个FTP连接(相同的机器,不同的路径),您可以在您的路由中使用Pollrelch。

FTP使用者(具有相同endpoint)不支持并发(备份FTP客户端不是线程安全的)。您可以使用多个FTP使用者从不同的endpoint轮询。它只是一个不支持并发使用者的单一endpoint。

本部分说明是否有多个FTP使用者点指向同一endpoint(即同一机器、同一路径)。它们可能会竞争相同的文件,并导致使用重复/不完整/空的文件。

 类似资料:
  • 我是Camel集成的初学者,我需要创建定制的Camel组件,并在Spring Boot应用程序中使用它。 我尝试使用maven原型生成我的组件。 所以命令是这样的: mvn原型:generate-DarchetypeGroupId=org。阿帕奇。骆驼ArchetypeArtifactid=camel原型组件-DarchetypeVersion=2.12.1-DgroupId=my。tcp。骆驼c

  • 我在camel Kafka starter依赖项中使用了一个Kafka组件。在这个问题中,建议我使用“定制器”。我将如何在spring boot应用程序中使用它?

  • 我有一个Camel/SpringBoot应用程序,它从GraphQLendpoint检索数据,将数据存储在内存数据库(2个表)中,通过运行SQL查询提取CSV文件,然后将文件上传到FTP服务器。由于将提取约350k条记录,我使用SQLs outputType=StreamList、splitter和stream:file。整个路线如下所示: 提取数据时不会出现任何问题,并使用记录创建CSV文件。但

  • 我将我的Fabric8 Spring Boot Camel pom.xml升级到使用Camel 2.16.0,但并非所有组件都在2.16.0中可用 我不得不将以下组件保留在2.15.3,因为我得到了2.16.0版本的“丢失项目”: 骆驼指标 骆驼jsonpath 骆驼Spring靴 这些在Camel 2.16.0中不可用吗? 我使用的是Fabric8版本2.2.46和Spring Boot版本1.

  • 我试图在代码中使用camel quarkus jdbc,但收到一个错误: msgstr"无法解析endpoint: jdbc://camel,原因是:在注册表中找不到bean: camel的类型:javax.sql.DataSource" 互联网上关于这方面的信息不多。这是官方文件,没有太多描述:https://camel.apache.org/camel-quarkus/latest/refer

  • 我有一个场景,我想“拉”RabbitMQ队列/主题的消息,并一次处理一个。特别是当消费者启动时,队列中已经有消息。我尝试了以下方法,但没有成功(这意味着,这些选项中的每一个都会读取队列,直到队列为空,或者直到另一个线程关闭上下文)。 1.第一次处理后立即停止路由 与1类似,但使用闩锁而不是while loop和sleep。 使用轮询消费者 使用ConsumerTemplate()-类似于上面的代码