【SSH项目实战】国税协同平台-33.quartz&SimpleTrigge

在我们“投诉管理”和“我要投诉”这两个模块完成之后,我们要做一个“自动投诉受理”功能。
我们来回顾一下“自动投诉受理”功能的需求分析:
自动投诉受理:在每个月月底最后一天对本月之前的投诉进行自动处理;将投诉信息的状态改为已失效。在后台管理中不能对该类型投诉进行回复。

自动投诉受理是在一定时间内自动的调度任务执行投诉状态的更新;那么需要使用任务调度,常见的任务调度有Jdk 的Timer 以及 quartz任务调度框架等。在spring中可以将这些任务调度集成由spring管理这些任务调度。

我们先使用Timer来完成这个模块:
一、JDK Timer & TimerTask
要使用JDK的Timer,需要完成以下两个动作:
① 继承TimerTask
② 制定Timer执行频率

我们首先在投诉管理的包下创建MyTimerTask,并继承TimerTask,我们在其中的run方法中显示了执行时间栈是当前的时间:

package cn.edu.hpu.tax.complain;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.TimerTask;

public class MyTimerTask extends TimerTask {

	@Override
	public void run() {
		SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("doing TimerTask..."+sdf.format(new Date()));
	}

}

如果你看一下TimerTask的源码,你就应该发现其实是继承了Runnable的,所以它是一个线程类。

我们写一个测试类来测试MyTimerTask:

package cn.edu.hpu.tax.complain;

import java.util.Timer;

public class MyTimer {

	public static void main(String[] args) {
		Timer timer=new Timer();
		//延迟2秒执行,每3秒执行一次
		timer.schedule(new MyTimerTask(),2000,3000);
	}

}

运行结果:

doing TimerTask...2015-12-02 10:51:30
doing TimerTask...2015-12-02 10:51:33
doing TimerTask...2015-12-02 10:51:36
doing TimerTask...2015-12-02 10:51:39
doing TimerTask...2015-12-02 10:51:42
doing TimerTask...2015-12-02 10:51:45
......

不停止运行的话,就以每3秒执行一次的频率无限执行下去。
也就是使用Timer(给定一个TimerTask任务栈),它就会按照规定的频率隔一段时间执行TimerTask栈中的run方法中的代码。

这就是我们的Timer和TimerTask。
如果要用Timer来做我们的“自动投诉受理”功能,我们就要每时每刻的去判断现在是不是本月的最后一天,这样做并不是太友好。

也就是说使用jdk的timer时发现无法满足这次的开发需求;即无法在指定的日期进行执行任务。

我们接下来介绍专门用来执行任务调度的框架,叫做Quartz 
二、Spring 集成Quartz 

Quartz是一个优秀的开源任务调度框架,这里加入的是quartz-1.8.6版本。Quart的官网:http://www.quartz-scheduler.org/;项目中的框架的spring是spring 3.0版本无法集成quartz 2.x及其后续版本;所以这里用quartz 1.8.6版本。

在spring中整合Quartz 进行任务调度:
首先将需要用到的jar包引入项目的lib目录下: 
(1)“org.springframework.context.support-3.0.2.RELEASE.jar”【 此包是spring根据quartz中的主要类进行再次封装成具有bean风格的类】
(2)“quartz-1.8.6.jar”【quartz的核心包】

我们把相关jar包引入进来之后,我们来使用quartz。
quartz也有两种运行机制,一个是以固定的频率来执行任务(这里和我们的Timer类似),另一个就是它可以配置非常精确的时间来执行你的任务(这个就是我们想要的)。

先来了解固定频率执行任务:
一、固定频率执行任务
我们要执行下面三个步骤来使用quartz

1、制定任务信息 bean
   作用:任务详细信息;包括调用哪个类;类中的哪个方法;执行时是否可并行执行任务。

   ① 设置执行对象
   ② 设置执行对象中对应的执行方法
   ③ 是否可以同步执行

2、制定任务执行时机(执行触发器) bean
   作用:主要用于定义任务信息 bean中任务什么时候执行

   2.1、简单触发器(SimpleTrigger)
   ① 设置任务详细
   ② 设置任务延迟执行时间
   ③ 设置任务执行频率

   2.2、任务触发器(CronTrigger)
   ① 设置任务详细
   ② 设置执行时机(cronExpression)
    cronExpression:秒 分 时 日 月 周 年(可选)

3、设置任务调度工厂 bean
   作用:用于调度各个任务触发器,设置触发器们

我们按步骤来编写代码测试:
首先我们写一个制定任务信息的bean:

