手写SpringBoot项目所使用的xxl-job分布式任务调度平台的starter

手写SpringBoot项目所使用的xxl-job分布式任务调度平台的starter

要将上述代码抽离成一个独立的 Spring Boot Starter,您需要创建一个新的 Maven 项目,并按照以下步骤进行操作:

  1. 创建 Maven 项目

    • 使用 IDE 或命令行创建一个新的 Maven 项目,命名为 xxl-job-starter(或自定义名称)。
    • 设置项目的 groupId(例如:com.example)、artifactId(例如:xxl-job-starter)和 version
  2. 添加必要的依赖

    • pom.xml 文件中添加 Spring Boot Starter、XXL-JOB 的依赖以及所需的其他库(如 Hutool)。
    <dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>com.xxl.job</groupId><artifactId>xxl-job-core</artifactId><version>{latest_xxjob_version}</version></dependency><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId><version>{latest_hutool_version}</version></dependency>
    </dependencies>
    

    替换 {latest_xxjob_version}{latest_hutool_version} 为相应库的最新版本。

  3. 创建XxlJobAutoConfiguration类

    • 在项目中创建一个名为 XxlJobAutoConfiguration(或自定义名称)的 Java 类,实现与您提供的代码相似的功能。将注释解除并调整代码结构如下:
/** Copyright (c) 2020, 2024, fpl1116.cn All rights reserved.**/
package cn.fpl.xxljob.autoconfiguration;import cn.fpl.xxljob.config.XxlJobConfig;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;/*** <p>Project: page-starter-demo - PageXAutoConfiguration</p>* <p>Powered by fpl1116 On 2024-02-19 16:18:07</p>* <p>描述:<p>** @author penglei* @version 1.0* @since 1.8*/
@Configuration
@Import( {XxlJobConfig.class})
//cn.fpl.pagex.enbale = xxx
@ConditionalOnProperty(prefix = "cn.fpl.xxljob", value = "enable",havingValue="true",matchIfMissing=true)
public class XxlJobAutoConfiguration { //领头羊
}
  1. 创建XxlJobProperties类
/** Copyright (c) 2020, 2024, fpl1116.cn All rights reserved.**/
package cn.fpl.xxljob.properties;import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;/*** <p>Project: page-starter-demo - PageXProperties</p>* <p>Powered by fpl1116 On 2024-02-19 16:19:05</p>* <p>描述:<p>** @author penglei* @version 1.0* @since 1.8*/
@Data
@ConfigurationProperties(prefix = "cn.fpl.xxljob")
public class XxlJobProperties {private boolean enable = true;private String adminAddresses;private String accessToken;private String appname;private String address;private String ip;private String logPath;private Integer logRetentionDays;
}
  1. 创建XxlJobConfig类
/** Copyright (c) 2020, 2024, fpl1116.cn All rights reserved.**/
package cn.fpl.xxljob.config;import cn.fpl.xxljob.properties.XxlJobProperties;
import cn.hutool.core.net.NetUtil;
import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;/*** <p>Project: page-starter-demo - XxlJobConfig</p>* <p>Powered by fpl1116 On 2024-04-16 14:12:56</p>* <p>描述:<p>** @author penglei* @version 1.0* @since 1.8*/
@Import({XxlJobProperties.class})
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.logpath}")private String logPath;@Value("${xxl.job.executor.logretentiondays}")private int logRetentionDays;@Beanpublic XxlJobSpringExecutor xxlJobExecutor() {logger.info(">>>>>>>>>>> xxl-job config init.");XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();xxlJobSpringExecutor.setAdminAddresses(adminAddresses);xxlJobSpringExecutor.setAppname(appname);xxlJobSpringExecutor.setAddress(address);xxlJobSpringExecutor.setIp(ip);//通过hutool工具获取一个本机可用端口int usableLocalPort = NetUtil.getUsableLocalPort();xxlJobSpringExecutor.setPort(usableLocalPort);xxlJobSpringExecutor.setAccessToken(accessToken);xxlJobSpringExecutor.setLogPath(logPath);xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);return xxlJobSpringExecutor;}}
  1. 创建 starter 的 META-INF 文件夹及 spring.factories 文件
    • 在项目的 src/main/resources 目录下创建 META-INF 文件夹。
    • META-INF 文件夹中创建 spring.factories 文件,内容如下:
  # Auto-configure componentsorg.springframework.boot.autoconfigure.EnableAutoConfiguration=\cn.fpl.xxljob.autoconfiguration.XxlJobAutoConfiguration

