开始准备

启动官方案例,准备两份官方案例代码,然后都启动起来

官方案例代码地址

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

  1. /**
  2. * 2、分片广播任务
  3. */
  4. @XxlJob("shardingJobHandler")
  5. public void shardingJobHandler() throws Exception {
  6. // 分片参数
  7. int shardIndex = XxlJobHelper.getShardIndex();
  8. int shardTotal = XxlJobHelper.getShardTotal();
  9. logger.info("shardIndex是:{}" ,shardIndex);
  10. XxlJobHelper.log("分片参数:当前分片序号 = {}, 总分片数 = {}", shardIndex, shardTotal);
  11. // 业务逻辑
  12. for (int i = 0; i < shardTotal; i++) {
  13. if (i == shardIndex) {
  14. XxlJobHelper.log("第 {} 片, 命中分片开始处理", i);
  15. } else {
  16. XxlJobHelper.log("第 {} 片, 忽略", i);
  17. }
  18. }
  19. }

配置方式

image.png

执行一次

image.png

查看两个项目的控制台输出

image.png