Spring3.1+Quertz1.8实现多个计划任务

1.主要是配置文件：如下：(这里说明一下主要是看红色部分的配置，其他的可以根据自己的实际情况修改，这里只是个思路。)

<?xml version="1.0"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"xmlns:security="http://www.springframework.org/schema/security"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.xsdhttp://www.springframework.org/schema/security http://www.springframework.org/schema/security/spring-security-3.1.xsd"><!-- 分散配置 --><context:property-placeholder location="classpath:jdbc.properties"/><!-- 组件扫描,此处的实现原理是递归扫描所有包，效率较差。开发模式写法如下。后期调优可以将具体包名全部列到下面，以逗号隔开 --><context:component-scan base-package="cn.gov.csrc.*"/><!-- 配置c3p0数据源 --><bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"><property name="driverClass" value="${jdbc.driverclass}" /><property name="jdbcUrl" value="${jdbc.url}" /><property name="user" value="${jdbc.username}" /><property name="password" value="${jdbc.password}" /><property name="maxPoolSize" value="${c3p0.pool.size.max}" /><property name="minPoolSize" value="${c3p0.pool.size.min}" /><property name="initialPoolSize" value="${c3p0.pool.size.ini}" /><property name="acquireIncrement" value="${c3p0.pool.size.increment}" /><property name="maxIdleTime" value="${cpool.maxIdleTime}" /></bean><!-- 本地回话工厂bean,spring整合hibernate的核心入口 --><bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"><!-- 数据源 --><property name="dataSource" ref="dataSource" /><!-- hibernate自身属性 --><property name="hibernateProperties"><props><prop key="hibernate.dialect">${hibernate.dialect}</prop><!-- 根据Bean自动生成数据库表,MySql5.5以后要使用org.hibernate.dialect.MySQL5InnoDBDialect才能创建成功！ --><prop key="hibernate.hbm2ddl.auto">${hibernate.hbm2ddl.auto}</prop><prop key="hibernate.show_sql">${hibernate.show_sql}</prop><prop key="hibernate.format_sql">false</prop><prop key="hibernate.temp.use_jdbc_metadata_defaults">false</prop><!-- 开启二级缓存,其实hibernate默认就是开启的,这里显示的指定一下 --><prop key="hibernate.cache.use_second_level_cache">true</prop> <prop key="hibernate.autoReconnect">true</prop><!-- 指定二级缓存产品的提供商 --> <!--  <prop key="hibernate.cache.provider_class">org.hibernate.cache.EhCacheProvider</prop><prop key="hibernate.cache.use_query_cache">true</prop> --></props></property><property name="packagesToScan"><list><value>cn.gov.csrc.base.systemmanager.model</value><value>cn.gov.csrc.report.model</value><value>cn.gov.csrc.noreal.report.model</value></list></property></bean><!-- hibernate事务管理器,在service层上实现事务管理,达到平台无关性 --><bean id="txManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager"><property name="sessionFactory" ref="sessionFactory" /><property name="globalRollbackOnParticipationFailure" value="false" /></bean><!-- 事务通知 --><tx:advice id="txAdvice" transaction-manager="txManager"><tx:attributes><tx:method name="save*" propagation="REQUIRED" isolation="DEFAULT"/><tx:method name="update*" propagation="REQUIRED" isolation="DEFAULT"/><tx:method name="delete*" propagation="REQUIRED" isolation="DEFAULT"/><tx:method name="batch*" propagation="REQUIRED" isolation="DEFAULT"/><tx:method name="load*" propagation="REQUIRED" isolation="DEFAULT" read-only="true"/><tx:method name="get*" propagation="REQUIRED" isolation="DEFAULT" read-only="true"/><tx:method name="find*" propagation="REQUIRED" isolation="DEFAULT" read-only="true"/><tx:method name="*" propagation="REQUIRED" isolation="DEFAULT"/></tx:attributes></tx:advice><bean id="genericLogger" class="cn.gov.csrc.base.log.GenericLogger"/><!-- aop配置 --><aop:config><!-- 切入点通知 --><aop:advisor advice-ref="txAdvice" pointcut="execution(* cn.gov.csrc.base.security..*.*(..))"/><aop:advisor advice-ref="txAdvice" pointcut="execution(* *..*Service.*(..))"/></aop:config><aop:config>   <aop:pointcut id="logger"   expression="execution(* *..*Dao.save*(..))or execution(* *..*Dao.update*(..))or execution(* *..*Dao.delete*(..))or execution(* *..*Dao.batch*(..))" />   <aop:aspect id="loggerAspect" ref="genericLogger">   <aop:around pointcut-ref="logger" method="invoke" />   </aop:aspect>   </aop:config> <!-- 任务计划 --><!-- 要调用的工作 --><bean id="timerAction" class="cn.gov.csrc.report.action.TimerAction"></bean><bean id="praseXmlAction" class="cn.gov.csrc.report.action.PraseXmlAction"></bean><!-- 定义调用对象和调用对象的方法 --><bean id="jobtask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"><!-- 调用的类 --><property name="targetObject"><ref bean="timerAction"/></property><!-- 调用类中的方法 --><property name="targetMethod"><value>start</value></property><!-- 作业不并发调度 --><property name="concurrent" value="false"/></bean><!-- 定义调用对象和调用对象的方法 --><bean id="jobTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"><!-- 调用的类 --><property name="targetObject"><ref bean="praseXmlAction"/></property><!-- 调用类中的方法 --><property name="targetMethod"><value>parseXml</value></property><!-- 作业不并发调度 --><property name="concurrent" value="false"/></bean><!-- 定义导出数据到xml的触发时间 --><bean id="doTime" class="org.springframework.scheduling.quartz.CronTriggerBean"><property name="jobDetail"><ref bean="jobtask"/></property><!-- cron表达式 --><property name="cronExpression"><!-- 每天晚上11点59分钟59秒执行一次 --><!-- <value>0 59 23 * * ?</value> --><value>0 23 14 * * ?</value></property></bean><!-- 定义解析xml的触发时间 --><bean id="doPraseXml" class="org.springframework.scheduling.quartz.CronTriggerBean"><property name="jobDetail"><ref bean="jobTask"/></property><!-- cron表达式 --><property name="cronExpression"><value>0 24 14 * * ?</value></property></bean><!-- 总管理类,如果将lazy-init='false'那么容器启动就会执行调度程序 --><bean id="startQuertz" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"><property name="triggers"><list><ref bean="doTime"/><ref bean="doPraseXml"/></list></property></bean></beans>


