websphere服务器，如何使用jndi数据源

你这是TOMCAT的写法，WAS的JNDI不是这样的：java:/comp/env/jdbc/cib_ds

如下编写就可以了：

Hashtable env = new Hashtable()

env.put(Context.INITIAL_CONTEXT_FACTORY,

"com.ibm.Websphere.naming.WsnInitialContextFactory")

InitialContext ctx = new InitialContext(env)

DataSource ds = (DataSource) ctx.lookup("jdbc/cib_ds")

1、 概述

在很多企业应用中有时需要在特定的时间运行一段代码，比如银行需要在晚上系统相对空闲的时间

内进行日结的对帐，那么到了规定时间系统需要触发对帐服务运行对帐程序，现在EJB定时器服务能解决这个问题，它是一个可靠的、事务性的、提供容器的服

务，允许Bean提供者注册定时反馈的企业Beans，它可以在特定时刻发生，或在某段时间之后发生，或以一定时间间隔重复发生。由于这个服务是可靠的，

容器破坏的时候定时依然有效，企业Beans的激活与失效、装载与保存周期都由定时器注册。定时器服务由EJB容器实现，定时器服务可以通过

EJBContext接口新增的getTimerService()方法来访问，它返回实现TimerService接口的对象：这个接口允许创建不同的

定时器来支持在不同时间、不同时间间隔、不同时间周期时发生的定时反馈。使用定时器服务的企业Beans的Bean类必须实现

javax.ejb.TimedObject接口。在EJB2.1中，只有无序的会话Beans和实体Beans可以注册为定时器服务。这个功能在以后的

规范中可能会扩展到其它类型的Bean。

定时器服务适合长时间的业务处理模型，但并不适合用于实时的事件模型。

在 WebSphere Application Server

6中，EJB 定时服务将 EJB

计时器作为新的调度程序服务任务实施。缺省情况下，内部调度程序实例用于管理那些任务，定时任务存放在与服务器进程关联的 Cloudscape

数据库中。在集群环境中，任务必须存放在企业关系型数据库中。下面我们以DB2为例讲述怎样在集群环境中配置定时服务。

回页首

2、 创建用于定时服务的数据库

每

个定时服务程序都需要一个数据库，以用于存储它的持久信息。数据库及其位置应当由应用程序开发者和服务器管理员决定。

定时服务程序使用这个数据库来存储任务，然后运行这些任务。定时服务程序性能极大地依赖于数据库的性能。如果需要每秒执行更多任务，您可以在更大型的系统

中运行定时服务程序守护程序，或通过使用多个定时服务程序对任务或分区使用的会话 bean

使用集群。但是，定时服务程序数据库最终会达到饱和状态，此时您就需要一个更大型或更优异的数据库系统。

当您在每个定时服务程序配置中指定唯一的表前缀值时，多个定时服务程序可以共享一个数据库。这一共享可以降低定时服务程序数据库的管理成本。

TIPS：Oracle

XA 数据库的限制，Oracle XA 不允许在全局事务环境中执行所需的模式 *** 作。本地事务是不受支持的。如果您的调度程序使用 Oracle

XA 数据源，您可以将调度程序配置临时更改为使用一个非 XA Oracle 数据源，或者使用提供的 DDL

文件手工创建表。如果使用管理控制台为配置为使用 Oracle XA 数据源的调度程序创建或删除调度程序表，您将接收到一条

SchedulerDataStoreException 错误消息并且 *** 作将失败。

下面我们将以DB2为例讲述定时服务：

在机器hostdb上安装DB2后，打开 DB2 命令行窗口。

确

保您拥有数据库系统的管理员权限，验证此数据库确实支持 Unicode（UTF-8）。 否则，此数据库无法存储 Java

代码中可以处理的所有字符，当客户机使用了不兼容的代码页时，这将导致代码页转换问题。要避免死锁，请确保将 DB2

隔离级别设置为"读稳定性"。如果需要，请输入命令 ：

db2set DB2_RR_TO_RS=YES

