WebLogic Server中的计划任务

南天一柱

近来总是在思考自己的项目中有一个web应用采用weblogic，而还有一个数据处理专用socket服务器、还有一个涉及业务操作的socket服务器，里面用到好多定时处理的问题，我们都是采用老外的scheduling.jar包并继承处理，然而这样总是给客户带来诸多不便，因为启动一次机器要启动三个服务，并同时维护三个服务的程序还要分别部署，所以就研究向weblogic这样的中间件是否也支持计划任务和类似socket之类的监听，如果可以得话我们将在下一个版本中将三个服务合成到中间件中，可以节省客户和我们自己的维护成本啊，呵呵，以下是我搜罗的计划任务相关资料，分享一下：）
运行计划任务的需求不断增加，而且在所有J2EE应用程序中日益普及。当前J2EE规范无法提供一种轻松的方式来计划企业应用程序内部的任务。
　　大体上，我们可以将J2EE计划任务划分为两类：特定于服务器的计划任务和特定于应用程序的计划任务。本文将探讨如何在WebLogic Application Server内部计划特定于应用程序的任务。
特定于服务器和特定于应用程序的计划任务
　　特定于服务器的计划任务涉及到应用服务器的生命周期。通常，这些任务在服务器启动期间开始执行，一直运行到服务器停机。由此，计划任务所需的所有资源都必须在服务器的类路径中指定。
　　特定于应用程序的计划任务涉及到企业应用程序的生命周期。它们在应用程序部署之后启动，一直运行到应用程序取消部署。特定于应用程序的计划任务所需的资源打包在企业应用程序中（EAR – 企业归档资源）。
　　应用程序任务优先于服务器任务，原因如下：
    * 应用程序任务的任何改变都可以使用应用程序（EAR文件）轻松地重新部署。对于服务器任务来说，新的改变要想生效，则必须重新启动服务器，这是非常不理想的，因为它影响了部署在该服务器上的其他应用程序的可用性。
    * 由于计划任务通常调用业务功能，所以在EAR文件中将它们打包在一起更加符合逻辑。
    * 通过关联资源和EAR文件，我们可以将EAR文件部署在WebLogic Server的另一个实例中，而不必重新配置该服务器的资源。
企业应用程序中的计划任务
　　我们将看一个如何实现特定于应用程序的计划任务的示例。我们将计划两个在某些指定间隔内调用业务功能的任务。
    * 订单提交 – 每天都调用。
    * 库存提交 – 每周调用一次。
在该示例中，我们将联合使用WebLogic的Application Lifecycle Events和WebLogic的Timer Notifications。
　　以下是设置计划任务时涉及到的三个步骤：
1. 实现负责添加、监听和处理定时通知的Timer Notification Listener。
2. 实现Application Lifecycle Listener，它实例化了期望应用程序生命周期事件上的Timer Notification Listener。
3. 在weblogic-application.xml中注册Application Lifecycle Listener。
实现MyAppJobScheduler
　　MyAppJobScheduler将实现javax.management.NotificationListener接口。
　　public final class MyAppJobScheduler implements NotificationListener
　　该类将实例化weblogic.management.timer.Timer类，并将自身注册为一个用于定时通知的监听器。Timer类是javax.management.TimerMBean的WebLogic实现。

timer = new Timer();
timer.addNotificationListener(this, null, "some handback object");

订单通知和库存通知在定时器启动之前添加到定时器中。

timer.addNotification("OrderSubmission",  "Order Submission",
this,orderSubmissionDate, DAILY_PERIOD);
timer.addNotification("InventorySubmission",
"Inventory Submission", this,inventorySubmissionDate,
WEEKLY_PERIOD);

我们将计划一些任务，以使Order任务在每天下午5点执行，Inventory任务每周五下午10点30分执行一次。请检查代码清单，了解如何构造具有指定时间的Date对象。
　　回调方法将得到一个通知。根据这一通知，业务流程组件（EJB）将被调用，以履行计划任务。

public void handleNotification(Notification notif, Object handback)
{
String type = notif.getType();
if ( type.equals("OrderSubmission") )
{
// invoke the component or ejb that does the order processing and submission
}
else if ( type.equals("InventorySubmission") )
{
// invoke the component or ejb that does the inventory processing and submission
}
}

MyAppJobScheduler的cleanup方法可以使定时器停止，并删除添加到其中的所有通知。我们可以按照上述的preStop方法，或者根据MyAppJobScheduler的finalize方法来调用cleanUp方法。

public synchronized void cleanUp() { System.out.println(">>> MyAppJobScheduler cleanUp method called."); try { timer.stop(); timer.removeNotification(orderNotificationId); timer.removeNotification(inventoryNotificationId); System.out.println(">>> MyAppJobScheduler Scheduler stopped."); } catch (InstanceNotFoundException e) { e.printStackTrace(); } }

MyAppJobScheduler的final方法如下所示：

protected void finalize() throws Throwable
{
System.out.println(">>> MyAppJobScheduler finalize called.");
cleanUp();
super.finalize();
}

实现MyAppListener
　　我们将编写一段可以扩展weblogic.application.ApplicationLifeCyleListener的类MyAppListener。应用程序生命周期监听器事件提供了开发人员在部署、取消部署和重新部署期间用来控制行为的处理。
public class MyAppListener extends ApplicationLifecycleListener
　　我们想在应用程序部署时立即启动计划任务。因此，我们使用MyAppListener的postStart方法来调用MyAppJobScheduler。如果希望在启动之前调用计划任务，则调用将使用preStart方法。

