springboot+xxl-job初体验

news2025/1/23 3:15:31

在日常开发中经常遇到任务调度的需求，下面体验一下分布式调度xxl-job。

1、常见定时任务的实现方式

  • Java自带的java.util.Timer类
  • ScheduledExcutorService
  • Springboot自带的@EnableScheduling注解
  • Quartz框架
  • Elastic-job框架
  • XXL-JOB框架

下面对xxl-job实现任务调度尝试一下。

2、xxl-job简介

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

XXL-JOB特性：

  • 简单：支持通过Web页面对任务进行CRUD操作，操作简单，一分钟上手；
  • 动态：支持动态修改任务状态、启动/停止任务，以及终止运行中任务，即时生效；
  • 调度中心HA（中心式）：调度采用中心式设计，“调度中心”自研调度组件并支持集群部署，可保证调度中心HA；
  • 执行器HA（分布式）：任务分布式执行，任务”执行器”支持集群部署，可保证任务执行HA；
  • …
    详细查看官网。

3、xxl-job下载部署

下载地址如下：

  • github：https://github.com/xuxueli/xxl-job
  • gitee：http://gitee.com/xuxueli0323/xxl-job

此处下载的版本的xxl-job-2.3.1.tar.gz，首先解压到指定目录，获取 “调度数据库初始化SQL脚本” 并执行即可。

“调度数据库初始化SQL脚本” 位置为：/xxl-job/doc/db/tables_xxl_job.sql

然后将源码导入IDE，使用maven进行编译即可，源码结构如下：

xxl-job-admin：调度中心
xxl-job-core：公共依赖
xxl-job-executor-samples：执行器Sample示例（选择合适的版本执行器，可直接使用，也可以参考其并将现有项目改造成执行器）
    ：xxl-job-executor-sample-springboot：Springboot版本，通过Springboot管理执行器，推荐这种方式；
    ：xxl-job-executor-sample-frameless：无框架版本；

在这里插入图片描述
配置调度中心项目xxl-job-admin中配置文件

调度中心配置文件地址：/xxl-job/xxl-job-admin/src/main/resources/application.properties

将mysql数据库的连接信息修改为本地数据库，将报警邮箱信息修改为自己的邮箱信息。

最后，启动调度中心服务即可。

调度中心访问地址：http://localhost:8080/xxl-job-admin
默认登录账号：admin/123456

登录后界面如下：
在这里插入图片描述
至此，调度中心服务部署成功。

部署执行器项目xxl-job-executor-sample-springboot中配置文件

源码中提供多种版本执行器供选择，现以 springboot 版本为例，可直接使用，也可以参考其并将现有项目改造成执行器。
其作用为负责接收“调度中心”的调度并执行；可直接部署执行器，也可以将执行器集成到现有业务项目中。
执行器配置文件地址：/xxl-job/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/application.properties

将配置文件中的调度中心的地址修改为本地信息，其他默认，具体详细解释参见官网。

最后，启动执行器服务即可，执行器服务部署成功。

4、开发第一个任务“hello world”

新建一个 “GLUE模式(Java)” 运行模式的任务为例。

“GLUE模式(Java)”的执行代码托管到调度中心在线维护，相比“Bean模式任务”需要在执行器项目开发部署上线，更加简便轻量。
确认“调度中心”和“执行器”项目已经成功部署并启动；

新建任务，参考如下
在这里插入图片描述
在这里插入图片描述
点击任务右侧“GLUE”按钮，进入GLUE便捷开发界面，如下
在这里插入图片描述
在这里插入图片描述
“GLUE模式(Java)” 运行模式的任务默认已经初始化了示例任务代码，即打印Hello World。

点击任务右侧“执行一次”按钮，可手动触发一次任务的执行，或“启动”，通过Cron表达式进行任务调度触发。
在这里插入图片描述
点击任务右侧“日志”按钮或左侧菜单，可前往调度日志界面查看任务日志，如下
在这里插入图片描述
在调度日志界面，点击每个日志右侧“执行日志”按钮，可进入日志控制台查看执行日志，如下
在这里插入图片描述
在这里插入图片描述