然后重新启动 DB2 实例以激活这一更改。在 DB2 命令行处理程序中输入以下命令使用示例名 timerdb 创建数据库：

db2 CREATE DATABASE scheddb USING CODESET UTF-8 TERRITORY en-us

即可创建名为 timerdb 的 DB2 数据库。

现已为定时服务创建了 DB2 数据库。

回页首

3、 创建定时服务的表空间和表

在WAS6的安装目录下，有一个名为scheduler的目录。下面包含WAS容器用来管理定时服务的各种数据库SQL定义。

对应于DB2的SQL定义文件名为createSchemaDB2.ddl和createTablespaceDB2.ddl，修改这两个文件选择你所要新建的表空间名和你所要的模式名称。这两个文件大致内容如下：

createTablespaceDB2.ddl

CREATE TABLESPACE @SCHED_TABLESPACE@ MANAGED BY SYSTEM USING

( '@location@\@SCHED_TABLESPACE@' )

可以修改表空间名称，这个文件也可不做修改。然后修改createSchemaDB2.ddl

修改后的的结果可以去掉原来的模式名称，那么新建用户表的时候将使用缺省连接数据库的用户的模式名。

CREATE TABLE "TASK" ("TASKID" BIGINT NOT NULL ,

"VERSION" VARCHAR(5) NOT NULL ,

"ROW_VERSION" INTEGER NOT NULL ,

"TASKTYPE" INTEGER NOT NULL ,

"TASKSUSPENDED" SMALLINT NOT NULL ,

"CANCELLED" SMALLINT NOT NULL ,

"NEXTFIRETIME" BIGINT NOT NULL ,

"STARTBYINTERVAL" VARCHAR(254) ,

"STARTBYTIME" BIGINT ,

"VALIDFROMTIME" BIGINT ,

"VALIDTOTIME" BIGINT ,

"REPEATINTERVAL" VARCHAR(254) ,

"MAXREPEATS" INTEGER NOT NULL ,

"REPEATSLEFT" INTEGER NOT NULL ,

"TASKINFO" BLOB(102400) LOGGED NOT COMPACT ,

"NAME" VARCHAR(254) NOT NULL ,

"AUTOPURGE" INTEGER NOT NULL ,

"FAILUREACTION" INTEGER ,

"MAXATTEMPTS" INTEGER ,

"QOS" INTEGER ,

"PARTITIONID" INTEGER ,

"OWNERTOKEN" VARCHAR(200) NOT NULL ,

"CREATETIME" BIGINT NOT NULL ) IN "@SCHED_TABLESPACE@"

这两个文件修改完成后，在命令行运行db2cmd转到db2命令窗口。

然后运行db2batch -d timerdb -f createTablespaceDB2.ddl

和db2batch -d timerdb -f createSchemaDB2.ddl生成定时服务所需要的表空间和表。

运行完成后用下列命令验证：

Db2 connect to timerdb

Db2 list tables

你将会看到有以下四个表被创建：

Table/ViewSchema Type

------------ ------------- -----

LMGRADMINT

LMPRADMINT

TASK ADMIN T

TREG ADMIN T

其中主表task存放了定时程序的相关信息。

回页首

4、 创建新的集群

分别在hosta,hostb,hostc上完成WAS6安装后，我们需要创建3个节点来组成一个新的群集。

1）在hosta上创建一个Network DeployManagement节点，启动概要表创建向导：

选择创建Deployment Manager概要表：

点下一步直至完成

。

2）分别在hostc和hostb两个节点上选择创建应用服务器概要表。

3）创建完成后在DeployManager概要上运行startManager.sh启动Network Manager。

4）启动完成后打开概要下的日志文件SystemOut.log查看soap端口，缺省为8879。

5）在hostb和hostc两个应用服务器节点上运行addNode.sh hosta 8879

6）运行完成后，打开ND管理控制台：http://hosta:9060/ibm/console

7）在服务器下新建一个群集timertest,创建两个成员为clus01,clus02。启动群集。

回页首

5、 创建定时服务的数据源

