这两天做了公司项目集成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;
}