通过前面的学习，你可能大致了解了Quartz，本篇博文为你打开学习SSMM+Quartz的旅程！欢迎上车，开始美好的旅程！
本篇是在SSM框架基础上进行的。
参考文章：
3.Quartz学习——Spring和Quartz集成详解（三）
4.Quartz学习——SSMM(Spring+SpringMVC+Mybatis+Mysql)和Quartz集成详解（四）
5.Quartz源码——JobStore保存JonDetail和Trigger源码分析（一）
6.Quartz源码——scheduler.start()启动源码分析（二）
7.Quartz源码——QuartzSchedulerThread.run() 源码分析（三）
8.Quartz源码——Quartz调度器的Misfire处理规则（四）
一：环境介绍
工具：Eclipse+ Mysql
框架：Spring+SpringMVC+Mybatis
日志：logback
构建工具：Maven
Quartz版本：2.2.1
二：SSMM+Quartz集成详解
1：概述
在之前SSM框架的基础集合Quartz写一个简单的Web项目，实现Quartz的动态添加，修改和删除功能！（这里只是对Cron类型的Trigger进行操作）
2:项目结构
3:初始化
在项目中找到初始化sql——quartz_test.sql ,导入自己的数据库中！初始化的表信息如下：
qrtz_blob_triggers,
qrtz_calendars,
qrtz_fired_triggers,
qrtz_locks,
qrtz_paused_trigger_grps,
qrtz_scheduler_state,
qrtz_simple_triggers,
qrtz_simprop_triggers,
qrtz_triggers,
user_t
4：配置文件介绍
（1）：在ApplicationContext.xml中添加下面的配置：
<bean name="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean" >
<property name="dataSource" ref ="dataSource" />
<property name="applicationContextSchedulerContextKey" value="applicationContextKey"/>
<property name="configLocation" value="classpath:quartz.properties"/>
</bean>
（2）：添加quartz.properties配置文件
# Default Properties file for use by StdSchedulerFactory
# to create a Quartz Scheduler Instance, if a different
# properties file is not explicitly specified.
# #============================================================================
# Configure Main Scheduler Properties
#============================================================================
org.quartz.scheduler.instanceName: quartzScheduler
org.quartz.scheduler.instanceId = AUTO org.quartz.scheduler.rmi.export: false
org.quartz.scheduler.rmi.proxy: false
org.quartz.scheduler.wrapJobExecutionInUserTransaction: false
#============================================================================
# Configure ThreadPool
#============================================================================
org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount: 2
org.quartz.threadPool.threadPriority: 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true org.quartz.jobStore.misfireThreshold: 60000
#============================================================================
# Configure JobStore
#============================================================================ #default config
#org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore
#持久化配置
org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties:true #============================================================================
#havent cluster spring
#============================================================================
org.quartz.jobStore.isClustered = false #数据库表前缀
org.quartz.jobStore.tablePrefix:qrtz_
#org.quartz.jobStore.dataSource:qzDS #============================================================================
# Configure Datasources
#============================================================================
#JDBC驱动 Sping去管理dataSource ，这里不在配置数据源信息
#org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver
#org.quartz.dataSource.qzDS.URL:jdbc:mysql://localhost:3306/quartz_test
#org.quartz.dataSource.qzDS.user:root
#org.quartz.dataSource.qzDS.password:root
#org.quartz.dataSource.qzDS.maxConnection:10
5：关键代码简单介绍
（1）：过滤器
添加过滤器拦截请求，若用户没有登录，则跳转到登录页面！
a. 新增LoginFilter.java,核心代码如下：
@Override
public void doFilter(ServletRequest req, ServletResponse resp, FilterChain chain) throws IOException, ServletException {
HttpServletRequest request = (HttpServletRequest) req;
HttpServletResponse response = (HttpServletResponse) resp;
HttpSession session = request.getSession();
//判断Session中是否有登录用户信息
String toke = (String) session.getAttribute(CommonConstant.LONGIN_TOKE);
if(!StringUtils.isEmpty(toke)){
chain.doFilter(req, resp);
}else{
//若没有则，跳转到登录页面
response.sendRedirect(request.getContextPath() + "/user/toLogin");
}
}
b.在web.xml配置过滤器：
<filter>
<filter-name>LoginFilter</filter-name>
<filter-class>org.ssm.dufy.filter.LoginFilter</filter-class>
</filter>
<filter-mapping>
<filter-name>LoginFilter</filter-name>
<url-pattern>/</url-pattern>
</filter-mapping>
（2）BAO和Service接口
Dao主要是用户的一些操作
public interface IUserDao {
int deleteByPrimaryKey(Integer id);
int insert(User record);
int insertSelective(User record);
User selectByPrimaryKey(Integer id);
int updateByPrimaryKeySelective(User record);
int updateByPrimaryKey(User record);
User findUser(User user);
}
Service主要是对定时任务的一些操作！
package org.ssm.dufy.service;
public interface QuartzService {
/**
* addJob(方法描述：添加一个定时任务) <br />
* (方法适用条件描述： – 可选)
*
* @param jobName
* 作业名称
* @param jobGroupName
* 作业组名称
* @param triggerName
* 触发器名称
* @param triggerGroupName
* 触发器组名称
* @param cls
* 定时任务的class
* @param cron
* 时间表达式 void
* @exception
* @since 1.0.0
*/
public void addJob(String jobName, String jobGroupName,String triggerName, String triggerGroupName, Class cls, String cron);
/**
*
* @param oldjobName 原job name
* @param oldjobGroup 原job group
* @param oldtriggerName 原 trigger name
* @param oldtriggerGroup 原 trigger group
* @param jobName
* @param jobGroup
* @param triggerName
* @param triggerGroup
* @param cron
*/
public boolean modifyJobTime(String oldjobName,String oldjobGroup, String oldtriggerName, String oldtriggerGroup, String jobName, String jobGroup,String triggerName, String triggerGroup, String cron);
/**
* 修改触发器调度时间
* @param triggerName 触发器名称
* @param triggerGroupName 触发器组名称
* @param cron cron表达式
*/
public void modifyJobTime(String triggerName,
String triggerGroupName, String cron);
/**
* 暂停指定的任务
* @param jobName 任务名称
* @param jobGroupName 任务组名称
* @return
*/
public void pauseJob(String jobName,String jobGroupName);
/**
* 恢复指定的任务
* @param jobName 任务名称
* @param jobGroupName 任务组名称
* @return
*/
public void resumeJob(String jobName,String jobGroupName);
/**
* 删除指定组任务
* @param jobName 作业名称
* @param jobGroupName 作业组名称
* @param triggerName 触发器名称
* @param triggerGroupName 触发器组名称
*/
public void removeJob(String jobName, String jobGroupName,
String triggerName, String triggerGroupName);
/**
* 开始所有定时任务。启动调度器
*/
public void startSchedule();
/**
* 关闭调度器
*/
public void shutdownSchedule();
}
操作用户通过Mybatis进行，操作定时器任务，使用的Quartz封装好的接口！
主要的实现代码就不在这里展示！如需查看请看源码！
（3）Controller
UserController 处理一些用户的请求操作！
QuartzController 处理Quartz的请求操作！
6：任务类
package org.ssm.dufy.job; import java.util.Date; import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; public class HelloWorldJob implements Job{ /**
* "0/5 * * * * ? 五秒运行一次
*/
@Override
public void execute(JobExecutionContext arg0) throws JobExecutionException {
System.out.println("----hello world---" + new Date());
} }
三：运行效果介绍
有两种方式启动本实例项目：
1：Tomcat方式，Tomcat方式不在讲解!
2：Jetty方式
在pom.xml中配置了Jetty的依赖的插件！
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-war-plugin</artifactId>
<version>2.4</version>
</plugin>
<plugin>
<groupId>org.mortbay.jetty</groupId>
<artifactId>jetty-maven-plugin</artifactId>
<version>8.1.15.v20140411</version> <configuration>
<scanIntervalSeconds>10</scanIntervalSeconds>
<stopPort>9999</stopPort>
<reload>manual</reload>
<webAppConfig>
<contextPath>/ssm_quratz</contextPath>
</webAppConfig>
<connectors>
<connector implementation="org.eclipse.jetty.server.nio.SelectChannelConnector">
<port>8080</port>
<maxIdleTime>60000</maxIdleTime>
</connector>
</connectors>
</configuration>
</plugin>
在Eclipse运行步骤如在截图：
配置的参数：
-server -Xms1024m -Xmx2048m -XX:PermSize=512m -XX:MaxPermSize=512m -XX:+CMSClassUnloadingEnabled -XX:+PrintGCDetails -Xloggc:%M2_HOME%/gc.log -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=%M2_HOME%/java_pid.hproyuan
配置好之后运行启动不报错就ok！
最后打开浏览器，输入 http://localhost:8080/ssm_quratz
3：运行结果图
（1）登录页面
（2）任务列表页面
（3）新增页面（编辑页面和此类似）
（4）Eclipse控制台打印的信息