OSGi 容器中的骆驼：将 InterceptStrategy 应用于所有骆驼上下文

Question

我有几个包（A、B 和 C）部署到一个 OSGi 容器，每个包都包含一个 CamelContext 和一些路由。我有另一个捆绑包（M），带有一个带有路由（用于收集监控数据）的CamelContext 和一个InterceptStrategy bean。我希望 M 中的 InterceptStrategy bean 自动应用于容器中的所有其他 CamelContexts（即 A、B 和 C 中的那些），而无需修改其他包。

最终，目标是将来自每个 CamelContext 的数据窃听到 M 中的路由中，而无需对 A、B 或 C 进行任何更改以显式路由 Exchange。这种方法或类似方法是否可行？

所有的CamelContexts 都是使用 Spring XML 配置的。

---

更新：附加上下文

捆绑包 A、B 和 C 包含负责处理数据的核心产品。 Bundle M 包含一个可选监控工具，旨在测量流经 A、B 和 C 的数据的某些参数。目前，添加可选工具需要更改 A、B 和 C 中的路由以添加额外的Processors用监控数据丰富Exchange，并读取<to />端点之前的监控数据。

我们的目标是能够将 Bundle M 放入一个已经验证过的具有 A、B 和 C 的系统中；并让它自动应用于现有路由，而无需修改现有和工作包的配置。 可以对 A、B 和 C 进行修改以支持这一点，只要这些更改不会导致 A、B 和 C 依赖于 M 运行（即 ABC 必须仍然在没有 M 的情况下运行）。

如果有比使用拦截器更好的方法来做到这一点，我愿意接受。主要目标是：

1. 保持 A、B 和 C 与 M 分离（尤其是在开发期间）
2. 确保尽可能轻松地将 M 与 A、B 和 C 集成
3. 无需手动更改 A、B 或 C 即可集成 M

Answer 1

要么使用 Spring-DM，要么更好地将所有基于 spring xml 的路由转换为蓝图路由。这是在 Karaf/Osgi 中使用基于 XML 的路由的最佳支持方式。

Answer 2

我认为使用InterceptorStrategy 是不可能的，因为它期望它在同一个骆驼上下文中运行。我知道跨多个上下文工作的唯一方法是使用 VM 端点（显然仅限于同一个 JVM），但是在这种情况下，您可能会更好地使用 JMS、JMX 或类似的东西。

JMS

为A, B & C 中的每个骆驼上下文创建一个InterceptorStrategy，将您的消息发布到M

intercept().bean(transformForMonitoring).to("jms:queue:monitoring");

from("whatever:endpoint")
    .process(myProcessor)
    .to("target:endpoint");

如果您不想要 JMS 的开销，您也可以在 intercept() 上使用 vm 组件，但这会将您的监控组件限制为单个 JVM。

JMX

这有点复杂，但基本思想是告诉骆驼上下文为A, B & C发布MBeans

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
  <jmxAgent id="agent" mbeanObjectDomainName="your.domain.name"/>
    ...
</camelContext>

然后让M 连接到JVM MBean 服务器并利用NotificationListener 之类的东西对交换做出反应。

Answer 3

其中一种可能性是在 Bundle 'M' 中定义 custom Tracer 并将其导出为 osgi 服务。

在包 A、B、C 中定义 osgi-reference 到导出的 Tracer bean

使用camel JMX 启用跟踪。

这将导致捆绑包 A、B、C 发生变化，但变化很小，而且还可以集成和配置跟踪（拦截）

我自己没有尝试过，但是hth