Spring Boot集成Quartz定时任务详解

在实际项目开发中，我们想在规定时间执行一些任务，所以会经常用到定时任务。当然定时任务有很多种，本文我来介绍下我在项目中用到的quartz定时任务，项目架构采用的是微服务，主要写Spring Boot集成Quartz详解。一、开发环境 MySql、Mybatis、PageHelper、Spring Boot、Quartz二、pom.xml依赖<dependency>.

十点摆码

3828人浏览 · 2018-07-14 11:00:07

十点摆码 · 2018-07-14 11:00:07 发布

在实际项目开发中，我们想在规定时间执行一些任务，所以会经常用到定时任务。当然定时任务有很多种，本文我来介绍下我在项目中用到的quartz定时任务，项目架构采用的是微服务，主要写Spring Boot集成Quartz详解。

一、开发环境

MySql、Mybatis、PageHelper、Spring Boot、Quartz

二、pom.xml依赖

<dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.2.1</version>
        </dependency>
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz-jobs</artifactId>
            <version>2.2.1</version>
        </dependency>

三、application.properties配置

# 固定前缀org.quartz
# 定时任务开关，true-开  false-关
quartz.autoStartup=false
quartz.delaySeconds=10
org.quartz.scheduler.instanceName=DefaultQuartzScheduler
org.quartz.scheduler.instanceId=AUTO
org.quartz.scheduler.rmi.export=false
org.quartz.scheduler.rmi.proxy=false
org.quartz.scheduler.wrapJobExecutionInUserTransaction=false
org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
# 并发个数
org.quartz.threadPool.threadCount=10
# 优先级
org.quartz.threadPool.threadPriority=5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread=true
org.quartz.jobStore.misfireThreshold=5000
# 默认存储在内存中
#org.quartz.jobStore.class=org.quartz.simpl.RAMJobStore
#持久化
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.tablePrefix=QRTZ_
org.quartz.jobStore.dataSource=qzDS
org.quartz.dataSource.qzDS.maxConnections=10

四、quartzConfig配置

package com.fintech.modules.base.quartz;

import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.impl.StdScheduler;
import org.quartz.impl.StdSchedulerFactory;
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.beans.factory.config.PropertiesFactoryBean;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.ClassPathResource;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;

import javax.sql.DataSource;
import java.io.IOException;
import java.util.Properties;

/**
 * @author lc
 * @date: 2017/12/4 15:03
 * @description: quartz配置加载类
 */
@Configuration
public class QuartzConfig {
    private Logger logger = LoggerFactory.getLogger(getClass());

    @Value("${quartz.autoStartup}")
    private Boolean autoStartup;

    @Value("${quartz.delaySeconds}")
    private Integer delaySeconds;

    @Value("${org.quartz.scheduler.instanceName}")
    private String schedulerInstanceName;

    @Value("${org.quartz.scheduler.rmi.export}")
    private String schedulerRmiExport;

    @Value("${org.quartz.scheduler.rmi.proxy}")
    private String schedulerRmiProxy;

    @Value("${org.quartz.scheduler.wrapJobExecutionInUserTransaction}")
    private String schedulerWrapJobExecutionInUserTransaction;

    @Value("${org.quartz.threadPool.class}")
    private String threadPoolClass;

    @Value("${org.quartz.threadPool.threadCount}")
    private String threadPoolThreadCount;

    @Value("${org.quartz.threadPool.threadPriority}")
    private String threadPoolThreadPriority;

    @Value("${org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread}")
    private String threadPoolThreadsInheritContextClassLoaderOfInitializingThread;

    @Value("${org.quartz.jobStore.misfireThreshold}")
    private String jobStoreMisfireThreshold;

    @Value("${org.quartz.jobStore.driverDelegateClass}")
    private String jobStoreDriverDelegateClass;

    @Value("${org.quartz.jobStore.class}")
    private String jobStoreClass;