5、springboot+xxl-job实例

可以将源码中的xxl-job-executor-sample-springboot项目进行改造，或新建一个springboot项目，然后参照xxl-job-executor-sample-springboot项目进行搭建。
添加依赖，如下

<dependency>
   <groupId>com.xuxueli</groupId>
   <artifactId>xxl-job-core</artifactId>
   <version>2.3.1</version>
</dependency>

修改配置文件application.properties

# web port
server.port=8082
# no web
#spring.main.web-environment=false

# log config
logging.config=classpath:logback.xml


### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"
xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin

### xxl-job, access token
xxl.job.accessToken=default_token

### xxl-job executor appname
xxl.job.executor.appname=xxl-job-executor-sample
### xxl-job executor registry-address: default use address to registry , otherwise use ip:port if address is null
xxl.job.executor.address=
### xxl-job executor server-info
xxl.job.executor.ip=
xxl.job.executor.port=9999
### xxl-job executor log-path
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
### xxl-job executor log-retention-days
xxl.job.executor.logretentiondays=30

添加XxlJobConfig配置

@Configuration
public class XxlJobConfig {
    private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);

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

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

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

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

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

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

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

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


    @Bean
    public XxlJobSpringExecutor xxlJobExecutor() {
        logger.info(">>>>>>>>>>> xxl-job config init.");
        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
        xxlJobSpringExecutor.setAppname(appname);
        xxlJobSpringExecutor.setAddress(address);
        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();
     */


}

添加定时器任务，类似如下

@Component
public class HelloXxlJob {

    @XxlJob("helloJobHandler")
    public void helloJobHandler() throws Exception {
        XxlJobHelper.log("Hello World.");
        for (int i = 0; i < 5; i++) {
            XxlJobHelper.log("times :" + i);
            TimeUnit.SECONDS.sleep(2);
        }
    }

}

在调度中心，新建调度任务，运行模式选中“BEAN模式”，JobHandler属性填写任务注解“@XxlJob”中定义的值
在这里插入图片描述
选择执行一次或是启动，查看日志，如下
在这里插入图片描述
在这里插入图片描述

6、小结

xxl-job任务调度上手还是非常方便的，在后续的工程中可以尝试应用~

注：若需要了解更多内容，参加官网：https://www.xuxueli.com/index.html

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

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

相关文章

【TypeScript】TS进阶-函数重载（七）

【TypeScript】TS进阶-函数重载（七）

&#x1f431;个人主页&#xff1a;不叫猫先生 &#x1f64b;‍♂️作者简介&#xff1a;前端领域新星创作者、华为云享专家、阿里云专家博主&#xff0c;专注于前端各领域技术&#xff0c;共同学习共同进步&#xff0c;一起加油呀&#xff01; &#x1f4ab;系列专栏&#xff…
阅读更多...
一文读懂电商数字员工究竟是什么？| RPA铺第1期

一文读懂电商数字员工究竟是什么？| RPA铺第1期

百度的曦灵&#xff0c;中核的核小智、万科集团数字员工“崔筱盼”都曾在2022年度爆火&#xff0c;数字员工一夜之间成为众多行业追捧的对象&#xff0c;那么&#xff0c;他/她们究竟代表着什么&#xff0c;对企业而言&#xff0c;是噱头大于收益&#xff0c;还是收益大于噱头呢…
阅读更多...
简单的客户端服务器(多线程)基于json通信

简单的客户端服务器(多线程)基于json通信

这是一个客户端和服务器通信的小项目&#xff0c;小编自己手写了一个json工具&#xff0c;测试比jsoncpp&#xff0c;protobuf "效率更高"&#xff08;浅拷贝&#xff09;&#xff0c;改写成深拷贝效率会急剧下降&#xff08;小编能力有限&#xff0c;知识点&#xf…
阅读更多...
技术分享 | Spring Boot 异常处理

技术分享 | Spring Boot 异常处理

