XXL

发布时间：2024-11-23 18:04

购买泳衣时，通常会标出'XS/S/M/L/XL/XXL'等尺码，选择比平时略小的尺码 #生活常识# #购物消费技巧# #服装尺码对照#

        在任务调度中心可以进行新建任务，新建任务之后可以在任务列表中查看相关任务，任务可以根据我们配置的cron表达式进行任务调度，或者也可以在任务列表中执行、暂停、删除和查看相关运行日志等操作。

一、任务调度中心管理

1、新建任务

、

2、任务列表任务操作

二、任务创建与操作

      我们了解到xxl-job是基于quartz来实现定时任务的(其实任务调度中心任务执行基于quartz，任务执行器就是一个被调用执行的服务)

1、任务创建

调用JobInfoController的add方法添加任务

@RequestMapping("/add")

@ResponseBody

public ReturnT<String> add(XxlJobInfo jobInfo) {

return xxlJobService.add(jobInfo);

}

调用XxlJobService的add方法，新建quartz任务

@Override

public ReturnT<String> add(XxlJobInfo jobInfo) {

XxlJobGroup group = xxlJobGroupDao.load(jobInfo.getJobGroup());

xxlJobInfoDao.save(jobInfo);

if (jobInfo.getId() < 1) {

return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_add")+I18nUtil.getString("system_fail")) );

}

String qz_group = String.valueOf(jobInfo.getJobGroup());

String qz_name = String.valueOf(jobInfo.getId());

try {

XxlJobDynamicScheduler.addJob(qz_name, qz_group, jobInfo.getJobCron());

return ReturnT.SUCCESS;

} catch (SchedulerException e) {

logger.error(e.getMessage(), e);

try {

xxlJobInfoDao.delete(jobInfo.getId());

XxlJobDynamicScheduler.removeJob(qz_name, qz_group);

} catch (SchedulerException e1) {

logger.error(e.getMessage(), e1);

}

return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_add")+I18nUtil.getString("system_fail"))+":" + e.getMessage());

}

}

数据库持久化数据：

在XxlJobDynamicScheduler中调用quartz的创建任务方法构建定时任务，定时任务执行类为QuartzJobBean的子类RemoteHttpJobBean，在定时任务执行时RemoteHttpJobBean会调用任务执行器接口，执行相关任务

public static boolean addJob(String jobName, String jobGroup, String cronExpression) throws SchedulerException {

TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);

JobKey jobKey = new JobKey(jobName, jobGroup);

if (checkExists(jobName, jobGroup)) {

logger.info(">>>>>>>>> addJob fail, job already exist, jobGroup:{}, jobName:{}", jobGroup, jobName);

return false;

}

CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression).withMisfireHandlingInstructionDoNothing();

CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(cronScheduleBuilder).build();

Class<? extends Job> jobClass_ = RemoteHttpJobBean.class;

JobDetail jobDetail = JobBuilder.newJob(jobClass_).withIdentity(jobKey).build();

Date date = scheduler.scheduleJob(jobDetail, cronTrigger);

logger.info(">>>>>>>>>>> addJob success, jobDetail:{}, cronTrigger:{}, date:{}", jobDetail, cronTrigger, date);

return true;

}

2、删除任务

删除任务简单来说就是将任务从quartz中移除，不再执行就好

JobInfoController中提供了删除任务接口

@RequestMapping("/remove")

@ResponseBody

public ReturnT<String> remove(int id) {

return xxlJobService.remove(id);

}

在XxlJobService中根据逻辑id删除任务，并且删除数据库中相关持久化数据

@Override

public ReturnT<String> remove(int id) {

XxlJobInfo xxlJobInfo = xxlJobInfoDao.loadById(id);

String group = String.valueOf(xxlJobInfo.getJobGroup());

String name = String.valueOf(xxlJobInfo.getId());

try {

XxlJobDynamicScheduler.removeJob(name, group);

xxlJobInfoDao.delete(id);

xxlJobLogDao.delete(id);

xxlJobLogGlueDao.deleteByJobId(id);

return ReturnT.SUCCESS;

} catch (SchedulerException e) {

logger.error(e.getMessage(), e);

}

return ReturnT.FAIL;

}

在XxlJobDynamicScheduler中调用removeJob方法删除相关任务

public static boolean removeJob(String jobName, String jobGroup) throws SchedulerException {

TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);

boolean result = false;

