分布式调度平台XXL-JOB源码分析-执行器端

深藏阁楼爱情的钟 2023-08-17 15:38 74阅读 0赞

上一篇文章已经说到调度中心端如何进行任务管理及调度，本文将分析执行器端是如何接收到任务调度请求，然后执行业务代码的。

XxlJobExecutorApplication为我们执行器的启动项，其中有个XxlJobConfig的配置项，发现其中有个属性为adminAddresses，这个就是我们调度中心的地址。

## XxlJobSpringExecutor ##

![Image 1][]

声明了init方法为start，点进来，

![Image 1][]

它又实现了ApplicationContextAware接口，用来保存spring的上下文信息。

它还有个父类XxlJobExecutor，暂时未找到其他子类。

程序开始执行start方法，

![Image 1][]

第一步，调用了本类的私有方法，这个方法就是把JobHandler的实现类取出来，再调用registJobHandler(name, handler)进行注册。

![Image 1][]

registJobHandler的实现方法在父类中，很简单，维护了一个Map，估计后面进行任务的执行时会来这个map里面进行查询。

![Image 1][]

第二步，估计是初始化了Glue的执行器。

第三步，调用父类的start方法，大部分的业务逻辑都在这里。

![Image 1][]

1.日志处理器初始化

2.向adminBizList字段中放入XxlRpcReferenceBean返回的代理类，作用之后会单独开一篇注册心跳的文章说明。

3.任务日志清除

4.任务结果回调处理线程

5.启动另一个执行器的执行线程XxlRpcProviderFactory这个类是XXl其他的开源项目，自研RPC。

## XxlRpcProviderFactory ##

看名字就知道这个类是可以返回Rpc调用服务提供端的工厂类，接上文，看他的initRpcProvider方法。

![Image 1][]

由上面的代码跟进来，发现这就是启动了一个以netty作为通讯模型、Hessian作为序列化方式的、ExecutorServiceRegistry作为注册逻辑实现类的服务提供端。

接着我们向其添加一个服务，名称为ExecutorBiz，版本为null，处理请求的实现类为ExecutorBizImpl，最后我们调用start方法完成执行器端的服务暴露。

![753271-20190925154224999-1695030336.png][]

此时的ServiceRegistry为ExecutorServiceRegistry，调用其start，以30秒的间隔和调度中心进行心跳通知，然后调用server的start方法，此时server为NettyHttpServer。

![753271-20190925154349234-1460768017.png][]

整个代码结构就是用netty启动了个服务，来看最后一个ChannelHandler，NettyHttpServerHandler。

![753271-20190925155522138-1402873489.png][]

调用私有方法process。

![753271-20190925155915425-1215171461.png][]

这里调用了xxlRpcProviderFactory的invokeService方法完成了服务实现的反射调用。

![753271-20190925160304276-200875200.png][]

从serviceData中拿到我们之前调用addService方法添加的服务实现类，这里是ExecutorBizImpl，这里反射调用的方法是run。

## ExecutorBizImpl ##

这个类实现了ExecutorBiz接口，看接口定义的方法，主要是作为执行器，提供给调度中心几个接口方法。

![753271-20190925160801425-305738742.png][]

重点来看run方法。

![753271-20190925163459341-1389381825.png][]

首先XxlJobExecutor内部会有个以jobId为key，执行这个任务的线程为value的字段jobThreadRepository，我们首先去尝试的获取当前正在执行这个任务的线程，如果有，那就根据任务设置的运行模式进行处理，如下图。

![753271-20190925165008049-434162815.png][]

如果没有正在执行此任务的线程，那就调用XxlJobExecutor.registJobThread()启动一个线程，最后将任务数据推送给这个可能是从jobThreadRepository获取到的也可能是新创建的线程，如下图。

![753271-20190925165224659-125497621.png][]

![753271-20190925165248918-1425892113.png][]

![753271-20190925165931587-260880281.png][]

JobThread的run方法会从triggerQueue里poll出任务，然后用之前设置的 handler进行execute的方法调用，并利用idleTimes字段进行线程无任务空转的次数控制，如下图。

![753271-20190925170654339-2065119258.png][]

至此，执行器完成了启动，暴露ExecutorBiz服务，接收任务调度数据TriggerParam，并在JobThread线程中完成任务配置的业务handler的执行。

## 时序图 ##

![753271-20190926143152030-1231085447.png][]

![753271-20190926143208681-502194714.png][]

![753271-20190926143221674-1010524771.png][]

转载于:https://www.cnblogs.com/jiangyang/p/11578066.html

[Image 1]: 
[753271-20190925154224999-1695030336.png]: /images/20230810/8e0c26d36b9040e0a6de1eac998ac80b.png
[753271-20190925154349234-1460768017.png]: /images/20230810/78d5c60fb3df46e885d75d2f66c658ed.png
[753271-20190925155522138-1402873489.png]: /images/20230810/1cd30ded3d2f46a19447e228ce0b6057.png
[753271-20190925155915425-1215171461.png]: /images/20230810/5c1952b10dcb4b49aa298791a2d974a5.png
[753271-20190925160304276-200875200.png]: /images/20230810/f503f272c0a746c7b737461f22538d5b.png
[753271-20190925160801425-305738742.png]: /images/20230810/da723266a3a647dbb728fa2ef23fb3a2.png
[753271-20190925163459341-1389381825.png]: /images/20230810/665a577fa8974600ba1a857f7c254d12.png
[753271-20190925165008049-434162815.png]: /images/20230810/9ddf30d03f7d400a8e12f47bb79a9003.png
[753271-20190925165224659-125497621.png]: /images/20230810/ba163271861c41b5b1d93f8e8eaf92e2.png
[753271-20190925165248918-1425892113.png]: /images/20230810/eacf07bb7df64130a5229196d509ed40.png
[753271-20190925165931587-260880281.png]: /images/20230810/fdb654b98c5944819059accd1879a694.png
[753271-20190925170654339-2065119258.png]: /images/20230810/5ec6afc7a28b44f693d9f60bfafc1ea8.png
[753271-20190926143152030-1231085447.png]: /images/20230810/24a1e5e6d1d9490089cd2ee4b4a39991.png
[753271-20190926143208681-502194714.png]: /images/20230810/d209b9cd5efd41d19d8a203dfbabdc97.png
[753271-20190926143221674-1010524771.png]: /images/20230810/1e89267967ae4e9497a49c916829e8bb.png