    @Value("${org.quartz.jobStore.tablePrefix}")
    private String jobStoreTablePrefix;

    @Value("${org.quartz.jobStore.dataSource}")
    private String jobStoreDataSource;

    /*@Value("${org.quartz.dataSource.qzDS.maxConnections}")
    private String dataSourceMaxConnections;

    @Value("${spring.datasource.driver-class-name}")
    private String dataSourceDriver;

    @Value("${spring.datasource.url}")
    private String dataSourceURL;

    @Value("${spring.datasource.username}")
    private String dataSourceUser;

    @Value("${spring.datasource.password}")
    private String dataSourcePassword;*/

    @Bean
    public Properties quartzProperties() throws IOException {
        Properties quartzProperties = new Properties();
        quartzProperties.setProperty("org.quartz.scheduler.instanceName", schedulerInstanceName);
        quartzProperties.setProperty("org.quartz.scheduler.rmi.export", schedulerRmiExport);
        quartzProperties.setProperty("org.quartz.scheduler.rmi.proxy", schedulerRmiProxy);
        quartzProperties.setProperty("org.quartz.scheduler.wrapJobExecutionInUserTransaction", schedulerWrapJobExecutionInUserTransaction);
        quartzProperties.setProperty("org.quartz.threadPool.class", threadPoolClass);
        quartzProperties.setProperty("org.quartz.threadPool.threadCount", threadPoolThreadCount);
        quartzProperties.setProperty("org.quartz.threadPool.threadPriority", threadPoolThreadPriority);
        quartzProperties.setProperty("org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread", threadPoolThreadsInheritContextClassLoaderOfInitializingThread);
        quartzProperties.setProperty("org.quartz.jobStore.misfireThreshold", jobStoreMisfireThreshold);
        quartzProperties.setProperty("org.quartz.jobStore.class", jobStoreClass);
        quartzProperties.setProperty("org.quartz.jobStore.driverDelegateClass", jobStoreDriverDelegateClass);
        quartzProperties.setProperty("org.quartz.jobStore.tablePrefix", jobStoreTablePrefix);
        quartzProperties.setProperty("org.quartz.jobStore.dataSource", jobStoreDataSource);
        /*quartzProperties.setProperty("org.quartz.dataSource.qzDS.maxConnections", dataSourceMaxConnections);
        quartzProperties.setProperty("org.quartz.dataSource.qzDS.driver", dataSourceDriver);
        quartzProperties.setProperty("org.quartz.dataSource.qzDS.URL", dataSourceURL);
        quartzProperties.setProperty("org.quartz.dataSource.qzDS.user", dataSourceUser);
        quartzProperties.setProperty("org.quartz.dataSource.qzDS.password", dataSourcePassword);*/

        return quartzProperties;
    }

    @Bean
    public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource) throws IOException {
        logger.info("开始配置quartz定时任务");
        SchedulerFactoryBean factory = new SchedulerFactoryBean();
        // 加载quartz数据源配置
        factory.setQuartzProperties(quartzProperties());
        // 加载数据源
        factory.setDataSource(dataSource);
        // 将spring上下文放入quartz中, 用于在job执行时获取注入bean
        factory.setApplicationContextSchedulerContextKey("applicationContextKey");

        factory.setOverwriteExistingJobs(true);

        if(autoStartup) {
            // 延时启动
            if(delaySeconds > 0) {
                factory.setStartupDelay(delaySeconds);
            }
            logger.info("quartz开启自动启动定时任务, 延时{}s启动", delaySeconds);
        } else {
            factory.setAutoStartup(false);
            logger.warn("quartz未开启自动启动定时任务");
        }

        logger.info("quartz定时任务配置成功");
        return factory;
    }
}

五、实现

1、新建Java Bean

package com.fintech.modules.quartzjobmanage.dto;

/**
 * @Description: 定时任务bean
 * @author lc
 * @date 2018年5月29日
 */
