Elasitc job 3.0随笔

         ElasticJob 社区在经过之前几年的停滞状况之后并入到apache,并且作为 Apache ShardingSphere 的子项目继续发光发热,终于迎来了它的3.0时代,作为一个老码农我也赶紧跟着时代的脚本,进行了一次深入学习和研究,这里记录下学习笔记。

首先elasticjob底层还是基于quartz实现的,熟悉quartz的朋友都知道quartz有三个非常重要的概念:

1、scheduler是一个计划调度器容器,容器里面可以有众多的JobDetail和trigger,当容器启动后,里面的每个JobDetail都会根据trigger按部就班自动去执行。

2、JobDetail是一个可执行的工作,它本身可能是有状态的。

3、Trigger代表一个调度参数的配置,什么时候去调。

当JobDetail和Trigger在scheduler容器上注册后,形成了装配好的作业(JobDetail和Trigger所组成的一对儿),就可以伴随容器启动而调度执行了。

scheduler是个容器,容器中有一个线程池,用来并行调度执行每个作业,这样可以提高容器效率。

elasticjob3.0.0相较之前不同之处

1、通过阅读官网发现elasticjob3.0.0新增了http类型的作业,可以直接调用http请求,并在请求头中将分片上下文以json串的形式传递,同时也增加了HttpJobExecutor来支撑HttpJob的执行

我们看看官网上的一段代码

文档关于这部分的介绍就寥寥数笔,没有写得很细致。

不过通过自己写个demo来体验再加上结合之前用ElasitcJob的经验仔细想想,个人总结了一下这样做的好处:之前都是将job任务处理的核心逻辑集中在job服务本身,job不仅要负责调度还需要处理核心业务逻辑,这样做之后job服务本身只需关注任务的调度和管理,核心逻辑可以分离到其他服务中去,有助于缕清微服务盛行的当下业务边界问题同时减少job服务本身的压力。

2、job监听器采用SPI的方式由ElasticJobServiceLoader来进行加载和管理

再来看官网上的一段代码

上面就调用了ScheduleJobBootstrap类的schedule()方法,job的启动就是从这里开始的,我们看看这个方法

继续跟进去发现是调用了JobScheduleController的scheduleJob(String corn)方法

发现调用了scheduler的start方法,而scheduler是quartz的任务调度器,到这里就接上了quartz的任务调度过程,有没有瞬间就懂了?

接下来我们关注下job的线程池,查看了下demo在执行job的调用栈

关注一下SimpleThreadpool,QuartzSchedulerThread,JobRunShell,LiteJob这4个类

其中QuartzSchedulerThread是一个线程类,负责查询并触发Triggers,该线程类的主要工作分为以下几个步骤:

1、等待QuartzScheduler启动

2、查询待触发的Trigger

3、等待Trigger触发时间到来

4、触发Trigger

5、循环上述步骤

具体的源码我将在单独的文章中进行解析,这里不再展开。

在底部发现由quartz的SimpleThreadpool拉起的,而这个线程池是由StdSchedulerFactory完成初始化的

看下StdSchedulerFactory的instantiate()方法,SimpleThreadpool和QuartzSchedulerThread都是这个方法中初始化的

可以看到QuartzScheduler构造方法中初始化了QuartzSchedulerThread并在线程池中启动

我们看下QuartzSchedulerThread的run方法

这里getThreadPool获取的线程池就是前面所述的 SimpleThreadPool,调用runInThread方法传入JobRunShell线程对象,并将JobRunShell赋值给SimpleThreadPool内部类定义的工作线程 ,进入runInThread方法之后启动了SimpleThreadPool内部类定义的工作线程 

在WorkThread的run方法中调用了JobRunShell的run方法,

这里的job就是LiteJob

这里实际上调用的是ElasticJobExecutor的execute方法,进入到方法里面

1、检查job执行环境

2、job执行前的处理

3、正常执行job

4、如果发生misfire则执行job

5、job执行后的处理

这里2和5就是调用ElasticJobListener进行处理的,经过轮询监听器然后调用对应的方法跟进execute方法最后发现调用的是JobItemExecutor.process方法 ,那前面我们知道有 SimpleJob、DataFlowJob、ScriptJob、HttpJob四种不同类型的作业,这个方法是怎么处理这四种不同的作业的呢?然后JobItemExecutor也是elasitcJob提供的一个接口,也是采用SPI的方式进行扩展的 ,根据不同的job类型加载不同的作业处理器进行对应作业的处理,我们来看看它的类结构

有兴趣的同学可以看看对应的job处理器是怎么处理作业的,这里就不再展开了。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 217,826评论 6 506
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,968评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 164,234评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,562评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,611评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,482评论 1 302
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,271评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,166评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,608评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,814评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,926评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,644评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,249评论 3 329
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,866评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,991评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,063评论 3 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,871评论 2 354

推荐阅读更多精彩内容