quartz监控日志（二）添加监听器

迷南。 2022-06-17 04:55 304阅读 0赞

上一章介绍监控job有三种方案，其实还有一个简单方案是实现quartz的TriggerListener。

上次我也试了这个方案，但是由于操作错误，导致没有监控成功，所以才选择分析源码来实现代理进行监控。

后面我看了些资料，并重新试了下，这种方案是可行的，并且非常方便。

首先实现TriggerListener，如下：

public class MonitorTriggerListener implements TriggerListener {
        
        private final static Logger logger=Logger.getLogger(MonitorJobRunShell.class);
        private ThreadLocal<QuartzLog> localLog=new ThreadLocal<QuartzLog>();
        /**  
         * @see org.quartz.TriggerListener#getName()    
         */
        @Override
        public String getName() {
            return "MonitorTriggerListener";
        }
        
        /**  
         * @see org.quartz.TriggerListener#triggerComplete(org.quartz.Trigger, org.quartz.JobExecutionContext, int)    
         */
        @Override
        public void triggerComplete(Trigger arg0, JobExecutionContext jec, int arg2) {
            try {
                QuartzLog quartzLog=localLog.get();
                if(quartzLog==null)return ;
                quartzLog.setExeTime(jec.getJobRunTime());
                getService().update(quartzLog);
            } catch (Exception e) {
                logger.error("记录job结束时间异常",e);
            }catch (Throwable e) {
                logger.error("记录job结束时间出错",e);
            }
        }
        
        /**  
         * @see org.quartz.TriggerListener#triggerFired(org.quartz.Trigger, org.quartz.JobExecutionContext)    
         */
        @Override
        public void triggerFired(Trigger arg0, JobExecutionContext jec) {
            try {
                JobDetail jobDetail = jec.getJobDetail();
                System.out.println(localLog.get());
                QuartzLog quartzLog=getService().insert(jobDetail.getName());
                localLog.set(quartzLog);
                System.out.println(quartzLog);
            } catch (Exception e) {
                logger.error("记录job开始时间异常",e);
            }catch (Throwable e) {
                logger.error("记录job开始时间出错",e);
            }
        }
        
        /**  
         * @see org.quartz.TriggerListener#triggerMisfired(org.quartz.Trigger)    
         */
        @Override
        public void triggerMisfired(Trigger arg0) {
        }
        
        /**  
         * @see org.quartz.TriggerListener#vetoJobExecution(org.quartz.Trigger, org.quartz.JobExecutionContext)    
         */
        @Override
        public boolean vetoJobExecution(Trigger arg0, JobExecutionContext arg1) {
            return false;
        }
        private QuartzLogService getService(){
            return (QuartzLogService)BeanLocator.getBeanInstance("quartzLogService");
        }
    }

然后在初始化StdSchedulerFactory时添加全局监听器，

factory = new StdSchedulerFactory(configProperties);
       //启动调度
      scheduler = factory.getScheduler();
       TriggerListener myListener=new MonitorTriggerListener();
      scheduler.addGlobalTriggerListener(myListener);
      scheduler.start();

这样同样可以达到监控效果。