Springboot 整合 xxljob 动态API调度任务(进阶篇)

╰半夏微凉° 2023-09-28 11:46 220阅读 0赞

# 前言 #

之前写了一篇 xxljob的新手入门篇：

[Springboot 整合 xxljob 使用定时任务调度(新手入门篇)\_小目标青年的博客-CSDN博客][Springboot _ xxljob _-CSDN]

这一篇非常非常简单，就是非常快速的springboot整合 xxljob，相当于拿来即用，能够通过页面配合代码去实现定时任务的使用。

这一篇，我们将在上一篇的基础上，做一些进阶使用，实现动态地调度定时任务。

我们平时工作经常会遇到这些业务使用场景（举例）：  
  
执行某个业务后，需要产生一个定时任务；

怎么怎么判断成功后，需要停止某个任务；

怎么怎么判断符合条件后，需要重新执行某个任务；

怎么怎么....移除某个任务；

摊牌了，实现的效果就是：  
  
**通过API方式（或者方法函数），我们动态随意地去 增删改查、设置定时规则等等去调度任务。**

上一篇几乎是基于HTML页面去对任务创建、启动、停在、删除等等， 非常需要有人去处理，这一篇就是解放我们双手！

# 正文 #

惯例，瞎话一张简图：

大致就是admin上面写一些开放接口，各个接入xxl job的demo服务都能通过接口调用，完成动态调度，至于啥时候调度，看自己的业务场景，自己使用。

![4a709c1095464b588665d6cf516e8c97.png][]

① admin 服务 加接口，其实说实话，原先也提供了很多api接口，但是我这次非得自己搞一下。

![d434726bdb0741848581cebb9b68af16.jpeg][]

提供的接口：  
![c0283b49a5a243238c0b9eedb1a0b908.png][]

MyDynamicApiController.java ：

import com.xxl.job.admin.controller.annotation.PermissionLimit;
    import com.xxl.job.admin.core.cron.CronExpression;
    import com.xxl.job.admin.core.model.XxlJobInfo;
    import com.xxl.job.admin.core.model.XxlJobQuery;
    import com.xxl.job.admin.core.thread.JobScheduleHelper;
    import com.xxl.job.admin.core.util.I18nUtil;
    import com.xxl.job.admin.service.LoginService;
    import com.xxl.job.admin.service.XxlJobService;
    import com.xxl.job.core.biz.model.ReturnT;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.*;
    
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import java.text.ParseException;
    import java.util.Date;
    import java.util.Map;
    
    /**
     * @Author: JCccc
     * @Date: 2022-6-2 14:23
     * @Description: xxl job rest api
     */
    @RestController
    @RequestMapping("/api/jobinfo")
    public class MyDynamicApiController {
        private static Logger logger = LoggerFactory.getLogger(MyDynamicApiController.class);
        @Autowired
        private XxlJobService xxlJobService;
        @Autowired
        private LoginService loginService;
    
        @RequestMapping(value = "/pageList",method = RequestMethod.POST)
        public Map<String, Object> pageList(@RequestBody XxlJobQuery xxlJobQuery) {
            return xxlJobService.pageList(
                    xxlJobQuery.getStart(),
                    xxlJobQuery.getLength(),
                    xxlJobQuery.getJobGroup(),
                    xxlJobQuery.getTriggerStatus(),
                    xxlJobQuery.getJobDesc(),
                    xxlJobQuery.getExecutorHandler(),
                    xxlJobQuery.getAuthor());
        }
        @PostMapping("/save")
        public ReturnT<String> add(@RequestBody(required = true)XxlJobInfo jobInfo) {
    
            // next trigger time (5s后生效，避开预读周期)
            long nextTriggerTime = 0;
            try {
                Date nextValidTime = new CronExpression(jobInfo.getJobCron()).getNextValidTimeAfter(new Date(System.currentTimeMillis() + JobScheduleHelper.PRE_READ_MS));
                if (nextValidTime == null) {
                    return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_never_fire"));
                }
                nextTriggerTime = nextValidTime.getTime();
            } catch (ParseException e) {
                logger.error(e.getMessage(), e);
                return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_unvalid")+" | "+ e.getMessage());
            }
    
            jobInfo.setTriggerStatus(1);
            jobInfo.setTriggerLastTime(0);
            jobInfo.setTriggerNextTime(nextTriggerTime);
    
            jobInfo.setUpdateTime(new Date());
    
            if(jobInfo.getId()==0){
                return xxlJobService.add(jobInfo);
            }else{
                return xxlJobService.update(jobInfo);
            }
        }
        @RequestMapping(value = "/delete",method = RequestMethod.GET)
        public ReturnT<String> delete(int id) {
            return xxlJobService.remove(id);
        }
        @RequestMapping(value = "/start",method = RequestMethod.GET)
        public ReturnT<String> start(int id) {
            return xxlJobService.start(id);
        }
        @RequestMapping(value = "/stop",method = RequestMethod.GET)
        public ReturnT<String> stop(int id) {
            return xxlJobService.stop(id);
        }
        @RequestMapping(value="login", method=RequestMethod.GET)
        @PermissionLimit(limit=false)
        public ReturnT<String> loginDo(HttpServletRequest request, HttpServletResponse response, String userName, String password, String ifRemember){
            boolean ifRem = (ifRemember!=null && ifRemember.trim().length()>0 && "on".equals(ifRemember))?true:false;
            ReturnT<String> result= loginService.login(request, response, userName, password, ifRem);
            return result;
        }
    }