package cn.edu.hpu.tax.complain;

import java.text.SimpleDateFormat;
import java.util.Date;

public class QuartzTask {

	public void doSimpleTriggerTask() {
		SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("doing simpleTrigger task..."+sdf.format(new Date()));
	}
}

然后是我们的quartz-spring.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" xmlns:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
	http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
	http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
	http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">

    <!-- 注册一个普通bean -->
    <bean id="quartzTask" class="cn.edu.hpu.tax.complain.QuartzTask"></bean>

    <!-- 1.指定任务详细信息 -->
    <bean id="jobDetial1" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
	    <!--  ① 设置执行对象 -->
	    <property name="targetObject" ref="quartzTask"></property>
	    <!--  ② 设置执行对象中对应的执行方法 -->
	    <property name="targetMethod" value="doSimpleTriggerTask"></property>
	    <!--  ③ 是否可以同步执行(这里设置不同步执行) -->
	    <property name="concurrent" value="false"></property>
    </bean>

    <!-- 2.制定任务执行时机(任务执行触发器) -->
    <bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">
    	<!-- ① 设置任务详细 -->
    	<property name="jobDetail" ref="jobDetial1"></property>
  	 	<!-- ② 设置任务延迟执行时间(延迟2秒) -->
  	 	<property name="startDelay" value="2000"></property>
   		<!-- ③ 设置任务执行频率(执行频率为每2秒执行一下) -->
   		<property name="repeatInterval" value="2000"></property>
    </bean>

    <!-- 3.设置调度工厂 -->
    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    	<property name="triggers">
    		<list>
    			<!-- 第一个触发器 -->
    			<ref bean="simpleTrigger"/>
    		</list>
    	</property>
    </bean>
</beans>

启动服务器测试,注意我们的服务器控制台,可以看到我们的任务正在后台悄无声息的按照我们配置的频率执行着:

十二月 02, 2015 12:45:39 下午 org.apache.coyote.http11.Http11Protocol start
信息: Starting Coyote HTTP/1.1 on http-80
十二月 02, 2015 12:45:39 下午 org.apache.jk.common.ChannelSocket init
信息: JK: ajp13 listening on /0.0.0.0:8009
十二月 02, 2015 12:45:39 下午 org.apache.jk.server.JkMain start
信息: Jk running ID=0 time=0/19  config=null
十二月 02, 2015 12:45:39 下午 org.apache.catalina.startup.Catalina start
信息: Server startup in 33863 ms
doing simpleTrigger task...2015-12-02 12:45:39
doing simpleTrigger task...2015-12-02 12:45:41
doing simpleTrigger task...2015-12-02 12:45:43
doing simpleTrigger task...2015-12-02 12:45:45
doing simpleTrigger task...2015-12-02 12:45:47
doing simpleTrigger task...2015-12-02 12:45:49
......

这个作用和Timer并没有太大区别,只是Timer是不可控的,参数不好改(要在代码里修改),但是spring架构下的quartzde的所有参数都是可以在配置文件中随意修改的,这里就比较可控。

我们上面使用的是spring架构下的quartzde的简单触发器,这个还不够好,我们的需求是到我们月末执行自动回复,我们可以利用quartzde的另一个触发器来实行点到点的定义(多少秒,什么时候来执行都可以)。

下一次我们继续。

转载请注明出处:http://blog.csdn.net/acmman/article/details/50183987

时间: 2024-10-07 13:38:04

【SSH项目实战】国税协同平台-33.quartz&amp;SimpleTrigge的相关文章

【SSH项目实战】国税协同平台-34.quartz&amp;amp;CronTrigger

我们上次使用quartz任务调度框架创建了一个在后台按照时间间隔不停运行的任务,我们使用的是simpleTrigger简单触发器,为了实现我们的月末自动回复的功能,我们要设置触发器能够在某个精确时间去自动执行任务,那么使用simpleTrigger简单触发器就远远不够了,我们需要使用CronTrigger任务触发器来实现这个功能. 我们的CronTrigger设置步骤如下: 任务触发器(CronTrigger) ① 设置任务详细 ② 设置执行时机(cronExpression) cronExpr

【SSH项目实战】国税协同平台-1.项目介绍