这样设置后,当其他项目引入您的 starter 时,XxlJobAutoConfiguration 类会自动被 Spring Boot 加载并应用配置。

  1. 打包发布 starter
    • 在完成上述步骤后,使用 IDE 或 Maven 命令行编译并打包项目(通常是生成 JAR 文件)或直接deploy发布项目到maven配置的私仓。
    • 将生成的 JAR 文件上传至 Maven 私服或公共仓库,以便其他项目通过 Maven 依赖方式引入。

现在,其他 Spring Boot 项目只需在 pom.xml 中添加对您创建的 xxl-job-starter 的依赖,即可自动配置 XXL-JOB。记得在应用的 application.propertiesapplication.yml 文件中设置对应的 XXL-JOB 配置属性。
8. application.properties配置内容

# XXL-JOB 相关配置# 安装xxl-job服务的ip和端口
xxl.job.admin.addresses=http://localhost:8080/xxl-job-admin
xxl.job.accessToken=my-access-token
xxl.job.executor.appname=my-app
xxl.job.executor.address=
xxl.job.executor.ip=127.0.0.1
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
xxl.job.executor.logretentiondays=30

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

JVM虚拟机(九)如何开启 GC 日志

目录 一、引言二、开启 GC 日志三、解析 GC 日志四、优化建议 一、引言 在 Java 应用程序的运行过程中&#xff0c;垃圾收集&#xff08;Garbage Collection&#xff0c;简称 GC&#xff09;是一个非常重要的环节。GC 负责自动管理内存&#xff0c;回收不再使用的对象所占用的…

zabbix 自动发现与自动注册 部署 zabbix 代理服务器

zabbix 自动发现&#xff08;对于 agent2 是被动模式&#xff09; zabbix server 主动的去发现所有的客户端&#xff0c;然后将客户端的信息登记在服务端上。 缺点是如果定义的网段中的主机数量多&#xff0c;zabbix server 登记耗时较久&#xff0c;且压力会较大。1.确保客户端…

一次配置Docker环境的完整记录

一次配置Docker环境的完整记录 Docker环境搭建报错与解决报错一报错二报错三 Docker环境搭建 本节介绍了一次配置docker环境的完整记录&#xff1a; 编写Dockerfile文件&#xff1a; FROM pytorch/pytorch:1.10.0-cuda11.3-cudnn8-develRUN rm /etc/apt/sources.list.d/cuda.l…

mfc 带有复选框的ListBox

mfc 带有复选框的 ListBox 效果&#xff1a; 添加 ListBox 控件 从工具箱拖拽 ListBox 控件到窗口上&#xff0c;并设置属性&#xff1a; 包含字符串&#xff1a;true所有者描述&#xff1a;Fixed 给ListBox添加控制变量 添加完后&#xff0c;将m_list_box的类型使用CC…

Qt+vstudio2022的报错信息积累

从今天开始记录一下平常开发工作中的报错记录&#xff0c;后续有错误动态补充&#xff01; 报错信息&#xff1a;【MSB8041】此项目需要 MFC 库。从 Visual Studio 安装程序(单个组件选项卡)为正在使用的任何工具集和体系结构安装它们。 解决&#xff1a; 背景&#xff1a;换…

uniapp--登录和注册页面-- login

目录 1.效果展示 2.源代码展示 测试登录 login.js 测试请求 request.js 测试首页index.js 1.效果展示 2.源代码展示 <template><view><f-navbar title"登录" navbarType"4"></f-navbar><view class"tips"><…

通俗易懂降维理解------SIFT【大白话版】!!!

SIFT&#xff08;尺度不变特征变换&#xff09;是一种在计算机视觉中用来发现图像中特定点&#xff08;特征点&#xff09;并能够精确描述这些点的方法&#xff0c;这样即使在图像的大小、角度或光线变化后&#xff0c;这些点仍然可以被识别和匹配。简单来说&#xff0c;SIFT帮…

图数据库Neo4J入门——Neo4J下载安装+Cypher基本操作+《西游记》人物关系图实例

这里写目录标题 一、效果图二、环境准备三、数据库设计3.1 人物节点设计3.2 关系设计 四、操作步骤4.1 下载、安装、启动Neo4J服务4.1.1 配置Neo4J环境变量4.1.2 启动Neo4J服务器4.1.3 启动Ne04J客户端 4.2 创建节点4.3 创建关系&#xff08;从已有节点创建关系&#xff09;4.4…

PhpStorm2024安装包(亲测可用)

目录 一、软件简介 二、软件下载 一、软件简介 PhpStorm是由JetBrains公司开发的一款商业的PHP集成开发环境&#xff08;IDE&#xff09;&#xff0c;深受全球开发人员的喜爱。它旨在提高开发效率&#xff0c;通过深刻理解用户的编码习惯&#xff0c;提供智能代码补全、快速导…