XxlJobQuery.java

（这里有说法，为什么我这篇特意写了一个这个查询类，抛砖引玉，在新手篇里面我介绍过，xxl job 是有数据库的，意味着我们可以很容易拓展）

/**
     * @Author: JCccc
     * @Date: 2022-6-2 14:23
     * @Description: xxl job rest api
     */
    public class XxlJobQuery {
    
    	private	int start;
    	private int length;
    	private int triggerStatus;
    	private String jobDesc;
    	private String executorHandler;
    	private String author;
    	private int jobGroup;
    
    	public int getStart() {
    		return start;
    	}
    
    	public void setStart(int start) {
    		this.start = start;
    	}
    
    	public int getLength() {
    		return length;
    	}
    
    	public void setLength(int length) {
    		this.length = length;
    	}
    
    	public int getTriggerStatus() {
    		return triggerStatus;
    	}
    
    	public void setTriggerStatus(int triggerStatus) {
    		this.triggerStatus = triggerStatus;
    	}
    
    	public String getJobDesc() {
    		return jobDesc;
    	}
    
    	public void setJobDesc(String jobDesc) {
    		this.jobDesc = jobDesc;
    	}
    
    	public String getExecutorHandler() {
    		return executorHandler;
    	}
    
    	public void setExecutorHandler(String executorHandler) {
    		this.executorHandler = executorHandler;
    	}
    
    	public String getAuthor() {
    		return author;
    	}
    
    	public void setAuthor(String author) {
    		this.author = author;
    	}
    
    	public int getJobGroup() {
    		return jobGroup;
    	}
    
    	public void setJobGroup(int jobGroup) {
    		this.jobGroup = jobGroup;
    	}
    }

② 在接入xxl job 的demo上 开始玩动态调度，其实就是调用admin里我们刚才写的提供的接口

> PS： 本篇里面有些不好的编码习惯，例如返回值用Map；打印用的输出，没用log； 接口返回没有统一返回数据等等， 因为我该篇是为了传递 怎么动态调度使用，具体细节大家自行调整就行，我们都是成年人，不要在意我这些点。

先是pom.xml 引入使用的一些jar：

（一个是fastjson，大家别学我，我是为了实战示例图方便，用的JsonObject来传参）

（一个是httpClient ，用于调用admin服务的api接口）

<dependency>
                <groupId>commons-httpclient</groupId>
                <artifactId>commons-httpclient</artifactId>
                <version>3.1</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>1.2.47</version>
            </dependency>