if (checkExists(jobName, jobGroup)) {

result = scheduler.unscheduleJob(triggerKey);

logger.info(">>>>>>>>>>> removeJob, triggerKey:{}, result [{}]", triggerKey, result);

}

return true;

}

3、暂停任务

暂停任务同意调用quartz的接口进行任务暂停处理

JobInfoController中提供接口处理

@RequestMapping("/pause")

@ResponseBody

public ReturnT<String> pause(int id) {

return xxlJobService.pause(id);

}

调用XxlJobService的paus进行任务停止

@Override

public ReturnT<String> pause(int id) {

XxlJobInfo xxlJobInfo = xxlJobInfoDao.loadById(id);

String group = String.valueOf(xxlJobInfo.getJobGroup());

String name = String.valueOf(xxlJobInfo.getId());

try {

boolean ret = XxlJobDynamicScheduler.pauseJob(name, group);

return ret?ReturnT.SUCCESS:ReturnT.FAIL;

} catch (SchedulerException e) {

logger.error(e.getMessage(), e);

return ReturnT.FAIL;

}

}

调用XxlJobDynamicScheduler的pauseJob进行任务停止，最终还是执行quartz 的接口完成任务暂停

public static boolean pauseJob(String jobName, String jobGroup) throws SchedulerException {

TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);

boolean result = false;

if (checkExists(jobName, jobGroup)) {

scheduler.pauseTrigger(triggerKey);

result = true;

logger.info(">>>>>>>>>>> pauseJob success, triggerKey:{}", triggerKey);

} else {

logger.info(">>>>>>>>>>> pauseJob fail, triggerKey:{}", triggerKey);

}

return result;

}

4、恢复任务

恢复任务就是将暂停的任务继续重新执行

JobInfoController中提供接口重新执行任务

@RequestMapping("/resume")

@ResponseBody

public ReturnT<String> resume(int id) {

return xxlJobService.resume(id);

}

调用XxlJobService的resume接口继续任务

@Override

public ReturnT<String> resume(int id) {

XxlJobInfo xxlJobInfo = xxlJobInfoDao.loadById(id);

String group = String.valueOf(xxlJobInfo.getJobGroup());

String name = String.valueOf(xxlJobInfo.getId());

try {

boolean ret = XxlJobDynamicScheduler.resumeJob(name, group);

return ret?ReturnT.SUCCESS:ReturnT.FAIL;

} catch (SchedulerException e) {

logger.error(e.getMessage(), e);

return ReturnT.FAIL;

}

}

在XllJobDynamicScheduler中调用quartz的接口重新开启任务

public static boolean resumeJob(String jobName, String jobGroup) throws SchedulerException {

TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);

boolean result = false;

if (checkExists(jobName, jobGroup)) {

scheduler.resumeTrigger(triggerKey);

result = true;

logger.info(">>>>>>>>>>> resumeJob success, triggerKey:{}", triggerKey);

} else {

logger.info(">>>>>>>>>>> resumeJob fail, triggerKey:{}", triggerKey);

}

return result;

}

 5、更新任务

任务更新操作就是更新一下任务相关参数

XxlJobController中提供update接口，完成任务更新操作

@RequestMapping("/update")

@ResponseBody

public ReturnT<String> update(XxlJobInfo jobInfo) {

return xxlJobService.update(jobInfo);

}

在XxlJobService中调用update更新任务，并更新相关数据库中的数据

@Override

public ReturnT<String> update(XxlJobInfo jobInfo) {

XxlJobInfo exists_jobInfo = xxlJobInfoDao.loadById(jobInfo.getId());

if (exists_jobInfo == null) {

return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_id")+I18nUtil.getString("system_not_found")) );

}

exists_jobInfo.setJobCron(jobInfo.getJobCron());

exists_jobInfo.setJobDesc(jobInfo.getJobDesc());

exists_jobInfo.setAuthor(jobInfo.getAuthor());

exists_jobInfo.setAlarmEmail(jobInfo.getAlarmEmail());

exists_jobInfo.setExecutorRouteStrategy(jobInfo.getExecutorRouteStrategy());

exists_jobInfo.setExecutorHandler(jobInfo.getExecutorHandler());

exists_jobInfo.setExecutorParam(jobInfo.getExecutorParam());

exists_jobInfo.setExecutorBlockStrategy(jobInfo.getExecutorBlockStrategy());

exists_jobInfo.setExecutorFailStrategy(jobInfo.getExecutorFailStrategy());

exists_jobInfo.setExecutorTimeout(jobInfo.getExecutorTimeout());

exists_jobInfo.setChildJobId(jobInfo.getChildJobId());

xxlJobInfoDao.update(exists_jobInfo);

String qz_group = String.valueOf(exists_jobInfo.getJobGroup());

String qz_name = String.valueOf(exists_jobInfo.getId());

try {

boolean ret = XxlJobDynamicScheduler.rescheduleJob(qz_group, qz_name, exists_jobInfo.getJobCron());

return ret?ReturnT.SUCCESS:ReturnT.FAIL;

} catch (SchedulerException e) {

logger.error(e.getMessage(), e);

}

return ReturnT.FAIL;

}

