分享
 
 
 

使用JAVA中的动态代理实现数据库连接池

王朝java/jsp·作者佚名  2008-05-19
窄屏简体版  字體: |||超大  

刘冬

珠海市创我科技发展有限公司软件工程师

数据库连接池在编写应用服务是经常需要用到的模块,太过频繁的连接数据库对服务性能来讲是一个瓶颈,使用缓冲池技术可以来消除这个瓶颈。我们可以在互联网上找到很多关于数据库连接池的源程序,但是都发现这样一个共同的问题:这些连接池的实现方法都不同程度地增加了与使用者之间的耦合度。很多的连接池都要求用户通过其规定的方法获取数据库的连接,这一点我们可以理解,毕竟目前所有的应用服务器取数据库连接的方式都是这种方式实现的。但是另外一个共同的问题是,它们同时不允许使用者显式的调用Connection.close()方法,而需要用其规定的一个方法来关闭连接。这种做法有两个缺点:

第一:改变了用户使用习惯,增加了用户的使用难度。

首先我们来看看一个正常的数据库操作过程:

int executeSQL(String sql) throws SQLException

{

Connection conn = getConnection();

//通过某种方式获取数据库连接

PreparedStatement ps = null;

int res = 0;

try{

ps = conn.prepareStatement(sql);

res = ps.executeUpdate();

}finally{

try{

ps.close();

}catch(Exception e){}

try{

conn.close();//

}catch(Exception e){}

}

return res;

}

使用者在用完数据库连接后通常是直接调用连接的方法close来释放数据库资源,如果用我们前面提到的连接池的实现方法,那语句conn.close()将被某些特定的语句所替代。

第二:使连接池无法对之中的所有连接进行独占控制。

由于连接池不允许用户直接调用连接的close方法,一旦使用者在使用的过程中由于习惯问题直接关闭了数据库连接,那么连接池将无法正常维护所有连接的状态,考虑连接池和应用由不同开发人员实现时这种问题更容易出现。

综合上面提到的两个问题,我们来讨论一下如何解决这两个要命的问题。

首先我们先设身处地的考虑一下用户是想怎么样来使用这个数据库连接池的。用户可以通过特定的方法来获取数据库的连接,同时这个连接的类型应该是标准的java.sql.Connection。用户在获取到这个数据库连接后可以对这个连接进行任意的操作,包括关闭连接等。

通过对用户使用的描述,怎样可以接管Connection.close方法就成了我们这篇文章的主题。

为了接管数据库连接的close方法,我们应该有一种类似于钩子的机制。例如在Windows编程中我们可以利用Hook API来实现对某个Windows API的接管。在JAVA中同样也有这样一个机制。JAVA提供了一个Proxy类和一个InvocationHandler,这两个类都在java.lang.reflect包中。我们先来看看SUN公司提供的文档是怎么描述这两个类的。

public interface InvocationHandler

InvocationHandler is the interface implemented by the invocation handler of a proxy instance.

Each proxy instance has an associated invocation handler.

When a method is invoked on a proxy instance,

the method invocation is encoded and dispatched to the invoke method of its invocation handler.

SUN的API文档中关于Proxy的描述很多,这里就不罗列出来。通过文档对接口InvocationHandler的描述我们可以看到当调用一个Proxy实例的方法时会触发Invocationhanlder的invoke方法。从JAVA的文档中我们也同时了解到这种动态代理机制只能接管接口的方法,而对一般的类无效,考虑到java.sql.Connection本身也是一个接口由此就找到了解决如何接管close方法的出路。

首先,我们先定义一个数据库连接池参数的类,定义了数据库的JDBC驱动程序类名,连接的URL以及用户名口令等等一些信息,该类是用于初始化连接池的参数,具体定义如下:

public class ConnectionParam implements Serializable

