当前位置：凯发ag旗舰厅登录网址下载 > 前端技术 > javascript >内容正文

javascript

开源调度框架xxl-凯发ag旗舰厅登录网址下载

发布时间：2025/1/21 javascript 17 豆豆

凯发ag旗舰厅登录网址下载收集整理的这篇文章主要介绍了开源调度框架xxl-job集成springbatch详解小编觉得挺不错的,现在分享给大家,帮大家做个参考.

文章目录

- - 一、启动xxl-job调度中心
  - 二、配置部署执行器项目
  - - 1、maven依赖
    - 2、执行器配置
    - 3、执行器组件配置
    - 4、springbatch调度任务开发
    - 5、调度中心，新建执行器
    - 6、调度中心，新建调度任务

写在前面：
我是「境里婆娑」。我还是从前那个少年，没有一丝丝改变，时间只不过是考验，种在心中信念丝毫未减，眼前这个少年，还是最初那张脸，面前再多艰险不退却。
写博客的目的就是分享给大家一起学习交流，如果您对 java感兴趣，可以关注我，我们一起学习。

前言：springbatch它对任务调度方面没有做出什么封装，如何把任务的执行时间实现cron表达式的可配置化，修改的时候并不需要修改配置文件，重启工程等等麻烦的事情，网上查找各种资料知道 xxl-job 及当当网开源的elastic-job，这里我就介绍xxl-job与spring batch的集成使用。

一、启动xxl-job调度中心

如何启动xxl-job调度中心，其官方文档已经写的很详细，在这里就不在重复介绍了。

启动xxl-job调用中心传送门：启动调度中心详细步骤

根据凯发ag旗舰厅登录网址下载官网调度中心启动完成界面如下：

二、配置部署执行器项目

执行器项目：spring-boot-springbatch (提供多种版本执行器供选择，现以 springboot 版本为例，可直接使用，也可以参考其并将现有项目改造成执行器)
作用：负责接收“调度中心”的调度并执行；可直接部署执行器，也可以将执行器集成到现有业务项目中。

1、maven依赖

spring-boot-springbatch pom文件中引入“ xxl-job-core”的maven依赖；

<dependency><groupid>com.xuxueligroupid><artifactid>xxl-job-coreartifactid><version>2.2.0version>dependency>

2、执行器配置

执行器配置，配置内容说明：

### 调度中心部署跟地址 [选填]：如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调"；为空则关闭自动注册； xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin ### 执行器通讯token [选填]：非空时启用； xxl.job.accesstoken= ### 执行器appname [选填]：执行器心跳注册分组依据；为空则关闭自动注册 xxl.job.executor.appname=spring-boot-springbatch ### 执行器注册 [选填]：优先使用该配置作为注册地址，为空时使用内嵌服务 ”ip:port“ 作为注册地址。从而更灵活的支持容器类型执行器动态ip和动态映射端口问题。 xxl.job.executor.address= ### 执行器ip [选填]：默认为空表示自动获取ip，多网卡时可手动设置指定ip，该ip不会绑定host仅作为通讯实用；地址信息用于 "执行器注册" 和 "调度中心请求并触发任务"； xxl.job.executor.ip= ### 执行器端口号 [选填]：小于等于0则自动获取；默认端口为9999，单机部署多个执行器时，注意要配置不同执行器端口； xxl.job.executor.port=9999 ### 执行器运行日志文件存储磁盘路径 [选填] ：需要对该路径拥有读写权限；为空则使用默认路径； xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler ### 执行器日志文件保存天数 [选填] ：过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能； xxl.job.executor.logretentiondays=30

3、执行器组件配置

执行器组件xxljobconfig配置如下：

@configuration public class xxljobconfig {private logger logger = loggerfactory.getlogger(xxljobconfig.class);@value("${xxl.job.admin.addresses}")private string adminaddresses;@value("${xxl.job.accesstoken}")private string accesstoken;@value("${xxl.job.executor.appname}")private string appname;@value("${xxl.job.executor.address}")private string address;@value("${xxl.job.executor.ip}")private string ip;@value("${xxl.job.executor.port}")private int port;@value("${xxl.job.executor.logpath}")private string logpath;@value("${xxl.job.executor.logretentiondays}")private int logretentiondays;@beanpublic xxljobspringexecutor xxljobexecutor() {logger.info(">>>>>>>>>>> xxl-job config init.");xxljobspringexecutor xxljobspringexecutor = new xxljobspringexecutor();xxljobspringexecutor.setadminaddresses(adminaddresses);xxljobspringexecutor.setappname(appname);xxljobspringexecutor.setaddress(address);xxljobspringexecutor.setip(ip);xxljobspringexecutor.setport(port);xxljobspringexecutor.setaccesstoken(accesstoken);xxljobspringexecutor.setlogpath(logpath);xxljobspringexecutor.setlogretentiondays(logretentiondays);return xxljobspringexecutor;} }

