任务调度之Quatz解析

爱被打了一巴掌 2022-07-28 09:56 200阅读 0赞

Quartz对任务调度的领域问题进行了高度的抽象，提出了调度器、任务和触发器这3个核心的概念，并在org.quartz通过接口和类对重要的这些核心概念进行描述。

# 应用场景： #

任务调度在软件，各大网站经常用到，比如：每隔半个小时生成精华文章的RSS文件，每天凌晨统计论坛用户的积分排名，每隔30分钟执行锁定用户解锁任务。  
对于一个典型的MIS系统来说，在每月1号凌晨统计上个月各部门的业务数据生成月报表，每半个小时查询用户是否已经有快到期的待处理业务……，这样的例子俯拾皆是，不胜枚举。

# 项目中应用及架构解析 #

以我最近做的一个项目为例，这个项目应用到后台系统定时对每天的的用户充值、银行卡绑定等进行核对，这是一项需要自动触发的任务，我们用Quartz来实现，与Timer,ScheduledExecutor相比，Quartz 可以满足更多更复杂的调度需求。  
首先看一下类之间的调用关系：  
InitJob–>WarningEngine–>WarningJob–>WarningJobExecuter

## InitJob: ##

继承HttpServlet,用init和destroy方法  
init方法,负责初始化Servlet对象  
destory方法,当Servlet对象退出声明周期时,负责释放占有的资源

@SuppressWarnings("serial")
    public class InitJob extends HttpServlet{ 
        private final Logger logger = Logger.getLogger(InitJob.class);
    
        public void init(){   
            System.out.println("job被加载!");
            startWarningJob();//启动预警平台任务 
        }
    
        public void startWarningJob(){
            try {
                new WarningEngine().startAllJobs();
            } catch (Exception e) {
                logger.error(e.getMessage());
            }
        }
    
        @Override
        public void destroy() {
            try {
                logger.info("开始停止预警调度");
                new WarningEngine().shutdown(true);
                logger.info("预警调度已成功停止");
            } catch (Exception e) {
                logger.error(e.getMessage());
            }
        }
    }

## WarningEngine ##

/** * 启动所有定时类型的预警条目 * @throws Exception */
        public void startAllJobs() throws Exception{
            //用于Scheduler的创建和管理。
            this.getScheduler().start();
            long startTime = new Date().getTime();
            //查询所有预警条目，启动服务的时候调用
            List<WarningEntryVO> entryList = new WarningEntryService().selectAllWarnEntryForBoot();
            //计算所有预警条目计算时间
            long executeLength = new Date().getTime() - startTime;
            logger.info("查询所有预警条目耗时：" + executeLength + "ms");
            //如果没有可执行的预警条目
            if(entryList == null || entryList.isEmpty()){
                return;
            }
            int successNum = 0;
            startTime = new Date().getTime();
            logger.info("开始调度预警条目，条目总数：" + entryList.size());
            //遍历所有预警插件并计数
            for(WarningEntryVO vo : entryList){
                Date firstFireTime = this.startJob(vo);
                if(firstFireTime != null){
                    successNum ++;
                }
            }
            executeLength = new Date().getTime() - startTime;
            logger.info("完成调度预警条目，成功数量：" + successNum + ", 耗时：" + executeLength + "ms");
        }
    ###selectAllWarnEntryForBoot
    /** * 查询所有预警条目，启动服务的时候调用 * @return * @throws Exception */
        public List<WarningEntryVO> selectAllWarnEntryForBoot() throws Exception{
            SqlMapClient sqlMap = DataAccessor.getSession();
            //查询所有调度信息
            List<WarningEntryVO> entryList = new WarningEntryDAO().queryAllForBoot(sqlMap);
            if(entryList == null || entryList.isEmpty()){
                return null;
            }
            // 查询所有预警模板
            List<WarningModelVO> modelList = new WarningModelDAO().queryAll(sqlMap);
            //list转map
            Map<Object, WarningModelVO> modelMap = new WarningVoUtil<WarningModelVO>().listToMap(modelList, WarningModelVO.MODEL_ID);
            // 查询出接收人
            List<WarningReceiverVO> receiverList = 
                    new WarningReceiverDAO().selectReceiverVoList(null, null, sqlMap);
            //list转map
            MapList<Object, WarningReceiverVO> receiverMapList = 
                    new WarningVoUtil<WarningReceiverVO>().listToMapList(receiverList, WarningReceiverVO.ENTRY_ID);
    
            // 查询出预警变量
            List<WarningEntryFieldVO> fieldList = 
                    new WarningEntryFieldDAO().selectEntryFieldVOList(null, null, sqlMap);
            //list转map
            MapList<Object, WarningEntryFieldVO> fieldsMapList = 
                    new WarningVoUtil<WarningEntryFieldVO>().listToMapList(fieldList, WarningEntryFieldVO.ENTRY_ID);
            //遍历调度信息
            for(int i = entryList.size() -1 ; i >= 0; i--){
                WarningEntryVO entryVo = entryList.get(i);
                WarningModelVO modelVO = modelMap.get(entryVo.getMODEL_ID());
                if(modelVO == null){
                    entryList.remove(i);
                    continue;
                }
                entryVo.setModelVO(modelVO);
                List<WarningReceiverVO> entryReceiverList = receiverMapList.get(entryVo.getENTRY_ID());
                entryVo.setReceiverList(entryReceiverList);
    
                List<WarningEntryFieldVO> entryFieldList = fieldsMapList.get(entryVo.getENTRY_ID());
                entryVo.setFieldList(entryFieldList);
            }
    
            return entryList;
        }

