xxl-job--01--简介

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档

文章目录

  • 1.xxl-job
    • 1. 1 发展历史
    • 1.2 XXL-JOB的系统架构
    • 1.3 xxl-job与其他框架对比
  • 2. XXL-JOB的使用
    • 2.1 准备工作- 配置调度中心
        • XXL-JOB的数据表
    • 2.2 配置执行器
      • 1 引入依赖包：
      • 2 配置配置项
      • 3 创建XxlJobConfig.java
    • 2.3 配置可视化界面
      • 1. 配置数据库路径以及其他信息
      • 2. 配置登陆账号密码
      • 3. 启动项目：XxlJobAdminApplication.java
      • 4. 登陆可视化界面 地址： http://10.4.7.214:8080/xxl-job-admin/jobinfo
    • 2.4 开发第一个任务 Hello,world
      • 1.首先在配置好了执行器的微服务下创建定时任务代码：
      • 2.依次启动微服务项目(Eureka,config…等)
      • 3.启动调度中心： XxlJobAdminApplication.java
      • 4.登录调度中心，输入账号密码，然后配置执行器
      • 5.进入==任务管理==页面
      • 6.点击新增任务,配置对应相关参数
      • 7.返回任务管理页面
      • 8.如果点击执行任务，则会只执行一次
      • 9.如果点击日志，则跳转至调度日志页面
      • 10.如果点击启动，则直接==启动定时任务(按照Corn表达式定时执行任务==)，并且启动按钮会变成停止按钮
      • 11.如果点击编辑，则进入定时任务的更新页面
    • 2.5 运行报表

1.xxl-job

  • XXL-JOB是一个分布式任务调度平台，其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线，开箱即用。

1. 1 发展历史

在这里插入图片描述

源码地址： https://github.com/xuxueli/xxl-job
中文文档：https://www.xuxueli.com/xxl-job/

在这里插入图片描述

1.2 XXL-JOB的系统架构

  • ​ xxl-job框架主要用于处理分布式的定时任务，其主要由调度中心和执行器组成。
    在这里插入图片描述

调度模块（调度中心）：

  • 负责管理调度信息，按照调度配置发出调度请求，自身不承担业务代码。调度系统与任务解耦，提高了系统可用性和稳定性，同时调度系统性能不再受限于任务模块；
  • 支持可视化、简单且动态的管理调度信息，包括任务新建，更新，删除，GLUE开发和任务报警等，所有上述操作都会实时生效，同时支持监控调度结果以及执行日志，支持执行器Failover。

执行模块（执行器）：

  • 负责接收调度请求并执行任务逻辑。任务模块专注于任务的执行等操作，开发和维护更加简单和高效；
  • 接收“调度中心”的执行请求、终止请求和日志请求等。

调度中心和执行器两个模块分开部署，相互分离，两者之间通过RPC进行通信，其中调度中心主要是提供一个平台，管理调度信息，发送调度请求，自己不承担业务代码，而执行器接受调度中心的调度执行业务逻辑。
在这里插入图片描述

1.3 xxl-job与其他框架对比

分布式定时任务调度的框架：quartz、elastic-job、xxl-job

在这里插入图片描述
在这里插入图片描述

2. XXL-JOB的使用

2.1 准备工作- 配置调度中心

下载官方源码

  • 将项目中 /xxl-job/doc/db/ 目录下的 tables_xxl_job.sql 的数据库表导入数据库
XXL-JOB的数据表

在这里插入图片描述

在这里插入图片描述

2.2 配置执行器

1 引入依赖包：

     <!-- xxl-job-core -->
        <dependency>
            <groupId>com.cdmtc</groupId>
            <artifactId>xxl-job-core</artifactId>
            <version>2.0.2</version>
        </dependency>

2 配置配置项

在这里插入图片描述
XXL-JOB执行器的相关配置项的意义，如下所示：

  • xxl.job.admin.addresses
    调度中心的部署地址。若调度中心采用集群部署，存在多个地址，则用逗号分隔。执行器将会使用该地址进行”执行器心跳注册”和”任务结果回调”。

  • xxl.job.executor.appname
    执行器的应用名称，它是执行器心跳注册的分组依据。

  • xxl.job.executor.ip
    执行器的IP地址，用于”调度中心请求并触发任务”和”执行器注册”。执行器IP默认为空，表示自动获取IP。多网卡时可手动设置指定IP，手动设置IP时将会绑定Host。

  • xxl.job.executor.port
    执行器的端口号，默认值为9999。单机部署多个执行器时，注意要配置不同的执行器端口。

  • xxl.job.accessToken
    执行器的通信令牌，非空时启用。

  • xxl.job.executor.logpath
    执行器输出的日志文件的存储路径，需要拥有该路径的读写权限。

  • xxl.job.executor.logretentiondays
    执行器日志文件的定期清理功能，指定日志保存天数，日志文件过期自动删除。限制至少保存3天，否则功能不生效。