![4fd35be8e2d34864955d4f549ccc58c1.png][]

XxlJobInfo.java

这个是原作者的其实，因为我们本质还是调用了作者xxl job提供的 XxlJobService 里面的方法。

import java.util.Date;
    
    /**
     * xxl-job info
     *
     * @author xuxueli  2016-1-12 18:25:49
     */
    public class XxlJobInfo {
    	
    	private int id;				// 主键ID
    	private int jobGroup;		// 执行器主键ID
    	private String jobDesc;     // 备注
    	private String jobCron;
    	private Date addTime;
    	private Date updateTime;
    	private String author;		// 负责人
    	private String alarmEmail;	// 报警邮件
    	private String scheduleType;			// 调度类型
    	private String scheduleConf;			// 调度配置，值含义取决于调度类型
    	private String misfireStrategy;			// 调度过期策略
    	private String executorRouteStrategy;	// 执行器路由策略
    	private String executorHandler;		    // 执行器，任务Handler名称
    	private String executorParam;		    // 执行器，任务参数
    	private String executorBlockStrategy;	// 阻塞处理策略
    	private int executorTimeout;     		// 任务执行超时时间，单位秒
    	private int executorFailRetryCount;		// 失败重试次数
    	private String glueType;		// GLUE类型	#com.xxl.job.core.glue.GlueTypeEnum
    	private String glueSource;		// GLUE源代码
    	private String glueRemark;		// GLUE备注
    	private Date glueUpdatetime;	// GLUE更新时间
    	private String childJobId;		// 子任务ID，多个逗号分隔
    	private int triggerStatus;		// 调度状态：0-停止，1-运行
    	private long triggerLastTime;	// 上次调度时间
    	private long triggerNextTime;	// 下次调度时间
    
    	public String getJobCron() {
    		return jobCron;
    	}
    
    	public void setJobCron(String jobCron) {
    		this.jobCron = jobCron;
    	}
    
    	public int getId() {
    		return id;
    	}
    
    	public void setId(int id) {
    		this.id = id;
    	}
    
    	public int getJobGroup() {
    		return jobGroup;
    	}
    
    	public void setJobGroup(int jobGroup) {
    		this.jobGroup = jobGroup;
    	}
    
    	public String getJobDesc() {
    		return jobDesc;
    	}
    
    	public void setJobDesc(String jobDesc) {
    		this.jobDesc = jobDesc;
    	}
    
    	public Date getAddTime() {
    		return addTime;
    	}
    
    	public void setAddTime(Date addTime) {
    		this.addTime = addTime;
    	}
    
    	public Date getUpdateTime() {
    		return updateTime;
    	}
    
    	public void setUpdateTime(Date updateTime) {
    		this.updateTime = updateTime;
    	}
    
    	public String getAuthor() {
    		return author;
    	}
    
    	public void setAuthor(String author) {
    		this.author = author;
    	}
    
    	public String getAlarmEmail() {
    		return alarmEmail;
    	}
    
    	public void setAlarmEmail(String alarmEmail) {
    		this.alarmEmail = alarmEmail;
    	}
    
    	public String getScheduleType() {
    		return scheduleType;
    	}
    
    	public void setScheduleType(String scheduleType) {
    		this.scheduleType = scheduleType;
    	}
    
    	public String getScheduleConf() {
    		return scheduleConf;
    	}
    
    	public void setScheduleConf(String scheduleConf) {
    		this.scheduleConf = scheduleConf;
    	}
    
    	public String getMisfireStrategy() {
    		return misfireStrategy;
    	}
    
    	public void setMisfireStrategy(String misfireStrategy) {
    		this.misfireStrategy = misfireStrategy;
    	}
    
    	public String getExecutorRouteStrategy() {
    		return executorRouteStrategy;
    	}
    
    	public void setExecutorRouteStrategy(String executorRouteStrategy) {
    		this.executorRouteStrategy = executorRouteStrategy;
    	}
    
    	public String getExecutorHandler() {
    		return executorHandler;
    	}
    
    	public void setExecutorHandler(String executorHandler) {
    		this.executorHandler = executorHandler;
    	}
    
    	public String getExecutorParam() {
    		return executorParam;
    	}
    
    	public void setExecutorParam(String executorParam) {
    		this.executorParam = executorParam;
    	}
    
    	public String getExecutorBlockStrategy() {
    		return executorBlockStrategy;
    	}
    
    	public void setExecutorBlockStrategy(String executorBlockStrategy) {
    		this.executorBlockStrategy = executorBlockStrategy;
    	}
    
    	public int getExecutorTimeout() {
    		return executorTimeout;
    	}
    
    	public void setExecutorTimeout(int executorTimeout) {
    		this.executorTimeout = executorTimeout;
    	}
    
    	public int getExecutorFailRetryCount() {
    		return executorFailRetryCount;
    	}
    
    	public void setExecutorFailRetryCount(int executorFailRetryCount) {
    		this.executorFailRetryCount = executorFailRetryCount;
    	}
    
    	public String getGlueType() {
    		return glueType;
    	}
    
    	public void setGlueType(String glueType) {
    		this.glueType = glueType;
    	}
    
    	public String getGlueSource() {
    		return glueSource;
    	}
    
    	public void setGlueSource(String glueSource) {
    		this.glueSource = glueSource;
    	}
    
    	public String getGlueRemark() {
    		return glueRemark;
    	}
    
    	public void setGlueRemark(String glueRemark) {
    		this.glueRemark = glueRemark;
    	}
    
    	public Date getGlueUpdatetime() {
    		return glueUpdatetime;
    	}
    
    	public void setGlueUpdatetime(Date glueUpdatetime) {
    		this.glueUpdatetime = glueUpdatetime;
    	}
    
    	public String getChildJobId() {
    		return childJobId;
    	}
    
    	public void setChildJobId(String childJobId) {
    		this.childJobId = childJobId;
    	}
    
    	public int getTriggerStatus() {
    		return triggerStatus;
    	}
    
    	public void setTriggerStatus(int triggerStatus) {
    		this.triggerStatus = triggerStatus;
    	}
    
    	public long getTriggerLastTime() {
    		return triggerLastTime;
    	}
    
    	public void setTriggerLastTime(long triggerLastTime) {
    		this.triggerLastTime = triggerLastTime;
    	}
    
    	public long getTriggerNextTime() {
    		return triggerNextTime;
    	}
    
    	public void setTriggerNextTime(long triggerNextTime) {
    		this.triggerNextTime = triggerNextTime;
    	}
    }

