Apache Storm-如何管理螺栓,喷口和序列化?

我正在尝试查找这些信息,但没有文章解决我的问题。

在Apache Storm中,有喷嘴和螺栓。据我了解,还有一个概念是工作进程(JVM),执行程序(JVM中的线程)和任务(Spout / Bolt的实例)。

我不明白的事情

  1. 何时创建螺栓/喷口?
  2. 谁创建螺栓/喷嘴?是Nimbus创建它,序列化并发送给所有Worker(JVM)吗?还是Nimbus将.jar发送给自己创建实例的主管?还是Nimbus可以创建整个Thread实例,对其进行序列化并将其作为现成的执行器发送给Supervisor?
  3. 在整个集群中创建了多少个喷口/螺栓实例?
  4. 在单个Worker进程中,拥有多个执行程序是否意味着在这些执行程序中运行的Spouts / Bolt需要关心线程安全性-因为它们共享JVM,因此具有相同的堆空间?
  5. 我了解,如果需要在Worker进程(不同的JVM)之间发送元组,则可以对它们进行序列化(使用Kryo)。螺栓/喷嘴也要序列化吗?如果是这样-为什么?
  6. 这是什么DRPC东西?

我真的希望Apache Storm文档更加精巧和最新。如果我在任何时候都错了,请纠正我。

iCMS 回答:Apache Storm-如何管理螺栓,喷口和序列化?

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/2180723.html

大家都在问