3 创建XxlJobConfig.java

package com.cdmtc.config;

import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * xxl-job config
 *
 * @author xuxueli 2017-04-28
 */
@Configuration
public class XxlJobConfig {
    private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);

    @Value("${record.xxl.job.admin.addresses}")
    private String adminAddresses;

    @Value("${record.xxl.job.executor.appname}")
    private String appName;

    @Value("${record.xxl.job.executor.ip}")
    private String ip;

    @Value("${record.xxl.job.executor.port}")
    private int port;

    @Value("${record.xxl.job.accessToken}")
    private String accessToken;

    @Value("${record.xxl.job.executor.logpath}")
    private String logPath;

    @Value("${record.xxl.job.executor.logretentiondays}")
    private int logRetentionDays;


    @Bean(initMethod = "start", destroyMethod = "destroy")
    public XxlJobSpringExecutor xxlJobExecutor() {
        logger.info(">>>>>>>>>>> xxl-job config init.");
        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
        xxlJobSpringExecutor.setAppName(appName);
        xxlJobSpringExecutor.setIp(ip);
        xxlJobSpringExecutor.setPort(port);
        xxlJobSpringExecutor.setAccessToken(accessToken);
        xxlJobSpringExecutor.setLogPath(logPath);
        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);

        return xxlJobSpringExecutor;
    }

    /**
     * 针对多网卡、容器内部署等情况，可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP；
     *
     *      1、引入依赖：
     *          <dependency>
     *             <groupId>org.springframework.cloud</groupId>
     *             <artifactId>spring-cloud-commons</artifactId>
     *             <version>${version}</version>
     *         </dependency>
     *
     *      2、配置文件，或者容器启动变量
     *          spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.'
     *
     *      3、获取IP
     *          String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();
     */


}

XxlJobConfig配置类有两点需要注意：

  1. 组件扫描
    第2行使用@ComponentScan注解，扫描com.example.demo.jobhandler包，将其中的任务处理器加载至Spring容器。
  2. 获取执行器实例
    第29行的xxlJobExecutor()方法会实例化一个XXL-JOB执行器对象，执行器初始化时调用它的start()方法

2.3 配置可视化界面

1. 配置数据库路径以及其他信息

在这里插入图片描述

2. 配置登陆账号密码

  • 可修改为其他账号密码

在这里插入图片描述

3. 启动项目：XxlJobAdminApplication.java

4. 登陆可视化界面 地址： http://10.4.7.214:8080/xxl-job-admin/jobinfo

  • 【可先等配置好了执行器再进行登陆，端口可自行配置或修改，默认是8080,这里演示的端口号为8888】
    在这里插入图片描述

2.4 开发第一个任务 Hello,world

1.首先在配置好了执行器的微服务下创建定时任务代码：

在这里插入图片描述

2.依次启动微服务项目(Eureka,config…等)

3.启动调度中心： XxlJobAdminApplication.java

4.登录调度中心，输入账号密码，然后配置执行器

在这里插入图片描述
在这里插入图片描述

5.进入任务管理页面

在这里插入图片描述

6.点击新增任务,配置对应相关参数

在这里插入图片描述

7.返回任务管理页面

在这里插入图片描述

8.如果点击执行任务，则会只执行一次

在这里插入图片描述

9.如果点击日志，则跳转至调度日志页面

在这里插入图片描述

10.如果点击启动，则直接启动定时任务(按照Corn表达式定时执行任务)，并且启动按钮会变成停止按钮

在这里插入图片描述

  • 如果没有点击停止按钮的话，则会一直是启动状态，如果点击了停止按钮，则定时任务停止，Corn表达式不再生效；

11.如果点击编辑，则进入定时任务的更新页面

在这里插入图片描述

  • 如果点击删除，则直接删除此定时任务配置；

  • 如果点击执行器，则展示该执行器下的对应定时任务。

  • 任务描述和JobHandler则为搜索条件，对定时任务配置进行搜索；

2.5 运行报表

  • 可视化直观展示定时任务运行情况
  • 图示如下：
    在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

一个脚本两步计算材料Raman谱（附数据处理和绘图脚本）

一个脚本两步计算材料Raman谱（附数据处理和绘图脚本）

在以往推送中已经介绍了相当多的计算材料Raman的方法&#xff0c;使用的软件主要为Phonopy-Spectroscopy&#xff0c;相关软件还有vasp&#xff0c;phonopy&#xff0c;phono3py等。 Phonopy-Spectroscopy计算材料红外和Raman光谱 Phonopy-Spectroscopy 计算红外和拉曼光谱 也…
阅读更多...
Github配置SSH免密认证

