Elastic-Job项目源码分析2--console执行一窥

x33g5p2x  于2021-12-21 转载在 其他  
字(1.4k)|赞(0)|评价(0)|浏览(301)

我们先来看下console的界面,简洁无华,两个维度以及基本的配置和操作。该有的基本都有了,还没有的估计在开发中,哈哈

今天我们研究的话题,触发按钮到底做了什么,如果你还不了解,请听我娓娓道来。

从架构上来看,console没有和elastic-job-lite发生直接的联系,而是借助ZK和 Elastic-job-lite联系了在一起

但是大家注意到Elastic-Job-Lite和zk怎么联系在一起的么?是的Listener 就是它。当Console增加或修改了zk上的节点时(这里指的是jobName节点下的节点和数据变动,感谢严欢欢同学指出),就会触发Listener,进而触发Job的相关的操作,如触发、暂停、恢复等等,有了这些。明白了原理,我们来看看代码,
Talk is cheap, show me code!

  • console UI 点击触发按钮 做了什么?

请求了/elastic-job-lite-console/job/trigger 这个接口,我们来瞧瞧这个Controller
在这里 elastic-job\elastic-job-lite\elastic-job-lite-console\src\main\java\com\dangdang\ddframe\job\lite\console\controller\JobOperationController.java

再找到这里Trigger的实现类
elastic-job\elastic-job-lite\elastic-job-lite-lifecycle\src\main\java\com\dangdang\ddframe\job\lite\lifecycle\internal\operate\JobOperateAPIImpl.java

我擦,原来亮哥,是在这个serverIp下插入了一个trigger节点,就完事了,是不是so easy?(后记:实际中我们没有并看到trigger节点,这是因为执行程序速度很快,你还没有看到节点,代码已经删除这个节点了,可以看JobTriggerStatusJobListener 中的代码,稍后会讲到)

  • Elastic-Job-Lite 是如何执行的?

我们先来看下基类AbstractJobListener做了什么。

我擦,原来继承了TreeCacheListener 用过curator的都知道这个吧,题外话,除了它,还有NodeCachePathCache,请读者自行阅读其使用方式。好了,谜底都差不多了,再回到JobTriggerStatusJobListener

  • 要点1 serverService.clearJobTriggerStatus(); 这里清除了trigger节点,所以大家看不到trigger节点了
  • 要点2 这里的jobScheduleController.triggerJob() 其实就是调用了quartz里的方法,一起来看看

为什么这里会有scheduler,jobDetail,这玩意,因为,一个job信息包含只有一个线程的quartz,还记得上篇quartz的ThreadCount为1吗?也就是说n个job就会有n个quartz实例~~~

好了,console上的Trigger按钮事件就分析完了,欢迎大家指正交流!

相关文章