2.TimerAction.java: 

package cn.gov.csrc.report.action;import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Blob;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.Set;import javax.annotation.Resource;import org.apache.struts2.convention.annotation.Action;
import org.apache.tools.zip.ZipEntry;
import org.apache.tools.zip.ZipOutputStream;
import org.jdom2.Document;
import org.jdom2.Element;
import org.jdom2.JDOMException;
import org.jdom2.input.SAXBuilder;
import org.jdom2.output.Format;
import org.jdom2.output.XMLOutputter;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.context.annotation.Scope;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.stereotype.Controller;import cn.gov.csrc.base.systemmanager.model.User;
import cn.gov.csrc.report.model.Accessory;
import cn.gov.csrc.report.model.Case;
import cn.gov.csrc.report.model.ReportedPerson;
import cn.gov.csrc.report.service.CaseService;@Controller()
@Scope("prototype")
@Action("TimerAction")
public class TimerAction extends QuartzJobBean {private int timeout;public TimerAction() {}/** 调度工厂实例化后，经过timeout时间开始执行调度 */public void setTimeout(int timeout) {this.timeout = timeout;}@Overrideprotected void executeInternal(JobExecutionContext context)throws JobExecutionException {System.out.println("定时任务执行中......");}/*** 定时导出外网数据到指定目录* @throws Exception*/public void start() throws Exception {	System.out.println("定时任务执行成功......");}}

3.要解析的xml模板文件如下： (这里我的xml文件放到了D:\admin\2014-03-18目录下) 

<?xml version="1.0" encoding="GBK"?>
<crsc>       <data><举报信息反馈><R index="1"><举报编号>1</举报编号><状态>1</状态><答复意见>填写答复意见</答复意见></R><R index="2"><举报编号>2</举报编号><状态>2</状态><答复意见>填写答复意见</答复意见></R><R index="3"><举报编号>3</举报编号><状态>3</状态><答复意见>填写答复意见</答复意见></R><R index="4"><举报编号>4</举报编号><状态>1</状态><答复意见>填写答复意见</答复意见></R></举报信息反馈></data>
</crsc>

