1. 全栈程序员必看首页

精进Quartz—SSMM(Spring+SpringMVC+Mybatis+Mysql)和Quartz集成详解（四）

全栈程序员-用户IM • • 未分类

当任何时候觉你得难受了，其实你的大脑是在进化，当任何时候你觉得轻松，其实都在使用以前的坏习惯。SSMM(Spring+SpringMVC+Mybatis+Mysql)和Quartz集成详解

大家好，又见面了，我是全栈君。

文章目录


欢迎关注我的公众号： Java编程技术乐园。分享技术，一起精进Quartz!

做一个积极的人

编码、改bug、提升自己

我有一个乐园，面向编程，春暖花开！

=================================================

对人工智能感兴趣的伙伴，分享一个我朋友的人工智能教程。零基础！通俗易懂！风趣幽默！大家可以看看是否对自己有帮助，点击这里查看教程。

=================================================

当任何时候觉你得难受了，其实你的大脑是在进化，当任何时候你觉得轻松，其实都在使用以前的坏习惯。

通过前面的学习，你可能大致了解了Quartz，本篇博文为你打开学习SSMM+Quartz的旅程！欢迎上车，开始美好的旅程！
本篇是在SSM框架——Spring+SpringMVC+Mybatis的搭建教程这篇为基础上进行的，如果不了解SSM搭建请先点击阅读！

一、环境介绍

工具：Eclipse+ Mysql
框架：Spring+SpringMVC+Mybatis
日志：logback
构建工具：Maven
单元测试：Junit4
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、配置文件介绍

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>

这里写图片描述

4.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、关键代码简单介绍

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>

5.2BAO和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封装好的接口！

主要的实现代码就不在这里展示！如需查看请看源码！

5.3 Controller

（1）：UserController

处理一些用户的请求操作！

（2）：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());
	}

}

7、待优化地方

  • 界面的美观性
  • 可以添加Simple类型的Trigger
  • 用户信息的管理
  • 抽象Job的Dao类
    。。。。。。

三、运行效果介绍

有两种方式启动本实例项目：
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

运行结果图
第一 ：登录页面

这里写图片描述

第二：任务列表页面

这里写图片描述

第三：新增页面（编辑页面和此类似）

这里写图片描述

第四：Eclipse控制台打印的信息

这里写图片描述

四、总结和源码

从前面的系列学习过来，那本文就是一个简单的实战，根据实际的项目和一些简单的案例进行讲解，Quartz掌握到这里，基本上企业级开发也能够应付了，后续持续学习，精进Quartz的源码！

源码：SSMM(Spring+SpringMVC+Mybatis+Mysql)和Quartz集成 源码

Quartz专栏系列

1.精进Quartz——Quartz大致介绍（一）
2.精进Quartz——Quartz简单入门Demo（二）
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处理规则（四）

谢谢你的阅读，如果您觉得这篇博文对你有帮助，请点赞或者喜欢，让更多的人看到！祝你每天开心愉快！

不管做什么，只要坚持下去就会看到不一样！在路上，不卑不亢!

博客首页 : http://blog.csdn.net/u010648555

愿你我在人生的路上能都变成最好的自己，能够成为一个独挡一面的人
精进Quartz—SSMM(Spring+SpringMVC+Mybatis+Mysql)和Quartz集成详解（四）

© 每天都在变得更好的阿飞云

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

发布者：全栈程序员-用户IM，转载请注明出处：https://javaforall.cn/121177.html原文链接：https://javaforall.cn

【正版授权，激活自己账号】： Jetbrains全家桶Ide使用，1年售后保障，每天仅需1毛

【官方授权 正版激活】： 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

赞 (0)
全栈程序员-用户IM全栈程序员-用户IM
0 0


相关推荐

  • 电脑播放已下载本地的m3u8缓存视频文件「建议收藏」

    电脑播放已下载本地的m3u8缓存视频文件「建议收藏」

    经常在网上看视频，不管是电脑上还是手机上！最近几年除了m3u8格式的视频流，其它格式都很少见了。而为啥不用种子下载，是因为要浏览下剧情，看是否喜欢！原先有简单的视频合并工具软件，但现在能用的很少了！连以前下载的缓存都不能合并了！所以在百度了资料和各位大咖的文章后，写下了这篇文章！如果你嫌麻烦请无视！毕竟本人不怎么会编程，纯手动记事本编辑。用Potplayer播放，用HttpFileServer运行服务器。1、首先你当然得知道你下载的文件在哪，把m3u8文件和视频缓存碎片文件夹都复制到电.

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年4月13日
  • 用自己的电脑搭建Web服务器建网站

    用自己的电脑搭建Web服务器建网站

    用自己的电脑搭建Web服务器建网站    这个也是个醉，上课时候在机房搭建成功了，结果回来很长时间没有管，居然给忘了，最近要写电子商务的作业，没办法，只能在捡起来了，又在自己电脑上搭建了一遍，过程都忘了，结果叫好友帮忙，谁知还是不行，还好我记得默认文档要改，这才成功搭建出来，不说了，开始今天的主题吧。搭建Web服务器建网站过程：1、当然是启用功能了window控制面板–&gt;程序与功能–&gt;启用或关闭W…

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年5月28日
  • PetaLinux学习笔记 2

    PetaLinux学习笔记 2

    PetaLinux学习笔记 2现在遇到这样一个问题，没有USB，甚至于USB都没有电压输出，检查电路，USB供电是由一个TPS2051BDBV来控制的，这个芯片又是USB3320C来控制的，说明这个芯片没有工作。官方的例子是可以正常工作的。我仔细查看教程，找到了被我忽略掉的一个内核文件：linux-xlnx-xilinx-v2017.4.tar.gz。这个文件既然由官方提供，那一定是有改动在里面的。黑金在打包这个目录的时候，…

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年9月12日
  • webservice体系结构中包括_致命框架1第六关

    webservice体系结构中包括_致命框架1第六关

    webservice体系结构中包括_致命框架1第六关   Web服务可以用来解决跨网络应用集合问题的开发模式,目的是保证不同平台的应用服务可以相互操作 JAX-WS实现WebServicepackagecom.service;importjavax.jws.WebService;/** WebService准备发布的接口* @WebService注解说明该类为Web服务发布类*/@WebServi…

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年9月21日
  • HTTP.sys远程执行代码漏洞验证及复现——CVE-2015-1635、MS15-034[通俗易懂]

    HTTP.sys远程执行代码漏洞验证及复现——CVE-2015-1635、MS15-034[通俗易懂]

    HTTP.sys远程执行代码漏洞验证及复现——CVE-2015-1635、MS15-034[通俗易懂]目录漏洞概述漏洞环境部署漏洞验证漏洞利用：ms15_034漏洞防御漏洞概述HTTP.sys简介HTTP.sys是MicrosoftWindows处理HTTP请求的内核驱动程序，为了优化IIS服务器性能，从IIS6.0引入，IIS服务进程依赖HTTP.sys。HTTP.sys远程代码执行漏洞实质是HTTP.sys的整数溢出漏洞漏洞成因远程执行代码漏洞存在于…

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年7月25日
  • HBASE的MAPREDUCE任务运行异常解决办法，无需CYGWIN，纯WINDOWS环境

    HBASE的MAPREDUCE任务运行异常解决办法，无需CYGWIN，纯WINDOWS环境

    HBASE的MAPREDUCE任务运行异常解决办法，无需CYGWIN，纯WINDOWS环境

    全栈程序员-用户IM 全栈程序员-用户IM
    2021年8月22日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号