public void postStart(ApplicationLifecycleEvent evt)
{
System.out.println( "MyAppListener:postStart Event");
//Start the Scheduler
myAppJobScheduler = new MyAppJobScheduler();
}


　　我们希望在应用程序取消部署之前计划任务。因此我们使用MyAppListener的preStop方法来调用MyAppJobScheduler的cleanUp方法。

public void preStop(ApplicationLifecycleEvent evt)
{
System.out.println( "MyAppListener:preStop Event");
//Stop the Scheduler
myAppJobScheduler.cleanUp();
}

注册MyAppListener
　　在weblogic-application.xml中，注册应用程序生命周期事件的MyAppListener类。

<listener>
<listener-class>MyAppListener</listener-class>
</listener>

　　在应用程序类路径中包含MyAppJobScheduler和MyAppListener，或者，可以使用<listener-uri>参数来指定jar文件。

<listener>
<listener-class>MyAppListener</listener-class>
<listener-uri>scheduler.jar</listener-uri>
</listener>



//源代码：
MyAppJobScheduler.java
/*
* MyAppJobScheduler.java
*
*/
import java.util.*;
import javax.management.Notification;
import javax.management.NotificationListener;
import javax.management.InstanceNotFoundException;
import weblogic.management.timer.Timer;
// Implementing NotificationListener
public final class MyAppJobScheduler implements NotificationListener
{
private static final long DAILY_PERIOD = Timer.ONE_DAY;
private static final long WEEKLY_PERIOD = 7 * Timer.ONE_DAY;
private Timer timer;
private Integer orderNotificationId;
private Integer inventoryNotificationId;
public MyAppJobScheduler()
{
// Instantiating the Timer MBean
timer = new Timer();
// Registering this class as a listener
timer.addNotificationListener(this, null, "some handback object");
// These values should be read from a property file
int orderSubmissionHour=17;
int orderSubmissionMinute=0;
int inventorySubmissionDay = 6;
int inventorySubmissionHour = 22;
int inventorySubmissionMinute = 30;
Calendar calendar = Calendar.getInstance();
calendar.set(Calendar.HOUR_OF_DAY,orderSubmissionHour);
calendar.set(Calendar.MINUTE,orderSubmissionMinute);
Date orderSubmissionDate = calendar.getTime();
calendar.set(Calendar.DAY_OF_WEEK, inventorySubmissionDay);
calendar.set(Calendar.HOUR_OF_DAY,inventorySubmissionHour);
calendar.set(Calendar.MINUTE,inventorySubmissionHour);
Date inventorySubmissionDate = calendar.getTime();
// Add the order notification which should run every day at 5:00 PM
orderNotificationId = timer.addNotification("OrderSubmission",
"Order Submission", this,orderSubmissionDate, DAILY_PERIOD);
// Add the inventory notification which should run every Friday at 10:30 PM
inventoryNotificationId = timer.addNotification("InventorySubmission",
"Inventory Submission", this, inventorySubmissionDate, WEEKLY_PERIOD);
timer.start();
System.out.println( ">>> MyAppJobScheduler started." );
}
protected void finalize() throws Throwable
{
System.out.println(">>> MyAppJobScheduler finalize called.");
cleanUp();
super.finalize();
}
public synchronized void cleanUp()
{
System.out.println(">>> MyAppJobScheduler cleanUp method called.");
try
{
timer.stop();
timer.removeNotification(orderNotificationId);
timer.removeNotification(inventoryNotificationId);
System.out.println(">>> MyAppJobScheduler Scheduler stopped.");
}
catch (InstanceNotFoundException e)
{
e.printStackTrace();
}
}
/* callback method */
public void handleNotification(Notification notif, Object handback)
{
String type = notif.getType();
if ( type.equals("OrderSubmission") )
{
// invoke the component or ejb that does the order processing and submission
}
else if ( type.equals("InventorySubmission") )
{
// invoke the component or ejb that does the inventory processing and submission
}
}
public static void main(String[] args)
{
MyAppJobScheduler myAppJobScheduler = new MyAppJobScheduler();
}
}
MyAppListener.java
/*
* MyAppListener.java
*
*/
import weblogic.application.ApplicationLifecycleListener;
import weblogic.application.ApplicationLifecycleEvent;
public class MyAppListener extends ApplicationLifecycleListener
{
MyAppJobScheduler myAppJobScheduler;
public void preStart(ApplicationLifecycleEvent evt)
{
System.out.println("MyAppListener:preStart Event");
}
public void postStart(ApplicationLifecycleEvent evt)
{
System.out.println( "MyAppListener:postStart Event");
// Start the Scheduler
myAppJobScheduler = new MyAppJobScheduler();
}
public void preStop(ApplicationLifecycleEvent evt)
{
System.out.println( "MyAppListener:preStop Event");
// Stop the Scheduler
myAppJobScheduler.cleanUp();
}
public void postStop(ApplicationLifecycleEvent evt)
{
System.out.println( "MyAppListener:postStop Event");
}
public static void main(String[] args)
{
System.out.println( "MyAppListener:main method");
}
}


weblogic-application.xml
<weblogic-application>
<listener>
<listener-class>MyAppListener</listener-class>
</listener>
</weblogic-application>