public class JobAndTriggerDTO {
	/**
	 * 任务名称
	 */
	private String jobName;
	
	/**
	 * 任务所在组
	 */
	private String jobGroup;
	
	/**
	 * 任务类名
	 */
	private String jobClassName;
	
	/**
	 * 触发器名称
	 */
	private String triggerName;
	
	/**
	 * 触发器所在组
	 */
	private String triggerGroup;
	
	/**
	 * 表达式
	 */
	private String cronExpression;
	
	/**
	 * 时区
	 */
	private String timeZoneId;
	
	/**
	 * 状态
	 */
	private String triggerStart;
	
	/**
	 * 创建时间
	 */
	private String startTime;
	
	/**
	 * 上次执行时间
	 */
	private String prevFireTime;
	
	/**
	 * 下次执行时间
	 */
	private String nextFireTime;
	
	public String getTriggerStart() {
		return triggerStart;
	}
	public void setTriggerStart(String triggerStart) {
		this.triggerStart = triggerStart;
	}
	public String getStartTime() {
		return startTime;
	}
	public void setStartTime(String startTime) {
		this.startTime = startTime;
	}
	public String getPrevFireTime() {
		return prevFireTime;
	}
	public void setPrevFireTime(String prevFireTime) {
		this.prevFireTime = prevFireTime;
	}
	public String getNextFireTime() {
		return nextFireTime;
	}
	public void setNextFireTime(String nextFireTime) {
		this.nextFireTime = nextFireTime;
	}
	public String getJobName() {
		return jobName;
	}
	public void setJobName(String jobName) {
		this.jobName = jobName;
	}
	public String getJobGroup() {
		return jobGroup;
	}
	public void setJobGroup(String jobGroup) {
		this.jobGroup = jobGroup;
	}
	public String getJobClassName() {
		return jobClassName;
	}
	public void setJobClassName(String jobClassName) {
		this.jobClassName = jobClassName;
	}
	public String getTriggerName() {
		return triggerName;
	}
	public void setTriggerName(String triggerName) {
		this.triggerName = triggerName;
	}
	public String getTriggerGroup() {
		return triggerGroup;
	}
	public void setTriggerGroup(String triggerGroup) {
		this.triggerGroup = triggerGroup;
	}
	public String getCronExpression() {
		return cronExpression;
	}
	public void setCronExpression(String cronExpression) {
		this.cronExpression = cronExpression;
	}
	public String getTimeZoneId() {
		return timeZoneId;
	}
	public void setTimeZoneId(String timeZoneId) {
		this.timeZoneId = timeZoneId;
	}
}

2、xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >  
<mapper namespace="com.fintech.modules.quartzjobmanage.dao.JobAndTriggerMapper">  
    
<select id="getJobAndTriggerDetails" resultType="com.fintech.modules.quartzjobmanage.dto.JobAndTriggerDTO">
	SELECT
	  qrtz_job_details.JOB_NAME          AS jobName,
	  qrtz_job_details.JOB_GROUP         AS jobGroup,
	  qrtz_job_details.JOB_CLASS_NAME    AS jobClassName,
	  qrtz_triggers.TRIGGER_NAME         AS triggerName,
	  qrtz_triggers.TRIGGER_GROUP        AS triggerGroup,
	  qrtz_cron_triggers.CRON_EXPRESSION AS cronExpression,
	  qrtz_cron_triggers.TIME_ZONE_ID    AS timeZoneId,
	  qrtz_triggers.TRIGGER_STATE        AS triggerStart,
	  FROM_UNIXTIME(qrtz_triggers.START_TIME/1000) AS startTime,
	  FROM_UNIXTIME(qrtz_triggers.PREV_FIRE_TIME/1000) AS prevFireTime,
	  FROM_UNIXTIME(qrtz_triggers.NEXT_FIRE_TIME/1000) AS nextFireTime
	FROM qrtz_job_details
	  JOIN qrtz_triggers
	  JOIN qrtz_cron_triggers
	    ON qrtz_job_details.JOB_NAME = qrtz_triggers.JOB_NAME
	      AND qrtz_triggers.TRIGGER_NAME = qrtz_cron_triggers.TRIGGER_NAME
	      AND qrtz_triggers.TRIGGER_GROUP = qrtz_cron_triggers.TRIGGER_GROUP
 </select>
    
