xxljob⼊门以及整合到⾃⼰的项⽬
搭建调度中⼼
1、官⽹下载代码
2、导⼊sql语句
调度数据库初始化SQL脚本- 位置为: /xxl-job/doc/db/tables_xxl_job.sql
3、修改数据库地址
spring.datasource.url=jdbc:mysql://localhost:3333/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shan ghai
spring.datasource.username=root
spring.datasource.password=root
4、启动admin模块
5、访问localhost:8080/xxl-job-admin/
搭建完成
---------------------------------------
搭建执⾏器(⾃⼰项⽬整合)
步骤⼀：maven依赖
确认pom⽂件中引⼊了 “xxl-job-core” 的maven依赖；
<!-- xxl-job-core -->
<dependency>
<groupId>com.xuxueli</groupId>
<artifactId>xxl-job-core</artifactId>
<version>2.3.0</version>
</dependency>
步骤⼆：执⾏器配置
执⾏器配置，配置⽂件地址：src/main/resources/application.properties
#xxl
### 调度中⼼部署跟地址[选填]：如调度中⼼集部署存在多个地址则⽤逗号分隔。执⾏器将会使⽤该地址进⾏"执⾏器⼼跳注册"和"任务结果回调"；为空则关闭⾃动注册；
xxl.job.admin.addresses=127.0.0.1:8080/xxl-job-admin
### 执⾏器通讯TOKEN [选填]：⾮空时启⽤；
xxl.job.accessToken=
### 执⾏器AppName [选填]：执⾏器⼼跳注册分组依据；为空则关闭⾃动注册
utor.appname=xxl-job-executor-sample
### 执⾏器注册[选填]：优先使⽤该配置作为注册地址，为空时使⽤内嵌服务 ”IP:PORT“ 作为注册地址。从⽽更灵活的⽀持容器类型执⾏器动态IP和动态映射端⼝问题。
utor.address=
### 执⾏器IP [选填]：默认为空表⽰⾃动获取IP，多⽹卡时可⼿动设置指定IP，该IP不会绑定Host仅作为通讯实⽤；地址信息⽤于"执⾏器注册"和"调度中⼼请求并触发任务"；
utor.ip=
### 执⾏器端⼝号[选填]：⼩于等于0则⾃动获取；默认端⼝为9999，单机部署多个执⾏器时，注意要配
置不同执⾏器端⼝；
utor.port=9999
### 执⾏器运⾏⽇志⽂件存储磁盘路径[选填]：需要对该路径拥有读写权限；为空则使⽤默认路径；
utor.logpath=/data/applogs/xxl-job/jobhandler
### 执⾏器⽇志⽂件保存天数[选填]：过期⽇志⾃动清理，限制值⼤于等于3时⽣效；否则，如-1，关闭⾃动清理功能；
utor.logretentiondays=30
步骤三：执⾏器组件配置
执⾏器组件，配置⽂件：XxlJobConfig
@Configuration
@Slf4j
public class XxlJobConfig {
@Value("${xxl.job.admin.addresses}")
private String adminAddresses;
@Value("${xxl.job.accessToken}")
private String accessToken;
@Value("${utor.appname}")
private String appname;
@Value("${utor.address}")
private String address;
@Value("${utor.ip}")
private String ip;
@Value("${utor.port}")
private int port;
@Value("${utor.logpath}")
怎么查自己的ipprivate String logPath;
@Value("${utor.logretentiondays}")
private int logRetentionDays;
@Bean
public XxlJobSpringExecutor xxlJobExecutor(){
log.info(">>>>>>>>>>> xxl-job config init.");
XxlJobSpringExecutor xxlJobSpringExecutor =new XxlJobSpringExecutor(); xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
xxlJobSpringExecutor.setAppname(appname);
xxlJobSpringExecutor.setIp(ip);
xxlJobSpringExecutor.setPort(port);
xxlJobSpringExecutor.setAccessToken(accessToken);
xxlJobSpringExecutor.setLogPath(logPath);
xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
return xxlJobSpringExecutor;
}
}
步骤四：部署执⾏器项⽬：
步骤五：测试执⾏器：
@Slf4j
@Service
public class CjXxlJobHandler{
@XxlJob("cjJobHandler")
public void cjJobHandler() throws Exception{
System.out.println("cjJobHandler-cjJobHandler, Hello World.--------------------"); // default success
}
}
配置调度中⼼
配置部署“执⾏器项⽬”
1、在下载下来的代码中检查配置⽂件是否正确，端⼝对应调度中⼼
2、执⾏器组件，配置⽂件地址：
/xxl-job/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/core/config/XxlJobConfig.java
3、部署执⾏器项⽬-启动项⽬
4、调度中⼼，新建调度任务、新建执⾏器等等
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论