springcloud集成 xxl-job

这两天做了公司项目集成xxl-job,记录一下

xxl-job-admin调度中心直接移植,在pom里引入一下core的依赖,我用了最新的版本

 

<dependency>
　　<groupId>com.xuxueli</groupId>
　　<artifactId>xxl-job-core</artifactId>
　　<version>2.1.2</version>
</dependency>

 

执行器参考了 springboot的示例,引入一下core依赖.

项目使用eureka作为注册中心,从eureka获取调度中心的地址,所以修改了一下yml 和 XxlJobConfig

 

xxl:
  job:
    executor:
      logpath: /home/jar/public/job-service/log/jobhandler
      appname: yurun-job
      port: -1
      logretentiondays: 10
      ip:
    # 调度中心 eureka服务
    admin:
      addresses: job-admin-service
    accessToken:

XxlJobConfig

 　　@Bean public XxlJobSpringExecutor xxlJobExecutor() { logger.info(">>>>>>>>>>> xxl-job config init."); XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor(); //服务发现 从eureka拉取服务 dll
        List<String> urls = Lists.newArrayList(); List<ServiceInstance> instances = discoveryClient.getInstances(adminAddresses); if(StringUtils.isNotEmpty(instances)) { instances.forEach(serviceInstance->{ urls.add("http://"+ serviceInstance.getHost() + ":" + serviceInstance.getPort()); }); } xxlJobSpringExecutor.setAdminAddresses(String.join(",",urls));  xxlJobSpringExecutor.setAppName(appName); xxlJobSpringExecutor.setIp(ip); xxlJobSpringExecutor.setPort(port); xxlJobSpringExecutor.setAccessToken(accessToken); xxlJobSpringExecutor.setLogPath(logPath); xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); return xxlJobSpringExecutor; }