关于动态 Apache 骆驼路线/上下文的设计问题

Question

我们有 ActiveMQ，系统中发生的事件都会发布到该 ActiveMQ 上。该项目涉及用户将实体添加到他们的监视列表中，每当这些实体上有事件时，我希望向感兴趣的参与者发送一封电子邮件。

该用例大致可以翻译为某人对目录上的产品信息页面表示兴趣，并且每当该产品发生任何活动（价格下降、有正面评价等）时就会发送一封电子邮件。我将这种交互建模为骆驼路线。

因此，例如，如果用户说每当该产品的评级等于 5 时给我发送电子邮件，则以下路由将添加到骆驼上下文中：

from("activemq:topic:events.product.save").filter().xpath("/object[<object id>]/rating").isEqualTo("5").to("email:<user's email>")

同样，如果用户希望在产品有新评论时收到通知，则另一条路由将被创建等等。当每个用户开始添加他们感兴趣的手表时，这可能最终会创建数千条路线。

我的一些问题是：

• 这是创建动态路由的可接受方式吗？我正在考虑的一种选择是使用收件人列表。但我一直无法想出一个解决方案，能够优雅地将消息路由到返回收件人列表的 bean。例如，对于上面解释的情况，bean 是否会有一堆 if-else 来查看要返回哪个收件人列表？

• camelcontext有一个从xml文件加载路由的方法，但没有方法来保存现有的路由。保存这些动态创建的路由的最简单（且有效）的方法是什么？ camel-users 列表中的这个线程总结了我的要求。

Answer 1

鉴于订阅需求的动态性质，您应该使用数据库来存储信息，而不是尝试创建动态路由。这是一种更具可扩展性/适当的技术使用...

那么您只需要一个静态路由或 POJO 使用者（见下文），可以使用简单的 POJO bean 处理产品更新消息 (bean-binding 可以提供帮助，等等）。然后 POJO bean 将负责查询数据库以查找所有“感兴趣”的用户并使用 camel- 发送电子邮件邮件

public class NotificationBean {

    @Consume(uri="activemq:topic:events.product.save")
    public void onUpdate(@XPath("/object/id") String id, 
                         @XPath("/object/rating") String rating) {
        //query database for subscriptions for this product ID/rating, etc.
        //for each interested subscriber
            //send email (camel-mail, etc)
    }

    public void addSubscription(String productID, Integer rating, String email) {
        //create/update subscription entry in database, etc...
    }
}