xxl-job分布式定时任务

1.启动java admin项目注册到nacos

2.启动定时任务微服务注册到定时任务中心

3.在定时任务微服务写bean

4.在http://localhost:8080/xxl-job-admin/joblog?jobId=2 任务管理添加任务的bean名字和 cron表达式

//想要得到参数,使用,逗号分隔java来处理,或者使用jackson json转对象
String jobParam = XxlJobHelper.getJobParam()

5.阻塞处理策略

  1. 单机串行(默认)

调度进入单机执行器后,调度请求进入FIFO队列执行

  1. 丢弃后续调度(推荐)(丢后执行前) 调度进入单机执行器后,发现有任务执行,丢弃后到的任务
  2. 覆盖之前调度(不推荐)(丢前执行后)
    调度进入单机执行器后,发现有任务在执行丢弃执行的任务, 清空队列,然后执行后到的任务

6.怎么实现分布式任务 executor 在界面选择分片广播 ,也可以使用轮询(集群),和指定第一个个最后一个机器执行(单机)
// 分片参数
//我知道那台机器执行哪个分片,就可以实现分布式定时任务了

int shardIndex = XxlJobHelper.getShardIndex();
int shardTotal = XxlJobHelper.getShardTotal();


        XxlJobHelper.log("分片参数:当前分片序号 = {}, 总分片数 = {}", shardIndex, shardTotal);

        // 业务逻辑
           for (int i = 0; i < shardTotal; i++) {
   
            if (i == shardIndex) {
   
                System.out.println("aaaa");
                XxlJobHelper.log("第 {} 片, 命中分片开始处理", i);
            } else {
   
                XxlJobHelper.log("第 {} 片, 忽略", i);
            }
        }
      

相关推荐

  1. xxl-job分布式定时任务

    2023-12-05 20:36:01       42 阅读

最近更新

  1. TCP协议是安全的吗?

    2023-12-05 20:36:01       16 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2023-12-05 20:36:01       16 阅读
  3. 【Python教程】压缩PDF文件大小

    2023-12-05 20:36:01       15 阅读
  4. 通过文章id递归查询所有评论(xml)

    2023-12-05 20:36:01       18 阅读

热门阅读

  1. SpringBoot整合Logback

    2023-12-05 20:36:01       37 阅读
  2. c++的文件读写

    2023-12-05 20:36:01       36 阅读
  3. 常用类与比较器

    2023-12-05 20:36:01       36 阅读
  4. Leetcode128.最长连续序列

    2023-12-05 20:36:01       32 阅读
  5. 如何保护 API 安全

    2023-12-05 20:36:01       41 阅读
  6. Diary17-Word页面设计

    2023-12-05 20:36:01       47 阅读
  7. 【lua】获取某月最大天数

    2023-12-05 20:36:01       30 阅读
  8. 【Android 线程】在子线程中更新UI

    2023-12-05 20:36:01       39 阅读
  9. spark学习一-------------------Spark算子最详细介绍

    2023-12-05 20:36:01       35 阅读
  10. 再探Docker:从Docker基础到跨服务器部署

    2023-12-05 20:36:01       24 阅读