Github配置SSH免密认证

以Ubuntu Server为例 生成SSH ssh-keygen -t ed25519 -C "your_emailexample.com" 如果系统不支持Ed25519算法&#xff0c;使用旧的命令&#xff1a; ssh-keygen -t rsa -b 4096 -C "your_emailexample.com" 根据提示生成公私钥文件&#xff0c;记下位置…
阅读更多...
深度学习_17_丢弃法调整过拟合

深度学习_17_丢弃法调整过拟合

除了权重衰退法调整过拟合&#xff0c;还有丢弃法调整模型得过拟合现象 过拟合&#xff1a; 丢弃法如果直接丢弃会导致新期望的不确定性&#xff0c;为了防止这个不确定被模型学到&#xff0c;所以要保证丢弃后的期望和丢弃前的期望一样&#xff08;个人观点&#xff09; 顾…
阅读更多...
微服务笔记

微服务笔记

什么是微服务? 微服务是一种经过良好架构设计的分布式架构方案&#xff0c;微服务架构特征: 1.单一职责:微服务拆分粒度更小&#xff0c;每一个服务都对应唯一的业务能力&#xff0c;做到单一职责&#xff0c;避免重复业发。 2.面向服务:微服务对外暴露业务接口 3.自治:团…
阅读更多...
基于Springboot的人事管理系统 （有报告）。Javaee项目，springboot项目。

基于Springboot的人事管理系统 （有报告）。Javaee项目，springboot项目。

演示视频&#xff1a; 基于Springboot的人事管理系统 &#xff08;有报告&#xff09;。Javaee项目&#xff0c;springboot项目。 项目介绍&#xff1a; 采用M&#xff08;model&#xff09;V&#xff08;view&#xff09;C&#xff08;controller&#xff09;三层体系结构&am…
阅读更多...
数据结构与算法学习【算法思想之二分法基础】

数据结构与算法学习【算法思想之二分法基础】

文章目录 数据结构与算法学习【算法思想之二分查找基础】本文学习目标或巩固的知识点 最基础的二分查找&#x1f7e2;通过题目可知题解结果验证 数据结构与算法学习【算法思想之二分查找基础】 本文学习目标或巩固的知识点 学习二分法类题目 巩固基础的二分法 提前说明&#…
阅读更多...
Matlab 机器人工具箱 Link类

Matlab 机器人工具箱 Link类

文章目录 1 Link类1.1 机械臂Link类1.2 构造函数1.3 信息/显示方法1.4 转换方法1.5 操作方法1.6 测试方法1.7 重载操作1.8 属性(读/写)1.9 例子2 Link.Link2.1 创建机器人连杆对象2.2 OPTIONS2.3 注意2.4 旧语法2.5 例子3 Link的其他函数3.1 Link.A3.2 Link.char3.3 Link.displ…
阅读更多...
ABAP - SALV教程10 添加可编辑checkbox列

ABAP - SALV教程10 添加可编辑checkbox列

几乎所有的功能报表都会有那么一个选择列&#xff0c;问了业务顾问&#xff0c;业务顾问说是用户不习惯使用报表原生的选择模式。效果图SALV的选择列是通过将列设置成checkbox_hotspot样式&#xff0c;注册单击事件完成勾选功能的。完成步骤 将SEL列设置成checkbox_hotspot样式…
阅读更多...
递推算法（c++）

递推算法（c++）

递推可以说是递归反过来的一种算法&#xff0c;递归是从后往前倒着算&#xff0c;递推是从前往后正着算。 统计每个月兔子的总数 题目描述 有一对兔子&#xff0c;从出生后第3个月起每个月都生一对兔子&#xff0c;一对小兔子长到第三个月后每个月又生一对兔子&#xff0c; …
阅读更多...
网络编程（IP、端口、协议、UDP、TCP）【详解】

网络编程（IP、端口、协议、UDP、TCP）【详解】

目录 1.什么是网络编程&#xff1f; 2.基本的通信架构 3.网络通信三要素 4.UDP通信-快速入门 5.UDP通信-多发多收 6.TCP通信-快速入门 7.TCP通信-多发多收 8.TCP通信-同时接收多个客户端 9.TCP通信-综合案例 1.什么是网络编程&#xff1f; 网络编程是可以让设…
阅读更多...
Cloud整合Zookeeper代替Eureka

Cloud整合Zookeeper代替Eureka