</mapper>

3、dao

package com.fintech.modules.quartzjobmanage.dao;

import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import com.fintech.modules.quartzjobmanage.dto.JobAndTriggerDTO;

/**
 * @Description: 定时任务dao
 * @author lc
 * @date 2018年5月29日
 */
@Mapper
public interface JobAndTriggerMapper {
	
	/**
	 * @Description: 查询定时任务信息
	 * @author lc
	 */
	public List<JobAndTriggerDTO> getJobAndTriggerDetails();
}

4、service

package com.fintech.modules.quartzjobmanage.service;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.fintech.modules.quartzjobmanage.dao.JobAndTriggerMapper;
import com.fintech.modules.quartzjobmanage.dto.JobAndTriggerDTO;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;

/**
 * @Description: 定时任务service
 * @author lc
 * @date 2018年5月29日
 */
@Service
public class JobAndTriggerService{

	@Autowired
	private JobAndTriggerMapper jobAndTriggerMapper;
	
	/**
	 * @Description: 查询定时任务信息
	 * @author lc
	 */
	public PageInfo<JobAndTriggerDTO> getJobAndTriggerDetails(int pageNum, int pageSize) {
		PageHelper.startPage(pageNum, pageSize);
		List<JobAndTriggerDTO> list = jobAndTriggerMapper.getJobAndTriggerDetails();
		PageInfo<JobAndTriggerDTO> page = new PageInfo<JobAndTriggerDTO>(list);
		return page;
	}

}

5、controller

package com.fintech.modules.quartzjobmanage.controller;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;

import java.util.HashMap;
import java.util.Map;

import org.apache.commons.lang3.StringUtils;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

import com.fintech.modules.base.util.SmsException;
import com.fintech.modules.quartzjobmanage.dto.JobAndTriggerDTO;
import com.fintech.modules.quartzjobmanage.service.JobAndTriggerService;
import com.fintech.modules.sms.common.dto.LayuiResult;
import com.github.pagehelper.PageInfo;

/**
 * @author xujunqi
 * @date: 2017/12/9 15:24
 * @description: 定时任务配置控制类
 */
@RestController
@RequestMapping(value = "/quartzjob")
@Api(tags="定时任务配置控制类")
public class QuartzJobController {
    private static Logger logger = LoggerFactory.getLogger(QuartzJobController.class);

    @Autowired
    private Scheduler scheduler;
    @Autowired 
    private JobAndTriggerService jobAndTriggerService;
    
    @ApiOperation(value= "添加定时任务", notes= "添加定时任务")
    @PostMapping(value = "/addjob")
    public String addjobController(@RequestParam(value = "jobClassName") String jobClassName,
                                 @RequestParam(value = "jobGroupName") String jobGroupName,
                                 @RequestParam(value = "cronExpression") String cronExpression) throws Exception {
        addJob(jobClassName, jobGroupName, cronExpression);

        return "定时任务添加成功";
    }

    public void addJob(String jobClassName, String jobGroupName, String cronExpression) throws Exception {
        if(StringUtils.isBlank(jobGroupName)) {
            jobGroupName = Scheduler.DEFAULT_GROUP;
        }
        // 启动调度器
        scheduler.start();
        //构建job信息
        JobDetail jobDetail = JobBuilder.newJob(getClass(jobClassName).getClass()).withIdentity(jobClassName, jobGroupName).build();
        //表达式调度构建器(即任务执行的时间)
        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
        //按新的cronExpression表达式构建一个新的trigger
        CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobClassName, jobGroupName)
                .withSchedule(scheduleBuilder).build();
        try {
            scheduler.scheduleJob(jobDetail, trigger);
        } catch (SchedulerException e) {
            logger.error("创建定时任务失败", e);
            throw new SmsException("创建定时任务失败");
        }
    }
    
