springboot集成xxl-job详解

news2025/2/25 9:48:15

文章目录

        • springboot集成xxl-job详解
        • 1、springboot集成xxl-job：
          • （1）pom文件里引入xxl-job依赖
          • （2）application.properties配置文件：
          • （3）在你的项目里新建文件结构如下：
            • XxlJobConfig.java文件内容如下：
            • DevUserHandler.java文件内容如下：
          • （4）登录xxl-job-admin新建执行器和新建任务：
          • （5）打印结果：

springboot集成xxl-job详解
1、springboot集成xxl-job：
（1）pom文件里引入xxl-job依赖
<!-- xxl-job-core -->
<dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>2.4.0</version>
</dependency>
（2）application.properties配置文件：
# xxl-job
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=xj-store
### 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
（3）在你的项目里新建文件结构如下：
|
|______BizApplication.java		# 启动类
|______biz
|_______|____controller
|_______|____job
|_______|______|____config
|_______|______|________|____XxlJobConfig.java
|_______|______|____handle
|_______|______|________|____DevUserHandler.java
XxlJobConfig.java文件内容如下：
package com.unicom.mark.job.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("${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();
     */


}
DevUserHandler.java文件内容如下：
package com.unicom.mark.job.handler;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.unicom.framework.utils.StringUtils;
import com.unicom.mark.dao.mapper.CertificationUserMapper;
import com.unicom.mark.dao.mapper.DevUserMapper;
import com.unicom.mark.dao.mapper.EntUserMapper;
import com.unicom.mark.utils.Constants;
import com.unicom.mark.vo.DevUserVo;
import com.unicom.mark.vo.EntUserVo;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

/**
 * XxlJob开发示例（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" 打印执行日志；
 *
 * @author xuxueli 2019-12-11 21:52:51
 */
@Component
public class DevUserHandler {
    private static Logger logger = LoggerFactory.getLogger(DevUserHandler.class);

    @Resource
    private CertificationUserMapper certificationUserMapper;

    @Resource
    private DevUserMapper devUserMapper;

    @Resource
    private EntUserMapper entUserMapper;

    /**
     * 1、简单任务示例
     */
    @XxlJob("demoJobHandler")
    public  ReturnT<String> demoJobHandler(String param) throws Exception {
        XxlJobHelper.log("XXL-JOB, Hello World.");
        JSONObject jsonObject = JSON.parseObject(param);
        System.out.println(param);
        for (int i = 0; i < 5; i++) {
            XxlJobHelper.log("beat at:" + i);
            System.out.printf("beat at：%d \n", i);
            TimeUnit.SECONDS.sleep(2);
        }
        // default success
        return ReturnT.SUCCESS;
    }

    /**
     * 2、同步开发方账号
     */
    @XxlJob("syncDevUser")
    public ReturnT<String> syncDevUser() throws Exception {
        List<DevUserVo> userList = certificationUserMapper.getDeveloperUser();
        if (userList.size()!=0) {
            List<String> idList = new ArrayList<>();
            for (DevUserVo userVo : userList) {
                // 处理devname字段为空的情况
                if(StringUtils.isBlank( userVo.getEntNameCn() )){
                    userVo.setEntNameCn("开发者");
                }
                int i = devUserMapper.insertUser(userVo, Constants.ENT_PASSWORD, Constants.DEV_ROLE);
                if (i == 1) {
                    idList.add(String.valueOf(userVo.getId()));
                }
            }
            String ids = String.join(",", idList);
            certificationUserMapper.updateDevelopPass(ids);
        }
        return ReturnT.SUCCESS;
    }

  




}
（4）登录xxl-job-admin新建执行器和新建任务：

新建执行器：
在这里插入图片描述
新建任务：
在这里插入图片描述
在这里插入图片描述

（5）打印结果：

在这里插入图片描述

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

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

相关文章

Pinia 及其数据持久化 Vue新一代状态管理插件

Pinia 及其数据持久化 Vue新一代状态管理插件

黑马前端Vue新一代状态管理插件Pinia快速入门视频教程 Pinia主页 超级简单&#xff0c;不需要耐心 pinia &#xff1a;新一代的VueX 1. 安装 npm install pinia2. 在main.js中引入 import { createPinia } from pinia app.use(createPinia())3. 新建stores目录&#xff0c…
阅读更多...
锐捷EG易网关login.php以及其后台cli.php/branch_passw.php RCE漏洞复现 [附POC]

锐捷EG易网关login.php以及其后台cli.php/branch_passw.php RCE漏洞复现 [附POC]

