目录
一、下载
1、源码
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-admin
accessToken: default_token
executor:
address:
appname: server-online-rental-xxljob
ip:
port: 9999
logpath: /data/applogs/xxl-job/jobhandler
logretentiondays: 30addresses的地址就是任务调度中心的地址，只需要改端口和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;
@Bean
public 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");
}执行任务，定时任务则自动开始，便可以看到执行的日志
