基于Seam框架的后台定时执行服务

[原创于：http://happydev.iteye.com]

 

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

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

 

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

 

 

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

 

一、服务的初始化

服务的初始化Seam组件：

 

@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的配置来实现：

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

  

 

二、服务的定时执行

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

 

@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;
	}

}

 

 

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

 

 

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

 

 

 

 

 

 

 

 

 

 

评论

6 楼 yourenyouyu2008 2009-09-02  

jzy19861984 写道

在Quartz中，存在一个StatefulJob，就是有状态Job，如果想在Seam中实现相同的东西，该怎么办呢？谢谢

可以自定义个组件来实现StatefulJob。

5 楼 eosite 2009-03-25  

eosite 写道

这例子是否缺少了些配置？运行不起来

可以运行起来了，谢谢啦

4 楼 eosite 2009-03-25  

这例子是否缺少了些配置？运行不起来

3 楼 jzy19861984 2009-03-06  

我这段时间就在搞Seam，成天搞的头晕，呵呵，新的颠覆传统的东西感觉学起来总是那么费劲。
我用的Seam版本是2.1.1.GA的，在使用其提供的Quartz中有很多问题，感觉到Seam对Quartz的集成并不理想(可能是我还不会使用，如果我下面说的有错误，还请您帮我指正 )。这么说是因为我有以下的问题不知道该如何在Seam提供的Quartz调度功能中实现（而这些功能在原始的Quartz中很轻易就可以实现的）：
[list]

1、无法指定Trigger 和 Job的名称、组

[*]2、在使用Quartz的JobStoreCMT时，将Job调度现场存储至数据库后，让Seam异常中止。再次启动后，就又会再生成另一个新的调度！我无法像在Quartz中一样，使用

Scheduler.getTriggerGroups()

、

Scheduler.getTriggerNames()

等方法获取Tirgger信息等，就算获取到了，由于第 1 点提到的问题，也没法判断是否是你想要的那个Trigger或Job，以恢复或者删除对应的调度。
[*]3、使用Seam集成的Quartz，能不能创建一个可以指定其执行次数的调度？这在原始的Quartz中是使用

Trigger.setRepeatCount(int count);

实现的

4、就是我问到的那个StatefulJob问题

[/list]
Quartz是多好的一个东西，有很好很方便很多的优点，被Seam这么一封装，搞的跟个太监似的，总觉得少点啥玩意。
哎，咱的鸟语不好，没法和人家Seam社区的沟通，只能在你这倒苦水啦，哈哈。
不知道我说的这些算不算问题？还是我真的不了解不会使用Seam的这个功能呢？
期盼回复。

2 楼 happylo 2009-03-05  

jzy19861984 写道

在Quartz中，存在一个StatefulJob，就是有状态Job，如果想在Seam中实现相同的东西，该怎么办呢？谢谢

应该可以通过Seam组件的生命周期来实现，如将保持状态数据的Seam组件的生命周期设置为Application。

1 楼 jzy19861984 2009-03-05  

在Quartz中，存在一个StatefulJob，就是有状态Job，如果想在Seam中实现相同的东西，该怎么办呢？谢谢