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

骆驼会为每条路线创建一个线程吗

刘棋
2023-03-14

最近我开始使用camel,我发现它有可能满足我的许多集成层需求。

我创建了一个java客户机应用程序(不在任何容器中运行),其中定义了两个路由:

路由1:将文件从传入文件夹1移动到文件夹2

route2:将文件内容从folderx移动到mq队列。

我启动我的应用程序,这些路由正在轮询这些文件夹并相应地路由消息。

谁能给我解释一下路线是如何工作的?骆驼(上下文)是否为每个路由创建线程。到底会发生什么?

注意:我在骆驼网站上找不到关于这个的简单说明。

共有1个答案

单于钊
2023-03-14

这取决于路由中使用的组件、创建和使用的线程数量。

此外,Camel中的一些EIP支持多个线程(线程池),因此可以配置为使用N个线程。

在您的示例中,它是文件组件,并且它使用单个线程。因为您有2个路由,所以您将使用2个线程。一些组件还允许配置它们的线程(例如线程池)。例如,最近我们在Camel 2.10中添加了对文件组件的支持(参见https://camel.apache.org/components/latest/file-component.html中的schduledExecutorService选项)

这里有一些关于驼峰线程模型的注释http://camel.apache.org/threading-model.html

 类似资料:
  • 问题内容: 我一直在仔细研究Apache Camel文档,试图对它的两个 最基本 概念(端点和路由)有一个具体的了解,尽管这些术语在文档中各处都使用,但是我找不到真正定义它们的参考。是以及它们的用途。尽管它们的名称听起来很明显,而且我 想 我理解它们的含义,但是现在我已被分配到一项使我深深陷入Apache Camel Land的任务,而了解这些机制的绝对至关重要是。 我的猜测是,“端点”只是一个b

  • 问题内容: 我尝试对Apache骆驼路线进行junit测试。像这样的东西: 构建器类的定义如下 “ myExportRouteProcessor”类仅从JPA存储库中获取一些数据,并将结果放入路由。我想要的是在测试类中触发此路由,以检查整个过程是否正确完成。当前,处理器未启动。我该怎么办? 问题答案: 您可以使用AdviceWithRouteBuilder#replaceFromWith直接替换测

  • 我试着为阿帕奇骆驼路线做一个jUnit测试。类似于这样: builder类的定义如下 myExportRouteProcencer类只是从JPA存储库中获取一些数据,并将结果放入路由。我想要的是在测试类中触发此路由,以检查整个过程是否正确完成。目前,处理器没有被触发。我应该做些什么?

  • 嗨,我在camel中有一个JMS消费者路由,我的要求是在特定事件时停止/暂停该路由(基于某个字段值),然后使用调度器恢复该路由。为此,我创建了两个路由,一个是我的原始jms消费者路由,另一个是调度程序路由,它们恢复jms消费者路由,虽然我能够暂停路由,但第二个路由不恢复暂停的路由,它显示的状态为已启动。 以下是我的两条路线 请帮助我如何实现上述场景。

  • 我有一个Springboot应用程序,其中配置了一些驼峰路线。 我想测试从到的路由。我试过这里提到的不同东西http://camel.apache.org/camel-test.html,但似乎无法让它工作。 我正在尝试这样做: 但是我的ProducerTemplate总是。我尝试了自动连接CamelContext,但遇到一个异常,它无法解析CamelContext。但这可以通过添加到类。但是我的

  • 我正在研究一个骆驼原型,它在同一骆驼环境中使用两个起点。 第一个路由使用用于“配置”应用程序的消息。消息通过配置服务bean加载到配置存储库中: 第二个路由实现了收件人列表eip模式,将不同类型的输入消息传递给许多收件人,这些收件人从同一个配置存储库中按顺序读取: 现在出现的问题是如何同步它们,因此如果第一个路由正在处理新数据,则第二个路由“等待”。 我是Apache Camel的新手,对如何处理