目录
一、下载
1、源码
2、项目结构
3、模块说明
二、部署任务调度中心
1、创建数据库xxl-job
2、配置数据库
3、启动admin模块
4、打开任务调度中心
三、SpringBoot整合xxl-job
1、导入依赖
2、配置yml文件
3、配置类
4、启动项目
5、任务配置
6、测试
一、下载
1、源码
gitee下载
github下载
2、项目结构
下载完成打开项目,以下为项目结构
3、模块说明
以下为对各模块的说明
xxl-job-admin:调度中心
xxl-job-core:公共依赖
xxl-job-executor-samples:执行器Sample示例;
xxl-job-executor-sample-springboot:Springboot版本,通过Springboot管理执行器
xxl-job-executor-sample-frameless:无框架版本;
二、部署任务调度中心
1、创建数据库xxl-job
将sql文件导入MySQL中
2、配置数据库
点击admin下的配置文件,数据库相关信息进行配置
3、启动admin模块
其中admin的端口为任务调度中心的端口,其他调用者将访问admin的端口进行调度
我是用的是8088端口
启动成功:
4、打开任务调度中心
http://localhost:8088/xxl-job-admin
接下来就可以使用SpringBoot整合xxljob作为调用方进行调用
三、SpringBoot整合xxl-job
1、导入依赖
<!-- xxl-job依赖 --><dependency><groupId>com.xuxueli</groupId><artifactId>xxl-job-core</artifactId><version>2.4.0</version></dependency>
2、配置yml文件
xxl:job:admin:addresses: http://localhost:8088/xxl-job-adminaccessToken: default_tokenexecutor:address:appname: server-online-rental-xxljobip:port: 9999logpath: /data/applogs/xxl-job/jobhandlerlogretentiondays: 30
addresses的地址就是任务调度中心的地址,只需要改端口和ip即可拿到自己项目使用
里面的executor.appname的内容就是执行器名称
3、配置类
import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** xxl-job config** @author xuxueli 2017-04-28*/
@Configuration
@Slf4j
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;}/*** 针对多网卡、容器内部署等情况,可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP;** 1、引入依赖:* <dependency>* <groupId>org.springframework.cloud</groupId>* <artifactId>spring-cloud-commons</artifactId>* <version>${version}</version>* </dependency>** 2、配置文件,或者容器启动变量* spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.'** 3、获取IP* String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();*/}
4、启动项目
出现以下内容即为启动成功
5、任务配置
打开任务调度中心,进行执行器的配置,执行器名称即为刚才的appname,名称可以自定义
任务管理选择执行器执行
自定义进行定时任务的管理
6、测试
java的定时任务方法
/*** 1、简单任务示例(Bean模式)*/@XxlJob("demoJobHandler")public void demoJobHandler() throws Exception {System.out.println(LocalDateTime.now()+":你好XXLJOB");}
执行任务,定时任务则自动开始,便可以看到执行的日志