当前位置: 首页 > article >正文

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);
            }
        }
      

http://www.kler.cn/a/154266.html

相关文章:

  • Cyberchef配合Wireshark提取并解析TCP/FTP流量数据包中的文件
  • uniapp微信小程序接入airkiss插件进行WIFI配网
  • 每日一博 - Java的Shallow Copy和Deep Copy
  • 【Linux庖丁解牛】—Linux基本指令(下)!
  • VMD + CEEMDAN 二次分解,CNN-LSTM预测模型
  • vue3【实战】切换全屏【组件封装】FullScreen.vue
  • USB Type-C的基本原理
  • 2023.11.30 关于 MyBatis 动态 SQL 的使用
  • conda环境下numpy模块ValueError: setting an array element with a sequence.问题解决
  • 计算机 Wi-Fi 掉线后重新连接并恢复网络访问(GPT4)
  • 修改apt-get的出口IP
  • 一篇带你串通数据结构
  • node的proxy-server使用
  • 【力扣1929】数组串联
  • Android 13 - Media框架(15)- OpenMax(三)
  • 微前端qiankun示例 Umi3.5
  • matlab 汽车单车模型固定点跟踪算法
  • io基础入门
  • CPU 使用率和负载Load
  • golang Pool实战与底层实现
  • k8s(三): 基本概念-ReplicaSet与Deployment
  • TA-Lib学习研究笔记——Price Transform (五)
  • 阿里千问Qwen-72 b在中文测试中击败了GPT-3.5
  • 【Matlab】如何快速入门一项新技能-以Matlab/Simulink入门为例
  • C语言中的格式化输出符号:%d %c %p %x等
  • 750mA Linear Charger with Power Path Management