4.PraseXmlAction.java: 

package cn.gov.csrc.report.action;import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;import org.apache.struts2.convention.annotation.Action;
import org.jdom2.Document;
import org.jdom2.Element;
import org.jdom2.JDOMException;
import org.jdom2.input.SAXBuilder;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.context.annotation.Scope;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.stereotype.Controller;@Controller()
@Scope("prototype")
@Action("PraseXmlAction")
public class PraseXmlAction extends QuartzJobBean {private static final String xmlPath = "D:\\admin\\" + getFileName()+ "\\case.xml";public PraseXmlAction() {}@Overrideprotected void executeInternal(JobExecutionContext arg0)throws JobExecutionException {// TODO Auto-generated method stubSystem.out.println("定时任务执行中......");}/*** 获取当前时间为文件夹名称* * @return*/protected static String getFileName() {String fileNames = null;Date date = new Date();SimpleDateFormat formatDateFormat = new SimpleDateFormat("yyyy-MM-dd");fileNames = formatDateFormat.format(date);return fileNames;}/*** JDom解析xml文件*/public void parseXml() {try {List<Element> elementList = getElementList();for (Element element : elementList) {Element nameElement = element.getChild("举报信息反馈");List<Element> children = nameElement.getChildren();for (Element element2 : children) {Element nameElement2 = element2.getChild("举报编号");if (nameElement2 != null) {System.out.println("   " + nameElement2.getName() + "："+ nameElement2.getTextTrim());}Element valueElement = element2.getChild("状态");if (valueElement != null) {System.out.println("   " + valueElement.getName() + "："+ valueElement.getTextTrim());}Element descriptElement = element2.getChild("答复意见");if (descriptElement != null) {System.out.println("   " + descriptElement.getName()+ "：" + descriptElement.getTextTrim());}System.out.println("--------------------");}}} catch (Exception e) {System.out.println(e.getMessage());}}public static List<Element> getElementList() throws FileNotFoundException,JDOMException, IOException {// 创建SAX建造者对象，该类构造方法的重载boolean类型的方法中validate表示是否验证xml文档SAXBuilder saxBuilder = new SAXBuilder(false);InputStream inputStream = new FileInputStream(new File(xmlPath));// 解析xml文档，返回document文档对象Document document = saxBuilder.build(inputStream);// 获取根节点Element rootElement = document.getRootElement();// 获取根节点下的第一个子节点List<Element> elementList = rootElement.getChildren();return elementList;}}



本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/443758.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

MySQL | 数据库的六种约束、表的关系、三大范式

MySQL | 数据库的六种约束、表的关系、三大范式

文章目录数据库约束NOT NULL&#xff08;非空约束&#xff09;UNIQUE&#xff08;唯一约束&#xff09;DEFAULT&#xff08;缺省约束&#xff09;PRIMARY KEY&#xff08;主键约束&#xff09;AUTO_INCREMENT 自增FOREIGN KEY&#xff08;外键约束&#xff09;CHECK&#xff08…
阅读更多...
哈希 ：哈希冲突、负载因子、哈希函数、哈希表、哈希桶

哈希 ：哈希冲突、负载因子、哈希函数、哈希表、哈希桶

文章目录哈希哈希&#xff08;散列&#xff09;函数常见的哈希函数字符串哈希函数哈希冲突闭散列&#xff08;开放地址法&#xff09;开散列&#xff08;链地址法/拉链法&#xff09;负载因子以及增容对于闭散列对于开散列结构具体实现哈希表&#xff08;闭散列&#xff09;创建…
阅读更多...
C++ 泛型编程（一）：模板基础：函数模板、类模板、模板推演成函数的机制、模板实例化、模板匹配规则

C++ 泛型编程（一）：模板基础：函数模板、类模板、模板推演成函数的机制、模板实例化、模板匹配规则

文章目录泛型编程函数模板函数模板实例化隐式实例化显式实例化函数模板的匹配规则类模板类模板的实例化泛型编程 泛型编程旨在削减重复工作&#xff0c;如&#xff1a; 将一个函数多次重载不如将他写成泛型。 void Swap(int& left, int& right) {int temp left;lef…
阅读更多...
你真的了解静态变量、常量的存储位置吗？

你真的了解静态变量、常量的存储位置吗？

文章目录引言C对内存的划分如何落实在Linux上自由存储区和堆之间的问题栈常量区静态存储区静态局部变量静态局部变量、静态全局变量、全局变量的异同macOS系统的测试结果总结引言 在动态内存的博客中&#xff0c;我提到&#xff1a; 在Linux 内存管理的博客中&#xff0c;我提…
阅读更多...
C++ 泛型编程（二）：非类型模板参数，模板特化，模板的分离编译

C++ 泛型编程（二）：非类型模板参数，模板特化，模板的分离编译

文章目录非类型模板参数函数模板的特化类模板的特化全特化偏特化部分参数特化参数修饰特化模板分离编译解决方法非类型模板参数 模板的参数分为两种&#xff1a; 类型参数&#xff1a; 则是我们通常使用的方式&#xff0c;就是在模板的参数列表中在 class 后面加上参数的类型…
阅读更多...
Java操作——获取文件扩展名，去掉文件扩展名

Java操作——获取文件扩展名，去掉文件扩展名

昨天收邮件&#xff0c;得知要参加一个产品部的会议&#xff0c;猜想&#xff0c;也许是因为我做的这个产品demo问题。于是昨天忙活到凌晨3点半&#xff0c;结果早上一来才知道又被调戏了。发邮件的MM把邮件误发给我了。悲催啊有木有&#xff0c;困啊有木有&#xff01;自己还是…
阅读更多...
数据结构 | B树、B+树、B*树

数据结构 | B树、B+树、B*树

文章目录搜索结构B树B树的插入B树的遍历B树的性能B树B树的插入B树的遍历B*树B*树的插入总结搜索结构 如果我们有大量的数据需要永久存储&#xff0c;就需要存储到硬盘之中。但是硬盘的访问速度远远小于内存&#xff0c;并且由于数据量过大&#xff0c;无法一次性加载到内存中。…
阅读更多...
MySQL 索引 ：哈希索引、B+树索引、全文索引

MySQL 索引 ：哈希索引、B+树索引、全文索引

文章目录索引引言常见的索引哈希索引自适应哈希索引B树索引聚集索引非聚集索引使用方法联合索引最左前缀匹配规则覆盖索引全文索引使用方法索引 引言 为什么需要索引&#xff1f; 倘若不使用索引&#xff0c;查找数据时&#xff0c;MySQL必须遍历整个表。而表越大&#xff0c;…
阅读更多...
服装店怎么引流和吸引顾客 服装店铺收银系统来配合

服装店怎么引流和吸引顾客 服装店铺收银系统来配合

实体店的同城引流和经营是实体经济的一个重要的一环&#xff0c;今天我们来分享服装行业的实体店铺怎么引流和吸引、留住顾客&#xff0c;并实现复购。大家点个收藏&#xff0c;不然划走就再也找不到了&#xff0c;另外可以点个关注&#xff0c;下次有新的更好的招&#xff0c;…
阅读更多...
约瑟夫环（丢手绢问题）

约瑟夫环（丢手绢问题）

文章目录问题描述思路代码实现问题描述 有 1~N 个数字&#xff0c;从 1~m 依次报数&#xff0c;数到 m 的数字要被删掉&#xff0c;求最后剩下的数字是&#xff1f; 思路 第一次报数第二次报数1n-m12n-m2……m-2n-2m-1n-1m被删掉了m11m22……n-1n-1-mnn-m 通过上面的表格&…
阅读更多...
MySQL 锁的相关知识 | lock与latch、锁的类型、简谈MVCC、锁算法、死锁、锁升级

MySQL 锁的相关知识 | lock与latch、锁的类型、简谈MVCC、锁算法、死锁、锁升级

文章目录lock与latch锁的类型MVCC一致性非锁定读&#xff08;快照读&#xff09;一致性锁定读&#xff08;当前读&#xff09;锁算法死锁锁升级lock与latch 在了解数据库锁之前&#xff0c;首先就要区分开 lock 和 latch。在数据库中&#xff0c;lock 和 latch 虽然都是锁&…
阅读更多...
Hibernate使用原生SQL适应复杂数据查询

Hibernate使用原生SQL适应复杂数据查询

HQL尽管容易使用&#xff0c;但是在一些复杂的数据操作上功能有限。特别是在实现复杂的报表统计与计算&#xff0c;以及多表连接查询上往往无能为力&#xff0c;这时可以使用SQL&#xff08;Native SQL&#xff09;实现HQL无法完成的任务。 1、使用SQL查询 使用SQL查询可以通过…
阅读更多...
MySQL 存储引擎 | MyISAM 与 InnoDB

MySQL 存储引擎 | MyISAM 与 InnoDB

文章目录概念innodb引擎的4大特性索引结构InnoDBMyISAM区别表级锁和行级锁概念 MyISAM 是 MySQL 的默认数据库引擎&#xff08;5.5版之前&#xff09;&#xff0c;但因为不支持事务处理而被 InnoDB 替代。 然而事物都是有两面性的&#xff0c;InnoDB 支持事务处理也会带来一些…
阅读更多...
MySQL 事务 | ACID、四种隔离级别、并发带来的隔离问题、事务的使用与实现

MySQL 事务 | ACID、四种隔离级别、并发带来的隔离问题、事务的使用与实现

文章目录事务ACID并发带来的隔离问题幻读&#xff08;虚读&#xff09;不可重复读脏读丢失更新隔离级别Read Uncommitted (读未提交)Read Committed (读已提交)Repeatable Read (可重复读)Serializable (可串行化)事务的使用事务的实现Redoundo事务 事务指逻辑上的一组操作。 …
阅读更多...
MySQL 备份与主从复制

MySQL 备份与主从复制

文章目录备份主从复制主从复制的作用备份 根据备份方法的不同&#xff0c;备份可划分为以下几种类型&#xff1a; 热备(Hot Backup) &#xff1a; 热备指的是在数据库运行的时候直接备份&#xff0c;并且对正在运行的数据库毫无影响&#xff0c;这种方法在 MySQL 官方手册中又…
阅读更多...
C++ 流的操作 | 初识IO类、文件流、string流的使用

C++ 流的操作 | 初识IO类、文件流、string流的使用

文章目录前言IO头文件iostreamfstreamsstream流的使用不能拷贝或对 IO对象 赋值条件状态与 iostate 类型输出缓冲区文件流fstream类型文件模式文件光标函数tellg() / tellp()seekg() / seekp()向文件存储内容/读取文件内容string流istringstreamostringstream前言 我们在使用 …
阅读更多...
Hibernate 更新部分更改的字段 hibernate update

Hibernate 更新部分更改的字段 hibernate update

Hibernate 中如果直接使用 Session.update(Object o);或则是Session.updateOrUpdate(Object o); 会把这个表中的所有字段更新一遍。 如&#xff1a; ExperClass4k e new ExperClass4k(); e.setTime(time); e.setQ_num(q_num); e.setK(k); if (str "finch_fix")…
阅读更多...
C++ 类的行为 | 行为像值的类、行为像指针的类、swap函数处理自赋值

C++ 类的行为 | 行为像值的类、行为像指针的类、swap函数处理自赋值

文章目录概念行为像值的类行为像指针的类概念引用计数动态内存实现计数器类的swap概念swap实现自赋值概念 行为像值的类和行为像指针的类这两种说法其实蛮拗口的&#xff0c;这也算是 《CPrimer》 翻译的缺点之一吧。。。 其实两者的意思分别是&#xff1a; 行为像值的类&am…
阅读更多...
C++ 右值引用 | 左值、右值、move、移动语义、引用限定符

C++ 右值引用 | 左值、右值、move、移动语义、引用限定符

文章目录C11为什么引入右值&#xff1f;区分左值引用、右值引用move移动语义移动构造函数移动赋值运算符合成的移动操作小结引用限定符规定this是左值or右值引用限定符与重载C11为什么引入右值&#xff1f; C11引入了一个扩展内存的方法——移动而非拷贝&#xff0c;移动较之拷…
阅读更多...
且谈关于最近软件测试的面试

且谈关于最近软件测试的面试

前段时间有新的产品需要招人&#xff0c;安排和参加了好几次面试&#xff0c;下面就谈谈具体的面试问题&#xff0c;在面试他人的同时也面试自己。 面试问题是参与面试同事各自设计的&#xff0c;我也不清楚其他同事的题目&#xff0c;就谈谈自己设计的其中2道题。 过去面试总是…
阅读更多...
最新文章

Copyright @ 2022~2023