我正在研究Apache风暴,我计划通过单个tibco-ems连接使用Apache-camel连接末端螺栓,以将消息传递给tibco-ems主题,但是螺栓的每个实例都应与该主题进行单独的会话为了避免过载,因为要传输的消息量很大。如何创建单独的会话?我已经在bolt类的prepare方法中实例化了骆驼上下文,并且在配置文件中实例化了路由和tibco ems连接。

根据以下链接中的解决方案实例化骆驼上下文:
Using Apache Camel ProducerTemplate in Apache Storm bolt

最佳答案

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

请记住,prepare将针对每个螺栓实例执行一次,因此您可以在此处初始化与tibco ems的连接。就像ProducerTemplate一样,您可以建立连接transient,因为您将在execute中反复使用。

在这里看看我的其他答案:Execution flow of a storm program

最后,您可以在设置拓扑时控制所需的螺栓实例数。

07-28 03:35
查看更多