XXL-JOB 任务调度平台实践

news/2024/7/5 2:34:57

XXL-JOB 任务调度平台实践

  • 一、调度中心(服务端)
    • 1、从gitbub 获取项目源码：[https://github.com/xuxueli/xxl-job](https://github.com/xuxueli/xxl-job)
    • 2、从源码中得到SQL脚本创建和初始化数据库
    • 3、Maven 编译打包 xxl-job-admin 并部署为调度中心
    • 4、启动运行 xxl-job-admin，并访问 http://localhost:8080/xxl-job-admin
  • 二、开发XXL-JOB执行器(客户端)
    • 1、创建一个新项目（New Module）
    • 2、配置任务调度中心
      • ①新增执行器:
      • ②新增任务管理:
      • ③查看调度日记

连接视频

一、调度中心(服务端)

1、从gitbub 获取项目源码：https://github.com/xuxueli/xxl-job

在这里插入图片描述

在这里插入图片描述

修改 xxl-job项目的配置文件【application.properties】，修改数据库连接为自己的数据库，修改发送邮件配置

### xxl-job, access token #设置访问xxl-job的token设值
xxl.job.accessToken=123456

2、从源码中得到SQL脚本创建和初始化数据库

sql文件位置：
在这里插入图片描述

在这里插入图片描述

3、Maven 编译打包 xxl-job-admin 并部署为调度中心

4、启动运行 xxl-job-admin，并访问 http://localhost:8080/xxl-job-admin

默认用户名：admin 密码：123456

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

二、开发XXL-JOB执行器(客户端)

1、创建一个新项目（New Module）

在这里插入图片描述

客户端（spring-xxl-job）

pom.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.zzp</groupId>
    <artifactId>spring-xxl-job</artifactId>
    <version>1.0.0</version>

	<packaging>war</packaging>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>
        <!-- xxl-job-core -->
        <dependency>
            <groupId>com.xuxueli</groupId>
            <artifactId>xxl-job-core</artifactId>
            <version>2.2.0</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>5.2.6.RELEASE</version>
        </dependency>


    </dependencies>

</project>

拷贝xxl-job-executor.properties配置文件在在resources目录下【参考xxl-job-executor-samples目录下的xxl-job-executor-sample-spring项目的xxl-job-executor.properties配置文件】

xxl-job-executor.properties文件

### 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
# 和服务端设置的配置accessToken保持一致
xxl.job.accessToken=123456

### xxl-job executor appname
# 执行器的名字
xxl.job.executor.appname=spring-xxl-job
### 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
# 执行器的ip（客户端的ip）
xxl.job.executor.ip=127.0.0.1
# 执行器的端口（客户端的端口）
xxl.job.executor.port=9999
### xxl-job executor log-path
# 日记存储地址
xxl.job.executor.logpath=F:/xxl-job/log
### xxl-job executor log-retention-days
# 日记存储有效天数
xxl.job.executor.logretentiondays=30

在resources目录下添加applicationContext.xml配置文件【参考xxl-job-executor-samples目录下的xxl-job-executor-sample-spring项目的applicationcontext-xxl-job.xml配置文件】

applicationContext.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">

    <bean id="propertyConfigurer" class="org.springframework.context.support.PropertySourcesPlaceholderConfigurer">
        <property name="fileEncoding" value="utf-8" />
        <property name="locations">
            <list>
                <value>classpath*:xxl-job-executor.properties</value>
            </list>
        </property>
    </bean>

    <!-- ********************************* 基础配置 ********************************* -->

    <!-- 配置01、JobHandler 扫描路径 在本地项目中创建包 -->
    <context:component-scan base-package="com.zzp.executor" />

    <!-- 配置02、执行器 依赖包 读取xxl-job-executor.properties文件中的配置 -->
    <bean id="xxlJobSpringExecutor" class="com.xxl.job.core.executor.impl.XxlJobSpringExecutor" >
        <!-- 执行器注册中心地址[选填]，为空则关闭自动注册 -->
        <property name="adminAddresses" value="${xxl.job.admin.addresses}" />
        <!-- 访问令牌[选填]，非空则进行匹配校验 -->
        <property name="accessToken" value="${xxl.job.accessToken}" />
        <!-- 执行器AppName[选填]，为空则关闭自动注册 -->
        <property name="appname" value="${xxl.job.executor.appname}" />
        <!-- 注册地址[选填]，优先使用该配置作为注册地址，为空时使用内嵌服务 ”IP:PORT“ 作为注册地址 -->
        <property name="address" value="${xxl.job.executor.address}" />
        <!-- 执行器IP[选填]，为空则自动获取 -->
        <property name="ip" value="${xxl.job.executor.ip}" />
        <!-- 执行器端口号[选填]，小于等于0则自动获取 -->
        <property name="port" value="${xxl.job.executor.port}" />
        <!-- 执行器日志路径[选填]，为空则使用默认路径 -->
        <property name="logPath" value="${xxl.job.executor.logpath}" />
        <!-- 日志保存天数[选填]，值大于3时生效 -->
        <property name="logRetentionDays" value="${xxl.job.executor.logretentiondays}" />
    </bean>

</beans>

在这里插入图片描述

创建MyJobHandler类【参考xxl-job-executor-samples目录下的xxl-job-executor-sample-spring项目的SampleXxlJob.java类】

MyJobHandler.java类

package com.zzp.executor;

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 此类就是真正的定时任务业务处理类（Bean模式）
 *
 * 也就是真正的定时任务功能逻辑在此类中完成（比如：定时对账，定时发送短信，定时清理）
 *
 * 开发步骤：
 *  1、在Spring Bean实例中，开发Job方法，方式格式要求为 "public ReturnT<String> execute(String param)"
 *  2、为Job方法添加注解 "@XxlJob(value="自定义jobhandler名称", init = "JobHandler初始化方法", destroy = "JobHandler销毁方法")"，注解value值对应的是调度中心新建任务的JobHandler属性的值。
 *  3、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志；
 *
 */
@Component
public class MyJobHandler {

    private  SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    /**
     * 1、简单任务示例（Bean模式）
     */
    @XxlJob(value = "myJobHandler")
    public ReturnT<String> myJobHandler(String param) throws Exception {
        //在改方法里面编写真正的定时任务功能逻辑 比如：定时对账，定时发送短信，定时清理
        XxlJobLogger.log("XXL-JOB, myJobHandler start:" + sdf.format(new Date()));
        XxlJobLogger.log("XXL-JOB, myJobHandler param:" + param);
        return ReturnT.SUCCESS;
    }

}

因为spring-xxl-job是web项目，需要web【拷贝xxl-job-executor-samples目录下的xxl-job-executor-sample-spring项目的web文件夹】

修改web.xml配置文件

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
	id="WebApp_ID" version="2.5">

	<display-name>spring-xxl-job</display-name>
	<context-param>
	    <param-name>webAppRootKey</param-name>
	    <param-value>spring-xxl-job</param-value>
	</context-param>

	<!-- spring -->
	<context-param>
		<param-name>contextConfigLocation</param-name>
		<param-value>classpath*:applicationContext.xml</param-value>
	</context-param>
	
	<listener>
		<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
	</listener>

	<welcome-file-list>
		<welcome-file>index.html</welcome-file>
	</welcome-file-list>
	
</web-app>

在这里插入图片描述

打包：
在这里插入图片描述
在这里插入图片描述

使用Tomcat启动spring-xxl-job项目

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

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

浏览器访问：

在这里插入图片描述

2、配置任务调度中心

①新增执行器:

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

②新增任务管理:

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

在这里插入图片描述

启动任务

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

③查看调度日记

在这里插入图片描述
这里失败，因为在执行器设值错误了

在这里插入图片描述

执行成功日记：

在这里插入图片描述

文件日记输出：

在这里插入图片描述


http://lihuaxi.xjx100.cn/news/863844.html

相关文章

【云原生】解读Kubernetes三层网络方案

【云原生】解读Kubernetes三层网络方案

在上一篇文章中&#xff0c;我以网桥类型的 Flannel 插件为例&#xff0c;为你讲解了 Kubernetes 里容器网络和 CNI 插件的主要工作原理。不过&#xff0c;除了这种模式之外&#xff0c;还有一种纯三层&#xff08;Pure Layer 3&#xff09;网络方案非常值得你注意。其中的典型…
阅读更多...
实战打靶集锦-004-My-Cmsms

实战打靶集锦-004-My-Cmsms

**写在前面&#xff1a;**记录一次艰难曲折的打靶经历。 目录1. 主机发现2. 端口扫描3. 服务枚举4. 服务探查4.1 WEB服务探查4.1.1 浏览器访问4.1.2 目录枚举4.1.3 控制台探查4.1.4 其他目录探查4.2 阶段小结5. 公共EXP搜索5.1 CMS搜索5.2 Apache搜索5.3 PHP搜索5.4 MySQL搜索5…
阅读更多...
vue项目第二天

vue项目第二天

项目中使用element-ui库中文网https://element.eleme.cn/#/zh-CN安装命令npm install element-ui安装按需加载babel插件npm install babel-plugin-component -Dnpm i //可以通过npm i 的指令让配置刷新重新配置一下项目中使用element-ui组件抽离文件中按需使用element ui &…
阅读更多...
低噪声与功放选型购买

低噪声与功放选型购买

低噪声与功率放大器的区别&#xff1f;购买时怎么区分&#xff1f; 低噪放 低噪放&#xff0c;低噪声射频放大器。作用就是要求噪声系数很低&#xff0c;放大电压信号。一般放在系统第一级&#xff0c;因为噪声系数低&#xff0c;接收放大的信号有很好的的信噪比。如天线的接…
阅读更多...
Java的异常处理

Java的异常处理

异常 异常就是程序非正常运行时的报错&#xff0c;不正常就是异常。 异常分类 通常分为两类&#xff1a; Error&#xff1a;错误。通常是Java虚拟机无法解决的严重问题。如&#xff1a;JVM系统内部错误、资源耗尽等严重情况。比如&#xff1a;StackOverflowError和OOM-->…
阅读更多...
2023-02-10 - 5 文本搜索

2023-02-10 - 5 文本搜索

与其他需要精确匹配的数据不同&#xff0c;文本数据在前期的索引构建和搜索环节都需要进行额外的处理&#xff0c;并且在匹配环节还要进行相关性分数计算。本章将详细介绍文本搜索的相关知识。 本章首先从总体上介绍文本的索引建立过程和搜索过程&#xff0c;然后介绍分析器的…
阅读更多...
PLC是什么？PLC相关知识小科普

PLC是什么？PLC相关知识小科普

欢迎各位来到东用知识小课堂1.PLC是什么&#xff1a;●PLC就是可编程控制器&#xff0c;它应用于工业环境&#xff0c;必须具有很强的抗干扰能力、广泛的适应能力和应用范围。●PLC是“数字运算操作的电子系统”&#xff0c;也是一种计算机&#xff0c;它是“专为在工业环境下应…
阅读更多...
tui-swipe-action组件上的按钮点击后有阴影的解决方法

tui-swipe-action组件上的按钮点击后有阴影的解决方法

大家好，我是雄雄，欢迎关注微信公众号：雄雄的小课堂。 目录 前言问题描述问题解决前言 一直未敢涉足电商领域，总觉得这里面的道道很多，又是支付、又是物流的，还涉及到金钱，所以我们所做的项目，一直都是XXXX管理系统，XXX考核系统，移动端的也是，XX健康管理平台…… 但…
阅读更多...
最新文章

Copyright @ 2022~2023