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.pswp.cn/news/443758.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/443758.shtml
英文地址，請注明出處：http://en.pswp.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