xxl-job 是如何注册、注销、维持存活态

我们通过源码发现，xxl-job主要是由客户端发起的注册和存活上报(心跳检测)的；

主要是执行器在启动时，会初始化一个线程，每隔30秒请求调度中心接口，维护存活状态；

  • 注册接口/上报接口：/api/register;
  • 调度中心存储执行器的信息，并维护其末次心跳上报时间xxl_job_registry.update_time

我们主要看 JobRegistryHelper 执行器注册类

包含3个功能: 1. 进行执行器的注册和心跳检测； 2. 执行器的注销下线 3. 刷新执行器的信息，将实时的执行器地址列表更新到表中；xxl_job_group;

  1. 执行器的注册和心跳检测：接收执行器的/api/register请求，插入或者更新updateTime. xxl_job_registry表。

public ReturnT<String> registry(RegistryParam registryParam) {// valid// registryGroup=EXECUTOR, registryKey=appName, registryValue=http://127.0.0.1:5555if (!StringUtils.hasText(registryParam.getRegistryGroup()) || !StringUtils.hasText(registryParam.getRegistryKey()) || !StringUtils.hasText(registryParam.getRegistryValue())) {return new ReturnT<String>(ReturnT.FAIL_CODE, "Illegal Argument.");}/ async execute// 异步执行注册和心跳检测的逻辑:xxl_job_registryregistryOrRemoveThreadPool.execute(new Runnable() {@Overridepublic void run() {int ret = XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().registryUpdate(registryParam.getRegistryGroup(), registryParam.getRegistryKey(), registryParam.getRegistryValue(), new Date());if (ret < 1) {XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().registrySave(registryParam.getRegistryGroup(), registryParam.getRegistryKey(), registryParam.getRegistryValue(), new Date());// freshfreshGroupRegistryInfo(registryParam);}}});return ReturnT.SUCCESS;
}
  1. 执行器的注销下线：当执行器服务关机时，会调用对应的/api/registerRemove接口进行执行器下线；

public ReturnT<String> registryRemove(RegistryParam registryParam) {// valid 参数和注册参数一致if (!StringUtils.hasText(registryParam.getRegistryGroup()) || !StringUtils.hasText(registryParam.getRegistryKey()) || !StringUtils.hasText(registryParam.getRegistryValue())) {return new ReturnT<String>(ReturnT.FAIL_CODE, "Illegal Argument.");}// 异步执行下线逻辑registryOrRemoveThreadPool.execute(new Runnable() {@Overridepublic void run() {// 删除对应的 xxl_job_registry 记录int ret = XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().registryDelete(registryParam.getRegistryGroup(), registryParam.getRegistryKey(), registryParam.getRegistryValue());if (ret > 0) {// freshfreshGroupRegistryInfo(registryParam);}}});return ReturnT.SUCCESS;
}
  1. 定时刷新执行器情况，并更新到xxl_job_group.address_list字段

每30秒检测一次执行器注册情况, 将超过90秒的执行器删除，将更新时间在90秒之内的更新到执行字段中。

