发帖    主题    评论    推荐    标签    作者    订阅    查搜    注册   登陆   关注
 
面向对象 设计模式 领域驱动设计 企业架构 框架 开发教程 微服务 CQRS 扩展性 并发编程 事件溯源 分布式 SOA
1 2 下一页 Go 2

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

2003-07-31 20:13
赞助商链接

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

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) {
//处理异常
}
}
}
}

2003-08-01 10:05

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

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

2003-08-01 11:49

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

2003-08-01 11:52

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

2003-08-01 14:06

作为一个好的连接池,在别人使用时应该感觉不到连接池的在在。

2Go 1 2 下一页

赞助商链接

赞助商链接

返回顶部

移动版 关于本站 使用帮助 联系管理员 最佳分辨率1366x768
OpenSource JIVEJDON Powered by JdonFramework Code © 2002-20 jdon.com