关于java:Java-Web应用结合Quartz实现定时任务

Leader：业务部门想统计我司调用人脸识别、联网核查服务的次数，你负责定期出个报表呗，便于业务人员费用结算。
Coder：OK，我思考通过定时工作每月 1 号凌晨汇总上月的数据，生成个 excel，让咱们组前端小妹整个页面供业务下载就是。

对于定时工作，我首先想到 Quartz，它是一个齐全由 Java 编写的开源作业调度框架。上面介绍几个外围概念：

Job 示意一个工作，要执行的具体内容。此接口中只有一个办法，如下：
```
void execute(JobExecutionContext jobExecutionContext)
```
JobDetail 示意一个具体的可执行的调度程序，Job 是这个可执行调度程序所要执行的内容。
Trigger 代表一个调度参数的配置，什么时候去调。其中 CronTrigger 比 Simple Trigger 更罕用，不是像 SimpleTrigger 那样准确指定工夫距离，而是基于日历的作业调度。
Scheduler 代表一个调度容器，一个调度容器中能够注册多个 JobDetail 和 Trigger。当 Trigger 与 JobDetail 组合，就能够被 Scheduler 容器调度了。

为了在利用启动时，主动加载定时工作，我采取实现 ServletContextListener 接口的
办法，ServletContextListener 是随 Web 利用的启动而启动，只初始化一次，随 Web 利用的进行而销毁。次要应用场景：做一些初始化的工作、设置一些根本的内容（比方公共参数或者是一些固定的对象等）。

在 Web 利用中导入相干的 jar 包。

在 web.xml 中定义 listener。

<listener>
 <listener-class>com.lee.demo01.MyScheduleListener</listener-class>
</listener>

创立 MyJob，实现 Job。这里我就打印下日期，理论可改成汇总数据生成 excel 的动作。

public class MyJob implements Job {
 @Override
 public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {System.out.println("MyJob starts at" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
 }
}

定义启动定时工作和进行定时工作。我在这里的 Cron 表达式定义为：”0/1 ?”，即每秒触发一次，Cron 表达式的用法请参考官网文档阐明。

public class MyQuartz {
 private static Scheduler scheduler;

 /*
 启动定时工作
  */
 public static void run() throws Exception {System.out.println("定时工作启动");
     JobDetail jobDetail = JobBuilder.newJob((Class<? extends Job>) MyJob.class).withIdentity("job1", "group1").build();
     CronTrigger cronTrigger = (CronTrigger) TriggerBuilder.newTrigger().withIdentity("trigger1", "group1").withSchedule(CronScheduleBuilder.cronSchedule("0/1 * * * * ?")).build();
     SchedulerFactory schedulerFactory = new StdSchedulerFactory();
     scheduler = schedulerFactory.getScheduler();
     scheduler.scheduleJob(jobDetail, cronTrigger);
     scheduler.start();}

 /*
 进行定时工作
  */
 public static void stop() throws Exception {System.out.println("定时工作进行");
     scheduler.shutdown();}
}

创立 MyScheduleListener，实现 ServletContextListener。

public class MyScheduleListener implements ServletContextListener {

 @Override
 public void contextInitialized(ServletContextEvent arg0) {System.out.println("定时工作启动");
     try {MyQuartz.run();
     } catch (Exception e) {e.printStackTrace();
     }
 }

 @Override
 public void contextDestroyed(ServletContextEvent arg0) {System.out.println("定时工作进行");
     try {MyQuartz.stop();
     } catch (Exception e) {e.printStackTrace();
     }
 }
}

启动 Web 利用，控制台能够看到定时工作启动和每秒打印的日志。

定时工作启动
定时工作启动
log4j:WARN No appenders could be found for logger (org.quartz.impl.StdSchedulerFactory).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
[2022-04-19 04:50:02,072] Artifact MyWeb:war exploded: Artifact is deployed successfully
[2022-04-19 04:50:02,072] Artifact MyWeb:war exploded: Deploy took 447 milliseconds
MyJob starts at 2022-04-19 16:50:02
MyJob starts at 2022-04-19 16:50:03
MyJob starts at 2022-04-19 16:50:04
MyJob starts at 2022-04-19 16:50:05
MyJob starts at 2022-04-19 16:50:06
MyJob starts at 2022-04-19 16:50:07
MyJob starts at 2022-04-19 16:50:08
MyJob starts at 2022-04-19 16:50:09
MyJob starts at 2022-04-19 16:50:10

下面我是将定时工作的调度写在了一个类中，为不便配置 Cron 表达式，也能够在配置文件中设置。

在 web.xml 中增加 QuartzInitializerServlet。在 Web 利用中导入相干的 jar 包和创立 MyJob 依然须要。

<servlet>
 <servlet-name>QuartzInitializer</servlet-name>
 <servlet-class>org.quartz.ee.servlet.QuartzInitializerServlet</servlet-class>
 <init-param>
     <param-name>shutdown-on-unload</param-name>
     <param-value>true</param-value>
 </init-param>
 <init-param>
     <param-name>config-file</param-name>
     <param-value>quartz.properties</param-value>
 </init-param>
 <load-on-startup>1</load-on-startup>
</servlet>

创立配置文件 quartz.properties。

org.quartz.scheduler.instanceName = AUTO
org.quartz.scheduler.instanceId = AUTO
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 5
org.quartz.threadPool.threadPriority = 5
org.quartz.plugin.triggHistory.class = org.quartz.plugins.history.LoggingJobHistoryPlugin
org.quartz.plugin.jobInitializer.class = org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin
org.quartz.plugin.jobInitializer.fileNames = quartz_jobs.xml
org.quartz.plugin.jobInitializer.failOnFileNotFound = true
org.quartz.plugin.jobInitializer.scanInterval = 10
org.quartz.plugin.jobInitializer.wrapInUserTransaction = false

创立配置文件 quartz_jobs.xml。

<?xml version="1.0" encoding="UTF-8"?>
<job-scheduling-data xmlns="http://www.quartz-scheduler.org/xml/JobSchedulingData"
                  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.0">
 <schedule>
     <job>
         <name>job1</name>
         <group>group1</group>
         <description> 定时工作 </description>
         <job-class>com.lee.demo01.MyJob</job-class>
     </job>
     <trigger>
         <cron>
             <name>trigger1</name>
             <group>group1</group>
             <job-name>job1</job-name>
             <job-group>group1</job-group>
             <cron-expression>0/1 * * * * ?</cron-expression>
         </cron>
     </trigger>
 </schedule>
</job-scheduling-data>

关于java:Java-Web应用结合Quartz实现定时任务

背景

常识储备

实操

补充阐明