/*    @ApiOperation(value= "根据条件查询定时任务", notes= "根据条件查询定时任务")
    @PostMapping(value = "/queryjob")
    public String queryjob(@RequestParam(value = "jobClassName") String jobClassName, @RequestParam(value = "jobGroupName") String jobGroupName) throws Exception {
        jobPause(jobClassName, jobGroupName);

        return "定时任务暂停成功";
    }*/

    @ApiOperation(value= "根据条件暂停定时任务", notes= "根据条件暂停定时任务")
    @PostMapping(value = "/pausejob")
    public String pausejob(@RequestParam(value = "jobClassName") String jobClassName, @RequestParam(value = "jobGroupName") String jobGroupName) throws Exception {
        jobPause(jobClassName, jobGroupName);

        return "定时任务暂停成功";
    }

    public void jobPause(String jobClassName, String jobGroupName) throws Exception {
        if(StringUtils.isBlank(jobGroupName)) {
            jobGroupName = Scheduler.DEFAULT_GROUP;
        }
        // 通过SchedulerFactory获取一个调度器实例
        scheduler.pauseJob(JobKey.jobKey(jobClassName, jobGroupName));
    }

    @ApiOperation(value= "根据条件恢复定时任务", notes= "根据条件恢复定时任务")
    @PostMapping(value = "/resumejob")
    public String resumejob(@RequestParam(value = "jobClassName") String jobClassName, @RequestParam(value = "jobGroupName") String jobGroupName) throws Exception {
        jobresume(jobClassName, jobGroupName);

        return "定时任务恢复成功";
    }

    public void jobresume(String jobClassName, String jobGroupName) throws Exception {
        if(StringUtils.isBlank(jobGroupName)) {
            jobGroupName = Scheduler.DEFAULT_GROUP;
        }
        // 通过SchedulerFactory获取一个调度器实例
        scheduler.resumeJob(JobKey.jobKey(jobClassName, jobGroupName));
    }

    @ApiOperation(value= "根据条件定时任务", notes= "根据条件定时任务")
    @PostMapping(value = "/reschedulejob")
    public String rescheduleJob(@RequestParam(value = "jobClassName") String jobClassName,
                              @RequestParam(value = "jobGroupName") String jobGroupName,
                              @RequestParam(value = "cronExpression") String cronExpression) throws Exception {
        jobreschedule(jobClassName, jobGroupName, cronExpression);

        return "定时任务重新调度成功";
    }

    public void jobreschedule(String jobClassName, String jobGroupName, String cronExpression) throws Exception {
        if(StringUtils.isBlank(jobGroupName)) {
            jobGroupName = Scheduler.DEFAULT_GROUP;
        }

        try {
            TriggerKey triggerKey = TriggerKey.triggerKey(jobClassName, jobGroupName);
            // 表达式调度构建器
            CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
            CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
            // 按新的cronExpression表达式重新构建trigger
            trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
            // 按新的trigger重新设置job执行
            scheduler.rescheduleJob(triggerKey, trigger);
        } catch (SchedulerException e) {
            logger.error("更新定时任务失败", e);
            throw new SmsException("更新定时任务失败");
        }
    }

    @ApiOperation(value= "根据条件删除定时任务", notes= "根据条件删除定时任务")
    @PostMapping(value = "/deletejob")
    public String deletejob(@RequestParam(value = "jobClassName") String jobClassName, @RequestParam(value = "jobGroupName") String jobGroupName) throws Exception {
        jobdelete(jobClassName, jobGroupName);

        return "定时任务删除成功";
    }

    public void jobdelete(String jobClassName, String jobGroupName) throws Exception {
        if(StringUtils.isBlank(jobGroupName)) {
            jobGroupName = Scheduler.DEFAULT_GROUP;
        }

        // 通过SchedulerFactory获取一个调度器实例
        scheduler.pauseTrigger(TriggerKey.triggerKey(jobClassName, jobGroupName));//停止触发器  
        scheduler.unscheduleJob(TriggerKey.triggerKey(jobClassName, jobGroupName));//移除触发器 
        scheduler.deleteJob(JobKey.jobKey(jobClassName, jobGroupName));//删除任务  
    }

    /**
     * @Description: 定时任务管理
     * @author lc
     */
    @ApiOperation(value= "定时任务管理", notes= "根据条件管理定时任务")
    @GetMapping(value = "/queryjob")
    public Map<String, Object> queryjob(@RequestParam(value = "pageNum") Integer pageNum, @RequestParam(value = "pageSize") Integer pageSize) {
        PageInfo<JobAndTriggerDTO> jobAndTrigger = jobAndTriggerService.getJobAndTriggerDetails(pageNum, pageSize);
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("JobAndTrigger", jobAndTrigger);
        map.put("number", jobAndTrigger.getTotal());
        return map;
    }
    
    /**
     * @Description: 查询定时任务
     * @author lc
     */
    @ApiOperation(value= "查询定时任务", notes= "根据条件查询定时任务")
    @GetMapping(value = "/queryJobList")
    public LayuiResult queryJobList(@RequestParam Map<String, Object> paramMap) {
        PageInfo<JobAndTriggerDTO> list = jobAndTriggerService.getJobAndTriggerDetails(Integer.parseInt(paramMap.get("page").toString()), Integer.parseInt(paramMap.get("limit").toString()));
        return LayuiResult.data(list.getTotal(), list.getList());
    }

    public static QuartzJobBean getClass(String classname) throws Exception {
        Class<?> class1 = Class.forName(classname);
        return (QuartzJobBean) class1.newInstance();
    }

}