项目介绍 1.1项目背景 国税协同办公平台包括了行政管理.后勤服务.在线学习.纳税服务.我的空间等几个子系统:我们本次主要的开发功能是纳税服务子系统的部分模块和基于纳税服务子系统信息的个人工作台首页.纳税服务子系统是办税PC前端或移动端的后台管理系统,主要包括的功能有系统角色管理.用户管理.信息发布管理.投诉受理.纳税咨询.易告知.服务预约.服务调查等模块. 系统的主界面: 我们要做的模块界面: 1.2项目前期 项目前期:一般是由客户经理从客户那边了解到有关该项目的招标信息,然后开发公司再组织竞

【SSH项目实战】国税协同平台-14.系统、子系统首页&amp;amp;登录功能1

我们做完了用户与角色的分配,在设置用户在相应的角色下的操作之前,我们先完成用户的登录功能. 首先,我们先加载我们的系统的首页和子首页.很简单,就是转发到一个jsp页面而已,我们先写一个HomeAction来设置跳转功能: package cn.edu.hpu.tax.core.action; import com.opensymphony.xwork2.ActionSupport; public class HomeAction extends ActionSupport{ //跳转到首页 pu

【SSH项目实战】国税协同平台-3.资源文件分类&amp;amp;log4j&amp;amp;抽取BaseAction

上次我们搭建了SSH框架的环境,然后做了单元测试,下面我们继续来完善我们工厂的准备工作. 3.1资源文件分类 (1)将配置文件归类到新建config文件夹: (2)源代码目录按照功能模块进行划分:cn.edu.hpu.子系统.功能模块.* (3)Jsp放置到WEB-INF目录下: (4)其它: 新建一个test源文件架(Source Folder),我们把上次所有测试的代码全部移入test文件夹下,然后专门为配置文件创建一个conf源文件夹,将配置文件移入,然后src中先建立一个包准备放新写的代

【SSH项目实战】国税协同平台-31.我要投诉功能1

我们之前完成了投诉回复和保存功能,这次我们将要完成历史受理信息的显示 以及数据回显功能,当然还有用户编写投诉信息的入口,我们这次继续. 可以注意到,在deilUI.jsp上我们之前的投诉人信息显示,不管是匿名还是不匿名,投诉人的姓名.手机号码都是显示出来的: <tr> <td class="tdBg">投诉人姓名:</td> <td><s:property value="complain.compName"/&g

【SSH项目实战】国税协同平台-4.用户管理需求分析&amp;amp;CRUD方法1

上次我们完成了日志模块的配置和基础增删改查类,下面我们根据用户的需求来正式开发项目的业务模块. 下面我们主要来开发系统用户管理的模块 我们有用户的功能说明书,打开功能说明书来看看这个模块需要什么功能: 功能说明 用户管理:可以根据用户名查询系统用户:在页面中点击"新增"可以添加用户.点击删除可以批量删除选中的用户."导出"则导出所有的用户列表到excel文件中并弹出下载提示框给用户下载:"导入"将需要用户将本地的用户列表按照一定格式将excel中

【SSH项目实战】国税协同平台-2.环境搭建和整合

框架整合 2.1新建数据库及web项目 2.1.1创建itcastTax数据库 -- 创建数据库 CREATE DATABASE itcastTax DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci; 我们使用的是Mysql数据库 2.1.2新建web项目 新建工作空间指定项目编码(或工作空间编码)为utf-8,再建 web project,配置buildpath 添加jstl的jar包和mysql驱动包:javax.servlet.jsp.j

【SSH项目实战】国税协同平台-7.POI导入用户列表文件

上次我们使用POI技术完成了用户列表的打印工作,下面我们来完成用户列表Excel文件的导入. 我们要导入这个Excel文件到我们的系统中: 确切的说,是我们要将excel中的数据导入到数据库中保存起来 我们的操作过程: 1.获取excel文件 2.导入 2.1.读取工作簿 2.2.读取工作表 2.3.读取行 2.4.读取单元格 2.5.保存用户 下面我们来进行具体的实现工作 我们在用户列表的jsp页面中可以看到还有一个"导出"的按钮, <input type="butt

【SSH项目实战】国税协同平台-19.信息发布管理完善&amp;amp;ueditor文本编辑插件

我们上次虽然完成了信息发布管理模块基础的增删改查,但是我们还有需求没有完成,其中最重要的一点就是需求上要求我们发布的信息必须是有格式的,word文档那种格式,而我们的原始textarea是清除所有文本格式的,我们在这一次来解决这个问题. 我们使用ueditor插件(百度开发)来解决这个问题,ueditor是一种"父文本编辑器",也叫"在线编辑器",可以使用这种插件来编辑各种格式的文本.(当然还有CKEdit.FckEdit等插件,我们这里使用ueditor插件,因为