{

private String driver;

//数据库驱动程序

private String url;

//数据连接的URL

private String user;

//数据库用户名

private String password;

//数据库密码

private int minConnection = 0;

//初始化连接数

private int maxConnection = 50;

//最大连接数

private long timeoutValue = 600000;//连接的最大空闲时间

private long waitTime = 30000;

//取连接的时候如果没有可用连接最大的等待时间

其次是连接池的工厂类ConnectionFactory,通过该类来将一个连接池对象与一个名称对应起来,使用者通过该名称就可以获取指定的连接池对象,具体代码如下:

/**

* 连接池类厂,该类常用来保存多个数据源名称合数据库连接池对应的哈希

* @author liusoft

*/

public class ConnectionFactory

{

//该哈希表用来保存数据源名和连接池对象的关系表

static Hashtable connectionPools = null;

static{

connectionPools = new Hashtable(2,0.75F);

}

/**

* 从连接池工厂中获取指定名称对应的连接池对象

* @param dataSource

连接池对象对应的名称

* @return DataSource

返回名称对应的连接池对象

* @throws NameNotFoundException

无法找到指定的连接池

*/

public static DataSource lookup(String dataSource)

throws NameNotFoundException

{

Object ds = null;

ds = connectionPools.get(dataSource);

if(ds == null || !(ds instanceof DataSource))

throw new NameNotFoundException(dataSource);

return (DataSource)ds;

}

/**

* 将指定的名字和数据库连接配置绑定在一起并初始化数据库连接池

* @param name

对应连接池的名称

* @param param

连接池的配置参数,具体请见类ConnectionParam

* @return DataSource

如果绑定成功后返回连接池对象

* @throws NameAlreadyBoundException

一定名字name已经绑定则抛出该异常

* @throws ClassNotFoundException

无法找到连接池的配置中的驱动程序类

* @throws IllegalAccessException

连接池配置中的驱动程序类有误

* @throws InstantiationException

无法实例化驱动程序类

* @throws SQLException

无法正常连接指定的数据库

*/

public static DataSource bind(String name, ConnectionParam param)

throws NameAlreadyBoundException,ClassNotFoundException,

IllegalAccessException,InstantiationException,SQLException

{

DataSourceImpl source = null;

try{

lookup(name);

throw new NameAlreadyBoundException(name);

}catch(NameNotFoundException e){

source = new DataSourceImpl(param);

source.initConnection();

connectionPools.put(name, source);

}

return source;

}

/**

* 重新绑定数据库连接池

* @param name

对应连接池的名称

* @param param

连接池的配置参数,具体请见类ConnectionParam

* @return DataSource

如果绑定成功后返回连接池对象

* @throws NameAlreadyBoundException

一定名字name已经绑定则抛出该异常

* @throws ClassNotFoundException

无法找到连接池的配置中的驱动程序类

* @throws IllegalAccessException

连接池配置中的驱动程序类有误

* @throws InstantiationException

无法实例化驱动程序类

* @throws SQLException

无法正常连接指定的数据库

*/

public static DataSource rebind(String name, ConnectionParam param)

throws NameAlreadyBoundException,ClassNotFoundException,

IllegalAccessException,InstantiationException,SQLException

{

try{

unbind(name);

}catch(Exception e){}

return bind(name, param);

}

/**

* 删除一个数据库连接池对象

* @param name

* @throws NameNotFoundException

*/

public static void unbind(String name) throws

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
2023年上半年GDP全球前十五强
 百态   2023-10-24
美众议院议长启动对拜登的弹劾调查
 百态   2023-09-13
上海、济南、武汉等多地出现不明坠落物
 探索   2023-09-06
印度或要将国名改为“巴拉特”
 百态   2023-09-06
男子为女友送行,买票不登机被捕
 百态   2023-08-20
手机地震预警功能怎么开?
 干货   2023-08-06
女子4年卖2套房花700多万做美容:不但没变美脸,面部还出现变形
 百态   2023-08-04
住户一楼被水淹 还冲来8头猪
 百态   2023-07-31
女子体内爬出大量瓜子状活虫
 百态   2023-07-25
地球连续35年收到神秘规律性信号,网友:不要回答!
 探索   2023-07-21
全球镓价格本周大涨27%
 探索   2023-07-09
钱都流向了那些不缺钱的人,苦都留给了能吃苦的人
 探索   2023-07-02
倩女手游刀客魅者强控制(强混乱强眩晕强睡眠)和对应控制抗性的关系
 百态   2020-08-20
美国5月9日最新疫情:美国确诊人数突破131万
 百态   2020-05-09
荷兰政府宣布将集体辞职
 干货   2020-04-30
倩女幽魂手游师徒任务情义春秋猜成语答案逍遥观:鹏程万里
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案神机营:射石饮羽
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案昆仑山:拔刀相助
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案天工阁:鬼斧神工
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案丝路古道:单枪匹马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:与虎谋皮
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:李代桃僵
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:指鹿为马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:小鸟依人
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:千金买邻
 干货   2019-11-12
 
推荐阅读
 
 
 
>>返回首頁<<
 
靜靜地坐在廢墟上,四周的荒凉一望無際,忽然覺得,淒涼也很美
© 2005- 王朝網路 版權所有