6、设置定时任务例子

package com.fintech.modules.base.quartzjobs;

import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.SchedulerContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.stereotype.Component;

import com.fintech.modules.sms.smsreport.service.SmsLogStatusReportService;

/**
 * @Description: 每分钟/短信报文统计发送状态
 * @author lc
 * @date 2018年4月10日
 * 每2分钟统计一次
 */
@Component
public class SmsReportStatisJob extends QuartzJobBean {
    private static final long serialVersionUID = 1L;
    private Logger logger = LoggerFactory.getLogger(this.getClass());
    
    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
    	logger.info("开始执行-定时短信发送报文统计：{}");
        try {
            SchedulerContext cont = context.getScheduler().getContext();
            ApplicationContext appCtx = (ApplicationContext) cont.get("applicationContextKey");
            // 调用具体sercive业务代码
            SmsLogStatusReportService service = appCtx.getBean(SmsLogStatusReportService.class);
            service.smsReportStatis();
        } catch (Exception e) {
            logger.error("每分钟/短信报文跑批统计发送状态异常！{}", e);
        } 
        logger.info("执行结束-定时短信发送报文统计：{}");
    }
}

六、页面管理

在Spring Boot的工程中，静态页面可以放在资源文件static目录下，controller已经写好了，页面完全按照自己的需求去实现即可，下面是我拷贝别人的管理页面，这里贴一下代码

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>定时任务</title>
<link rel="stylesheet"
	href="https://unpkg.com/element-ui@2.0.5/lib/theme-chalk/index.css">
<script src="https://unpkg.com/vue/dist/vue.js"></script>
<script src="http://cdn.bootcss.com/vue-resource/1.3.4/vue-resource.js"></script>
<script src="https://unpkg.com/element-ui@2.0.5/lib/index.js"></script>

