通过apache-camel连接到storm bolts时创建主题tibco ems的多个会话

Question

我在apache storm上工作，我计划通过一个单独的tibco-ems连接，使用Apache-camel将消息传递到tibco-ems的主题，但是每个螺栓的实例都应该有一个单独的主题会话，以避免过载，因为要传输的消息量是巨大的。如何创建单独的会话？我已经在Bolt类的prepare方法中实例化了camel-context，并且在配置文件中实例化了路由和tibco ems连接。

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

Answer 1

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

请记住，prepare将为执行一次您的螺栓的每个实例，因此这是您初始化到tibco ems的连接的位置。就像ProducerTemplate一样，你可以将你的连接设为transient，因为你会在execute中一次又一次地重用。

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

最后，您可以控制在设置拓扑时需要多少个螺栓实例。