Spring使用Quartz配置调度事务

系统管理员 2022-09-24 15:27 106阅读 0赞

首先编写服务类：

![None.gif][] package QuartzTest;  
![None.gif][]  
![None.gif][] import java.util.Date;  
![None.gif][]  
![ExpandedBlockStart.gif][] public  class CourseService \{  
![ExpandedSubBlockStart.gif][]    public  void start()\{  
![InBlock.gif][]       System.out.println( new Date().getSeconds());  
![ExpandedSubBlockEnd.gif][]   \}  
![ExpandedBlockEnd.gif][]\}  
![None.gif][]

编写调度类，需要继承QuartzJobBean ：

![None.gif][] package QuartzTest;  
![None.gif][]  
![None.gif][] import org.quartz.JobExecutionContext;  
![None.gif][] import org.quartz.JobExecutionException;  
![None.gif][] import org.springframework.scheduling.quartz.QuartzJobBean;  
![None.gif][]  
![None.gif][]  
![ExpandedBlockStart.gif][] public  class QuartzJob  extends QuartzJobBean \{      
![InBlock.gif][]      
![ExpandedSubBlockStart.gif][]     protected  void executeInternal(JobExecutionContext arg0)  throws JobExecutionException \{  
![InBlock.gif][]        courseService.start();  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]     private CourseService courseService;  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]     public CourseService getCourseService() \{  
![InBlock.gif][]         return courseService;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]     public  void setCourseService(CourseService courseService) \{  
![InBlock.gif][]         this.courseService = courseService;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]      
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}  
![None.gif][]

编写配置文件

需要说明的是，我们有两种trigger，分别是simple和cron模式，simple方式和timertask类似，采用设置interval方式进行调度，而cron可以特有的语法很详细的定制调度执行时间，具体描述在配置文件的注释中

![None.gif][] <? xml version="1.0" encoding="UTF-8" ?>  
![None.gif][] <! DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"  >  
![None.gif][] < beans >  
![None.gif][]    < bean  id ="courseService"  class ="QuartzTest.CourseService" />  
![None.gif][]      
![None.gif][]    < bean  id ="reportJbo"  class ="org.springframework.scheduling.quartz.JobDetailBean" >  
![None.gif][]      < property  name ="jobClass" >  
![None.gif][]        < value >QuartzTest.QuartzJob </ value >  
![None.gif][]      </ property >  
![None.gif][]      < property  name ="jobDataAsMap" >  
![None.gif][]        < map >

![None.gif][]          < entry  key ="courseService" >  
![None.gif][]            < ref  bean ="courseService" />  
![None.gif][]           </ entry >  
![None.gif][]        </ map >  
![None.gif][]      </ property >  
![None.gif][]    </ bean >  
![None.gif][]  
![None.gif][]      
![None.gif][]      
![None.gif][]    < bean  id ="simpleReportTrigger"  class ="org.springframework.scheduling.quartz.SimpleTriggerBean" >  
![None.gif][]       < property  name ="jobDetail" >  
![None.gif][]         < ref  bean ="reportJbo" />  
![None.gif][]       </ property >  
![None.gif][]       < property  name ="repeatInterval" >  
![None.gif][]         < value >1000 </ value >  
![None.gif][]       </ property >  
![None.gif][]    </ bean >  
![None.gif][]   
![None.gif][]      
![None.gif][]    < bean  id ="cronReportTrigger"  class ="org.springframework.scheduling.quartz.CronTriggerBean" >  
![None.gif][]       < property  name ="jobDetail" >  
![None.gif][]         < ref  bean ="reportJbo" />  
![None.gif][]       </ property >  
![None.gif][]       < property  name ="cronExpression" >  
![None.gif][]         < value >02 20 21 7 6 ? 2007 </ value >   
![None.gif][]           
![None.gif][]       </ property >  
![None.gif][]    </ bean >  
![None.gif][]   
![None.gif][]      
![None.gif][]    < bean  id ="start"  class ="org.springframework.scheduling.quartz.SchedulerFactoryBean" >  
![None.gif][]      < property  name ="triggers" >  
![None.gif][]        < list >  
![None.gif][]          < ref  bean ="cronReportTrigger" />  
![None.gif][]        </ list >  
![None.gif][]      </ property >  
![None.gif][]    </ bean >  
![None.gif][] </ beans >  
![None.gif][]  
![None.gif][]

Spring还为我们提供了更简单的加载调度的方式，也就说我们在已经有业务方法CourseService时不需要再额外编写调度类QuartzJob,可以直接配置service的方法

<bean id="reportJbo" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">  
     <property name="targetObject">  
      <ref bean="courseService"/>  
     </property>  
     <property name="targetMethod">  
        <value>start</value>  
     </property>  
   </bean>

[None.gif]: /images/20220719/0ffcd723be9246fdb331b334810786cf.png
[ExpandedBlockStart.gif]: /images/20220719/3b31750ee2a24d778e1f99343d57c997.png
[ExpandedSubBlockStart.gif]: /images/20220719/abb0d2ff08ab41deafe662d5b40098a0.png
[InBlock.gif]: /images/20220719/d2a20ed89eb5491d9418f45775b3f3d6.png
[ExpandedSubBlockEnd.gif]: /images/20220719/fa64d9bddfab4db0a6afd2343f60eaf3.png
[ExpandedBlockEnd.gif]: /images/20220719/777b00293ae940ae9b3aee52abedd6f5.png