### startJob ###

public Date startJob(WarningEntryVO entryVo){
            String jobName = this.getJobName(entryVo);
            //定义一个具体作业jobName，并加入GROUP_NAME组，并且绑定到具体的作业类WarningJob上 
            JobDetail jobDetail = new JobDetail(jobName, GROUP_NAME, WarningJob.class);
            jobDetail.getJobDataMap().put("ENTRYVO" ,entryVo);
            String croExpress = entryVo.getTIMEREXPRESSION();
            String triggerName = "Trigger" + entryVo.getENTRY_ID();
            Date firstExecuteTime = null;
            try {
                /*创建一个触发器，用CronTrigger，你可以定义任务计划像“每周五的中午”， * 或“每个工作日的早上9：30”，甚至可以定义“1月份的每周一、周三、周五早上9：00至10：00，每5分钟一次”。*/
                Trigger trigger = new CronTrigger(triggerName, GROUP_NAME, croExpress);
                // 设置调度的具体作业和相关的触发器
                firstExecuteTime = getScheduler().scheduleJob(jobDetail, trigger);
                logger.info("调度预警条目:" + jobName 
                        + ", 下次执行时间" + WarningCommonUtil.formatDate(firstExecuteTime));
            } catch (Exception e) {
                logger.error("调度预警条目时发生异常,插件类：" + entryVo.getModelVO().getMODEL_PLUGIN()
                    + ", entryId:" + entryVo.getENTRY_ID() + ", 克隆表达式:" + croExpress, e);
                return null;
            }
            return firstExecuteTime;
        }

## 解析 ##

Quartz 是个开源的作业调度框架，为在 Java 应用程序中进行作业调度提供了简单却强大的机制。Quartz框架包含了调度器监听、作业和触发器监听。你可以配置作业和触发器监听为全局监听或者是特定于作业和触发器的监听。Quartz 允许开发人员根据时间间隔（或天）来调度作业。它实现了作业和触发器的多对多关系，还能把多个作业与不同的触发器关联。整合了 Quartz 的应用程序可以重用来自不同事件的作业，还可以为一个事件组合多个作业。Quartz在功能上远远超越了JDK自带的Timer，很好很强大！