spring 定时任务job（quartz）可视化

本文介绍的是使用spring(spring继承并简化的quartz)的作业框架时，作业的可视化(管理,本文的可视化管理做的不完善)

解决办法就是使用监听器，实现job历史记录、job统计、异常记录、手动触发job

先来看一下实现的流程

这里只需要自己实现几个监听器并注册即可

- StatisticSchedulerListener 监听触发规则triggers，一般是在spring启动和刷新时触发

- StatisticJobListener JOB监听（监听JOB执行前和执行后）

- StatisticTriggerListener

这里主要使用 StatisticJobListener

public class StatisticJobListener implements JobListener {

private static Logger log = Logger.getLogger(StatisticJobListener.class);

private static ThreadLocal<JobStatisticBean> threadLocal = new ThreadLocal<JobStatisticBean>();

private String name;

public void setName(String name) {

this.name = name;

}

@Override

public String getName() {

return this.name;

}

//beginging

@Override

public void jobToBeExecuted(JobExecutionContext context) {

log.info("JOB将要执行... "+context.getJobDetail().getName());

JobStatisticBean jobStatisticBean = new JobStatisticBean();

jobStatisticBean.setJobName(context.getJobDetail().getName());

jobStatisticBean.setJobDetail(context.getJobDetail());

jobStatisticBean.setTrigger(context.getTrigger());

jobStatisticBean.setStartTime(new Timestamp(System.currentTimeMillis()));

jobStatisticBean.setJobExecutionContext(context);

jobStatisticBean.setJobIntance(context.getJobInstance());

threadLocal.set(jobStatisticBean);

}

@Override

public void jobExecutionVetoed(JobExecutionContext context) {

log.info("jobExecutionVetoed "+context.getJobDetail().getName());

}

@Override

public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {

log.info("JOB执行完毕 "+context.getJobDetail().getName());

JobStatisticBean jobStatisticBean = threadLocal.get();

if(jobStatisticBean!=null){

jobStatisticBean.setEndTime(new Timestamp(System.currentTimeMillis()));

jobStatisticBean.setTakesTime(jobStatisticBean.getEndTime().getTime()-jobStatisticBean.getStartTime().getTime());

StatisticProcessor.add(jobStatisticBean);

}

具体的缓存可以自己扩展，这里就是简单的使用了当前的jvm缓存，自己可以扩展Redis

public class StatisticProcessor extends Thread implements ApplicationContextAware, InitializingBean, DisposableBean {

private static Logger logJob = Logger.getLogger(LoggerCategory.JOB_STATISTIC);

private static Logger logJobHistory = Logger.getLogger(LoggerCategory.JOB_STATISTIC_HISTORY);

private static Logger logJobException = Logger.getLogger(LoggerCategory.JOB_STATISTIC_EXCEPTION);

private static volatile Queue<JobStatisticBean> jobQueue = new ConcurrentLinkedQueue<JobStatisticBean>();

private static volatile Queue<SchedulerExceptionBean> exceptionQueue = new ConcurrentLinkedQueue<SchedulerExceptionBean>();

private static volatile Map<String, JobStatisticBean> jobMap = new ConcurrentHashMap<String, JobStatisticBean>();

/**

* 手动触发JOB

* @param jobStatisticBean

* @return

* @throws Exception

public static boolean runByHand(JobStatisticBean jobStatisticBean) throws Exception{

if(jobStatisticBean==null)

return false;

JobExecutionContext context = jobStatisticBean.getJobExecutionContext();

Job job = jobStatisticBean.getJobIntance();

job.execute(context);

return true;

}

/**

* 添加一个JOB的实例（使用map防止重复），并记录JOB执行记录(Queue)

* @param jobStatisticBean

* @return

public static boolean add(JobStatisticBean jobStatisticBean){

if(!jobMap.containsKey(jobStatisticBean.getJobName())) {

logJob.info("add job "+ JacksonUtil.toJsonString(jobStatisticBean));

}

jobMap.put(jobStatisticBean.getJobName(), jobStatisticBean);

logJobHistory.info(JacksonUtil.toJsonString(jobStatisticBean));

return jobQueue.add(jobStatisticBean);

}

/**

* 添加执行异常LOG

* @param schedulerExceptionBean

* @return

public static boolean add(SchedulerExceptionBean schedulerExceptionBean){

logJobException.info(JacksonUtil.toJsonString(schedulerExceptionBean));

return exceptionQueue.add(schedulerExceptionBean);

}

public static List<JobStatisticBean> getALlJobs() {

int size = jobMap.size();

size = size>100? 100:size;

return Arrays.asList(jobMap.values().toArray(new JobStatisticBean[size]));

}

public static List<JobStatisticBean> getAllJobHistory() {

int size = jobQueue.size();

size = size>100? 100:size;

return Arrays.asList(jobQueue.toArray(new JobStatisticBean[size]));

}

public static List<SchedulerExceptionBean> getAllExceptions(){

int size = exceptionQueue.size();

size = size>100? 100:size;

return Arrays.asList(exceptionQueue.toArray(new SchedulerExceptionBean[size]));

}

private volatile boolean exit = false;

private ApplicationContext applicationContext = null;

private static volatile StatisticProcessor processorIntance = null;

public synchronized void init(){

if(processorIntance==null) {

logJob.info("--------------------- "+new Date().toLocaleString()+" --------------------------");

logJobHistory.info("--------------------- "+new Date().toLocaleString()+" --------------------------");

logJobException.info("--------------------- "+new Date().toLocaleString()+" --------------------------");

processorIntance = new StatisticProcessor();

processorIntance.setName(GConstants.THREA_HEAD + "JobStatisticProcessor");

processorIntance.setDaemon(true);

processorIntance.start();

}

@Override

public void run() {

do{

try {

Thread.sleep(1000*30);

synchronized (jobQueue) {

if (!jobQueue.isEmpty()) {

long outSize = jobQueue.size() - 100;

while (outSize-- > 0) {

jobQueue.poll();

}

synchronized (exceptionQueue) {

if (!exceptionQueue.isEmpty()) {

long outSize = exceptionQueue.size() - 100;

while (outSize-- > 0) {

exceptionQueue.poll();

}

}catch (Exception e){

e.printStackTrace();

}

}while( !this.exit);

}

@Override

public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {

this.applicationContext = applicationContext;

}

@Override

public void afterPropertiesSet() throws Exception {

this.init();

}

@Override

public void destroy(){

this.exit = true;

}

public class JobStatisticBean implements Serializable {

private static long serialVersionUID = -1L;

private String jobName;

private String className;

private Timestamp startTime;

private Timestamp endTime;

private Long takesTime;

private JobDetail jobDetail;

private Trigger trigger;

private JobExecutionContext jobExecutionContext;

private Job jobIntance;

//.. getter & setter

}

job.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">

<list>

</list>

</property>

<list>

</bean>

</list>

</property>

<list>

</bean>

</list>

</property>

</bean>

</bean>

</property>

</bean>

</bean>

</property>

</bean>

</beans>

JobStatisticAction.java

public class JobStatisticAction extends BaseAction {

private List<JobStatisticBean> jobList;

private List<JobStatisticBean> jobHistoryList;

private List<SchedulerExceptionBean> jobExceptionList;

public String jobStatistic() throws Exception {

jobList = StatisticProcessor.getALlJobs();

jobHistoryList = StatisticProcessor.getAllJobHistory();

Collections.reverse(jobHistoryList);

jobExceptionList = StatisticProcessor.getAllExceptions();

return Action.SUCCESS;

}

//============================

public List<JobStatisticBean> getJobList() {

return jobList;

}

public List<JobStatisticBean> getJobHistoryList() {

return jobHistoryList;

}

public List<SchedulerExceptionBean> getJobExceptionList() {

return jobExceptionList;

}

job.jsp

<%@ page contentType="text/html;charset=UTF-8" language="java" %>

<%@ taglib uri="/struts-tags" prefix="s" %>

<%@ page import="java.text.SimpleDateFormat" %>

<%@ page import="java.util.Date" %>

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");

String nowTime = sdf.format(new Date());

<html>

<head>

<title>Job Statistic</title>

<style>

table{

font-size: smaller;

}

</style>

</head>

<body>

</div>

<tr>

<th style="min-width: 180px;">最近执行时间</th>

</tr>

<s:iterator value="jobList" id="jobList" status="step">

<tr>

<td>${step.index+1}</td>

<td>${jobName}</td>

<td>${startTime} - ${endTime}</td>

<td>${takesTime}</td>

<td>

<tr>

<td align="right">Class :</td>

<td> ${jobDetail.jobClass} </td>

</tr>

<tr>

<td align="right">CronEx :</td>

<td> ${trigger.cronExpression} </td>

</tr>

<tr>

<td align="right">NextFireTime :</td>

</tr>

<tr>

<td align="right">PreFireTime :</td>

</tr>

<tr>

<td align="right">StartTime :</td>

</tr>

</table>

</td>

</tr>

</s:iterator>

</table>

</div>

<h2 class="text-center">Job Error</h2>

</div>

<tr>

</tr>

<s:iterator value="jobExceptionList" id="jobList" status="step">

<tr>

<td>${step.index+1}</td>

<td>${exception}</td>

</tr>

</s:iterator>

</table>

</div>

<h2 class="text-center">Job History</h2>

</div>

<tr>

<th style="width: 100px;">class</th>

</tr>

<s:iterator value="jobHistoryList" id="jobList" status="step">

<tr>

<td>${step.index+1}</td>

<td>${jobName}</td>

<td>${startTime} - ${endTime}</td>

<td>${takesTime}</td>

<td>${jobDetail.jobClass}</td>

</tr>

</s:iterator>

</table>

</div>

</body>

</html>

本文介绍的只是一个简单的实现，推荐使用设计模式的一些方式进行重构，如果以后有时间我也会重构

spring 定时任务job（quartz）可视化

相关推荐