使用Camel http4向数量不断变化的endpoint发送消息

Question

我已经创建了下面这段代码，我想使用骆驼HTTP4将相同的JSON主体发送到多个endpoint，而不仅仅是一个endpoint。endpoint的数量可能会随着时间的推移而变化。

                    .choice()
                        .when(simple("${body} != null"))
                              .setHeader(Exchange.HTTP_METHOD, constant("POST"))
                              .setHeader(Exchange.HTTP_URI, simple(url))
                              .setProperty("ObjectBody", body())
                              .to("http4://someEndpoint?throwExceptionOnFailure=true&httpClient.socketTimeout=300000")
                        .otherwise()
                            .log(LoggingLevel.ERROR, "Incoming request has empty body")
                        .endChoice()
                    .end()

我试图找出在这种情况下配置和使用多个endpoint的最佳方法。

我已经查看了多播EIP，但看起来我必须事先知道endpoint的数量。

非常感谢您的任何想法！

Answer 1

你看了RouteBox吗？

对驼峰路由盒endpoint的需求路由盒组件旨在简化复杂环境中的集成，该环境需要大量路由，涉及大量需要以不同方式集成的endpoint技术

在这样的环境中，通常需要通过在驼峰路线之间创建一种分层感来设计集成解决方案，从而有效地将它们组织到

粗粒度或更高级别的路由——作为Routeboxendpoint公开的内部或较低级别路由的聚合集合，代表一个集成焦点区域。例如

https://camel.apache.org/components/2.x/routebox-component.html

其用法：

from ("direct:sendToMapBasedRoutebox")
    .setHeader("ROUTE_DISPATCH_KEY", constant("addToCatalog"))
    .to("routebox:multipleRoutes?innerRegistry=#registry&routeBuilders=#routes&dispatchMap=#map")
    .to("log:Routes operation performed?showAll=true");

然后理论上，这应该将请求分散到RouteBox封装的所有（路由）上。