Apache Camel - 动态构建端点和端点

Question

我有一条骆驼路线，它处理来自process queue 的消息并将其发送到upload queue。

from("activemq:queue:process" ).routeId("activemq_processqueue")
        .process(exchange -> {
            SomeImpl impl = new SomeImpl();
            impl.process(exchange);
        })
        .to(ExchangePattern.InOnly, "activemq:queue:upload");

在impl.process 中，我正在填充Id 和destination server path。现在我需要定义一个使用上传队列中的消息的新路由，并复制一个本地文件夹（基于先前路由中生成的 Id）并将其上传到作为 ftp 服务器的目标文件夹（这也填充在先前的路由中）

那么如何设计一条从端点到端点都是动态的新路由，如下所示？

from("activemq:queue:upload" )
        .from("file:basePath/"+{idFromExchangeObject})
    .to("ftp:"+{serverIpFromExchangeObject}+"/"+{pathFromExchangeObject});

Answer 1

可以使用.toD() 描述on this page on the Camel site. 在Camel 中向端点添加动态（如注释中所述） 我不知道有任何 fromD() 等价物。但是，您可以通过在CamelContext 上调用addRoutes 方法来添加动态路由。这在this page on the Camel site. 上有所描述

稍微扩展 Camel 网站的示例，应该会让您朝着正确的方向前进。

public void process(Exchange exchange) throws Exception {
   String idFromExchangeObject = ...
   String serverIpFromExchangeObject = ...
   String pathFromExchangeObject = ...

   exchange.getContext().addRoutes(new RouteBuilder() {
       public void configure() {
           from("file:basePath/"+ idFromExchangeObject)
            .to("ftp:"+ serverIpFromExchangeObject +"/"+pathFromExchangeObject);
       }
   });
}

Camel 中可能还有其他选项，因为该框架具有数量惊人的 EIP 和功能。

Answer 2

我认为对于您的情况有更好的替代方案，当然您使用的是 2.16 之后的 Camel 版本。（存在以前版本的替代方案，但更复杂且看起来不优雅 - （例如 consumerTemplate & 收件人列表）。

您可以将第一个“动态来源”替换为 pollEnrich，它使用轮询消费者和简单的表达式来丰富消息以构建动态文件端点。对于第二部分，如前所述，动态 uri .toD 将完成这项工作。所以你的路线看起来像这样：

 from("activemq:queue:upload" )
    .pollEnrich().simple("file:basePath/${header.idFromExchangeObject})
    .aggregationStrategy(new ExampleAggregationStrategy()) // * see explanation 
    .timeout(2000) // the timeout is optional but recommended
    .toD("ftp:${header.serverIpFromExchangeObject}/${header.pathFromExchangeObject}") 

1. 请参阅内容丰富器部分“使用动态 uri” http://camel.apache.org/content-enricher.html.

   您将需要一个聚合策略，将原始交换与资源交换相结合，以确保标头 serverIpFromExchangeObject、pathFromExchangeObject 将包含在丰富后的聚合交换中。如果您不包含自定义策略，那么 Camel 默认使用从资源中获取的主体。查看 content-enricher.html 中的 ExampleAggregationStrategy 示例以了解其工作原理。

2. 对于 .toD()，请查看 http://camel.apache.org/how-to-use-a-dynamic-uri-in-to.html