文章目录 锐捷EG易网关login.php以及其后台cli.php/branch_passw.php远程代码执行漏洞复现 [附POC]0x01 前言0x02 漏洞描述0x03 影响版本0x04 漏洞环境0x05 漏洞复现1.访问漏洞环境2.构造POC3.复现 锐捷EG易网关login.php以及其后台cli.php/branch_passw.php远程代码执行漏洞复…
阅读更多...
盘点一款制作电子杂志的网站，小白也能快速上手

盘点一款制作电子杂志的网站，小白也能快速上手

随着科技的进步&#xff0c;电子宣传册已经成为了企业宣传和推广的重要工具之一。它们不仅易于制作和更新&#xff0c;而且可以轻松地在网络上传播&#xff0c;让更多的人了解您的品牌和产品。 现在&#xff0c;给大家推荐一款FLBOOK在线制作电子杂志平台。无需任何专业的设计技…
阅读更多...
信创之路数据库人大金仓篇

信创之路数据库人大金仓篇

概要 信创大势所趋&#xff0c;吾等上下求索 参考文档 Linux&#xff1a;人大金仓数据库-KingBaseES V8与 php7的连接配置 laravel9适配人大金仓&#xff08;kingbase&#xff09;数据库 thinkphp6适配人大金仓&#xff08;Kingbase&#xff09;数据库 数据库选型 目前比较…
阅读更多...
解决网络编程中的EOF违反协议问题：requests库与SSL错误案例分析

解决网络编程中的EOF违反协议问题：requests库与SSL错误案例分析

1. 问题背景 近期&#xff0c;一个用户在使用requests库进行网络编程时遭遇到了一个不寻常的问题&#xff0c;涉及SSL错误&#xff0c;并提示错误消息为SSLError(SSLEOFError(8, uEOF occurred in violation of protocol (_ssl.c:661)),))。该用户表示已经采取了多种方法来解决…
阅读更多...
防范Java多线程陷阱：探秘ABA问题的起因及解决之道！

防范Java多线程陷阱：探秘ABA问题的起因及解决之道！

一、概念 CAS&#xff08;Compare and Swap&#xff09;是一种乐观锁机制&#xff0c;它是一种基于硬件指令实现的原子操作&#xff0c;可以在不使用传统互斥锁的情况下&#xff0c;保证多线程对共享变量的安全访问。在Java中&#xff0c;我们可以使用Atomic类和AtomicReferenc…
阅读更多...
微服务架构演进

微服务架构演进

系统架构演变 没有最好的架构&#xff0c;只有最合适的架构&#xff1b;架构发展过程&#xff1a;单体架构》垂直架构》SOA 面向服务架构》微服务架构&#xff1b;推荐看看《淘宝技术这十年》&#xff1b; 单体架构 互联网早期&#xff0c;一般的网站应用流量较小&#xff0…
阅读更多...
PDF处理控件Aspose.PDF功能演示：使用C＃查找和替换PDF文件中的文本

PDF处理控件Aspose.PDF功能演示：使用C＃查找和替换PDF文件中的文本

使用“查找并替换”选项可以一次性替换文档中的特定文本。这样&#xff0c;您不必手动定位和更新整个文档中每次出现的文本。本文甚至更进一步&#xff0c;介绍了如何在PDF文档中自动查找和替换文本功能。特别是&#xff0c;将学习如何使用C&#xff03;在整个PDF&#xff0c;特…
阅读更多...
此芯科技加入绿色计算产业联盟，参编绿色计算产业发展白皮书

此芯科技加入绿色计算产业联盟，参编绿色计算产业发展白皮书

近日&#xff0c;此芯科技正式加入绿色计算产业联盟&#xff08;Green Computing Consortium&#xff0c;简称GCC&#xff09;&#xff0c;以Arm架构通用智能CPU芯片及高能效的Arm PC计算解决方案加速构建软硬协同的绿色计算生态体系&#xff0c;推动绿色计算产业加速发展。 继…
阅读更多...
Ubuntu 20.04 LTS ffmpeg gif mp4 互转 许编译安装ffmpeg ；解决gif转mp4转换后无法播放问题

Ubuntu 20.04 LTS ffmpeg gif mp4 互转 许编译安装ffmpeg ；解决gif转mp4转换后无法播放问题

安装ffmpeg apt install ffmpeg -y gif转mp4 ffmpeg -f gif -i ldh.gif ldh.mp4 故障&#xff1a;生成没报错&#xff0c;但mp4无法播放&#xff0c;体积也不正常 尝试编译安装最新版 sudo apt install -y yasm axel -n 100 https://ffmpeg.org/releases/ffmpeg-6.0.1.tar.x…
阅读更多...
【k8s集群搭建(二)：基于虚拟机的linux的k8s集群搭建_超详细_可视化界面Dashboard安装_记录全过程踩坑记录及解决方法】

