我们知道jndi是java的命名和目录服务的api,为什么要有它了,是 因为我们在网络条件下可能要查找和使用一些分布式的资源。
JNDI(Java Naming and Directory Interface,Java命名和目录接口)是一组在Java应用中访问命名和目录服务的API。命名服务将名称和对象联系起来,使得我们可以用名称访问对象。目录服务是一种命名服务,在这种服务里,对象不但有名称,还有属性。
JNDI(Java Naming and Directory Interface)是一个应用程序设计的API,为开发人员提供了查找和访问各种命名和目录服务的通用、统一的接口,类似JDBC都是构建在抽象层上。
Name Service:命名服务,将名字和一个对象关联起来
Directory Service:目录服务,是命名服务扩展和提高,对象不但有名称,还有属性,它提供对命名信息管理和操作(增删改查)
JNDI-API:面向应用程序的开发者
JNDI-SPI:(服务提供者接口)面向服务器生产商
应用服务器一般都会自带一个目录服务器
在J2EE容器中配置JNDI参数
所有命名操作都相对于某一上下文,该初始上下文实现Context接口并提供解析名称的起始点(类似于JS的document)
JBoss的JNDI连接工厂
env.put("java.naming.factory.initial", " org.jnp.interfaces.NamingContextFactory ");
设置命名服务器的URL
env.put("java.naming.provider.url", " localhost:1099 ");
备注:不同的应用服务器,JNDI的连接工厂代码是不一致的,URL的端口也不一致。
使用Jboss动态的设定JNDI对象
package hb.jndi; import java.io.FileInputStream; import java.util.Properties; import javax.naming.Context; import javax.naming.InitialContext; public class TestJbossJNDI { public TestJbossJNDI() { super(); } public static void main(String[] args) { try { Properties env = new Properties(); // 载入jboss的SPI相关参数,包括初始上下文工厂,服务URL,等等 env.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory"); env.put("java.naming.provider.url", "localhost:1099"); // 通过JNDI api 初始化上下文 InitialContext ctx = new javax.naming.InitialContext(env); // InitialContext ctx = new javax.naming.InitialContext(); System.out.println("Got context"); // create a subContext ctx.createSubcontext("/sylilzy"); ctx.createSubcontext("sylilzy/sily"); // rebind a object ctx.rebind("sylilzy/sily/a", "I am sily a!"); ctx.rebind("sylilzy/sily/b", "I am sily b!"); // lookup context Context ctx1 = (Context) ctx.lookup("sylilzy"); Context ctx2 = (Context) ctx1.lookup("/sylilzy/sily"); ctx2.bind("/sylilzy/g", "this is g"); // lookup binded object Object o; o = ctx1.lookup("sily/a"); System.out.println("get object from jndi:" + "get object from jndi:" + o); // rename the object ctx2.rename("/sylilzy/g", "g1"); o = ctx2.lookup("g1"); System.out.println("get object from jndi:" + "get object from jndi:" + o); } catch (Exception e) { e.printStackTrace(); } } }
操作步骤:
1、新建一个web工程,并引入C:\jboss-4.2.2.GA\client目录下面的所有jar包
(将java文件打包成jar,然后放在jboss容器中即可)
2、在工程中添加上面这个java文件
3、启动jboss,然后再运行上面的java文件
运行结果:
Got context
get object from jndi:get object from jndi:I am sily a!
get object from jndi:get object from jndi:this is g
备注:如果不适用Properties 对象设置环境变量,则可以使用jndi.properties文件,然后放在class目录下面,即最外层的包目录
jndi.properties的内容如下:
java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory java.naming.provider.url=jnp://localhost:1099 java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
使用JBoss 配置数据源,并访问数据库
1、将C:\jboss-4.2.2.GA\docs\examples\jca目录下的oracle-ds.xml文件拷贝到C:\jboss-4.2.2.GA\server\default\deploy目录下面,并做相应的修改,内容如下:
<?xml version="1.0" encoding="UTF-8"?> <datasources> <local-tx-datasource> <jndi-name>huangbiaoDS</jndi-name> <use-java-context>false</use-java-context>? <connection-url>jdbc:oracle:thin:@localhost:1521:orcl</connection-url> <driver-class>oracle.jdbc.driver.OracleDriver</driver-class> <user-name>huangbiao</user-name> <password>huangbiao</password> <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.OracleExceptionSorter</exception-sorter-class-name> <metadata> <type-mapping>Oracle9i</type-mapping> </metadata> </local-tx-datasource> </datasources>
2、然后在工程目录下新建ConnectDB.java文件,用来测试连接数据库
package hb.jndi.db; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Properties; import javax.naming.InitialContext; import javax.naming.NamingException; import javax.sql.DataSource; public class ConnectDB { public static void main(String[] args) { Properties env = new Properties(); // 载入jboss的SPI相关参数,包括初始上下文工厂,服务URL,等等 env.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory"); env.put("java.naming.provider.url", "localhost:1099"); Connection conn = null; PreparedStatement preStmt = null; ResultSet resultSet = null; try { // 通过JNDI api 初始化上下文 InitialContext ctx = new InitialContext(env); DataSource datasource = (DataSource)ctx.lookup("huangbiaoDS"); conn = datasource.getConnection(); String sql="select * from student"; preStmt = conn.prepareStatement(sql); resultSet = preStmt.executeQuery(); while(resultSet.next()){ System.out.println(resultSet.getString(2)); } } catch (NamingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ try { resultSet.close(); preStmt.close(); conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
备注:
对应的数据库驱动应该添加到: C:\jboss-4.2.2.GA\server\default\lib目录下面 (server目录中对应的lib下),否则将无法连接到数据库 。
操作步骤如下:
1、先启动Jboss
2、然后在运行ConnectDB.java文件