因為工作需要要使用到連接池，所以拜讀了互聯網上眾多前輩的文章，學了不少經驗，這裡想做一個小結，加上自己的想法和在一起，希望能給大家一些幫助。
目的：
消除數據庫頻繁連接帶來的開銷和瓶頸。
解決方案：
不過多的限制用戶的使用，既不能太多的要求用戶按規定的方法得到和使用數據庫連
盡量保持用戶的習慣
目前的很多方法都是要求用戶只能按規定方法使用連接，不能使用直接關閉數據連接的方法。解決辦法就是使用代理類，來中間解決。可以參考http://www-900.ibm.com/developerWorks/cn/java/l-connpoolproxy/index.shtml
能維護連接的正常狀態
因為針對數據庫連接創建的資源，假如不能及時的釋放，就會影響下一次數據連接的使用。例如在sql 2k中，一個連接不同創建多條Statement否則操作時會有數據連接占線的異常，所以必須在歸還連接以後釋放這些資源。
//判定是使用了createStatement語句 if (CREATESTATE.equals(method.getName())) { obj = method.invoke(conn, args); statRef = (Statement)obj;//記錄語句 return obj; }
//判定是否調用了close的方法，假如調用close方法則把連接置為無用狀態 if(CLOSE.equals(method.getName())) { //設置不使用標志 setIsFree(false); //檢查是否有後續工作，清除該連接無用資源 if (statRef != null) statRef.close(); if (prestatRef != null) prestatRef.close(); return null; }
正確保護類不被違例使用
一個考慮就是不能讓用戶隨便使用代理類，而只能自己使用，一個就是用內部私有類，一個就是使用只有指定類才能調用的標志。我的實現就是采用後者。
/** * 創建連接的工廠，只能讓工廠調用 * @param factory 要調用工廠，並且一定被正確初始化 * @param param 連接參數 * @return 連接 */ static public _Connection getConnection(ConnectionFactory factory, ConnectionParam param) { if (factory.isCreate())//判定是否正確初始化的工廠 { _Connection _conn = new _Connection(param); return _conn; } else return null; }
提供良好的用戶接口，簡單實用
使用靜態方法創建工廠，然後來得到連接，使用完全和普通的Connection方法一樣，沒有限制。同時為了方便，設置了連接參數類和工廠參數類。
ConnectionParam param = new ConnectionParam(driver,url,user,passWord); ConnectionFactory cf = null;//new ConnectionFactory(param, new FactoryParam()); try{ cf = new ConnectionFactory(param,new FactoryParam()); Connection conn1 = cf.getFreeConnection(); Connection conn2 = cf.getFreeConnection(); Connection conn3 = cf.getFreeConnection(); Statement stmt = conn1.createStatement(); ResultSet rs = stmt.executeQuery("select * from requests"); if (rs.next()) { System.out.println("conn1 y"); } else { System.out.println("conn1 n"); } stmt.close(); conn1.close();
為了實現連接池的正常運作，使用了單態模
/** * 使用指定的參數創建一個連接池 */ public ConnectionFactory(ConnectionParam param, FactoryParam fparam) throws SQLException { //不答應參數為空 if ((param == null)(fparam == null)) throw new SQLException("ConnectionParam和FactoryParam不能為空"); if (m_instance == null) { synchronized(ConnectionFactory.class){ if (m_instance == null) { //new instance //參數定制 m_instance = new ConnectionFactory(); m_instance.connparam = param; m_instance.MaxConnectionCount = fparam.getMaxConn(); m_instance.MinConnectionCount = fparam.getMinConn(); m_instance.ManageType = fparam.getType(); m_instance.isflag = true; //初始化，創建MinConnectionCount個連接 System.out.println("connection factory 創建！"); try{ for (int i=0; i < m_instance.MinConnectionCount; i++) { _Connection _conn = _Connection.getConnection(m_instance, m_instance.connparam); 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(); } } } } }
連接池的治理
