我们先来看下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!
触发按钮
做了什么?请求了/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
中的代码,稍后会讲到)
我们先来看下基类AbstractJobListener做了什么。
我擦,原来继承了TreeCacheListener
用过curator的都知道这个吧,题外话,除了它,还有NodeCache
、PathCache
,请读者自行阅读其使用方式。好了,谜底都差不多了,再回到JobTriggerStatusJobListener
serverService.clearJobTriggerStatus();
这里清除了trigger节点,所以大家看不到trigger节点了jobScheduleController.triggerJob()
其实就是调用了quartz里的方法,一起来看看为什么这里会有scheduler,jobDetail,这玩意,因为,一个job信息包含只有一个线程的quartz,还记得上篇quartz的ThreadCount为1吗?也就是说n个job就会有n个quartz实例~~~
好了,console上的Trigger按钮事件就分析完了,欢迎大家指正交流!
版权说明 : 本文为转载文章, 版权归原作者所有 版权申明
原文链接 : https://blog.csdn.net/spy19881201/article/details/61648889
内容来源于网络,如有侵权,请联系作者删除!