XxlJobUtil.java

import com.alibaba.fastjson.JSONObject;
    import org.apache.commons.httpclient.*;
    import org.apache.commons.httpclient.methods.GetMethod;
    import org.apache.commons.httpclient.methods.PostMethod;
    import org.apache.commons.httpclient.methods.RequestEntity;
    import org.apache.commons.httpclient.methods.StringRequestEntity;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    
    /**
     * @Author: JCccc
     * @Date: 2022-6-22 9:51
     * @Description:
     */
    public class XxlJobUtil {
        private static String cookie="";
    
    
        /**
         * 查询现有的任务（可以关注这个整个调用链，可以自己模仿着写其他的拓展接口）
         * @param url
         * @param requestInfo
         * @return
         * @throws HttpException
         * @throws IOException
         */
        public static JSONObject pageList(String url,JSONObject requestInfo) throws HttpException, IOException {
            String path = "/api/jobinfo/pageList";
            String targetUrl = url + path;
            HttpClient httpClient = new HttpClient();
            PostMethod post = new PostMethod(targetUrl);
            post.setRequestHeader("cookie", cookie);
            RequestEntity requestEntity = new StringRequestEntity(requestInfo.toString(), "application/json", "utf-8");
            post.setRequestEntity(requestEntity);
            httpClient.executeMethod(post);
            JSONObject result = new JSONObject();
            result = getJsonObject(post, result);
            System.out.println(result.toJSONString());
            return result;
        }
    
    
    
        /**
         * 新增/编辑任务
         * @param url
         * @param requestInfo
         * @return
         * @throws HttpException
         * @throws IOException
         */
        public static JSONObject addJob(String url,JSONObject requestInfo) throws HttpException, IOException {
            String path = "/api/jobinfo/save";
            String targetUrl = url + path;
            HttpClient httpClient = new HttpClient();
            PostMethod post = new PostMethod(targetUrl);
            post.setRequestHeader("cookie", cookie);
            RequestEntity requestEntity = new StringRequestEntity(requestInfo.toString(), "application/json", "utf-8");
            post.setRequestEntity(requestEntity);
            httpClient.executeMethod(post);
            JSONObject result = new JSONObject();
            result = getJsonObject(post, result);
            System.out.println(result.toJSONString());
            return result;
        }
    
        /**
         * 删除任务
         * @param url
         * @param id
         * @return
         * @throws HttpException
         * @throws IOException
         */
        public static JSONObject deleteJob(String url,int id) throws HttpException, IOException {
            String path = "/api/jobinfo/delete?id="+id;
            return doGet(url,path);
        }
    
        /**
         * 开始任务
         * @param url
         * @param id
         * @return
         * @throws HttpException
         * @throws IOException
         */
        public static JSONObject startJob(String url,int id) throws HttpException, IOException {
            String path = "/api/jobinfo/start?id="+id;
            return doGet(url,path);
        }
    
        /**
         * 停止任务
         * @param url
         * @param id
         * @return
         * @throws HttpException
         * @throws IOException
         */
        public static JSONObject stopJob(String url,int id) throws HttpException, IOException {
            String path = "/api/jobinfo/stop?id="+id;
            return doGet(url,path);
        }
    
        public static JSONObject doGet(String url,String path) throws HttpException, IOException {
            String targetUrl = url + path;
            HttpClient httpClient = new HttpClient();
            HttpMethod get = new GetMethod(targetUrl);
            get.setRequestHeader("cookie", cookie);
            httpClient.executeMethod(get);
            JSONObject result = new JSONObject();
            result = getJsonObject(get, result);
            return result;
        }
    
        private static JSONObject getJsonObject(HttpMethod postMethod, JSONObject result) throws IOException {
            if (postMethod.getStatusCode() == HttpStatus.SC_OK) {
                InputStream inputStream = postMethod.getResponseBodyAsStream();
                BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));
                StringBuffer stringBuffer = new StringBuffer();
                String str;
                while((str = br.readLine()) != null){
                    stringBuffer.append(str);
                }
                String response = new String(stringBuffer);
                br.close();
    
                return (JSONObject) JSONObject.parse(response);
            } else {
                return null;
            }
    
    
        }
    
        /**
         * 登录
         * @param url
         * @param userName
         * @param password
         * @return
         * @throws HttpException
         * @throws IOException
         */
    
        public static String login(String url, String userName, String password) throws HttpException, IOException {
            String path = "/api/jobinfo/login?userName="+userName+"&password="+password;
            String targetUrl = url + path;
            HttpClient httpClient = new HttpClient();
            HttpMethod get = new GetMethod((targetUrl));
            httpClient.executeMethod(get);
            if (get.getStatusCode() == 200) {
                Cookie[] cookies = httpClient.getState().getCookies();
                StringBuffer tmpcookies = new StringBuffer();
                for (Cookie c : cookies) {
                    tmpcookies.append(c.toString() + ";");
                }
                cookie = tmpcookies.toString();
            } else {
                try {
                    cookie = "";
                } catch (Exception e) {
                    cookie="";
                }
            }
            return cookie;
        }
    }