说到异常处理&#xff0c;我们都知道使用 try-catch 可以捕捉异常&#xff0c;可以 throws 抛出异常。那么在 Spring Boot 中我们如何处理异常&#xff0c;如何更优雅的处理异常&#xff0c;如何全局处理异常。是本章讨论解决的问题。Java 异常类首先让我们简单了解或重新学习下…
阅读更多...
Android开发-AS学习（一）

Android开发-AS学习（一）

完整项目最精简流程&#xff1a;Android <-> 接口 <-> 数据库Android开发工具&#xff1a;Android Studio项目目录信息&#xff1a;一、控件1.1 TextView基础属性描述layout_width组件的宽度layout_height组件的高度id为TextView设置一个组件idtext设置显示的文本内…
阅读更多...
Linux 学习笔记（借鉴黑马程序员Linux课程）

Linux 学习笔记（借鉴黑马程序员Linux课程）

Linux视频课程 简介 Linux诞生于1991年&#xff0c;由林纳斯托瓦兹在21岁时完成。此后成为最为流行的服务器操作系统之一。 Linux内核和系统发行版 由Linux系统内核和系统级应用程序两部分组成。 内核提供系统最核心的功能&#xff0c;如&#xff1a;调度CPU、调度内存、调…
阅读更多...
【笑小枫的按步照搬系列】Redis多系统安装（Windows、Linux、Ubuntu）

【笑小枫的按步照搬系列】Redis多系统安装（Windows、Linux、Ubuntu）

笑小枫&#x1f495; 欢迎来到笑小枫的世界&#xff0c;喜欢的朋友关注一下我呦&#xff0c;大伙的支持&#xff0c;就是我坚持写下去的动力。 微信公众号&#xff1a;笑小枫 笑小枫个人博客&#xff1a;https://www.xiaoxiaofeng.com Windows 下安装 方式一&#xff1a;https…
阅读更多...
HCL（新华三模拟器）如何连接CRT及改界面颜色

HCL（新华三模拟器）如何连接CRT及改界面颜色

我使用的HCL版本是2.1.1官网下载连接&#xff1a;https://www.h3c.com/cn/Service/Document_Software/Software_Download/Other_Product/H3C_Cloud_Lab/Catalog/HCL/&#xff0c;一键直达下载官网这个版本可以适配virtualbox的5.2.44的版本&#xff0c;同时支持华为的ensp模拟器…
阅读更多...
Spring Security 表单配置（一）

Spring Security 表单配置（一）

Spring Security 表单配置&#xff08;一&#xff09;工具版本及环境参考资源配置详细说明工具版本及环境 工具&#xff1a; IDEA 2021.3 Maven 3.8.6 JDK 8 Spring Boot 2.7.7 Spring Securiity 5.7.6 参考资源 Spring Security官网: https://docs.spring.io/spring-security…
阅读更多...
javaEE 初阶 — 常见的锁策略

javaEE 初阶 — 常见的锁策略

文章目录1. 乐观锁 vs 悲观锁2. 互斥锁 vs 读写锁3. 重量级锁 vs 轻量级锁4. 自旋锁 vs 挂起等待锁5. 公平锁 vs 非公平锁6. 可重入锁 vs 不可重入锁7. synchronized 是哪种锁8. 相关面试题1. 乐观锁 vs 悲观锁 乐观锁 指的是预测锁竞争不是很激烈&#xff0c;也就是指这里做的…
阅读更多...
排列组合两个列表中的元素 product(a,b)

排列组合两个列表中的元素 product(a,b)