【k8s集群搭建(二)：基于虚拟机的linux的k8s集群搭建_超详细_可视化界面Dashboard安装_记录全过程踩坑记录及解决方法】

在 master 执行 # 根据 在线配置文件 创建资源 kubectl apply -f https://raw.githubusercontent.com/kubernetes/dashboard/v2.3.1/aio/deploy/recommended.yaml设置访问端口 # 修改配置文件 找到 type&#xff0c;将 ClusterIP 改成 NodePort kubectl edit svc kubernetes-…
阅读更多...
QML20、布局

QML20、布局

1.概述 首先，QML同样允许大家使用硬编码的方式将位置数值直接写到代码中，但是这样做首先难以适应UI的调整，其次代码维护起来也很困难。因此不推荐这样做。推荐大家使用的是以下三种布局管理器：Row,、Column、Grid、Flow，以及使用Anchor进行布局。 2.Row QML 中的 Row 元素…
阅读更多...
JS-项目实战-鼠标悬浮变手势（鼠标放单价上生效）

JS-项目实战-鼠标悬浮变手势（鼠标放单价上生效）

1、鼠标悬浮和离开事件.js //当页面加载完成后执行后面的匿名函数 window.onload function () {//get:获取 Element:元素 By:通过...方式//getElementById()根据id值获取某元素let fruitTbl document.getElementById("fruit_tbl");//table.rows:获取这个表格…
阅读更多...
如何录制视频课程？打造高品质在线教学！

如何录制视频课程？打造高品质在线教学！

在线教学和知识分享已经成为一种新型的教育模式&#xff0c;录制视频课程成为了许多教师、教育培训机构以及知识分享爱好者的首选。可是如何录制视频课程呢&#xff1f;本文将介绍两种录制视频课程的方法&#xff0c;并对其进行分步骤详细说明&#xff0c;以帮助您轻松创建令人…
阅读更多...
手写LASSO回归python实现

手写LASSO回归python实现

import numpy as np from matplotlib.font_manager import FontProperties from sklearn.datasets import make_regression from sklearn.model_selection import train_test_split import matplotlib.pyplot as pltclass Lasso():def __init__(self):pass# 数据准备def prepar…
阅读更多...
YB2502单片集成带可设定输出电流开关型降压转换器

YB2502单片集成带可设定输出电流开关型降压转换器

描述&#xff1a; YB2502单片集成带可设定输出电 流开关型降压转换器&#xff0c;可在宽输入电压范围提供1.2安培的持续输出电流&#xff0c;具有优良的负载和线性调整度。最大输出电流可通过外接高精度取样电阻来设定。安全保护机制包括每周期的峰值限流、内部软启动和温度保护…
阅读更多...
深度学习入门（第二天）——走进深度学习的世界 神经网络模型

深度学习入门（第二天）——走进深度学习的世界 神经网络模型

反向传播计算方法 简单的例子&#xff1a; 如何让 f 值更小&#xff0c;就是改变x、y、z&#xff0c;而损失函数也是这样&#xff0c;那么我们分别求偏导&#xff0c;则能得出每个值对结果的影响 链式法则 梯度是一步一步传的 复杂的例子&#xff1a; 神经网络整体架构 类生…
阅读更多...
SpringBoot + Disruptor 实现特快高并发处理，使用Disruptor高速实现队列

SpringBoot + Disruptor 实现特快高并发处理，使用Disruptor高速实现队列

1 前言 工作中遇到项目使用Disruptor做消息队列&#xff0c;对&#xff01;你没看错&#xff0c;不是Kafka也不是rabbitmq。Disruptor有个最大的优点就是快&#xff0c;还有一点它是开源的哦&#xff0c;下面做个简单的记录。 2 Disruptor介绍 Disruptor 是英国外汇交易公司…
阅读更多...
【原创分享】PMU电源PCB设计要点

【原创分享】PMU电源PCB设计要点

PMU&#xff08;Power Management Unit&#xff09;电源管理单元是一种集成在计算机、手机等电子设备中的芯片&#xff0c;用于管理设备的电源供应和功耗控制。 PMU主要具有以下功能&#xff1a; 1. 供电管理&#xff1a;PMU负责向设备的各个部分提供适当的电源电压和电流。 …
阅读更多...
android studio编译SDL so库

android studio编译SDL so库

一、下载源码 SDL官网 二、解压&#xff0c;拷贝android项目&#xff0c;并重新命名 2.1、解压 2.2&#xff0c;重命名项目名称&#xff08;androidSDL&#xff09;AndroidSDL Github 三、导入头文件和源文件&#xff0c;修改android.mk文件 3.1、在jni目录下创建SDL2文件…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023