步骤一

maven依赖

打开项目： Image110.png 对easy-job-core模块进行deploy。引入了 “easyjob-job-core” 的maven依赖；

  1. <!-- easy-job-core -->
  2. <dependency>   
  3. <groupId>com.git</groupId>   
  4. <artifactId>easy-job-core</artifactId>   
  5. <version>1.0.0-SNAPSHOT</version>
  6. </dependency>

步骤二

执行器配置在Springboot项目配置文件application.yml或application.properties 文件中配置 执行器配置，配置内容说明：

  1. ###调度中心部署根地址 [选填]：如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调"；为空则关闭自动注册； easyjob.job.admin.addresses=http://127.0.0.1:8080/easyjob-job-admin ### 执行器通讯TOKEN [选填]：非空时启用； 
  2. easyjob.job.accessToken= 
  3. ### 执行器AppName [选填]：执行器心跳注册分组依据；为空则关闭自动注册 easyjob.job.executor.appname=easyjob-job-executor-sample 
  4. ### 执行器注册 [选填]：优先使用该配置作为注册地址，为空时使用内嵌服务 ”IP:PORT“ 作为注册地址。从而更灵活的支持容器类型执行器动态IP和动态映射端口问题。 
  5. easyjob.job.executor.address= 
  6. ### 执行器IP [选填]：默认为空表示自动获取IP，多网卡时可手动设置指定IP，该IP不会绑定Host仅作为通讯实用；地址信息用于 "执行器注册" 和 "调度中心请求并触发任务"； 
  7. easyjob.job.executor.ip= 
  8. ### 执行器端口号 [选填]：小于等于0则自动获取；默认端口为9999，单机部署多个执行器时，注意要配置不同执行器端口； 
  9. easyjob.job.executor.port=9999 
  10. ### 执行器运行日志文件存储磁盘路径 [选填] ：需要对该路径拥有读写权限；为空则使用默认路径； 
  11. easyjob.job.executor.logpath=/data/applogs/easyjob-job/jobhandler 
  12. ### 执行器日志文件保存天数 [选填] ： 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能； easyjob.job.executor.logretentiondays=30
  13. easy:   
  14.   job:     
  15.    admin:       
  16.     addresses: http://127.0.0.1:9090     
  17. ### easy-job executor address     executor:       
  18. appname: easy-job-executor-sample       
  19. ip:       
  20. port: 9999       
  21. ### easy-job log path       
  22. logpath: /app/tomcat/deploy/log/jobhandler       
  23. ### easy-job log retention days       l
  24. ogretentiondays: -1     
  25. ### easy-job, 
  26. access token     
  27. accessToken:

步骤三

引入配置类

新增 EasyJobConfig

  1. @Configuration public class EasyJobConfig {     private Logger logger = LoggerFactory.getLogger(EasyJobConfig.class);     @Value("${easy.job.admin.addresses}")     private String adminAddresses;     @Value("${easy.job.executor.appname}")     private String appName;     @Value("${easy.job.executor.ip}")     private String ip;     @Value("${easy.job.executor.port}")     private int port;     @Value("${easy.job.accessToken}")     private String accessToken;     @Value("${easy.job.executor.logpath}")     private String logPath;     @Value("${easy.job.executor.logretentiondays}")     private int logRetentionDays;     @Bean(initMethod = "start", destroyMethod = "destroy")     public EasyJobSpringExecutor easyJobExecutor() {         logger.info(">>>>>>>>>>> easy-job config init.");         EasyJobSpringExecutor easyJobSpringExecutor = new EasyJobSpringExecutor();         easyJobSpringExecutor.setAdminAddresses(adminAddresses);         easyJobSpringExecutor.setAppName(appName);         easyJobSpringExecutor.setIp(ip);         easyJobSpringExecutor.setPort(port);         easyJobSpringExecutor.setAccessToken(accessToken);         easyJobSpringExecutor.setLogPath(logPath);         easyJobSpringExecutor.setLogRetentionDays(logRetentionDays);         return easyJobSpringExecutor;     }

步骤四

调度中心新增执行器

  1. insert into TB_JOB_GROUP (ID, APP_NAME, TITLE,  ORDER_NUM, ADDRESS_TYPE, ADDRESS_LIST,  JOB_TASKID)values (1019, 'easy-job-executor-credit', '授信子系统半批', 19, 0, null, 'HALFCRD020120');

注意： APP_NAME字段与配置文件执行名一致。不能写错。 执行器ID 自定义，与调度任务绑定。

步骤五

检查是否集成成功 查询注册表中，是否有SpringBoot项目IP

  1. select * from  tb_job_registry;

在执行器功能页面查看信息执行器信息。