一、写一个servlet实现ServletContextListener接口
代码如下：
我要评论package jobs;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @Description: 任务调度监听器：服务器启动时加载定时任务
* @author Emmanuev.yi
*
*/
public class JobsListener implements ServletContextListener {
private static final Logger logger = LoggerFactory.getLogger(JobsListener.class);
@Override
public void contextInitialized(ServletContextEvent sce) {
logger.info("------------The listener is in effect!!!------------");
try {
//任务调度工厂
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
//任务实例
//定时任务1
JobDetail jobDetail1 = JobBuilder
.newJob(InitTabDataJob.class)
.withIdentity("initTabDataJob", "group1")
.build();
//定时任务2
JobDetail jobDetail2 = JobBuilder
.newJob(EveryHourUpdadteJob.class)
.withIdentity("everyHourUpdadteJob", "group1")
.build();
//任务触发器：
//任务1（初始化表格）触发器
CronTrigger cronTrigger1 = TriggerBuilder
.newTrigger()
.withIdentity("ehujTrigger", "Tgroup1")
.startNow()
.withSchedule(CronScheduleBuilder.cronSchedule("0 0 8 * * ?")) //每天8点触发 0 0 8 * * ?
//.withSchedule(CronScheduleBuilder.cronSchedule("0 45 16 * * ?"))
.build();
//任务2（每小时更新数据）触发器
CronTrigger cronTrigger2 = TriggerBuilder.newTrigger()
.withIdentity("itdj", "Tgroup2")
.startNow()
//.withSchedule(CronScheduleBuilder.cronSchedule("0 */1 * * * ?")) //每小时10分触发，每隔半小时触发一次 0 10/30 * * * ? 0/5 * * * * ?
.withSchedule(CronScheduleBuilder.cronSchedule("0 0 14 * * ?"))
.build();
//添加任务调度
scheduler.scheduleJob(jobDetail1, cronTrigger1);
scheduler.scheduleJob(jobDetail2, cronTrigger2);
//启动调度器
scheduler.start();
} catch (SchedulerException e) {
e.printStackTrace();
}
}
/**
* 任务销毁
*/
@Override
public void contextDestroyed(ServletContextEvent sce) {
sce.getServletContext().log("timer task over ！！！");
}
}
二、在web.xml文件中配置监听器类，将以上的JobsListener 类配置其中，以确保能在服务器启动时加载任务。以下为配置信息。
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
<display-name>OEE</display-name>
<listener>
<listener-class>jobs.JobsListener</listener-class>
</listener>
<welcome-file-list>
<welcome-file>index.html</welcome-file>
<welcome-file>index.htm</welcome-file>
<welcome-file>index.jsp</welcome-file>
<welcome-file>default.html</welcome-file>
<welcome-file>default.htm</welcome-file>
<welcome-file>default.jsp</welcome-file>
</welcome-file-list>
</web-app>
三、书写具体任务
1、任务1：InitTabDataJob
package jobs;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import cn.itcast.jdbc.JdbcUtils;
import utils.CommonUtil;
import utils.FileUtil;
/**
* 初始化表数据任务
* @author Emmanuev.yi
*
*/
public class InitTabDataJob implements Job{
private static final Logger logger = LoggerFactory.getLogger(InitTabDataJob.class);
/**
* @Description: 任务执行方法
*/
public void execute(JobExecutionContext arg0) throws JobExecutionException {
//Logger
logger.info("table initialization beginning......");
initTab_execute();
}
/**
* @Description: 初始化表格：批量插入初始化数据，每天8点执行一次
*/
public void initTab_execute() {
//这里是业务代码，就不写了......
}
}
2、任务2：EveryHourUpdadteJob
package jobs;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.Set;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import org.dom4j.DocumentException;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import entity.EveryHourRatio;
import entity.MachineRunInfo;
import utils.CommonUtil;
import utils.FileUtil;
import utils.JdbcUtils;
/**
* 每小时插入机台效率的任务
* @author Emmanuev.yi
*
*/
public class EveryHourUpdadteJob implements Job{
private static final Logger logger = LoggerFactory.getLogger(EveryHourUpdadteJob.class);
private static final String FORMAT = "yyyy-MM-dd HH:mm:ss";
private String str_dayShiftStart; //开始时间
private String str_dayShiftEnd; //结束时间
private FileUtil fu = new FileUtil();
//构造代码块：创建本类对象时进行初始化参数
{
Date currentDate = new Date();
String strCurrentDate = CommonUtil.dateToTime(currentDate, "yyyy-MM-dd");
Calendar c = Calendar.getInstance();
c.setTime(currentDate);
int hour = c.get(Calendar.HOUR_OF_DAY);
/*
* 根据时间当前时间点确定查询的[开始时间]和[结束时间]
* 8~23：
* 查询时间区间：当天8点~当天+1天8点
* 0~8：
* 查询时间区间：当天-1天8点~当天8点
*/
if(hour >= 8 && hour <= 23) {
str_dayShiftStart = strCurrentDate+" 08:00:00";
str_dayShiftEnd = CommonUtil.arithmeticTime_day(str_dayShiftStart, FORMAT, 1);
}else if(hour >= 0 && hour < 8) {
str_dayShiftEnd = strCurrentDate+" 08:00:00";
str_dayShiftStart = CommonUtil.arithmeticTime_day(str_dayShiftEnd, FORMAT, -1);
}
}
@Override
public void execute(JobExecutionContext arg0) throws JobExecutionException {
try {
logger.info("update datas beginning......");
update_execute();
} catch (Exception e) {
e.printStackTrace();
}
}
//更新数据
public void update_execute() throws SQLException, ParseException, DocumentException {
//这里是业务代码，就不写了......
}
}
四、结语
没什么好说的，就是这么简单，祝大家编码愉快！
本文地址：https://blog.csdn.net/yimianzhen/article/details/107345611
如对本文有疑问， 点击进行留言回复！！
现在微服务这么火，你还不了解吗？阿里P8推荐的微服务学习指南
论文笔记：SlowFast Networks for Video Recognition
网友评论