Apache Camel如何从路由中动态添加/删除endpoint

Question

我试图熟悉EIP和Apache骆驼，我有一个用例，我不太确定如何使用骆驼来表达或实现

用例：

假设您设计了一个集成解决方案，它从ftp中获取文件，进行一些处理并将其上传到队列。您选择Apache Camel来实现此解决方案，并且您在JavaDSL中的路由如下所示：

 from("ftp://user@hostname/directoryname")
   .process(new Processor() {
              public void process(Exchange exchange) throws Exception
              {
                //my fantastic prosessing goes here
              }
 }).to("jms:queue:queueName");

路线可能比这复杂得多，但在这里没关系。想象一下你的解决方案是如此的成功，以至于有一个计划来实现一个服务，任何人都可以添加他的ftp服务器，并处理文件并上传到队列。所以你想要的是

1. （灵活性）能够从应用程序中动态添加/删除服务器
2. （缩放）能够处理潜在的大量这样的服务器

让我们忘掉#2，关注灵活性部分。

所以我想问题是：

如何动态（在运行时）添加/删除终结点到/从Apache骆驼路由？

到目前为止我考虑的是：

首先，我承认我对集成模式不太熟悉，但只要浏览一下目录，唯一符合要求的就是内容丰富器。它可以带着一条信息，然后去别的地方，带上别的东西。所以我在想，如果有人添加一个ftp服务器，连接细节可以封装在消息中，然后内容丰富器可以连接到该ftp服务器，获取文件，并将其进一步推送到路由中。。。。因此，它实际上是一个能够连接到多个ftp服务器的内容丰富器。。。。听起来有点不对。首先，我不认为这是该模式背后的意图，其次，因为Camel中有ftp组件，所以我应该能够在该场景中使用它

第二种方法是使用vm组件将路由分成两部分，如下所示：

 from("ftp://user@hostname/directoryname").to("vm:internalQ");
 from("vm:internalQ")
   .process(new Processor() {
              public void process(Exchange exchange) throws Exception
              {
                //my fantastic prosessing goes here
              }
 }).to("jms:queue:queueName");

所以现在，我可以创建许多带有ftpendpoint的路由，这些endpoint可以写入内部队列，这样就可以拾取它。将路由动态添加到CamelContext似乎是可能的（在Java中在运行时添加CamelRoute）。是这样吗？还是我只是想用骆驼的方式来使用它？

Answer 1

您可以动态添加路由到您的CamelContext：

MyRouteBuilder trb = new MyRouteBuilder(servletEndpoint, mockEndpoint);
camelContext.addRoutes(trb);

和MyRouteBuilder：

MyRouteBuilder(Endpoint servletEndpointStart, MockEndpoint mockEndpointEnd, String allowedParameters){
        this._servletEndpoint = servletEndpointStart;
        this._mockEndpoint = mockEndpointEnd;
    }

    @Override
    public void configure() throws Exception {
        from(this._servletEndpoint)
        .id(TESTING_ROUTE_NAME)
        .process(new Processor(){ // some processor })
        .to(_mockEndpoint);
    }

您也可以修改路由，但需要重新启动它，以便正常工作，检查在：org中是如何完成的。阿帕奇。骆驼模型常规定义。adviceWith（ModelCamelContext，RouteBuilder）