XxlJobController.java

（用于模拟触发我们的任务创建、编辑、删除、停止等等）

import java.util.Date;
    import com.alibaba.fastjson.JSONObject;
    import org.springframework.web.bind.annotation.*;
    import java.io.IOException;
    
    /**
     * @Author: JCccc
     * @Date: 2022-6-22 9:26
     * @Description:
     */
    @RestController
    public class XxlJobController {
    
    
        @RequestMapping(value = "/pageList",method = RequestMethod.GET)
        public Object pageList() throws IOException {
            //int jobGroup, int triggerStatus, String jobDesc, String executorHandler, String author
            JSONObject test=new JSONObject();
            test.put("length",10);
            XxlJobUtil.login("http://127.0.0.1:8961/xxl-job-admin","admin","123456");
            JSONObject response = XxlJobUtil.pageList("http://127.0.0.1:8961/xxl-job-admin", test);
            return  response.get("data");
        }
    
        @RequestMapping(value = "/add",method = RequestMethod.GET)
        public void add() throws IOException {
            XxlJobInfo xxlJobInfo=new XxlJobInfo();
            xxlJobInfo.setJobCron("0/5 * * * * ?");
            xxlJobInfo.setJobGroup(3);
            xxlJobInfo.setJobDesc("我来试试");
            xxlJobInfo.setAddTime(new Date());
            xxlJobInfo.setUpdateTime(new Date());
            xxlJobInfo.setAuthor("JCccc");
            xxlJobInfo.setAlarmEmail("864477182@com");
            xxlJobInfo.setScheduleType("CRON");
            xxlJobInfo.setScheduleConf("0/5 * * * * ?");
            xxlJobInfo.setMisfireStrategy("DO_NOTHING");
            xxlJobInfo.setExecutorRouteStrategy("FIRST");
            xxlJobInfo.setExecutorHandler("clockInJobHandler");
            xxlJobInfo.setExecutorParam("att");
            xxlJobInfo.setExecutorBlockStrategy("SERIAL_EXECUTION");
            xxlJobInfo.setExecutorTimeout(0);
            xxlJobInfo.setExecutorFailRetryCount(1);
            xxlJobInfo.setGlueType("BEAN");
            xxlJobInfo.setGlueSource("");
            xxlJobInfo.setGlueRemark("GLUE代码初始化");
            xxlJobInfo.setGlueUpdatetime(new Date());
            JSONObject test = (JSONObject) JSONObject.toJSON(xxlJobInfo);
            XxlJobUtil.login("http://127.0.0.1:8961/xxl-job-admin","admin","123456");
            JSONObject response = XxlJobUtil.addJob("http://127.0.0.1:8961/xxl-job-admin", test);
            if (response.containsKey("code") && 200 == (Integer) response.get("code")) {
                System.out.println("新增成功");
            } else {
                System.out.println("新增失败");
            }
    
    
        }
    
        @RequestMapping(value = "/stop/{jobId}",method = RequestMethod.GET)
        public void stop(@PathVariable("jobId") Integer jobId) throws IOException {
    
            XxlJobUtil.login("http://127.0.0.1:8961/xxl-job-admin","admin","123456");
            JSONObject response = XxlJobUtil.stopJob("http://127.0.0.1:8961/xxl-job-admin", jobId);
            if (response.containsKey("code") && 200 == (Integer) response.get("code")) {
                System.out.println("任务停止成功");
            } else {
                System.out.println("任务停止失败");
            }
        }
    
        @RequestMapping(value = "/delete/{jobId}",method = RequestMethod.GET)
        public void delete(@PathVariable("jobId") Integer jobId) throws IOException {
    
            XxlJobUtil.login("http://127.0.0.1:8961/xxl-job-admin","admin","123456");
            JSONObject response = XxlJobUtil.deleteJob("http://127.0.0.1:8961/xxl-job-admin", jobId);
            if (response.containsKey("code") && 200 == (Integer) response.get("code")) {
                System.out.println("任务移除成功");
            } else {
                System.out.println("任务移除失败");
            }
        }
    
    
        @RequestMapping(value = "/start/{jobId}",method = RequestMethod.GET)
        public void start(@PathVariable("jobId") Integer jobId) throws IOException {
    
            XxlJobUtil.login("http://127.0.0.1:8961/xxl-job-admin","admin","123456");
            JSONObject response = XxlJobUtil.startJob("http://127.0.0.1:8961/xxl-job-admin", jobId);
            if (response.containsKey("code") && 200 == (Integer) response.get("code")) {
                System.out.println("任务启动成功");
            } else {
                System.out.println("任务启动失败");
            }
        }
        
    }

