數據庫連接池java實現小結

數據庫連接池java實現小結

因為工作需要要使用到連接池，所以拜讀了互聯網上眾多前輩的文章，學了不少經驗，這里想做一個小結，加上自己的想法和在一起，希望能給大家一些幫助。

· 目的：

• 消除數據庫頻繁連接帶來的開銷和瓶頸。

· 解決方案：

• 不過多的限制用戶的使用，既不能太多的要求用戶按規定的方法得到和使用數據庫連

• 盡量保持用戶的習慣

目前的很多方法都是要求用戶只能按規定方法使用連接，不能使用直接關閉數據連接的方法。解決辦法就是使用代理類，來中間解決?？梢詤⒖?http://www-900.ibm.com/developerWorks/cn/java/l-connpoolproxy/index.shtml

• 能維護連接的正常狀態

因為針對數據庫連接創建的資源，如果不能及時的釋放，就會影響下一次數據連接的使用。例如在sql 2k中，一個連接不同創建多條Statement否則操作時會有數據連接占線的異常，所以必須在歸還連接以后釋放這些資源。

CCCCCC">//判 斷是使用了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(); } } } } }

• 連接池的管理
• 對于連接池的管理，我是設想使用靜態管理和動態管理兩種策略，設置了最大限制，和恒定的連接數。使用了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); } } }

源代碼下載

原文轉自：http://www.anti-gravitydesign.com