xxl-job集成SpringBoot

news/2024/7/8 6:37:38 标签: spring boot, 后端, java

安装xxl-job客户端一般有很多方式，我这里给大家提供两种安装方式，包含里面的各项配置等等。

前期需要准备好MySQL数据库。复制SQL到数据库里面。

#
# XXL-JOB v2.4.2-SNAPSHOT
# Copyright (c) 2015-present, xuxueli.

CREATE database if NOT EXISTS `xxl_job` default character set utf8mb4 collate utf8mb4_unicode_ci;
use `xxl_job`;

SET NAMES utf8mb4;

CREATE TABLE `xxl_job_info` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `job_group` int(11) NOT NULL COMMENT '执行器主键ID',
  `job_desc` varchar(255) NOT NULL,
  `add_time` datetime DEFAULT NULL,
  `update_time` datetime DEFAULT NULL,
  `author` varchar(64) DEFAULT NULL COMMENT '作者',
  `alarm_email` varchar(255) DEFAULT NULL COMMENT '报警邮件',
  `schedule_type` varchar(50) NOT NULL DEFAULT 'NONE' COMMENT '调度类型',
  `schedule_conf` varchar(128) DEFAULT NULL COMMENT '调度配置，值含义取决于调度类型',
  `misfire_strategy` varchar(50) NOT NULL DEFAULT 'DO_NOTHING' COMMENT '调度过期策略',
  `executor_route_strategy` varchar(50) DEFAULT NULL COMMENT '执行器路由策略',
  `executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',
  `executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',
  `executor_block_strategy` varchar(50) DEFAULT NULL COMMENT '阻塞处理策略',
  `executor_timeout` int(11) NOT NULL DEFAULT '0' COMMENT '任务执行超时时间，单位秒',
  `executor_fail_retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '失败重试次数',
  `glue_type` varchar(50) NOT NULL COMMENT 'GLUE类型',
  `glue_source` mediumtext COMMENT 'GLUE源代码',
  `glue_remark` varchar(128) DEFAULT NULL COMMENT 'GLUE备注',
  `glue_updatetime` datetime DEFAULT NULL COMMENT 'GLUE更新时间',
  `child_jobid` varchar(255) DEFAULT NULL COMMENT '子任务ID，多个逗号分隔',
  `trigger_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '调度状态：0-停止，1-运行',
  `trigger_last_time` bigint(13) NOT NULL DEFAULT '0' COMMENT '上次调度时间',
  `trigger_next_time` bigint(13) NOT NULL DEFAULT '0' COMMENT '下次调度时间',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `xxl_job_log` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `job_group` int(11) NOT NULL COMMENT '执行器主键ID',
  `job_id` int(11) NOT NULL COMMENT '任务，主键ID',
  `executor_address` varchar(255) DEFAULT NULL COMMENT '执行器地址，本次执行的地址',
  `executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',
  `executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',
  `executor_sharding_param` varchar(20) DEFAULT NULL COMMENT '执行器任务分片参数，格式如 1/2',
  `executor_fail_retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '失败重试次数',
  `trigger_time` datetime DEFAULT NULL COMMENT '调度-时间',
  `trigger_code` int(11) NOT NULL COMMENT '调度-结果',
  `trigger_msg` text COMMENT '调度-日志',
  `handle_time` datetime DEFAULT NULL COMMENT '执行-时间',
  `handle_code` int(11) NOT NULL COMMENT '执行-状态',
  `handle_msg` text COMMENT '执行-日志',
  `alarm_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '告警状态：0-默认、1-无需告警、2-告警成功、3-告警失败',
  PRIMARY KEY (`id`),
  KEY `I_trigger_time` (`trigger_time`),
  KEY `I_handle_code` (`handle_code`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `xxl_job_log_report` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `trigger_day` datetime DEFAULT NULL COMMENT '调度-时间',
  `running_count` int(11) NOT NULL DEFAULT '0' COMMENT '运行中-日志数量',
  `suc_count` int(11) NOT NULL DEFAULT '0' COMMENT '执行成功-日志数量',
  `fail_count` int(11) NOT NULL DEFAULT '0' COMMENT '执行失败-日志数量',
  `update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `i_trigger_day` (`trigger_day`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `xxl_job_logglue` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `job_id` int(11) NOT NULL COMMENT '任务，主键ID',
  `glue_type` varchar(50) DEFAULT NULL COMMENT 'GLUE类型',
  `glue_source` mediumtext COMMENT 'GLUE源代码',
  `glue_remark` varchar(128) NOT NULL COMMENT 'GLUE备注',
  `add_time` datetime DEFAULT NULL,
  `update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `xxl_job_registry` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `registry_group` varchar(50) NOT NULL,
  `registry_key` varchar(255) NOT NULL,
  `registry_value` varchar(255) NOT NULL,
  `update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`),
  KEY `i_g_k_v` (`registry_group`,`registry_key`,`registry_value`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `xxl_job_group` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `app_name` varchar(64) NOT NULL COMMENT '执行器AppName',
  `title` varchar(12) NOT NULL COMMENT '执行器名称',
  `address_type` tinyint(4) NOT NULL DEFAULT '0' COMMENT '执行器地址类型：0=自动注册、1=手动录入',
  `address_list` text COMMENT '执行器地址列表，多地址逗号分隔',
  `update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `xxl_job_user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `username` varchar(50) NOT NULL COMMENT '账号',
  `password` varchar(50) NOT NULL COMMENT '密码',
  `role` tinyint(4) NOT NULL COMMENT '角色：0-普通用户、1-管理员',
  `permission` varchar(255) DEFAULT NULL COMMENT '权限：执行器ID列表，多个逗号分割',
  PRIMARY KEY (`id`),
  UNIQUE KEY `i_username` (`username`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `xxl_job_lock` (
  `lock_name` varchar(50) NOT NULL COMMENT '锁名称',
  PRIMARY KEY (`lock_name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

INSERT INTO `xxl_job_group`(`id`, `app_name`, `title`, `address_type`, `address_list`, `update_time`) VALUES (1, 'xxl-job-executor-sample', '示例执行器', 0, NULL, '2018-11-03 22:21:31' );
INSERT INTO `xxl_job_info`(`id`, `job_group`, `job_desc`, `add_time`, `update_time`, `author`, `alarm_email`, `schedule_type`, `schedule_conf`, `misfire_strategy`, `executor_route_strategy`, `executor_handler`, `executor_param`, `executor_block_strategy`, `executor_timeout`, `executor_fail_retry_count`, `glue_type`, `glue_source`, `glue_remark`, `glue_updatetime`, `child_jobid`) VALUES (1, 1, '测试任务1', '2018-11-03 22:21:31', '2018-11-03 22:21:31', 'XXL', '', 'CRON', '0 0 0 * * ? *', 'DO_NOTHING', 'FIRST', 'demoJobHandler', '', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2018-11-03 22:21:31', '');
INSERT INTO `xxl_job_user`(`id`, `username`, `password`, `role`, `permission`) VALUES (1, 'admin', 'e10adc3949ba59abbe56e057f20f883e', 1, NULL);
INSERT INTO `xxl_job_lock` ( `lock_name`) VALUES ( 'schedule_lock');

commit;

docker服务器安装xxl-job集成xxl-job

拉取指定版本：

docker pull xuxueli/xxl-job-admin:2.4.0

在根目录创建data文件夹，然后创建xxl-job文件夹，启用docker镜像，注意修改里面MySQL的账号密码，以及 xxl.job.accessToken，这个我们随机定义一串长字符串，主要用于调度时交互使用

    docker run -di -e PARAMS="--spring.datasource.url=jdbc:mysql://172.17.0.1:3306/xxl_job?Unicode=true&characterEncoding=UTF-8 --spring.datasource.username=root --spring.datasource.password=1111 --xxl.job.accessToken=aaaaaaaaaaaa.ddss.cccc" \
    -p 9001:8080 \
    -v /data/xxl-job:/data/applogs \
    --name xxl-job \
    --privileged=true \
    xuxueli/xxl-job-admin:2.4.0

完成以后我们开放服务器端口9001，然后使用http://服务器ip:9001/xxl-job-admin 进行访问，输入账号admin   密码 123456 即可

集成SpringBoot: 我们在本地搭建一个SpringBoot项目，使用本地项目连接服务器xxl-job进行调度。

<dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>2.4.1</version>
</dependency>
xxl.job:
    admin:
      #这个是我们的服务器xxl-job后台访问地址  
      addresses: http://服务器ip:9001/xxl-job-admin
    #这个就是服务器创建镜像时设置的 xxl.job.accessToken
    accessToken: aaaaaaaaaaaa.ddss.cccc
    executor:
      #这个是xxl-job管理后台（执行器管理）里面的AppName 名称
      appname: web-server
      #不填就是使用默认的自动录入 
      address: ""
      #不填就是使用默认的    
      ip: ""
      #指定使用9990进行调度任务通信
      port: 9990
      logpath: ""
      #日志只保存5天的    
      logretentiondays: 5

在项目里面创建一个类，使用xxlJob注解

java">package com.app.web.task;

import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class MyJobHandler{

    @XxlJob("demoJobHandler")
    public void execute(){
        log.info("任务调用成功啦，哈哈哈哈哈哈哈哈哈哈哈哈哈");
    }
}

由于我们是本地服务器连接测试服务器上面的xxl-job，所以这里的注入方式我们需要改成一个服务器能访问到我们本地端口9990的服务，我们将注册方式改为手动录入，并填入能访问我们本地服务的链接

点击任务管理，添加如下：

然后本地项目启动，点击执行任务，任务调度成功。。。。。。。。。。。

搭建xxl-job系统

本地搭建xxl-job项目本地服务启动，下载项目源码：https://github.com/xuxueli/xxl-job/,下载完成以后主要也是修改admin模块下面配置文件application.properties。修改里面数据库连接方式以及xxl.job.accessToken，打包项目然后启动服务即可。启动成功以后访问 http://127.0.0.1:9001/xxl-job-admin，注意端口一定要和本地xxl-job项目端口一致。

xxl.job:
    admin:
      #这个是我们的服务器xxl-job后台访问地址  
      addresses: http://服务器ip:9001/xxl-job-admin
    #这个就是服务器创建镜像时设置的 xxl.job.accessToken
    accessToken: aaaaaaaaaaaa.ddss.cccc
    executor:
      #这个是xxl-job管理后台（执行器管理）里面的AppName 名称
      appname: web-server
      #不填就是使用默认的自动录入 
      address: ""
      #不填就是使用默认的    
      ip: ""
      #小于等于0则自动获取；默认端口为9999，单机部署多个执行器时，注意要配置不同执行器端口
      port: 0
      logpath: ""
      #日志只保存5天的    
      logretentiondays: 5

最后各个参数详细解释如下，不明白的可以在看一下具体的

  • admin: addresses

    • 含义: 这是 XxlJob Admin 的地址，用于 XxlJob Executor 连接到 XxlJob Admin 进行注册和任务调度通信。
    • 示例: http://服务器ip:9001/xxl-job-admin
    • 作用: Executor 通过这个地址向 XxlJob Admin 注册，并从 Admin 处接收任务调度信息。

  • accessToken

    • 含义: 这是用于 Executor 与 Admin 之间通信的令牌，用来进行身份验证。
    • 示例: aaaaaaaaaaaa.ddss.cccc
    • 作用: 确保通信安全，只有持有正确令牌的 Executor 才能注册和与 Admin 通信。

  • executor: appname

    • 含义: 执行器的应用名称，通常在 XxlJob Admin 中用于区分不同的执行器实例。
    • 示例: web-server
    • 作用: 在 XxlJob Admin 中识别和管理该 Executor 实例。

  • executor: address

    • 含义: 手动指定 Executor 的地址。通常情况下可以留空，由系统自动获取。
    • 示例: ""
    • 作用: 允许手动指定 Executor 的地址，便于在某些特定网络环境下进行特殊配置。

  • executor: ip

    • 含义: 手动指定 Executor 的 IP 地址。通常情况下可以留空，由系统自动获取。
    • 示例: ""
    • 作用: 允许手动指定 Executor 的 IP 地址，便于在某些特定网络环境下进行特殊配置。

  • executor: port

    • 含义: Executor 监听的端口号。如果设置为 0 或不设置，则会自动选择一个端口（默认是 9999）。
    • 示例: 0
    • 作用: 在同一台机器上运行多个 Executor 实例时，需要设置不同的端口号避免冲突。

  • executor: logpath

    • 含义: 执行器日志的存放路径。
    • 示例: ""
    • 作用: 指定 Executor 生成的日志文件存放的目录。如果不设置，系统会使用默认路径。

  • executor: logretentiondays

    • 含义: 日志保留的天数。
    • 示例: 5
    • 作用: 指定日志文件保留的天数，超过这个天数的日志文件会被自动清理，避免日志文件占用过多磁盘空间。

http://www.niftyadmin.cn/n/5536697.html

相关文章

Spring Boot 2到3升级体验：解锁新特性与优势

Spring Boot 2到3升级体验：解锁新特性与优势

目录 Spring Boot 2到3升级体验&#xff1a;解锁新特性与优势一、升级背景与动机二、新特性概览1. Java版本提升2. Spring Framework 6支持3. 模块化支持增强4. Web框架更新5. 数据库访问技术更新 三、升级体验与案例分析1. 环境配置与依赖升级2. 代码迁移与调整3. 性能与启动速…
阅读更多...
论文阅读YOLO-World: Real-Time Open-Vocabulary Object Detection

论文阅读YOLO-World: Real-Time Open-Vocabulary Object Detection

核心&#xff1a; 开放词汇的实时的yolo检测器。重参数化的视觉语言聚合路径模块Re-parameterizable VisionLanguage Path Aggregation Network (RepVL-PAN)实时核心&#xff1a;轻量化的检测器离线词汇推理过程重参数化 方法 预训练方案&#xff1a;将实例注释重新定义为区域…
阅读更多...
DALL-E、Stable Diffusion 等 20+ 图像生成模型综述

DALL-E、Stable Diffusion 等 20+ 图像生成模型综述

二、任务场景 2.1. 无条件生成 无条件生成是指生成模型在生成图像时不受任何额外条件或约束的影响。模型从学习的数据分布中生成图像&#xff0c;而不需要关注输入条件。 2.2. 有条件生成 有条件生成是指生成模型在生成图像时受到额外条件或上下文的影响。这些条件可以是类别…
阅读更多...
超详细之IDEA上传项目到Gitee完整步骤

超详细之IDEA上传项目到Gitee完整步骤

1. 注册gitee 账号密码&#xff0c;gitee官网地址&#xff1a;Gitee官网&#xff0c;注册完成后&#xff0c;登录。 2. 创建仓库&#xff0c;在主页左下角有新建按钮&#xff0c;点击新建后会进入到此页面填写仓库信息。 3. 创建完成后复制仓库地址 4. 打开IntelliJ IDEA新建或…
阅读更多...
Java | Leetcode Java题解之第213题打家劫舍II

Java | Leetcode Java题解之第213题打家劫舍II

题目&#xff1a; 题解&#xff1a; class Solution {public int rob(int[] nums) {int length nums.length;if (length 1) {return nums[0];} else if (length 2) {return Math.max(nums[0], nums[1]);}return Math.max(robRange(nums, 0, length - 2), robRange(nums, 1,…
阅读更多...
开发者工具攻略：前端测试的极简指南

开发者工具攻略：前端测试的极简指南

前言 许多人存在一个常见的误区&#xff0c;认为测试只是测试工程师的工作。实际上&#xff0c;测试是整个开发团队的责任&#xff0c;每个人都应该参与到测试过程中。 在这篇博客我尽量通俗一点地讲讲我们前端开发过程中&#xff0c;该如何去测试 浏览器开发者工具简介 开…
阅读更多...
探索企业知识边界，鸿翼ECM AI助手开启智慧问答新时代

探索企业知识边界，鸿翼ECM AI助手开启智慧问答新时代

在信息化迅速发展的当下&#xff0c;企业积累的数字文档数量巨大&#xff0c;这些文档中蕴含的深层信息对业务发展至关重要。然而&#xff0c;传统的搜索技术常常因只能进行关键字查询而无法满足对文档深层次理解的需求。 据Gartner调查&#xff0c;高达47%的员工在寻找有效工…
阅读更多...
Java中多线程开发减少线程上下文切换开销

Java中多线程开发减少线程上下文切换开销

使用线程池&#xff1a; 创建和销毁线程是有代价的&#xff0c;线程池可以重用已存在的线程&#xff0c;减少这种开销。合理设置线程池的大小&#xff0c;避免线程过多导致频繁的上下文切换。减少锁竞争&#xff1a; 锁是引起上下文切换的主要原因之一。尽量减少锁的使用&#…
阅读更多...
最新文章

Copyright @ 2022~2023