开始准备
启动官方案例,准备两份官方案例代码,然后都启动起来
官方案例代码地址
xxl-job-master\xxl-job-executor-samples\xxl-job-executor-sample-springboot\src\main\java\com\xxl\job\executor\XxlJobExecutorApplication.java
代码地址在
ZJJ_xxl-job\xxl-job-master\xxl-job-executor-samples\xxl-job-executor-sample-
springboot\src\main\java\com\xxl\job\executor\service\jobhandler\SampleXxlJob.java
/**
* 2、分片广播任务
*/
@XxlJob("shardingJobHandler")
public void shardingJobHandler() throws Exception {
// 分片参数
int shardIndex = XxlJobHelper.getShardIndex();
int shardTotal = XxlJobHelper.getShardTotal();
logger.info("shardIndex是:{}" ,shardIndex);
XxlJobHelper.log("分片参数:当前分片序号 = {}, 总分片数 = {}", shardIndex, shardTotal);
// 业务逻辑
for (int i = 0; i < shardTotal; i++) {
if (i == shardIndex) {
XxlJobHelper.log("第 {} 片, 命中分片开始处理", i);
} else {
XxlJobHelper.log("第 {} 片, 忽略", i);
}
}
}