进入ND管理控制台，展开资源，点击JDBC 提供者，选择要新建的资源所在的服务器

点新建。按提示输入所需资料。点数据源，进入数据源页面。

新建一个名为testtimer的数据源，指定jndi名为jdbc/testtimer

测试连接通过后。做下一步设置。

回页首

6、 修改服务器设置

打开管理控制台。

单击服务器 >应用程序服务器 >服务器名 >EJB 容器设置 >EJB 定时服务设置。 出现"定时服务设置"面板。

如果您要使用内部或预配置的调度程序实例，则单击使用内部 EJB 定时服务调度程序实例单选按钮。

如果您选择不更改缺省的设置，则此实例与 Cloudscape 数据库相关联。

更改数据源选择输入您所选的数据源别名。选择前面创建的jdbc/testtimer数据源。

输入表前缀为你创建表时的用户缺省模式名称，必须注意的是，在模式名称后面必须要带上一个小数点.。具体对应的每个值的意思可以点击帮助页面查看。

回页首

7、 开发基于J2EE标准的定时服务企业bean

下面的例子是在RAD环境下开发，要实现定时服务，EJB必须要实现javax.ejb.TimedObject接口。

EJB里面需要涉及到的接口或类分别是：

要实现的TimedObject和TimerService，Timer。

在

EJB中的ejbContext增加了一个方法.getTimerService()用于获得TimerService类。但这个方法不能在

setEntityContext()、setSessionContext()、setMessageContext()方法中调用。

下面列出了三个接口的定义：

public interface TimedObject{

public void ejbTimeout(Timer timer)

}

public interface TimerService{

public Timer createTimer(Date expiration,Serializable info)

public Timer createTimer(long duration,Serialzable info)

public Timer createTimer(Date initalExpiration,long intervalDuration,Serializable info)

public Timer createTimer(long initalDuration,long intevalDuration,Serializable info)

public java.util.Collection getTimers()

}

public interface Timer{

public void cancel()

public java.io.Serializable getInfo()

public Date getNextTimeout()

public long getTimeRemaining()

public TimerHandle getHandle()//这是一个local对象，不能传到remote client端使用

}

对于Stateless　SessionBean来说，不要在ejbCreate()和ejbRemove()中设置Timer。主要是因为ejbCreate和ejbRemove调用的时间和次数都因Container Vendor而异。可能导致错误设置Timer。

对MessageDriven Bean 而言，和Stateless SessionBean的情况基本相似。但是设置Timer应该在onMessage（）里面。通过一个JMS来进行触发。

ejbTimedout是一个回调方法，执行具体的商业逻辑，那么怎样设置什么时间触发这个方法呢，我们利用javax.ejb.TimerSevice。该对象我们可以从EJBContext中获得该对象实例。

当

定时器创建的特定时间到达后，容器就会触发ejbTimeout()，运行ejbTimeOut方法提，Bean在终止之前通过调用定时器Cancel方

法取消定时器，它是定时器接口的一部分，如果定时器被取消，ejbTimeout()方法就不会被调用了。定时器接口的getHandle()方法返回一

个序列化的handle对象。接下来，这个持续的Handle能够"非序列化"，通过调用getTimer()方法得到定时器。由于定时器是本地对

象，TimerHandle不必通过Bean的远程接口或Web Services接口来传递。

具体步骤如下：

新建一个EJB项目otherTimer，在这个EJB项目里新建一个otherTimer的会话Bean。

在Bean实体里面需要实现两个方法：

startTimer()和ejbTimeOut。

在

startTimer()方法里面，我们通过EJBCONTEXT取得一个TimerService然后创建一个Timer。这个timer将在

2005，9月19日晚上8点过5分触发，触发后，EJB容器会调用ejbTimeOut（）方法运行具体的商业逻辑，并且这个Timer会在80000

毫秒后再次触发。

javax.ejb.TimerService ts=this.getSessionContext().getTimerService()

System.out.println("启动一个时钟！")

Timer timer = ts.createTimer(new Date(105,9,19,20,5,0),80000,"other timer")

