WebLogic下的JNDI/JTA编程_Tomcat, WebLogic及J2EE讨论区_Weblogic技术|Tuxedo技术|中间件技术|Oracle论坛|JAVA论坛|Linux/Unix技术|hadoop论坛

总帖数

每页帖数

1/1页

返回列表

发起投票

查看: 3399 | 回复: 0

主题： WebLogic下的JNDI/JTA编程

zhian.zuo

注册用户

等级：上士
经验：314
发帖：10
精华：0
注册：1970-1-1
状态：离线
发送短消息息给zhian.zuo

加好友发送短消息息给zhian.zuo

发消息

发表于：

2014-7-9 14:22:55 | [全部帖] [楼主帖]

楼主

WebLogic下的JNDI/JTA编程开发

JNDI编程

JNDI(Java Naming and Directory Interface) 是SUN公司提供的一种标准的Java命名系统接口，JNDI提供统一的客户端API，通过不同的访问提供者接口JNDI SPI的实现，由管理者将 JNDI API映射为特定的命名服务和目录系统，使得Java应用程序可以和这些命名服务和目录服务之间进行交互。集群JNDI实现了高可靠性 JNDI[8]，通过服务器的集群，保证了JNDI的负载平衡和错误恢复。在全局共享的方式下，集群中的一个应用服务器保证本地JNDI树的独立性，并拥有全局的JNDI树。每个应用服务器在把部署的服务对象绑定到自己本地的JNDI树的同时，还绑定到一个共享的全局JNDI树，实现全局JNDI和自身 JNDI的联系。

(1)JNDI优点：

包含了大量的命名和目录服务，使用通用接口来访问不同种类的服务；
可以同时连接到多个命名或目录服务上；
建立起逻辑关联，允许把名称同Java对象或资源关联起来，而不必指导对象或资源的物理ID。

（2）JNDI程序包

javax.naming：命名操作；
javax.naming.directory：目录操作；
javax.naming.event：在命名目录服务器中请求事件通知；
javax.naming.ldap：提供LDAP支持；
javax.naming.spi：允许动态插入不同实现。

（3）常用的JNDI操作：

void bind(String sName,Object object);――绑定：把名称同对象关联过程
void rebind(String sName,Object object);――重新绑定：用来把对象同一个已经存在的名称重新绑定
void unbind(String sName);――释放：用来把对象从目录中释放出来
void lookup(String sName,Object object);――查找：返回目录总的一个对象
void rename(String sOldName,String sNewName);――重命名：用来修改对象名称绑定的名称
NamingEnumeration listBinding(String sName);――清单：返回绑定在特定上下文中对象的清单列表
NamingEnumeration list(String sName);

（4）JNDI编程
1.获得名字服务的初始环境

Contect ctx=new InitailContext();

这样获得的初始环境为默认的命名服务。假如你想改变提供JNDI服务的类（或厂商）和提供JNDI服务的命名服务器，可以采用以下方法：

java.util.Properties h = new java.util.Properties();
h.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
h.put(Context.PROVIDER_URL, "t3://localhost:7001");
//初始化Context对象。
Context ctx = new InitialContext(h);

2.将对象与某个名字相绑定
用bind(String name,Object obj)方法，把对象obj绑定到名字name上
例： import javax.naming.*;

public class TestJNDI
{
      public static void main(String[] args)
      {
            try
            {
                  Context ctx=new InitialContext();
                  Ctx.bind(“JNDIName”,”BindSring”); //把BindSring字符串绑定到JNDIName上
            }
            catch(NamingException e)
            {
                  e.printStackTrace();
            }
      }
}

如果名字已绑定或命名服务器没有启动，则会出现NamingException异常
3.重新绑定
用ctx.rebind(String name,Object o) 如：

ctx.rebind(“JNDIName”,”BindSring”); //现在BindSring字符串绑定到JNDIName上

4.解除绑定

ctx.unbind(String name);

不过你要确保该名字存在，否则出现NameNotFoundException 异常
5.利用名字查找已绑定的对象
用ctx.lookup(String name);根据name找对象
例：

import javax.naming.*;
public class TestJNDI
{
      public static void main(String[] args)
      {
            try
            {
                  Context ctx=new InitialContext();
                  Object obj=ctx.lookup(“JNDIName”); //根据JNDI名查找绑定的对象
                  String str=(String)obj;//强制转换
            }
            catch(NamingException e)
            {
                  e.printStackTrace();
            }
            catch(ClassCastException e)
            {
                  e.printStackTrace();
            }
      }
}

6.JNDI 在EJB 组件的编程中的应用（查找EJB HOME 对象）

try
{
      Context context = getInitialContext();
      Object ref = context.lookup("mathSessionEJBBean"); //look up jndi name
      mathSessionEJBHomeObject = (mathSessionEJBHome) PortableRemoteObject.narrow(ref, mathSessionEJBHome.class);
      //下面为创建出Remote主接口类型的对象
      mathSessionEJBRemote = mathSessionEJBHomeObject.create();
      //下面为利用Remote主接口类型的对象对EJBBean类中的方法进行访问
      System.out.println("利用无状态会话EJB计算10+20的结果="+mathSessionEJBRemote.getSummary(10,20));
}
catch(Exception e) {
e.printStackTrace();
}

