JStorm:JStorm原始码学习 源码包

暴风雨 JStorm原始码学习:主要包含Storm重新启动,Nimbus启动,Supervisor启动,Executor创建和启动 风暴编程模型 Nimbus:负责资源分配和任务调度。 主管:负责接受nimbus分配的任务,启动和停止属于自己管理的worker进程。 Worker:运行特定处理组件逻辑的进程。Worker运行的任务类型只有两种,一种是Spout任务,一种是Bolt任务。 任务:工人中每一个嘴/螺栓的螺纹称为一个任务。在storm0.8之后,任务不再与物理线程对应,不同的spout / bolt的任务可能会共享一个物理线程,该线程称为执行器。 风暴编程模型 数据来源:外部数据源 Spout:接受外部数据源的组件,将外部数据源转换成Storm内部的数据,以Tuple为基本的传输单元下发给Bolt Bolt:接受Spout发送的数据,或上游的bolt的发送的数据。根据