用service locator 模式实现命名访问

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

用service locator 模式实现命名访问服务

在b/s开发中， 我们经常要用到名称服务，如jndi，xmlns等。名称服务随不同厂家而不同。每次需要获得名称服务时，需要适当的名称环境信息，然后查找服务，重复查找的成本很高。

此外，在持久性框架中，要求将所有的服务访问都包装到对象中，开发人员不需要知道名称服务后面的平台（数据库）类型，及任何安全信息或地址。在一个大型软件产品间存在多个ejb和多个数据源连接时（我们目前只有一个写死的数据源webgl）需要一个类来实现统一的访问管理。

因此，这就要求我们对这些访问进行封装隔离。这时我们就可以利用service locator模式。

我们将利用一个文件service.properties来管理所有的命名服务。例子代码实现了ejb本地，数据源的访问。

格式如下：

defaultds=webgl

ntclassref=nthome.class

把它保存在classpath引用的路径里。

源代码：

package com.learn;

import java.util.hashtable;

import java.util.properties;

import java.io.*;

import javax.ejb.ejbhome;

import javax.naming.initialcontext;

import javax.naming.context;

import javax.naming.namingexception;

import javax.rmi.portableremoteobject;

import java.sql.connection;

import java.sql.sqlexception;

import javax.sql.datasource;

public class servicelocator {

private static servicelocator servicelocatorref = null;

private static hashtable ejbhomecache = null;

private static hashtable datasourcecache = null;

private static properties servicecache = null;

static {

servicelocatorref = new servicelocator();

}

private servicelocator() {

ejbhomecache = new hashtable();

datasourcecache = new hashtable();

try {

string servicefilename = "service.properties";

servicecache.load(new fileinputstream(servicefilename));

}

catch (ioexception e) {

system.out.println(e.tostring());

}

}

/**

* 使用singleton.模式静态对象多次调用节省资源 */

public static servicelocator getinstance() {

return servicelocatorref;

}

/*

* 由键获得键值,一般在数据源，xmlns访问用到这个方法

*/

static private string getservicename(string serviceid)

throws servicelocatorexception{

string servicename=null;

if (servicecache.containskey(serviceid)) {

servicename = (string) servicecache.get(serviceid);

}

else {

throw new servicelocatorexception(

"unable to locate the service statement requested");

}

return servicename;

}

/*************************************************

* ejb本地类引用

*************************************************/

static private class getejbhomeref(string serviceid) throws

servicelocatorexception {

class homeref = null;

if (servicecache.containskey(serviceid)) {

homeref = (class) servicecache.get(serviceid);

}

else {

throw new servicelocatorexception(

"unable to locate the service statement requested");

}

return homeref;

}

/************************************************************************

* 获得ejbhome对象

***********************************************************************/

public ejbhome getejbhome(string serviceid) throws servicelocatorexception {

ejbhome ejbhome = null;

try {

//先检查缓存是否存在ejbhome接口

if (ejbhomecache.containskey(serviceid)) {

ejbhome = (ejbhome) ejbhomecache.get(serviceid);

return ejbhome;

}

else {

//如果没有存在，则解析并存到缓存中

context ctx = new initialcontext();

object jndiref = ctx.lookup(serviceid);

object portableobj = portableremoteobject.narrow(jndiref,

getejbhomeref(serviceid));

ejbhome = (ejbhome) portableobj;

ejbhomecache.put(serviceid, ejbhome);

return ejbhome;

}

}

catch (namingexception e) {

throw new servicelocatorexception(

"naming exception error in servicelocator.getejbhome()", e);

}

}

/*

* 获得jndi数据源

*/

public connection getdbconn(string serviceid) throws

servicelocatorexception {

connection conn = null;

string servicename=getservicename(serviceid);

try {

/*checking to see if the requested datasource is in the cache*/

if (datasourcecache.containskey(serviceid)) {

datasource ds = (datasource) datasourcecache.get(serviceid);

conn = ( (datasource) ds).getconnection();

return conn;

}

else {

/*

* the datasource was not in the cache. retrieve it from jndi

* and put it in the cache.

*/

context ctx = new initialcontext();

datasource newdatasource = (datasource) ctx.lookup(servicename);

datasourcecache.put(serviceid, newdatasource);

conn = newdatasource.getconnection();

return conn;

}

}

catch (sqlexception e) {

throw new servicelocatorexception("a sql error has occurred in " +

"servicelocator.getdbconn()", e);

}

catch (namingexception e) {

throw new servicelocatorexception("a jndi naming exception has occurred " +

" in servicelocator.getdbconn()", e);

}

catch (exception e) {

throw new servicelocatorexception("an exception has occurred " +

" in servicelocator.getdbconn()", e);

}

}

}

异常处理类：

package com.learn;

public class servicelocatorexception extends dataaccessexception{

public servicelocatorexception(string pexceptionmsg){

super(pexceptionmsg);

}

public servicelocatorexception(string pexceptionmsg, throwable pexception){

super(pexceptionmsg, pexception);

}

}