java—通过ApacheCamel连接到storm bolts时创建主题tibco ems的多个会话

ffdz8vbo  于 2021-06-24  发布在  Storm
关注(0)|答案(1)|浏览(344)

我正在开发apache storm,我计划通过一个tibco-ems连接将端螺栓连接起来,使用apache camel将消息传递到tibco-ems的主题,但是螺栓的每个示例都应该与主题有一个单独的会话,以避免过载,因为要传输的消息量是巨大的。如何创建单独的会话?我已经在bolt类的prepare方法中示例化了camel上下文,routes和tibco ems连接正在config文件中示例化。
camel上下文是根据下面链接中的解决方案示例化的:在apache storm bolt中使用apache camel producertemplate

jhiyze9q

jhiyze9q1#

当你说“tibco ems连接正在配置文件中示例化”时,我有点困惑。
记得 prepare 将对每个bolt示例执行一次,因此在这里初始化到tibco ems的连接。就像 ProducerTemplate 你可以建立你的联系 transient 因为你会一次又一次的重复使用 execute .
看看我的另一个答案:storm程序的执行流程
最后,您可以控制在设置拓扑时需要多少螺栓示例。

相关问题