Seam集成的定时器应用_基于Seam框架的后台定时执行服务

转自:http://blog.csdn.net/beenin/article/details/4363075

 

在企业应用中，需要编写后台定时服务的需求经常会遇到，如要对某个数据表的字段进行定时刷新等。

在基于Seam框架中要编写一个后台定时执行服务主要要考虑以下两个方面：

 

1. 服务的初始化；
2. 服务的定时执行；

 

 

本文以Seam集成的QuartZ来实现后台定时执行服务。

 

一、服务的初始化

服务的初始化Seam组件：

 

Java代码

1. @Name("scheduleController")   
2. @AutoCreate  
3. public class ScheduleController implements Serializable {   
4.   
5.     private static final long serialVersionUID = -6332836501640042340L;   
6.        
7.     @In  
8.     EntityManager entityManager;   
9.   
10.     @In  
11.     EntOnlineProcessor entOnlineProcessor;   
12.        
13.     @Logger  
14.     Log log;   
15.   
16.   
17.     public void scheduleTimer() {   
18.   
19.         //启动客户端代理服务   
20.         Long now = System.currentTimeMillis();   
21.         Date when = new Date(now);   
22.         String cron = "0 0/1 * * * ?";//每1分钟   
23.         Date stoptime = new Date(now + 360000000000L);   
24.            
25.         entOnlineProcessor.scheduleOnlineTask(when, cron, stoptime);   
26.         log.info("客户端代理服务服务已成功启动");   
27.            
28.     }   
29.   
30.   
31. }  

@Name("scheduleController") @AutoCreate public class ScheduleController implements Serializable { private static final long serialVersionUID = -6332836501640042340L; @In EntityManager entityManager; @In EntOnlineProcessor entOnlineProcessor; @Logger Log log; public void scheduleTimer() { //启动客户端代理服务 Long now = System.currentTimeMillis(); Date when = new Date(now); String cron = "0 0/1 * * * ?";//每1分钟 Date stoptime = new Date(now + 360000000000L); entOnlineProcessor.scheduleOnlineTask(when, cron, stoptime); log.info("客户端代理服务服务已成功启动"); } }

 

在Seam框架中如何在Seam环境初始化后来自动执行该初始化方法呢，可以components.xml的配置来实现：

Xml代码

加入xmlns:async="http://jboss.com/products/seam/async"

1. <event type="org.jboss.seam.postInitialization">    

1.    <action execute="#{scheduleController.scheduleTimer}"/>    
2. </event>  
3.   
4.   
5.  <!-- Install the QuartzDispatcher -->  
6.  <async:quartz-dispatcher/>  
7. sp;  

 <event type="org.jboss.seam.postInitialization"> <action execute="#{scheduleController.scheduleTimer}"/> </event> <!-- Install the QuartzDispatcher --> <async:quartz-dispatcher/>  

  

 

二、服务的定时执行

服务的定时执行关键是服务的实现，参考实现如下代码：

 

Java代码

1. @Name("entOnlineProcessor")   
2. @AutoCreate  
3. public class EntOnlineProcessor {   
4.   
5.     @In    
6.     EntityManager entityManager;   
7.   
8.     @Logger Log log;   
9.   
10.        
11.     @Asynchronous  
12.     @Transactional  
13.     public QuartzTriggerHandle scheduleOnlineTask(@Expiration Date when,    
14.                                  @IntervalCron String cron,    
15.                                  @FinalExpiration Date stoptime)    
16.     {    
17.     ......   
18.         return null;   
19.     }   
20.   
21. }  

@Name("entOnlineProcessor") @AutoCreate public class EntOnlineProcessor { @In EntityManager entityManager; @Logger Log log; @Asynchronous @Transactional public QuartzTriggerHandle scheduleOnlineTask(@Expiration Date when, @IntervalCron String cron, @FinalExpiration Date stoptime) { ...... return null; } }

 

 

关于如何触发该异步方法，并且控制定时机制在上一个代码中已包含了：

 

 

Java代码

1. //启动客户端代理服务   
2. cron = "0 0/1 * * * ?";//每1分钟   
3. entOnlineProcessor.scheduleOnlineTask(when, cron, stoptime);   
4. log.info("客户端代理服务服务已成功启动");