registryMonitorThread = new Thread(new Runnable() {@Overridepublic void run() {while (!toStop) {try {// 查询自动注册的执行器List<XxlJobGroup> groupList = XxlJobAdminConfig.getAdminConfig().getXxlJobGroupDao().findByAddressType(0);if (groupList!=null && !groupList.isEmpty()) {// 移除超时下线节点 xxl_job_registry，超时时间为执行器注册(心跳)间隔的3倍；Dead_Timeout = 30 * 3;List<Integer> ids = XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().findDead(RegistryConfig.DEAD_TIMEOUT, new Date());if (ids!=null && ids.size()>0) {XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().removeDead(ids);}// 刷新在线的机器（执行器地址）HashMap<String, List<String>> appAddressMap = new HashMap<String, List<String>>();List<XxlJobRegistry> list = XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().findAll(RegistryConfig.DEAD_TIMEOUT, new Date());if (list != null) {for (XxlJobRegistry item: list) {if (RegistryConfig.RegistType.EXECUTOR.name().equals(item.getRegistryGroup())) {String appname = item.getRegistryKey();List<String> registryList = appAddressMap.get(appname);if (registryList == null) {registryList = new ArrayList<String>();}if (!registryList.contains(item.getRegistryValue())) {registryList.add(item.getRegistryValue());}appAddressMap.put(appname, registryList);}}}// fresh group addressfor (XxlJobGroup group: groupList) {List<String> registryList = appAddressMap.get(group.getAppname());String addressListStr = null;if (registryList!=null && !registryList.isEmpty()) {Collections.sort(registryList);StringBuilder addressListSB = new StringBuilder();for (String item:registryList) {addressListSB.append(item).append(",");}addressListStr = addressListSB.toString();addressListStr = addressListStr.substring(0, addressListStr.length()-1);}group.setAddressList(addressListStr);group.setUpdateTime(new Date());// 将执行器地址列表自动更新到表中的对应字段 xxl_job_groupXxlJobAdminConfig.getAdminConfig().getXxlJobGroupDao().update(group);}}} catch (Exception e) {if (!toStop) {logger.error(">>>>>>>>>>> xxl-job, job registry monitor thread error:{}", e);}}try {// 每30秒检测一次执行器注册情况TimeUnit.SECONDS.sleep(RegistryConfig.BEAT_TIMEOUT);} catch (InterruptedException e) {if (!toStop) {logger.error(">>>>>>>>>>> xxl-job, job registry monitor thread error:{}", e);}}}logger.info(">>>>>>>>>>> xxl-job, job registry monitor thread stop");}
});
registryMonitorThread.setDaemon(true);
registryMonitorThread.setName("xxl-job, admin JobRegistryMonitorHelper-registryMonitorThread");
registryMonitorThread.start();

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.xdnf.cn/news/14922.html

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

Ps：OpenColorIO 设置

Ps：OpenColorIO 设置

Ps菜单&#xff1a;编辑/OpenColorIO 设置 Edit/OpenColorIO Settings 在专业的图像编辑和色彩管理工作流程中&#xff0c;准确的色彩呈现和转换至关重要。OpenColorIO&#xff08;OCIO&#xff09; 是一种开源的色彩管理框架&#xff0c;广泛应用于影视、动画和视觉特效行业。…
阅读更多...
如何抓取某大学网站专业录取分数

如何抓取某大学网站专业录取分数

当我们在浏览器中浏览网页时&#xff0c;网页上显示的数据实际上已经被加载到浏览器内存中&#xff0c;只是以一种可视化的方式呈现出来。那么是否有一种简便的方法可以将这些数据从网页中提取出来&#xff0c;并保存为表格格式呢&#xff1f; 这是某大学的专业分数录取情况数…
阅读更多...
举例理解LSM-Tree，LSM-Tree和B+Tree的比较

举例理解LSM-Tree，LSM-Tree和B+Tree的比较

写操作 write1&#xff1a;WAL 把操作同步到磁盘中WAL做备份&#xff08;追加写、性能极高&#xff09; write2&#xff1a;Memtable 完成WAL后将(k,v)数据写入内存中的Memtable&#xff0c;Memtable的数据结构一般是跳表或者红黑树 内存内采用这种数据结构一方面支持内存…
阅读更多...
JAVA开源项目 微服务在线教育系统 计算机毕业设计

JAVA开源项目 微服务在线教育系统 计算机毕业设计

博主说明&#xff1a;本文项目编号 T 060 &#xff0c;文末自助获取源码 \color{red}{T060&#xff0c;文末自助获取源码} T060&#xff0c;文末自助获取源码 目录 一、系统介绍二、演示录屏三、启动教程四、功能截图五、文案资料5.1 选题背景5.2 国内外研究现状5.3 可行性分析…
阅读更多...
深入浅出《钉钉AI》产品体验报告

深入浅出《钉钉AI》产品体验报告

1. 引言 随着人工智能技术的迅猛发展&#xff0c;企业协同办公领域迎来了新的变革。钉钉作为阿里巴巴集团旗下的企业级通讯与协同办公平台&#xff0c;推出了钉钉AI助理&#xff0c;旨在提高工作效率&#xff0c;优化用户体验。本报告将对钉钉AI助理进行全面的产品体验分析&am…
阅读更多...
揭开基础动销方案的神秘面纱

揭开基础动销方案的神秘面纱

在如今竞争激烈的市场大环境下&#xff0c;产品实现有效动销可谓是企业生存发展的关键所在。而基础动销方案&#xff0c;正是推动产品销售的重要利器。 基础动销方案到底是什么呢&#xff1f;它指的是企业为促进产品销售&#xff0c;运用一系列营销手段和策略&#xff0c;提升产…
阅读更多...
YOLO v5 Series - Image Comparison

YOLO v5 Series - Image Comparison

图像相似度 Image Similarity 图片差异度 Image Dissimilaritypuzzle-diff pacman -S autoconf automake base-devel libtool pacman -S mingw-w64-x86_64-libgdautogen /opt/admin/libpuzzle>./configure configure: loading site script /etc/config.site che…
阅读更多...
sqli—labs靶场 5-8关 （每日4关练习）持续更新！！！

sqli—labs靶场 5-8关 （每日4关练习）持续更新！！！

Less-5 上来先进行查看是否有注入点&#xff0c;判断闭合方式&#xff0c;查询数据列数&#xff0c;用union联合注入查看回显位&#xff0c;发现到这一步的时候&#xff0c;和前四道题不太一样了&#xff0c;竟然没有回显位&#xff1f;&#xff1f;&#xff1f; 我们看一下源…
阅读更多...
InnoDB引擎

InnoDB引擎

6.1 逻辑存储结构 InnoDB的逻辑存储结构如下图所示: 6.2 架构 6.2.1 概述 MySQL5.5 版本开始&#xff0c;默认使用InnoDB存储引擎&#xff0c;它擅长事务处理&#xff0c;具有崩溃恢复特性&#xff0c;在日常开发中使用非常广泛。下面是InnoDB架构图&#xff0c;左侧为内存结…
阅读更多...
C#与C++交互开发系列（二十二）：跨进程通信之使用基于HTTP协议的REST风格的API

C#与C++交互开发系列（二十二）：跨进程通信之使用基于HTTP协议的REST风格的API

1. 前言 REST API&#xff08;Representational State Transfer Application Programming Interface&#xff09;是一种基于HTTP协议的通信方式&#xff0c;广泛用于网络服务和分布式应用程序之间的通信。通过REST API&#xff0c;可以让C#和C应用程序进行跨进程、甚至跨平台的…
阅读更多...
想让三维模型与实时视频融合？这款软件值得一试

想让三维模型与实时视频融合？这款软件值得一试

视频融合&#xff0c;是指将视频数据投影到地理特征表面&#xff0c;并通过相应姿态参数控制投影效果的一种三维展示方式&#xff0c;实现了三维模型与实时视频的融合。 四维轻云是一款轻量化的地理空间数据管理云平台&#xff0c;支持地理空间数据的在线管理、编辑以及分享。…
阅读更多...
汉化版WinHex和CFF Explorer下载及程序脱壳后修复，重建引入表，修改程序PE文件（附下载链接）

汉化版WinHex和CFF Explorer下载及程序脱壳后修复，重建引入表，修改程序PE文件（附下载链接）

前言 现有一个加壳程序&#xff0c;要求对程序脱壳&#xff0c;需要修复脱壳后的程序 使用PEiD查壳&#xff0c;显示为NsPack 1.4 -> Liuxingping [Overlay] * 先定位程序的OEP&#xff0c;使用od打开程序&#xff0c;看到有压入栈的操作 进行查找&#xff0c;查找命令序列…
阅读更多...
STM32F407简单驱动步进电机（标准库）

STM32F407简单驱动步进电机（标准库）

配置 单片机型号&#xff1a;STM32F104ZGT6 步进电机&#xff1a;YK28HB40-01A 驱动器&#xff1a;YKD2204M-Plus 接线方式&#xff1a; pu&#xff1a;接对应的产生PWM的引脚&#xff0c;这里接PF9&#xff0c;对应TIM14_CH1通道&#xff01; pu-&#xff1a;接单片机的G…
阅读更多...
linux-DNS解析

linux-DNS解析

dns解析 dns&#xff1a;域名系统&#xff0c;将域名和ip地址互相映射的一个分布式的数据库&#xff0c;方便用户访问互联网。 ip地址&#xff1a;是所有设备和网站在互联网上的唯一地址&#xff0c;通信一定是ip和ip之间的通信。 dns解析&#xff1a;根据域名在互联网当中找…
阅读更多...
光伏电站容量计算方法科普

光伏电站容量计算方法科普

光伏电站的容量计算是设计和评估光伏系统性能的关键步骤。通过了解光伏电站的容量&#xff0c;我们可以预估其发电量&#xff0c;优化系统设计&#xff0c;并确保系统能满足电力需求。本文将详细介绍几种常见的光伏电站容量计算方法&#xff0c;并特别介绍小程序“光伏一点通”…
阅读更多...
采集opc da 转 profinet IO项目案例

采集opc da 转 profinet IO项目案例

目录 1 案例说明 1 2 VFBOX网关工作原理 1 3 应用条件 2 4 查看OPC DA服务器的相关参数 2 5 配置网关采集opc da数据 4 6 用profinet IO协议转发数据 6 7 在服务器上运行仰科OPC DA采集软件 9 8 案例总结 11 1 案例说明 在OPC DA服务器上运行OPC DA client软件查看OPC DA服务…
阅读更多...
循环矩阵和BCCB矩阵与向量乘积的快速计算——矩阵向量乘积与频域乘积之间的转换

循环矩阵和BCCB矩阵与向量乘积的快速计算——矩阵向量乘积与频域乘积之间的转换

目录 循环矩阵循环矩阵的定义特征值与特征向量循环矩阵的对角化 循环矩阵与向量的乘积 BCCB矩阵BCCB矩阵的定义BCCB矩阵的对角化BCCB 矩阵与向量的乘积BCCB 矩阵与向量乘积的实现 总结 循环矩阵&#xff08;Circulant Matrix&#xff09;和块循环对称矩阵&#xff08;Block Cir…
阅读更多...
（动画版)排序算法 -希尔排序

（动画版)排序算法 -希尔排序

文章目录 1. 希尔排序&#xff08;Shellsort&#xff09;1.1 简介1.2 希尔排序的步骤1.3 希尔排序的C实现1.4 时间复杂度1.5 空间复杂度1.6 希尔排序动画 1. 希尔排序&#xff08;Shellsort&#xff09; 1.1 简介 希尔排序&#xff08;Shells Sort&#xff09;&#xff0c;又…
阅读更多...
蓝桥杯每日真题 - 第7天

蓝桥杯每日真题 - 第7天

题目&#xff1a;&#xff08;爬山&#xff09; 题目描述&#xff08;X届 C&C B组X题&#xff09; 解题思路&#xff1a; 前缀和构造&#xff1a;为了高效地计算子数组的和&#xff0c;我们可以先构造前缀和数组 a&#xff0c;其中 a[i] 表示从第 1 个元素到第 i 个元素的…
阅读更多...
socketcan-goloang

socketcan-goloang

模拟接收 模拟发送 package mainimport ("context""fmt""go.einride.tech/can""go.einride.tech/can/pkg/candevice""go.einride.tech/can/pkg/socketcan" )func main() {// linux系统设置// sudo ip link add dev can0 ty…
阅读更多...
最新文章

Copyright @ 2022~2023