我试图找到这些信息,但没有文章解决我的问题。
在Apache风暴有喷口和螺栓。据我所知,还有工作进程(jvm)、执行器(jvm中的线程)和任务(spout/bolt的一个示例)的概念。
我无法理解的事情:
何时创建螺栓/喷嘴?
谁制造螺栓/喷口?是nimbus创建了它,序列化并发送给所有的工作者(jvm)吗?或者更确切地说是nimbus将.jar发送给自己创建示例的主管?或者nimbus创建整个线程示例,序列化它们,并将它们作为随时可用的执行器发送给主管?
在整个集群中创建了多少个喷口/螺栓示例?
在一个工作进程中,有多个执行器意味着在这些执行器中运行的喷口/螺栓需要关心线程安全—因为它们共享jvm,因此具有相同的堆空间?
我知道,如果需要跨工作进程(不同的jvm)发送元组,元组可以序列化(使用kryo)。螺栓/喷嘴是否也序列化?如果是-为什么?
drpc是什么东西?
我真的希望apachestorm文档更加精巧和最新。如果我有什么地方错了,请纠正我。
暂无答案!
目前还没有任何答案,快来回答吧!