因为工作需要要使用到连接池所以拜读了互联网上众多前辈的文章学了不少经验这里想做一个小结加上自己的想法和在一起希望能给大家一些帮助
目的
消除数据库频繁连接带来的开销和瓶颈
解决方案
不过多的限制用户的使用既不能太多的要求用户按规定的方法得到和使用数据库连
尽量保持用户的习惯
目前的很多方法都是要求用户只能按规定方法使用连接不能使用直接关闭数据连接的方法解决办法就是使用代理类来中间解决可以参考html
能维护连接的正常状态
因为针对数据库连接创建的资源如果不能及时的释放就会影响下一次数据连接的使用例如在sql k中一个连接不同创建多条Statement否则操作时会有数据连接占线的异常所以必须在归还连接以后释放这些资源
//判断是使用了createStatement语句 if (CREATESTATEequals(methodgetName())) { obj = methodinvoke(conn args); statRef = (Statement)obj;//记录语句 return obj; }
//判断是否调用了close的方法如果调用close方法则把连接置为无用状态 if(CLOSEequals(methodgetName())) { //设置不使用标志 setIsFree(false); //检查是否有后续工作清除该连接无用资源 if (statRef != null) statRefclose(); if (prestatRef != null) prestatRefclose(); return null; }
正确保护类不被违例使用
一个考虑就是不能让用户随便使用代理类而只能自己使用一个就是用内部私有类一个就是使用只有指定类才能调用的标志我的实现就是采用后者
/** * 创建连接的工厂只能让工厂调用 * @param factory 要调用工厂并且一定被正确初始化 * @param param 连接参数 * @return 连接 */ static public _Connection getConnection(ConnectionFactory factory ConnectionParam param) { if (factoryisCreate())//判断是否正确初始化的工厂 { _Connection _conn = new _Connection(param); return _conn; } else return null; }
提供良好的用户接口简单实用
使用静态方法创建工厂然后来得到连接使用完全和普通的Connection方法一样没有限制同时为了方便设置了连接参数类和工厂参数类
ConnectionParam param = new ConnectionParam(driverurluserpassword); ConnectionFactory cf = null;//new ConnectionFactory(param new FactoryParam()); try{ cf = new ConnectionFactory(paramnew FactoryParam()); Connection conn = cfgetFreeConnection(); Connection conn = cfgetFreeConnection(); Connection conn = cfgetFreeConnection(); Statement stmt = conncreateStatement(); ResultSet rs = stmtexecuteQuery(select * from requests); if (rsnext()) { Systemoutprintln(conn y); } else { Systemoutprintln(conn n); } stmtclose(); connclose();
为了实现连接池的正常运作使用了单态模
/** * 使用指定的参数创建一个连接池 */ public ConnectionFactory(ConnectionParam param FactoryParam fparam) throws SQLException { //不允许参数为空 if ((param == null)||(fparam == null)) throw new SQLException(ConnectionParam和FactoryParam不能为空); if (m_instance == null) { synchronized(ConnectionFactoryclass){ if (m_instance == null) { //new instance //参数定制 m_instance = new ConnectionFactory(); nnparam = param; m_instanceMaxConnectionCount = fparamgetMaxConn(); m_instanceMinConnectionCount = fparamgetMinConn(); m_instanceManageType = fparamgetType(); m_instanceisflag = true; //初始化创建MinConnectionCount个连接 Systemoutprintln(connection factory 创建！); try{ for (int i=; i < m_instance.MinConnectionCount; i++) { _Connection _conn = _Connection.getConnection(m_instance, nnparam); if (_conn == null) continue; System.out.println("connection创建"); m_instance.FreeConnectionPool.add(_conn);//加入空闲连接池 m_instance.current_conn_count ++; //标志是否支持事务 m_instance.supportTransaction = _conn.isSupportTransaction(); } } catch(Exception e) { e.printStackTrace(); } //根据策略判断是否需要查询 if (m_instance.ManageType != 0) { Thread t = new Thread(new FactoryMangeThread(m_instance)); t.start(); } } } } }
连接池的管理
对于连接池的管理，我是设想使用静态管理和动态管理两种策略，设置了最大限制，和恆定的连接数。tW.wingwiT.COM使用了2个池，一个空闲池，一个使用池。静态就是使用的时候发现空闲连接不够再去检查。动态就是使用了一个线程定时检查。
//根据策略判断是否需要查询 if (m_instance.ManageType != 0) { Thread t = new Thread(new FactoryMangeThread(m_instance)); t.start(); }
//连接池调度线程public class FactoryMangeThread implements Runnable { ConnectionFactory cf = null; long delay = 1000; public FactoryMangeThread(ConnectionFactory obj) { cf = obj; } /* (non-Javadoc) * @see java.lang.Runnable#run() */ public void run() { while(true){ try{ Thread.sleep(delay); } catch(InterruptedException e){} System.out.println("eeeee"); //判断是否已经关闭了工厂，那就退出监听 if (cf.isCreate()) cf.schedule(); else System.exit(1); } }}
最后给出完整的源代码：
--------------------------------------------------------------------------------
_Connectio.java
package nnectionpool;
import java.lang.reflect.*;import java.sql.*;
/** * @author youyongming * 定义数据库连接的代理类 */public class _Connection implements InvocationHandler { //定义连接 private Connection conn = null; //定义监控连接创建的语句 private Statement statRef = null; private PreparedStatement prestatRef = null; //是否支持事务标志 private boolean supportTransaction = false; //数据库的忙状态 private boolean isFree = false; //最后一次访问时间 long lastAccessTime = 0; //定义要接管的函数的名字 String CREATESTATE = "createStatement"; String CLOSE = "close"; String PREPARESTATEMENT = "prepareStatement"; String COMMIT = "commit"; String ROLLBACK = "rollback";
/** * 构造函数，采用私有，防止被直接创建 * @param param 连接参数 */ private _Connection(ConnectionParam param) { //记录日至 try{ //创建连接 Class.forName(param.getDriver()).newInstance(); conn = DriverManager.getConnection(param.getUrl(),param.getUser(), param.getPassword()); DatabaseMetaData dm = null; dm = conn.getMetaData(); //判断是否支持事务 supportTransaction = dm.supportsTransactions(); } catch(Exception e) { e.printStackTrace(); } }
/* (non-Javadoc) * @see java.lang.reflect.InvocationHandler#invoke(java.lang.Object, java.lang.reflect.Method, java.lang.Object[]) */ public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { Object obj = null; //判断是否调用了close的方法，如果调用close方法则把连接置为无用状态 if(CLOSE.equals(method.getName())) { //设置不使用标志 setIsFree(false); //检查是否有后续工作，清除该连接无用资源 if (statRef != null) statRef.close(); if (prestatRef != null) prestatRef.close(); return null; } //判断是使用了createStatement语句 if (CREATESTATE.equals(method.getName())) { obj = method.invoke(conn, args); statRef = (Statement)obj;//记录语句 return obj; } //判断是使用了prepareStatement语句 if (PREPARESTATEMENT.equals(method.getName())) { obj = method.invoke(conn, args); prestatRef = (PreparedStatement)obj; return obj; } //如果不支持事务，就不执行该事物的代码 if ((COMMIT.equals(method.getName())||ROLLBACK.equals(method.getName())) && (!isSupportTransaction())) return null; obj = method.invoke(conn, args); //设置最后一次访问时间，以便及时清除超时的连接 lastAccessTime = System.currentTimeMillis(); return obj; }
/** * 创建连接的工厂，只能让工厂调用 * @param factory 要调用工厂，并且一定被正确初始化 * @param param 连接参数 * @return 连接 */ static public _Connection getConnection(Connec