（5）查看 WebLogic 中的JNDI 树
（1）在控制台中右击本服务器的名称，然后在快捷菜单中选择“查看JNDI 树”则显示出新的窗口
（2）在新的窗口中将显示出已经在WebLogic服务器中已经绑定的各个对象

Weblogic 管理控制台配置JDBC下的JTA编码：

JTA，即Java Transaction API，JTA允许应用程序执行分布式事务处理——在两个或多个网络计算机资源上访问并且更新数据。JDBC驱动程序的JTA支持极大地增强了数据访问能力。

下面七个步骤展示JTA事务基本��容：建立事务、开始事务、找到数据源、建立数据库连接，执行与数据源有关的操作，关闭连接，完成事务。

在建立事务之前要先创建一个上下文环境，代码如下：

String url = "t3://localhost:7001";
String user = "weblogic";
String password = "weblogic";
Properties properties = null;
try{
      properties = new Properties();
      properties.put(Context.INITIAL_CONTEXT_FACTORY, " weblogic.jndi.WLInitialContextFactory");
      properties.put(Context.PROVIDER_URL, url);
      if(user != null){
            properties.put(Context.SECURITY_PRINCIPAL, user);
            properties.put(Context.SECURITY_CREDENTIALS,password == null ? "" : password);
      }
      return new InitialContext(properties);
}catch (Exception e){
throw e;
}

注意红色部分的文字，不要出错，这里WLInitialContextFactory是由weblogic.jar提供的一个类，主要负责和数据库的连接

1.建立事务

在weblogic下实现JTA的第一步是创建一个UserTransaction类的实例。UserTransaction类可以控制事务并发线程的执行。一个事务的并发线程可以是各种各样的服务。可以通过JNDI检索UserTransaction类。

ctx = getInitialContext();
tx = (UserTransaction)ctx.lookup("javax.transaction.UserTransaction");

2.开始事务。

调用UserTransaction对象的begin（）方法。例如：tx.begin();

3.找到数据源。

ds = (javax.sql.DataSource)ctx.lookup("mssql");

4.建立数据库连接。

通过Tx Data Source对象ds可以建立数据库连接：

javax.sql.Connection myConn = ds.getConnection();

5.执行与资源有关的操作。

如建立语句对象，然后通过语句对象执行数据库操作。

// 执行与资源有关的操作
myStatement = myConn.createStatement();
myStatement.executeUpdate("INSERT INTO emp (empname,empid,job) VALUES ('John','10','sales')");

6.关闭连接。

创建的连接用完后必须关闭。

7.完成事务

源码.

package com;
import java.sql.*;
import javax.naming.*;
import javax.sql.*;
import java.util.Properties;
import javax.transaction.*;
/**
* @author Richard
*
*/
public class JTATest {
      public static void main(String args[]){
            DataSource ds = null;
            Context ctx = null;
            Connection myConn = null;
            UserTransaction tx = null;
            try{
                  ctx = getInitialContext();//创建一个上下文环境
                  // 建立事务
                  tx = (UserTransaction)ctx.lookup("javax.transaction.UserTransaction");
                  // 开始事务
                  tx.begin();
                  // 找到数据源
                  ds = (javax.sql.DataSource)ctx.lookup("mssql");
            }catch(Exception E){
            System.out.println("Init Error: "+ E);
      }
      Statement myStatement = null;
      ResultSet myResult = null;
      try{
            // 建立数据库连接
            myConn = ds.getConnection();
            // 执行与资源有关的操作
            myStatement = myConn.createStatement();
            myStatement.executeUpdate("INSERT INTO emp (empname,empid,job) VALUES ('John','10','sales')");
            tx.commit(); //提交事务
            System.out.println("Success!");
      }catch (Exception e){
      try{
            tx.rollback(); //事务的回滚
      }catch(Exception el){
}System.out.println("Error message = " + e.getMessage());
}finally{
      try{
            if(myStatement != null){
                  myStatement.close();//关闭操作
            }
            if(myConn != null){
                  myConn.close(); //关闭数据库连接完成事务
            }
      }catch(SQLException e){
      System.out.println("Error code = " + e.getErrorCode()); // 异常的编码
      System.out.println("Error message = " + e.getMessage());
}
}
}
private static Context getInitialContext() throws Exception{
      String url = "t3://localhost:7001";
      String user = "weblogic";
      String password = "123456789";
      Properties properties = null;
      try{
            properties = new Properties();
            properties.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
            properties.put(Context.PROVIDER_URL, url);
            if(user != null){
                  properties.put(Context.SECURITY_PRINCIPAL, user);
                  properties.put(Context.SECURITY_CREDENTIALS,password == null ? "" : password);
            }
            return new InitialContext(properties);
      }catch (Exception e){
      throw e;
}
}
}

本版精华
热门帖子

操作引用/回复

总帖数

每页帖数

1/1页

返回列表

用户登录

Weblogic中间件技术论坛

Tuxedo中间件技术论坛

数据库论坛

Java论坛

Linux/unix论坛

网站地图