【小白从小学Python、C、Java】【计算机等级考试500强双证书】【Python-数据分析】排列组合两个列表中的元素product(a,b)关于以下python代码表述错误的一项是?from itertools import producta [1,2,3]b [4,5,6]print("【显示】a",a)print("【显示】b",…
阅读更多...
修改Keil开发环境背景（修改为黑色主题）

修改Keil开发环境背景（修改为黑色主题）

修改Keil开发背景&#xff08;修改为黑色主题&#xff09;引言步骤总结引言 我们平时在Keil uVision5下开发单片机/嵌入式程序的时候&#xff0c;如果始终用的是官方的主题背景&#xff0c;往往会因为背景太白了&#xff0c;而导致视疲劳。我们使用VSCode往往不会有这种困扰&a…
阅读更多...
Python处理字符串 中文（汉字）编码示例

Python处理字符串 中文（汉字）编码示例

在实际开发中&#xff0c;发现打印Python打印经常出现乱码&#xff0c;大部分都是编码引起&#xff0c;这里只是简单说一下utf-8/ gbk/ unicode编码之间的相互转换问题&#xff1a; utf-8是Unix下的一种通用编码&#xff0c;gbk是win环境下的一种汉字编码&#xff0c;unicode是…
阅读更多...
计算机组成原理_总线仲裁

计算机组成原理_总线仲裁

计算机组成原理总目录总线仲裁 由于总线连接着多个设备&#xff0c;那么在同一时刻多个设备想要占用总线时&#xff0c;就会发生冲突问题 为了解决冲突问题&#xff0c;就需要规定好所有设备使用设备的优先权&#xff0c;仲裁也就是判断设备占用总线的优先权 例如设备A的任务比…
阅读更多...
Docker--安装mysql8--方法/步骤

Docker--安装mysql8--方法/步骤

原文网址&#xff1a;Docker--安装mysql8--方法/步骤_IT利刃出鞘的博客-CSDN博客 简介 本文介绍如何使用docker安装mysql8。 查看mysql版本 https://hub.docker.com/_/mysql/tags 我选择8.0&#xff0c;点击右侧箭头处直接复制命令。 拉取镜像 拉取镜像的命令 docker pul…
阅读更多...
RADIANT：一种全新的雷达图像关联网络用于3D目标检测

RADIANT：一种全新的雷达图像关联网络用于3D目标检测

RADIANT&#xff1a;一种全新的雷达图像关联网络用于3D目标检测 论文地址&#xff1a;RADIANT: Radar-Image Association Network for 3D Object Detection 源码&#xff1a;https://github.com/longyunf/radiant 单位&#xff1a;密歇根大学、福特 动机 作为一种能够直接…
阅读更多...
全景剖析阿里云容器网络数据链路（二）：Terway EN

全景剖析阿里云容器网络数据链路（二）：Terway EN

作者&#xff1a;余凯 本系列文章由余凯执笔创作&#xff0c;联合作者&#xff1a;阿里云容器服务 谢石 对本文亦有贡献 前言 近几年&#xff0c;企业基础设施云原生化的趋势越来越强烈&#xff0c;从最开始的 IaaS 化到现在的微服务化&#xff0c;客户的颗粒度精细化和可观…
阅读更多...
使用小度音箱+Blinker控制ESP01S Relay继电器模块

使用小度音箱+Blinker控制ESP01S Relay继电器模块

一. 使用ESP01S模块&#xff0c;PIN脚定义如下&#xff1a; 管脚功能如下&#xff1a; ESP01S模块原理图&#xff1a; ESP01S模块比ESP01模块做了以下优化&#xff1a; LED灯的管脚发生变化&#xff0c;由ESP01的TXD0变成ESP01s的GPIO2引脚&#xff1b;ESP01s模块的IO0、RST、…
阅读更多...
Java开发 - Spring MVC框架初体验

Java开发 - Spring MVC框架初体验

前言 上一篇Spring框架感觉写的偏向于理论知识&#xff0c;所以从这篇开始&#xff0c;转变此系列的写作思维&#xff0c;更多的将从实操的角度来讲解Spring MVC框架的使用和相关知识点&#xff0c;会尽量详细&#xff0c;但这一系列课程针对的还是有Java基础的小伙伴&#xf…
阅读更多...
树莓派上如何安装anaconda/miniconda环境配置

树莓派上如何安装anaconda/miniconda环境配置

目录1. 前言2. miniconda下载3. miniconda 安装4. 添加 .bashrc 配置5. Conda 更换源&#xff0c;软件更新6. 部分问题及解决方案报错一&#xff1a;报错二&#xff1a;报错三&#xff1a;7. 卸载miniconda8. 版本问题/注意事项1. 前言 在装完树莓派之后&#xff0c;当你想要使…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023