我正在开发apache storm，我计划通过一个tibco-ems连接将端螺栓连接起来，使用apache camel将消息传递到tibco-ems的主题，但是螺栓的每个示例都应该与主题有一个单独的会话，以避免过载，因为要传输的消息量是巨大的。如何创建单独的会话？我已经在bolt类的prepare方法中示例化了camel上下文，routes和tibco ems连接正在config文件中示例化。
camel上下文是根据下面链接中的解决方案示例化的：在apache storm bolt中使用apache camel producertemplate
1条答案
按热度按时间jhiyze9q1#
当你说“tibco ems连接正在配置文件中示例化”时，我有点困惑。
记得
prepare将对每个bolt示例执行一次，因此在这里初始化到tibco ems的连接。就像ProducerTemplate你可以建立你的联系transient因为你会一次又一次的重复使用execute.看看我的另一个答案：storm程序的执行流程
最后，您可以控制在设置拓扑时需要多少螺栓示例。