回页首

8、 WAS Scheduler实现

基

于WAS

Scheduler实现定时服务，需要配置一个scheduler,在WAS管理控制台展开资源，点scheduler，新建一个scheduler指定

名称、JNDI名、数据源JNDI名（这里可以用前面设置的jndi/testtimer）和表前缀，跟前面设置服务器EJB定时服务容器设置类似。

设置完成后就可以使用scheduler来实现定时服务了。

在

EJB模块中创建一个无状态会话bean，该 bean 实现了 com.ibm.websphere.scheduler.TaskHandler

远程接口中的 process() 方法。将您要创建的业务逻辑放入 process() 方法中。当运行任务时，将调用 process()

方法。Home 和 Remote 接口在部署描述符 bean 中必须设置如下：

com.ibm.websphere.scheduler.TaskHandlerHome

com.ibm.websphere.scheduler.TaskHandler

通过使用以下示例工厂方法创建 BeanTaskInfo 接口的一个实例。 使用 JSP 文件、servlet 或 EJB 组件创建实例，如以下代码示例所示。此代码必须与先前创建的 TaskHandler EJB 模块位于同一应用程序中：

Object schedulerObj = initialContext.lookup("java:comp/env/Scheduler")

BeanTaskInfo taskInfo = (BeanTaskInfo) schedulerObj.createTaskInfo(BeanTaskInfo.class)

注：

创建 BeanTaskInfo 对象并不会将任务添加到持久存储中。它将为必要的数据创建一个占位符。直到调用调度程序中的 create()

方法，才会将任务添加到持久存储中。设置 BeanTaskInfo 对象中的参数。 这些参数定义了调用哪些会话 bean

以及何时调用它们。TaskInfo 接口包含可用于控制任务执行的各种 set() 方法，其中包括运行任务的时间以及运行任务时它执行的 *** 作。

BeanTaskInfo

接口要求使用 setTaskHandler 方法设置 TaskHandler JNDI 名称或 TaskHandlerHome。如果使用

WASScheduler MBean API 来设置任务处理程序，则 JNDI 名称必须是标准的全局 JNDI 名称。

使用 TaskInfo 接口 API 方法设置参数，如以下代码示例所示：

java.util.Date startDate = new java.util.Date(System.currentTimeMillis()+30000)

Object reportGenHomeObj = initialContext.lookup("java:comp/env/ejb/ReportGenerator")

TaskHandlerHome reportGenHome = (TaskHandlerHome)PortableRemoteObject.narrow

(reportGenHomeObj,TaskHandlerHome.class)taskInfo.setTaskHandler(home)

taskInfo.setStartTime(startDate)

scheduler.create(taskInfo)

那么EJB容器将在当前时间的30000毫秒后触发process方法，在taskinfo里面可以设置一些其他schduler的属性，比如运行次数，运行间隔等。

方法/步骤

1

登录was控制台，选择“资源”->"JDBC提供程序"->选择"应用服务器"->"新建"

2

选择“数据库类型”->选择“提供程序类型”->选择”实施类型“

3

输入”数据库类路径信息“，/home/jar是指存放驱动程序jar的目录，后面不要加上jar包的名称。，后续 *** 作直接“下一步”-“完成”。

4

选择”JDBC-数据源“->"新建"

5

”输入基本数据源信息“，选择”创建新建J2C认证别名“

选择”新建“

输入相关信息，别名可以任意输入，“用户标识”和“密码”是指连接数据库用的用户名和密码。

一定要选择“保存”，设置才能生效。

输入基本数据源信息，JNDI名称要记住，在配置应用里数据库连接的时候会用到它。

创建数据源，选择”Oracle驱动程序“

URL中每个冒号前后不能有空格，URL中的IP地址是数据库服务器的IP, 紧跟着IP的是端口号，oracle默认的是1521，之后是SID,oracle默认是orcl。

直接单击”完成“

一定要选择“保存”，设置才能生效。

选择刚刚新建的数据源，单击”测试链接“

测试通过说明配置正确，否则配置错误。

---