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

超、凢脫俗 2022-05-20 02:15 113阅读 0赞

# JStorm源码分析(七):Excutor启动和创建 #

## JStorm源码分析文件 ##

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

Executor的创建与启动是在Worker的execute()方法中完成的。

1.在我们启动Worker时，调用Worker的mk\_worker()方法，mk\_worker方法创建Worker实例，并调 用worker的execute()方法。

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

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

2.调用createTasks()方法，用来创建Task  
![这里写图片描述][70 2]

3.创建并启动Task线程，Task执行的任务在其run()方法中执行。  
![这里写图片描述][70 3]

4.在Task的run()方法中调用自己的execute()方法，执行Task任务。

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

5.在Task的execute()方法中，首先调用mkTaskSending()方法，获得一个Tuple的发送对象。

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

6.创建对应类型的Executor，并在Executor中实现数据的发送与业务逻辑的处理。

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

调用mkExecutor()方法，创建Executor。

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

至此，Executor已经创建并启动。

## 相关系列文章 ##

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

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

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

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

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

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

## 微信公众号 ##

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

[JStorm]: https://github.com/oeljeklaus-you/JStorm
[70]: /images/20220520/229006e9aa3549a0baf8bcef6f177ec9.png
[70 1]: /images/20220520/ee79de5da7b14de89737589852c9578d.png
[70 2]: /images/20220520/f43638376f034bc78d739e37fd1fc47e.png
[70 3]: /images/20220520/b9e07f1d4156406b854c06226b98f27e.png
[70 4]: /images/20220520/887f8cd3f11f426b993efebf4afb7dfe.png
[70 5]: /images/20220520/2686406b6c2049898d430ce54f6eab91.png
[70 6]: /images/20220520/5937ed914ca14991b7ab76e8ba6995ff.png
[70 7]: /images/20220520/e3430f7b2c2641fd94aa829d9f9ed925.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_Supervisor_Worker]: https://blog.csdn.net/Oeljeklaus/article/details/80992642
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L09lbGpla2xhdXM_size_16_color_FFFFFF_t_70]: /images/20220520/7c79acf705d448b9bacb7430b4e16323.png