写了个连接池的类,和大家一起探讨,欢迎交流

03-07-31 dalong
写了个连接池的类,和大家一起探讨,欢迎交流

package com.dalong.connectionpool;

import java.util.HashMap;

import java.util.Vector;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.*;

public class ConnectionPool {

//连接池的管理器,首先初始化,仅仅有一个对象,管理连接池

private static HashMap connectionPoolManager=new HashMap();

//没有用过的连接池,用vector实现同步

private static Vector noUseConnectionPool;

//没有用过的连接池

private static HashMap nowUseConnectionPool;

private static String dbDriver="odbc:jdbc:OdbcJdbcDriver";

private static String dbUrl="dalong@XX";

private static String userName="dalong";

private static String userPassword="dalong";

//默认为100个连接池

private static int MAX_POOL=100;

//singleTon 设计模式

private ConnectionPool(String driver,String url,String name,String password,int max)

throws ClassNotFoundException {

Class.forName(driver);

dbUrl=url;

userName=name;

userPassword=password;

MAX_POOL=max;

}

public static ConnectionPool getConnManagerInstance(String poolName)

throws ClassNotFoundException{

ConnectionPool tempPool=(ConnectionPool)connectionPoolManager.get(poolName);

if(tempPool==null){

tempPool=new ConnectionPool(dbDriver,dbUrl,userName,userPassword,MAX_POOL);

connectionPoolManager.put(poolName,tempPool);

return tempPool;

}else

return tempPool;

}

//通过连接池获得真正的链接

public static Connection getConnection() throws java.sql.SQLException{

Connection conn=null;

synchronized(noUseConnectionPool){

if(noUseConnectionPool.size()>0){

conn=(Connection)noUseConnectionPool.firstElement();

noUseConnectionPool.remove(conn);

return conn;

}

}

//如果数据库连接池没有链接了,自己创建一个

if(conn==null){

conn=createConnection(dbDriver,dbUrl,userName,userPassword);

}else if(conn.isClosed()){

nowUseConnectionPool.remove(conn);

conn=createConnection(dbDriver,dbUrl,userName,userPassword);

}

conn.setAutoCommit(false);

nowUseConnectionPool.put(conn,conn);

return conn;

}

//如果连接池没有链接了,就需要产生一个链接

private static Connection createConnection(String driver,String url,String user,String password)

throws java.sql.SQLException{

Connection conn=DriverManager.getConnection(url,user,password);

return conn;

}

public static void releaseConnection(Connection conn,boolean isCommit)

throws java.sql.SQLException{

if(isCommit)

conn.commit();

else

conn.rollback();

nowUseConnectionPool.remove(conn);

if(noUseConnectionPool.size() + nowUseConnectionPool.size()<MAX_POOL){

synchronized(noUseConnectionPool){

noUseConnectionPool.add(conn);

}

}else{

conn.close();

}

}

public static void main(String[] args) {

//测试模拟10个客户

for (int i = 0; i < 10; i++) {

try {

//xxxx 一般为属性文件读取

ConnectionPool pool = ConnectionPool.getConnManagerInstance("xxxx");

Connection conn = pool.getConnection();

}catch (SQLException ex1) {

//处理异常

}

catch (ClassNotFoundException ex) {

//处理异常

}

}

}

}

mellon
2003-08-01 10:05
如果我现在有一个应用,使用你的连接池,后来,连接池改用Weblogic等AppServer提供的连接池或DataSource ,这时候怎么办,释放连接的代码是xxx.releaseConnection(conn),也就是说,要么修改所有使用连接的代码,要么使用你的连接池再Pool一遍那些本来已经被Appserver pool了的Connection。

换句话说,你需要将你的释放连接的代码改为以Connection.close();的方式释放连接而不是xxx.releaseConnection(conn);

robbin
2003-08-01 11:49
现在写连接池还有必要吗?每个App Server都自带连接池,另外还有大把成熟的第三方连接池,何必非要自己写?

robbin
2003-08-01 11:52
现在写连接池还有必要吗?每个App Server都自带连接池,另外还有大把成熟的第三方连接池,何必非要自己写?

tele6224
2003-08-01 14:06
作为一个好的连接池,在别人使用时应该感觉不到连接池的在在。

wwlhp@jdon.com
2003-08-01 14:06
我不同意robbin的看法。在操作系统理论当中,这是一个很著名的管理有限资源的问题,不逊于哲学者吃饭的问题。

我觉得他的思路还是很好的,但对于互斥和同步还做得不够。

KillerMan
2003-08-01 16:56
up,

自己练练还是很有好处的,至少知道怎么作。

第三方往往意味着中庸,使用app自带的连接池有移植性的问题。

猜你喜欢