【xxl-job】使用restful api的方式管理任务(动态创建/编辑/删除/启停任务)

news/2024/5/19 1:44:05 标签: restful, xxl-job

前言

首先,当前最新版本2.4.1-SNAPSHOT(20230530)还不支持此操作,只支持简单的restful api。所以需要我们自己在源码基础上改造。但好在后台管理已经实现了相关任务的增删改查。所以我们可以直接复用此部分代码。

直接使用

如果不想关注怎么修改的可以直接使用我修改好的版本:
https://gitee.com/yuanheqiuye/xxl-job,Maven Java工程下载下来打包即可。

xxl-job-admin/src/test/java/com/xxl/job/adminbiz/AdminBizTest.java下有相应的测试用例可以参考使用。

如何修改

从官方文档中可以知道,当前xxl-job提供的restful api com.xxl.job.core.biz.client.AdminBizClient下,那么我们只要在这个类中将所需接口实现,同时实现对应的后台的接口逻辑类com.xxl.job.admin.service.impl.AdminBizImpl。这两个类的父类都是:com.xxl.job.core.biz.AdminBiz,所以我们需要先在其中定义接口:

  • AdminBiz接口定义
	//这里的XxlJobInfo就是后台管理使用的接口参数,所以后台可以实现什么样的添加,接口就可以实现什么样的添加行为,具体怎么传参,不会的话可以在后台添加一个,通过F12看下参数,照葫芦画瓢即可
	public ReturnT<String> addJob(XxlJobInfo jobInfo);

	//更新类似新增
    public ReturnT<String> updateJob(XxlJobInfo jobInfo);

	//删除任务,因为这里要穿json,所以对id参数进行了一层封装
    public ReturnT<String> removeJob(JobIdReq jobIdReq);

	//启动任务,同上
    public ReturnT<String> startJob(JobIdReq jobIdReq);

	//停止任务,同上
    public ReturnT<String> stopJob(JobIdReq jobIdReq);
  • AdminBizClient 客户端实现。太简单了,就不具体说了
  @Override
    public ReturnT<String> addJob(XxlJobInfo jobInfo) {
        return XxlJobRemotingUtil.postBody(addressUrl + "api/addJob", accessToken, timeout, jobInfo, String.class);
    }

    @Override
    public ReturnT<String> updateJob(XxlJobInfo jobInfo) {
        return XxlJobRemotingUtil.postBody(addressUrl + "api/updateJob", accessToken, timeout, jobInfo, String.class);
    }

    @Override
    public ReturnT<String> removeJob(JobIdReq jobIdReq) {
        return XxlJobRemotingUtil.postBody(addressUrl + "api/removeJob", accessToken, timeout, jobIdReq, String.class);
    }

    @Override
    public ReturnT<String> startJob(JobIdReq jobIdReq) {
        return XxlJobRemotingUtil.postBody(addressUrl + "api/startJob", accessToken, timeout, jobIdReq, String.class);
    }

    @Override
    public ReturnT<String> stopJob(JobIdReq jobIdReq) {
        return XxlJobRemotingUtil.postBody(addressUrl + "api/stopJob", accessToken, timeout, jobIdReq, String.class);
    }
  • 后台接口逻辑实现,XxlJobService是后台管理页面用的service,直接注入进来使用即可
@Service
public class AdminBizImpl implements AdminBiz {

    @Resource
    private XxlJobService xxlJobService;
		
	//之前有的代码这里为了简介就删掉了

    @Override
    public ReturnT<String> addJob(XxlJobInfo jobInfo) {
        return xxlJobService.add(jobInfo);
    }

    @Override
    public ReturnT<String> updateJob(XxlJobInfo jobInfo) {
        return xxlJobService.update(jobInfo);
    }

    @Override
    public ReturnT<String> removeJob(JobIdReq jobIdReq) {
        return xxlJobService.remove(jobIdReq.getJobId());
    }

    @Override
    public ReturnT<String> startJob(JobIdReq jobIdReq) {
        return xxlJobService.start(jobIdReq.getJobId());
    }

    @Override
    public ReturnT<String> stopJob(JobIdReq jobIdReq) {
        return xxlJobService.stop(jobIdReq.getJobId());
    }

}

OK,搞定!!


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

相关文章

C#各种方法汇总

目录 静态方法 构造方法 析构方法 虚方法--virtual&#xff1a;&#xff08;小蜜蜂&#xff09; 抽写方法--override 抽象方法--abstract&#xff1a;&#xff08;大懒虫&#xff09; 扩展方法ExtendMethod 静态方法 特点&#xff1a;1.生命周期一旦创建到应用结束才会…

如何增加音频音量,给大家分享两个免费方法!

相信许多音频剪辑新手在刚开始的阶段需要探索学习各种操作方法。其中&#xff0c;许多用户发现自己的音频文件音量太小&#xff0c;想要增加音量&#xff0c;但却不知道使用哪种工具更好&#xff0c;如何操作更为方便。为此&#xff0c;我为您整理了两种方法&#xff0c;并向新…

在Python中使用字符串和字符串方法

## Python中的字符串及其方法 在Python中&#xff0c;字符串是最常用的数据类型之一。在本文中&#xff0c;我们将介绍什么是字符串&#xff0c;如何创建和使用字符串&#xff0c;并且探讨一些常见的字符串方法。 ### 字符串简介 字符串是由零个或多个字符组成的序列&#x…

如何搭建与使用FTP服务器

一、概述 目前用作搭建FTP服务器端的软件有很多&#xff0c;比如 Vsftpd、ProFTPD、PureFTPd、Wuftpd、ServerU、Filezilla Server等&#xff0c;这里使用Vsftpd进行搭建。 vsftpd 是“very secure ftp daemon”的首字母缩写&#xff0c;它是一款在Linux发行版中最受推崇的免…

华为OD高频面试真题

华为OD机试真题目录:真题目录 题目保证都是考过的真题,后几题都是考过很多次的题目 一、一种字符串压缩表示的解压 有一种简易压缩算法:针对全部由小写英文字母组成的字符串,将其中连续超过两个相同字母的部分压缩为连续个数加该字母,其他 部分保持原样不变。例如:字符…

Android系统中的Binder通信机制分析(6)- Binder通信机制详解

声明 其实对于Android系统Binder通信的机制早就有分析的想法&#xff0c;记得2019年6、7月份Mr.Deng离职期间约定一起对其进行研究的&#xff0c;但因为我个人问题没能实施这个计划&#xff0c;留下些许遗憾…文中参考了很多书籍及博客内容&#xff0c;可能涉及的比较多先不具…

【学习日记2023.5.30】之 管理端订单模块完善_调用百度地图优化用户端提交订单是否超出配送距离

文章目录 9. 管理端订单模块完善9.1 需求分析和涉及9.2 代码开发Controller层Service层接口Service层实现类Mapper层 9.3 功能测试9.4 提交代码9.5 优化用户下单功能&#xff0c;引入距离判断 9. 管理端订单模块完善 订单搜索各个状态的订单数量统计查询订单详情接单拒单取消订…

三、浅谈机器人的底盘设计

两电机差速底盘 方式1&#xff1a;驱动轮在后&#xff0c;万向轮在前&#xff08;支撑轮也可以换成全向轮&#xff0c;目的只是撑地&#xff09;&#xff0c;在一般的巡线比赛中较常用。 该底盘的优点&#xff1a;运动灵活&#xff0c;组装简单 该底盘的缺点&#xff1a;车体…