通过 apache-camel 连接到风暴螺栓时创建多个主题 tibco ems 会话

Question

我正在研究 Apache Storm，我计划使用 Apache-camel 通过单个 tibco-ems 连接连接末端螺栓以将消息传递到 tibco-ems 主题，但螺栓的每个实例都应该有一个单独的会话由于要传输的消息量很大，因此要避免超载。如何创建单独的会话？我已经在螺栓类的准备方法中实例化了骆驼上下文，并且正在配置文件中实例化路由和 tibco ems 连接。

camel-context 根据以下链接中的解决方案进行实例化： Using Apache Camel ProducerTemplate in Apache Storm bolt

Answer 1

当您说“正在配置文件中实例化 tibco ems 连接”时，我有点困惑。

请记住，prepare 将为 bolt 的每个实例 执行一次，因此您将在此处初始化与 tibco ems 的连接。就像ProducerTemplate 一样，您可以建立您的连接transient，因为您将在execute 中一遍又一遍地重复使用。

在这里看看我的另一个答案：Execution flow of a storm program

最后，您可以在设置拓扑时控制想要的螺栓实例数。