微服务间通信重构与服务治理笔记-CSDN博客 Zookeeper是一个分布式协调工具,可以实现注册中心功能 安装Zookeeper 随便 就用最新版本吧 进入Zookeeper 包目录 cd /usr/local/develop/ 解压 tar -zxvf apache-zookeeper-3.9.1-bin.tar.gz -C /usr/local/develop 进入配置文件…
阅读更多...
electron nsis 安装包 window下任务栏无法正常固定与取消固定 Pin to taskbar

electron nsis 安装包 window下任务栏无法正常固定与取消固定 Pin to taskbar

问题 win10系统下&#xff0c;程序任务栏在固定后取消固定&#xff0c;展示的程序内容异常。 排查 1.通过论坛查询&#xff0c;应该是与app的api setAppUserModelId 相关 https://github.com/electron/electron/issues/3303 2.electron-builder脚本 electron-builder…
阅读更多...
VUE CLI3项目搭建 ESLint配置

VUE CLI3项目搭建 ESLint配置

VUE项目框架配置 一、工具准备 Node.js安装 安装方法&#xff1a;点击查看WebStorm安装 下载地址&#xff1a;点击查看 二、环境准备 镜像准备 1.查看代理&#xff1a;npm get registry 2.设置淘宝镜像 2.1临时使用. npm --registry https://registry.npm.taobao.org ins…
阅读更多...
vue 使用vue-scroller 列表滑动到底部加载更多数据

vue 使用vue-scroller 列表滑动到底部加载更多数据

安装插件 npm install vue-scroller -dmain.js import VueScroller from vue-scroller Vue.use(VueScroller)<template><div class"wrap"><div class"footer"><div class"btn" click"open true">新增</d…
阅读更多...
LeetCode --- 三数之和

LeetCode --- 三数之和

题目描述 三数之和 代码解析 暴力 在做这一道题的时候&#xff0c;脑海里先想出来的是暴力方法&#xff0c;一次排序&#xff0c;将这个数组变为有序的&#xff0c;再通过三次for循环来寻找满足条件的数字&#xff0c;然后将符合条件的数组与之前符合条件的数组进行一一对比…
阅读更多...
Matlab 机器人工具箱 运动学

Matlab 机器人工具箱 运动学

文章目录 R.fkine()R.ikine()R.ikine6s()R.jacob0、R.jacobn、R.jacob_dotjtrajctraj参考链接官网：Robotics Toolbox - Peter Corke R.fkine() 正运动学，根据关节坐标求末端执行器位姿 mdl_puma560; % 加载puma560模型 qz % 零角度 qr
阅读更多...
Spring学习笔记（六)利用Spring的jdbc实现学生管理系统的用户登录功能

Spring学习笔记（六)利用Spring的jdbc实现学生管理系统的用户登录功能

一、案例分析 本案例要求学生在控制台输入用户名密码&#xff0c;如果用户账号密码正确则显示用户所属班级&#xff0c;如果登录失败则显示登录失败。 &#xff08;1&#xff09;为了存储学生信息&#xff0c;需要创建一个数据库。 &#xff08;2&#xff09;为了程序连接数…
阅读更多...
备战蓝桥杯Day21 - 堆排序的内置模块+topk问题

备战蓝桥杯Day21 - 堆排序的内置模块+topk问题

一、内置模块 在python中&#xff0c;堆排序已经设置好了内置模块&#xff0c;不想自己写的话可以使用内置模块&#xff0c;真的很方便&#xff0c;但是堆排序算法的底层逻辑最好还是要了解并掌握一下的。 使用heapq模块的heapify()函数将列表转换为堆&#xff0c;然后使用he…
阅读更多...
CVPR2023 RIFormer, 无需TokenMixer也能达成SOTA性能的极简ViT架构

CVPR2023 RIFormer, 无需TokenMixer也能达成SOTA性能的极简ViT架构

编辑 | Happy 首发 | AIWalker 链接 | https://mp.weixin.qq.com/s/l3US8Dsd0yNC19o7B1ZBgw project, paper, code Token Mixer是ViT骨干非常重要的组成成分&#xff0c;它用于对不同空域位置信息进行自适应聚合&#xff0c;但常规的自注意力往往存在高计算复杂度与高延迟问题…
阅读更多...
记录一次架构优化处理性能从3千-＞3万

记录一次架构优化处理性能从3千-＞3万

0.背景 优化Kafka消费入Es&#xff0c;适配600台设备上报数据&#xff0c;吞吐量到达2万每秒 1.环境配置 2.压测工具 3.未优化之前的消费逻辑 4.优化之后的消费流程 5.多线程多ESclient 6.修改ES配置&#xff0c;增加kafka分区&#xff0c;增加线程&#xff0c;提升吞吐量 7.…
阅读更多...
最新文章

Copyright @ 2022~2023