简介

用xxl-job做后台任务管理, 主要是快速解决定时任务的HA问题, 项目代码量不大, 功能精简, 没有特殊依赖. 因为产品中用到了这个项目, 上午花了点时间研究了一下运行机制. 把看到的记一下.

项目地址
- https://github.com/xuxueli/xxl-job
- http://gitee.com/xuxueli0323/xxl-job
文档 https://www.xuxueli.com/xxl-job/

环境

<!-- http://repo1.maven.org/maven2/com/xuxueli/xxl-job-core/ -->
<dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>${最新稳定版本}</version>
</dependency>

运行需要 JDK1.8, MySQL5.7

数据库结构

库编码 utf8mb4_unicode_ci
Table: xxl_job_group
任务分组, 组名, 只支持一级分组, address_list 字段支持多个执行端地址, 逗号分隔
Table: xxl_job_info
任务主表, 记录了任务明细, 调度明细以及预警设置
Table: xxl_job_log
任务每次执行的日志
Table: xxl_job_log_report
按日对执行日志进行统计的结果
Table: xxl_job_logglue
Table: xxl_job_registry
用于登记任务的执行者, 记录group:分组, key:名称, value:接口地址. 名称是可以重复的, 接口地址会添加到任务分组表中的注册字段
Table: xxl_job_user
简单的登录控制, 与其它表没有关联
Table: xxl_job_lock
单字段表, 用于并发时加锁避免冲突

代码结构

项目用到的都是常见组件, MyBatis, FreeMarker, Bootstrap, 当前版本基于SpringBoot 2.6.7
线上运行的是 xxl-job-admin 模块, 提供执行端注册, 任务发起和日志记录等服务
项目中需要实现 xxl-job-executor, 项目中提供了例子

项目文件结构如下

├───doc
│   ├───db                                               # 初始化的sql
│   └───images
├───xxl-job-admin                                        # 运行的服务端模块, 提供界面和调度
│   └───src
│       ├───main
│       │   ├───java
│       │   │   └───com
│       │   │       └───xxl
│       │   │           └───job
│       │   │               └───admin
│       │   │                   ├───controller
│       │   │                   │   ├───annotation
│       │   │                   │   ├───interceptor
│       │   │                   │   └───resolver
│       │   │                   ├───core
│       │   │                   ├───dao
│       │   │                   └───service
│       │   │                       └───impl
│       │   └───resources
│       │       ├───i18n                                 # 多国化, 简繁英
│       │       ├───mybatis-mapper                       # xml形式的mapper
│       │       ├───static                               # 前端静态文件
│       │       └───templates                            # Freemarker模板
│       └───test
│           └───java
│
├───xxl-job-core                                         # 公用jar包, 模块内部依赖
│   └───src
│       └───main
│           └───java
│
└───xxl-job-executor-samples
    ├───xxl-job-executor-sample-frameless                # 任务执行层示例
    │   └───src
    │       ├───main
    │       │   ├───java
    │       │   └───resources
    │       └───test
    │           └───java
    └───xxl-job-executor-sample-springboot               # 使用SpringBoot的执行层示例
        └───src
            ├───main
            │   ├───java
            │   └───resources
            └───test

运行机制

执行端需要准备以下信息

adminAddresses 服务端地址, 例如 http://127.0.0.1:8080/xxl-job-admin
accessToken 貌似是服务端的token, 在调用服务端 api/registry, api/registryRemove 等操作时需要验证
appname 执行端名称
address 执行端地址, 和 ip:port 二选一, 存在则覆盖 ip:port
ip 执行端IP
port 执行端服务端口
执行端启动后将自己注册到服务端, 等待回调
任务执行通过 XxlJobTrigger.processTrigger() 发起, 准备参数, 并在分组中选择一个地址
根据这个地址取得 ExecutorBiz, 调用 executorBiz.run() 执行任务
服务端: 通过 ExecutorBizClient,
- 调用XxlJobRemotingUtil.postBody(addressUrl + "run", accessToken, timeout, triggerParam, String.class);
- 其中 accessToken 是服务端的accessToken
执行端: 通过 ExecutorBizImpl.run()
- 调用 XxlJobExecutor.loadJobHandler(triggerParam.getExecutorHandler());得到XxlJob方法
- 通过 XxlJobExecutor.registJobThread(triggerParam.getJobId(), jobHandler, removeOldReason) 执行

非 Spring 的场景

通过调用 FrameLessXxlJobConfig.getInstance().initXxlJobExecutor() 这个方法将 XxlJobSimpleExecutor 实例化, 并注册到xxl_job服务端

Spring 场景

在 @Configuration 中, 将 XxlJobSpringExecutor 作为一个 @Bean 添加到 Spring context
XxlJobSpringExecutor 是 XxlJobExecutor 的子类并实现了 SmartInitializingSingleton 接口的 afterSingletonsInstantiated()方法
在afterSingletonsInstantiated()方法中
- 调用 initJobHandlerMethodRepository(), 在这个方法中, 找到所有@XxlJob注解的方法
- 通过 registJobHandler(), 将@XxlJob方法添加到private static ConcurrentMap<String, IJobHandler> jobHandlerRepository
- 调用 XxlJobExecutor.start(), 将自己注册到 xxl_job 服务端

远程调用服务

xxl_job 并未使用Spring的

首页上一页 1 2 下一页尾页 1/2/2
【大中小】【打印】【繁体】【投稿】【收藏】【推荐】【举报】【评论】【关闭】【返回顶部】

上一篇：过滤器和拦截器总结	下一篇：hibernate validate工具，小心你..