JStorm源码分析(六)Supervisor启动Worker的过程

左手的ㄟ右手 2022-05-20 02:14 213阅读 0赞

# JStorm源码分析(六):Supervisor启动Worker的过程 #

## JStorm源码分析文件 ##

对于整个JStorm源码分析系列，我将JStorm源码分析的文件放在我的GitHub上[JStorm源码剖析][JStorm],欢迎大家fork和star  
Worker的启动是在Supervis or获取任务的过程中完成的:

1.Supervisor启动后，SyncSupervisorEvent会定时的循环扫描Zookeeper的任务分配目录，看是否 有自己的任务，如果有，那么把对应的信息写到本地(Supervisor)机器的指定目录中，这个工作 主要是有SyncSupervisorEvent 线程中的run方法来完成的。在SyncSupervisorEvent 线程的run方 法 中 ， 最 后 给 p r o c e s s E v e n t Ma n a g e r 添 加 一 个 s y n c P r o c e s s e s 事 件 ， 而 W o r k e r 的 创 建 和 启 动 就 是 在 syncProcesses的run方法中完成的。

2.在syncProcesses的run方法中调用startNewWorkers()方法，启动新的Worker。

![这里写图片描述][70]

3.在startNewWorkers()方法中，生成新的worker id、创建新的worker目录，调用launchWorker()方 法启动worker

![这里写图片描述][70 1]

![这里写图片描述][70 2]

![这里写图片描述][70 3]

4.集群模式下，在launchWorker()方法中，拼接java命令，启动Worker  
![这里写图片描述][70 4]  
(1)launchWorker()方法调用java命令，启动worker的过程，首先是调 用JStormUtils.launchProcess()  
![这里写图片描述][70 5]

(2)在launchProcess()方法中，拆分并组装命令，然后调用launchProcess(command, cmdList, environment, backend)方法  
![这里写图片描述][70 6]

![这里写图片描述][70 7]

(3)最后调用jdk的launchProcess(cmdWrapper, environment)方法，执行命令，启动worker

![这里写图片描述][70 8]

(5)通过ProcessBuilder执行一条命令 java -server backtype.storm.daemon.worker 调用Worker 的main方法，在main方法中调用mk\_worker()方法。

以下的流程与本地模式的启动方式一致。

5.在本地模式下，调用W orker类的mk\_worker()方法，启动worker

![这里写图片描述][70 9]

6.在W orker类的mk\_worker()方法中，拼装worker的相关信息，创建worker实例对象，并调用其 execute()方法

![这里写图片描述][70 10]

## 相关系列文章 ##

[JStorm源码分析(一)Storm执行脚本][JStorm_Storm]

[JStorm源码分析(二)Storm任务提交流程][JStorm_Storm 1]

[JStorm源码分析(三)Nimbus的任务分配过程][JStorm_Nimbus]

[JStorm源码分析(四)Storm集群启动过程][JStorm_Storm 2]

[ JStorm源码分析(五)Supervisor获取任务][JStorm_Supervisor]

[ JStorm源码分析(七)Excutor启动和创建][JStorm_Excutor]

## 微信公众号 ##

有兴趣的同学可以关注小编哟!  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L09lbGpla2xhdXM_size_16_color_FFFFFF_t_70]

[JStorm]: https://github.com/oeljeklaus-you/JStorm
[70]: /images/20220520/ce39dc7627654b1ca8eeb3e106efabd1.png
[70 1]: /images/20220520/b1b9d39e5e5d497cab502ca659067a94.png
[70 2]: /images/20220520/9dbe511ac5a048c99f1d7fa888206cf0.png
[70 3]: /images/20220520/41c77c99b45f4b9187540c0e55cb3e4b.png
[70 4]: /images/20220520/cb0fd8746e0d45a0a2252edf1f8c840b.png
[70 5]: /images/20220520/1a0feb5c3dee454cbb98acc250a56d54.png
[70 6]: /images/20220520/068bec28809d4ffb965e235d261435cb.png
[70 7]: /images/20220520/2a3fa43c6c5f4e16b93d40725de10f10.png
[70 8]: /images/20220520/58308e26052d49979d1cad96fe95e9c5.png
[70 9]: /images/20220520/e4766eac59734090a9c5accea5aa0ae6.png
[70 10]: /images/20220520/50061585cdd1499cb394eb5e3a2a4807.png
[JStorm_Storm]: https://blog.csdn.net/oeljeklaus/article/details/80992277
[JStorm_Storm 1]: https://blog.csdn.net/oeljeklaus/article/details/80992310
[JStorm_Nimbus]: https://blog.csdn.net/oeljeklaus/article/details/80992459
[JStorm_Storm 2]: https://blog.csdn.net/Oeljeklaus/article/details/80992523
[JStorm_Supervisor]: https://blog.csdn.net/Oeljeklaus/article/details/80992587
[JStorm_Excutor]: https://blog.csdn.net/oeljeklaus/article/details/80992673
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L09lbGpla2xhdXM_size_16_color_FFFFFF_t_70]: /images/20220520/4c3b1d3f45ba45f2a7fa57e8e2ceaadb.png