4、springbatch调度任务开发

基于bean模式（方法形式）
bean模式任务，支持基于方法的开发方式，每个任务对应一个方法。

joblauncherservice配置如下

/*** @author shuliangzhao* @date 2020/12/12 19:17*/ @service public class joblauncherservice {private static final logger log = loggerfactory.getlogger(joblauncherservice.class);@autowiredprivate joblauncher joblauncher;public map<string,object> startjob(job job, jobparameters jobparameters) throws exception {map<string,object> resultmap = collutil.newhashmap();//计时stopwatch stopwatch = new stopwatch();stopwatch.start(job.getname());//执行任务jobexecution run = joblauncher.run(job, jobparameters);//返回结果stringbuffer stringbuffer = new stringbuffer();collection<stepexecution> stepexecutions = run.getstepexecutions();stepexecutions.foreach(stepexecution -> {stringbuffer.append("readcount:" stepexecution.getcommitcount() logconstants.log_str_comma);stringbuffer.append("filtercount:" stepexecution.getfiltercount() logconstants.log_str_comma);stringbuffer.append("commitcount:" stepexecution.getcommitcount() logconstants.log_str_comma);stringbuffer.append("writecount:" stepexecution.getwritecount());});stopwatch.stop();exitstatus exitstatus = run.getexitstatus();string returnstr = system.lineseparator() "resultcount: " stringbuffer.tostring() system.lineseparator() "exitstatus: "exitstatus system.lineseparator() "timeinfo: "stopwatch.prettyprint();log.info(returnstr);resultmap.put(syncconstants.str_return_result,returnstr);resultmap.put(syncconstants.str_return_exitstatus,exitstatus);return resultmap;} }

启动job工具类配置：

/*** @author shuliangzhao* @date 2020/12/12 19:24*/ public class jobutil {/*** 构建jobparameters* @return*/private static jobparameters makejobparameters() {jobparameters jobparameters = new jobparametersbuilder().addlong("time",system.currenttimemillis()).tojobparameters();return jobparameters;}public static returnt<string> runjob4executor(string jobname, joblauncherservice joblauncherservice, job job) throws exception {xxljoblogger.log("start sync "jobname " data");map<string, object> resultmap = joblauncherservice.startjob(job, makejobparameters());string resultstr = (string)resultmap.get(syncconstants.str_return_result);xxljoblogger.log("end sync "jobname " data, result: "system.lineseparator()resultstr);exitstatus exitstatus = (exitstatus)resultmap.get(syncconstants.str_return_exitstatus);string exitcode = exitstatus.getexitcode();//若成功，返回successif(exitstatus.completed.getexitcode().equals(exitcode)){return ijobhandler.success;}else{return ijobhandler.fail;}} }

执行器开发patternmatchjobhandler

1、任务开发：在spring bean实例中，开发job方法；
2、注解配置：为job方法添加注解 “@xxljob(value=“自定义jobhandler名称”, init = “jobhandler初始化方法”, destroy = “jobhandler销毁方法”)”，注解value值对应的是调度中心新建任务的jobhandler属性的值。
3、执行日志：需要通过 “xxljobhelper.log” 打印执行日志；
4、任务结果：默认任务结果为 “成功” 状态，不需要主动设置；如有诉求，比如设置任务结果为失败，可以通过 “xxljobhelper.handlefail/handlesuccess” 自主设置任务结果；

/*** @author shuliangzhao* @date 2020/12/12 19:31*/ @component public class patternmatchjobhandler {@autowiredprivate joblauncherservice joblauncherservice;@xxljob(value="patternmatchjobhandler")public returnt<string> execute(string s) throws exception {return jobutil.runjob4executor("patternmatchjob",joblauncherservice,springcontextutil.getbean("patternmatchjob", job.class));} }