前端解析URL的两种方式

方法一&#xff1a;利用 splice 分割 循环依次取出 方法一&#xff1a; function queryURLparams(url) {let obj {}if (url.indexOf(?) < 0) return objlet arr url.split(?)url arr[1]let array url.split(&)for (let i 0; i < array.length; i) {let arr2…

Linux bash 与 命令行 查找进程的不同

#必须使用 GL2ServerConsole.dll 来过滤 #不能使用 GL2ServerConsole #在命令行模式下一样 #但是通过远程bash调用 后者会返回如下内容: root 25800 0.0 0.0 113280 1220 ? S 20:36 0:00 bash -c /root/Run_GL2ServerConsole.sh root 25801 0.0 0.0 113284 872 ? S 20:36 0:…

【JavaEE】网络编程

文章目录 一、什么是网络编程网络编程中的基本概念 一、什么是网络编程 网络编程&#xff0c;指网络上的主机&#xff0c;通过不同的进程&#xff0c;以编程的方式实现网络通信&#xff08;或称为网络数据传输&#xff09;。 当然&#xff0c;我们只要满足进程不同就行&#x…

Java面试八股文(JVM篇)(❤❤)

Java面试八股文_JVM篇 1、知识点汇总2、知识点详解&#xff1a;3、说说类加载与卸载11、说说Java对象创建过程12、知道类的生命周期吗&#xff1f;14、如何判断对象可以被回收&#xff1f;17、调优命令有哪些&#xff1f;18、常见调优工具有哪些20、你知道哪些JVM性能调优参数&…

vue的就地更新与v-for的key属性

vue的就地更新 Vue中的就地更新到底是怎么回事&#xff0c;为什么会存在就地更新的现象&#xff1f; 注意下面的例子&#xff0c;使用v-for指令时&#xff0c;没有绑定key值&#xff0c;才有就地更新的现象&#xff0c;因为Vue默认按照就地更新的策略来更新v-for渲染的元素列表…

CTFHUB-技能树-Web前置技能-文件上传(前端验证—MIME绕过、00截断、00截断-双写后缀)

CTFHUB-技能树-Web前置技能-文件上传&#xff08;前端验证—MIME绕过、00截断、00截断-双写后缀&#xff09; 文章目录 CTFHUB-技能树-Web前置技能-文件上传&#xff08;前端验证—MIME绕过、00截断、00截断-双写后缀&#xff09;前端验证—MIME绕过有关MIMEMIME的作用 解题时有…

元宇宙VR虚拟线上展馆满足企业快速布展的需要

想要拥有一个VR线上虚拟展馆&#xff0c;展现您的城市风采或企业特色吗? 相比实体展馆搭建&#xff0c;VR线上虚拟展馆投入资金少&#xff0c;回报周期短&#xff0c;只需几个月的时间&#xff0c;您就能开始资金回笼。那么一个VR线上虚拟展馆多少钱呢? 深圳VR公司华锐视点基…

数据库基本概念和SQL基本语句

数据库&#xff08;Database&#xff09;是按照数据结构来组织、存储和管理数据的仓库。在数据库中&#xff0c;数据通常以表格的形式存储&#xff0c;这些表格包含了行和列。行通常代表记录&#xff0c;而列代表记录中的不同字段。数据库的设计允许对数据进行高效地查询、更新…

bp神经网络拟合函数未知参数【源码+视频教程】

专栏导读 作者简介&#xff1a;工学博士&#xff0c;高级工程师&#xff0c;专注于工业软件算法研究本文已收录于专栏&#xff1a;《复杂函数拟合案例分享》本专栏旨在提供 1.以案例的形式讲解各类复杂函数拟合的程序实现方法&#xff0c;并提供所有案例完整源码&#xff1b;2.…

无人零售行业展望:智能化与便利性引领未来

无人零售行业展望&#xff1a;智能化与便利性引领未来 无人零售&#xff0c;这一依靠智能化技术如人工智能、物联网、和大数据的零售模式&#xff0c;正逐步成为全球零售行业的新趋势。该模式允许消费者在没有店员的情况下自助完成购物&#xff0c;提供了24小时服务&#xff0…

IO、存储、硬盘、文件系统相关常识

目录 IO 文件系统 文件在硬盘上的存储 IO IO&#xff0c;就是Input和Output&#xff0c;即输入和输出操作。我们的电脑可以通过网络下载文件&#xff0c;也可以通过网络上传文件。通过网络下载文件就是输入操作&#xff0c;上传文件就是输出。如何区分输入和输出呢&#xf…