#       开始验证测试 #

##       创建任务： ##

##  ##

### 打开admin的HTML页面，这是原来上次我们手动创建的任务：   ![acbacbd450484b199b201714a00f23ca.png][] ###

现在我们通过api调用创建一个新的任务：  
![4654d1c292e5409eb7fb294eafb3c66b.png][]

调用接口后，可以看的任务创建出来了，按照我们的cron和其他调度规则开始跑了：

![099e2be9aab444d08f91988392d7c9e3.png][]

![614b1d436b3f4ba8bae100cf4c605fea.png][]

然后我们调用停止任务接口（通过任务ID停止）：  
![d20f06dbc633422e8ce35b22551a27ed.png][]

![454eb25d617d4fcf84ceed7d6dcf1fa7.png][]

停在成功：

![567b50b4b3b54209a89dcd6a454d0e82.png][]

那么玩到这，可能大伙会有疑问，我怎么知道哪个我要停止的任务的任务ID是哪个？

所以我抛砖引玉写了个查询列表接口，大家可以意会一下，数据都在的，数据还不好拓展么，什么业务场景，怎么使用怎么调度，都可以自由发挥啊：  
![856f83fbd12b40e68985a4a66ddf660a.png][]

数据就在库里，自己查不就好了：  
![949b68aad8564c858ac945f22594419f.png][]