<style>
#top {
	background: #20A0FF;
	padding: 5px;
	overflow: hidden
}
</style>
</head>
<body>
	<div id="test">
		<div id="top">
			<el-button type="text" @click="search" style="color:white">查询</el-button>
			<el-button type="text" @click="handleadd" style="color:white">添加</el-button>
			</span>
		</div>
		<br />
		<div style="margin-top: 15px">
			<el-table ref="testTable" :data="tableData" style="width:100%" border>
			<el-table-column prop="jobName" label="任务名称" sortable
				show-overflow-tooltip> </el-table-column> <el-table-column
				prop="jobGroup" label="任务所在组" sortable> </el-table-column> <el-table-column
				prop="jobClassName" label="任务类名" sortable> </el-table-column> <el-table-column
				prop="triggerName" label="触发器名称" sortable> </el-table-column> <el-table-column
				prop="triggerGroup" label="触发器所在组" sortable> </el-table-column> <el-table-column
				prop="cronExpression" label="表达式" sortable> </el-table-column> <el-table-column
				prop="timeZoneId" label="时区" sortable> </el-table-column> <el-table-column
				label="操作" width="300"> <template scope="scope">
			<el-button size="small" type="warning"
				@click="handlePause(scope.$index, scope.row)">暂停</el-button> <el-button
				size="small" type="info"
				@click="handleResume(scope.$index, scope.row)">恢复</el-button> <el-button
				size="small" type="danger"
				@click="handleDelete(scope.$index, scope.row)">删除</el-button> <el-button
				size="small" type="success"
				@click="handleUpdate(scope.$index, scope.row)">修改</el-button> </template> </el-table-column> </el-table>

			<div align="center">
				<el-pagination @size-change="handleSizeChange"
					@current-change="handleCurrentChange" :current-page="currentPage"
					:page-sizes="[10, 20, 30, 40]" :page-size="pagesize"
					layout="total, sizes, prev, pager, next, jumper"
					:total="totalCount"> </el-pagination>
			</div>
		</div>

		<el-dialog title="添加任务" :visible.sync="dialogFormVisible">
		<el-form :model="form"> <el-form-item label="任务名称"
			label-width="120px" style="width:35%"> <el-input
			v-model="form.jobName" auto-complete="off"></el-input> </el-form-item> <el-form-item
			label="任务分组" label-width="120px" style="width:35%"> <el-input
			v-model="form.jobGroup" auto-complete="off"></el-input> </el-form-item> <el-form-item
			label="表达式" label-width="120px" style="width:35%"> <el-input
			v-model="form.cronExpression" auto-complete="off"></el-input> </el-form-item> </el-form>
		<div slot="footer" class="dialog-footer">
			<el-button @click="dialogFormVisible = false">取 消</el-button>
			<el-button type="primary" @click="add">确 定</el-button>
		</div>
		</el-dialog>

		<el-dialog title="修改任务" :visible.sync="updateFormVisible">
		<el-form :model="updateform"> <el-form-item label="表达式"
			label-width="120px" style="width:35%"> <el-input
			v-model="updateform.cronExpression" auto-complete="off"></el-input> </el-form-item>
		</el-form>
		<div slot="footer" class="dialog-footer">
			<el-button @click="updateFormVisible = false">取 消</el-button>
			<el-button type="primary" @click="update">确 定</el-button>
		</div>
		</el-dialog>
	</div>

	<footer align="center">
		<p>&copy; Quartz 任务管理</p>
	</footer>
	<script>
	var vue = new Vue({			
			el:"#test",
		    data: {		  
		    	//表格当前页数据
		    	tableData: [],
		        //请求的URL
		        url:'quartzjob/queryjob',
		        //默认每页数据量
		        pagesize: 10,		        
		        //当前页码
		        currentPage: 1,
		        //查询的页码
		        start: 1,
		        //默认数据总数
		        totalCount: 0,
		        //添加对话框默认可见性
		        dialogFormVisible: false,
		        //修改对话框默认可见性
		        updateFormVisible: false,
		        //提交的表单
		        form: {
		        	jobName: '',
		        	jobGroup: '',
		        	cronExpression: '',
		          },
		        updateform: {
		        	jobName: '',
		        	jobGroup: '',
		        	cronExpression: '',
		        },
		    },
		    methods: {
		        //从服务器读取数据
				loadData: function(pageNum, pageSize){					
					this.$http.get('quartzjob/queryjob?' + 'pageNum=' +  pageNum + '&pageSize=' + pageSize).then(function(res){
						console.log(res)
                		this.tableData = res.body.JobAndTrigger.list;
                		this.totalCount = res.body.number;
                	},function(){
                  		console.log('failed');
                	});					
				},			    		        
		        //单行删除
			    handleDelete: function(index, row) {
					this.$http.post('quartzjob/deletejob',{"jobClassName":row.jobName,"jobGroupName":row.jobGroup},{emulateJSON: true}).then(function(res){
						this.loadData( this.currentPage, this.pagesize);
		            },function(){
		                console.log('failed');
		            });
		        },
		        //暂停任务
		        handlePause: function(index, row){
		        	this.$http.post('quartzjob/pausejob',{"jobClassName":row.jobName,"jobGroupName":row.jobGroup},{emulateJSON: true}).then(function(res){
						this.loadData( this.currentPage, this.pagesize);
		            },function(){
		                console.log('failed');
		            });
		        },
		        //恢复任务
		        handleResume: function(index, row){
		        	this.$http.post('quartzjob/resumejob',{"jobClassName":row.jobName,"jobGroupName":row.jobGroup},{emulateJSON: true}).then(function(res){
						this.loadData( this.currentPage, this.pagesize);
		            },function(){
		                console.log('failed');
		            });
		        },
		        //搜索
		        search: function(){
		        	this.loadData(this.currentPage, this.pagesize);
		        },
		        //弹出对话框
		        handleadd: function(){		                
		            this.dialogFormVisible = true;	              
		        },
		        //添加
		        add: function(){
		        	this.$http.post('quartzjob/addjob',{"jobClassName":this.form.jobName,"jobGroupName":this.form.jobGroup,"cronExpression":this.form.cronExpression},{emulateJSON: true}).then(function(res){
        				this.loadData(this.currentPage, this.pagesize);
        				this.dialogFormVisible = false;
                    },function(){
                        console.log('failed');
                    });
		        },
		        //更新
		        handleUpdate: function(index, row){
		        	console.log(row)
		        	this.updateFormVisible = true;
		        	this.updateform.jobName = row.jobClassName;
		        	this.updateform.jobGroup = row.jobGroup;
		        },
		        //更新任务
		        update: function(){
		        	this.$http.post
		        	('quartzjob/reschedulejob',
		        			{"jobClassName":this.updateform.jobName,
		        			 "jobGroupName":this.updateform.jobGroup,
		        			 "cronExpression":this.updateform.cronExpression
		        			 },{emulateJSON: true}
		        	).then(function(res){
		        		this.loadData(this.currentPage, this.pagesize);
        				this.updateFormVisible = false;
		        	},function(){
                        console.log('failed');
                    });
		        },
		        //每页显示数据量变更
		        handleSizeChange: function(val) {
		            this.pagesize = val;
		            this.loadData(this.currentPage, this.pagesize);
		        },
		        //页码变更
		        handleCurrentChange: function(val) {
		            this.currentPage = val;
		            this.loadData(this.currentPage, this.pagesize);
		        },	      
		    },	    
		  });
		  //载入数据
    	  vue.loadData(vue.currentPage, vue.pagesize);
	</script>
</body>
</html>

向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

云原生

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...