我正在研究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
最后,您可以在设置拓扑时控制所需的螺栓实例数。