剩下还有启动 start接口，删除delete接口，修改update接口，我就不一一展示测试了。

这些增删改查，怎么组合使用，什么业务使用，大家自己玩起来就行。

好吧，该篇就到这。

[Springboot _ xxljob _-CSDN]: https://blog.csdn.net/qq_35387940/article/details/125275354
[4a709c1095464b588665d6cf516e8c97.png]: https://img-blog.csdnimg.cn/4a709c1095464b588665d6cf516e8c97.png
[d434726bdb0741848581cebb9b68af16.jpeg]: https://img-blog.csdnimg.cn/d434726bdb0741848581cebb9b68af16.jpeg
[c0283b49a5a243238c0b9eedb1a0b908.png]: https://img-blog.csdnimg.cn/c0283b49a5a243238c0b9eedb1a0b908.png
[4fd35be8e2d34864955d4f549ccc58c1.png]: https://img-blog.csdnimg.cn/4fd35be8e2d34864955d4f549ccc58c1.png
[acbacbd450484b199b201714a00f23ca.png]: https://img-blog.csdnimg.cn/acbacbd450484b199b201714a00f23ca.png
[4654d1c292e5409eb7fb294eafb3c66b.png]: https://img-blog.csdnimg.cn/4654d1c292e5409eb7fb294eafb3c66b.png
[099e2be9aab444d08f91988392d7c9e3.png]: https://img-blog.csdnimg.cn/099e2be9aab444d08f91988392d7c9e3.png
[614b1d436b3f4ba8bae100cf4c605fea.png]: https://img-blog.csdnimg.cn/614b1d436b3f4ba8bae100cf4c605fea.png
[d20f06dbc633422e8ce35b22551a27ed.png]: https://img-blog.csdnimg.cn/d20f06dbc633422e8ce35b22551a27ed.png
[454eb25d617d4fcf84ceed7d6dcf1fa7.png]: https://img-blog.csdnimg.cn/454eb25d617d4fcf84ceed7d6dcf1fa7.png
[567b50b4b3b54209a89dcd6a454d0e82.png]: https://img-blog.csdnimg.cn/567b50b4b3b54209a89dcd6a454d0e82.png
[856f83fbd12b40e68985a4a66ddf660a.png]: https://img-blog.csdnimg.cn/856f83fbd12b40e68985a4a66ddf660a.png
[949b68aad8564c858ac945f22594419f.png]: https://img-blog.csdnimg.cn/949b68aad8564c858ac945f22594419f.png