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

柔情只为你懂 2022-05-20 02:14 199阅读 0赞

# JStorm源码分析(五):Supervisor获取任务 #

## JStorm源码分析文件 ##

对于整个JStorm源码分析系列，我将JStorm源码分析的文件放在我的GitHub上[JStorm源码剖析][JStorm],欢迎大家fork和star

1.在Supervisor的启动过程中，即在mkSupervisor()方法中，源码如下:

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

SyncSupervisorEvent会定时的循环扫描Zookeeper的任务分配目录，看是否有自己的任务，如果 有，那么把对应的信息写到本地(Supervisor)机器的指定目录中，这个工作主要是有 SyncSupervisorEvent 线程中的run方法来完成的。

2.SyncSupervisorEvent 的成员信息

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

3.任务配置信息Assignment对象所包含的相关信息

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

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

3.SyncSupervisorEvent 的run()方法

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

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

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

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

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

4.getAllAssignments()获取所有的任务信息，放入本地库中

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

5.syncProcesses.run(zkAssignment, downloadFailedTopologyIds)

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

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

## 相关系列文章 ##

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

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

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

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

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

[ 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/440ea2f517314a249c60ec54aae6a532.png
[70 1]: /images/20220520/09966c3138324c8f9fb5b6b9128b46b1.png
[70 2]: /images/20220520/042d6dc397674b4aa1d5af25eeab53fe.png
[70 3]: /images/20220520/5b5edc75194a4249a84c5a25443501c9.png
[70 4]: /images/20220520/513599b4206842e28d68543019e7b856.png
[70 5]: /images/20220520/e5cd7f0d8c334e00a2773831eb48be59.png
[70 6]: /images/20220520/402afb2d71b14f3fa68ec0b289bc2b00.png
[70 7]: /images/20220520/808295d74f624b11be9ced477e5e700f.png
[70 8]: /images/20220520/6366cacc142a47c4bc48c519673f0bb0.png
[70 9]: /images/20220520/6140fe8ef1f54be9b708e9deb3b41bef.png
[70 10]: /images/20220520/c5a8fe684e754f3d998b3d1dcb98c181.png
[70 11]: /images/20220520/6eed5bf1e37548e1923795e9947ce7a5.png
[70 12]: /images/20220520/45f443d049e44612b4855e94be4b2707.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_Worker]: https://blog.csdn.net/oeljeklaus/article/details/80992642
[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/394cddd42e094c58a55c0e51f79d1220.png