在XxlJobDynamicScheduler中调用quartz相关方法重新配置定时任务

public static boolean rescheduleJob(String jobGroup, String jobName, String cronExpression) throws SchedulerException {

if (!checkExists(jobName, jobGroup)) {

logger.info(">>>>>>>>>>> rescheduleJob fail, job not exists, JobGroup:{}, JobName:{}", jobGroup, jobName);

return false;

}

TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);

CronTrigger oldTrigger = (CronTrigger) scheduler.getTrigger(triggerKey);

if (oldTrigger != null) {

String oldCron = oldTrigger.getCronExpression();

if (oldCron.equals(cronExpression)){

return true;

}

CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression).withMisfireHandlingInstructionDoNothing();

oldTrigger = oldTrigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(cronScheduleBuilder).build();

scheduler.rescheduleJob(triggerKey, oldTrigger);

} else {

CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression).withMisfireHandlingInstructionDoNothing();

CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(cronScheduleBuilder).build();

JobKey jobKey = new JobKey(jobName, jobGroup);

JobDetail jobDetail = scheduler.getJobDetail(jobKey);

HashSet<Trigger> triggerSet = new HashSet<Trigger>();

triggerSet.add(cronTrigger);

scheduler.scheduleJob(jobDetail, triggerSet, true);

}

logger.info(">>>>>>>>>>> resumeJob success, JobGroup:{}, JobName:{}", jobGroup, jobName);

return true;

}

6、立即执行任务

在任务调度中心可以立即进行任务调用

在JobInfoController中提供接口直接进行任务调用

@RequestMapping("/trigger")

@ResponseBody

public ReturnT<String> triggerJob(int id) {

return xxlJobService.triggerJob(id);

}

 在XxlJobService中调用接口triggerJob可以直接进行任务调度

@Override

public ReturnT<String> triggerJob(int id) {

JobTriggerPoolHelper.trigger(id);

return ReturnT.SUCCESS;

在JobTriggerPoolHelper的trigger方法会将任务id添加多线程中，最终的实现同样是调用RemoteHttpJobBean的executeInternal进行任务调度，不是依赖quartz实现，接下来我们会用一篇博客详细讲解一下。

网址：XXL https://www.yuejiaxmz.com/news/view/216516

上一篇：查找： 关键字=任务管理器
下一篇：完成任务=完成结果？管理者必须跨

相关内容

【各季节的穿衣搭配】
【xxxl是多大号】生活小贴士之—xxxl是多大号
【各季节服装搭配方式】
北美生活小贴士：中国和美国衣服尺码对比
M=美L=烂？大润发就女装尺码表致歉：物料已撤，将加强管理
环保内饰理念，绿色出行新选择荣威Ei5
【各个季节的服装搭配】
PolyBoard(橱柜设计软件)免费版下载
约翰·威克/分布式新闻头条项目

随便看看

最新动态分享

热点动态分享

  1. 1500大卡的食物对照表
    2828
  2. 李居明2025年九宫图风水方位图解，乙巳蛇年家居风水布置图
    2700
  3. 如何关闭今日头条推送的直播 关闭今日头条推送直播方法
    2642
  4. 2025独生子女证停办了吗？记牢此日期还可补领
    2364
  5. 二手商铺过户费太高了怎么办 二手商铺过户费怎么算 商铺卖100万缴多少税
    2212
  6. 【荣耀智慧空间】这样设置荣耀手机 超省电 从此告别一天一充
    1842
  7. 魔兽世界怀旧服烹饪1到300升级攻略
    1653
  8. 哪些旧书收藏价值高 80年代旧书收藏价格一览
    1501
  9. 四川一敬老院藏污纳垢 卖淫女光天化日拉客
    1400
  10. 屁屁影院43·ccom——让你体验前所未有的视听盛宴！
    1314

专题