連接池的實現 1、連接池模型
本文討論的連接池包括一個連接池類(DBConnectionPool)和一個連接池管理類(DBConnetionPoolManager)。連接池類是對某一數據庫所有連接的“緩沖池”,主要實現以下功能:①從連接池獲取或創建可用連接;②使用完畢之后,把連接返還給連接池;③在系統關閉前,斷開所有連接并釋放連接占用的系統資源;④還能夠處理無效連接(原來登記為可用的連接,由于某種原因不再可用,如超時,通訊問題),并能夠限制連接池中的連接總數不低于某個預定值和不超過某個預定值。
連接池管理類是連接池類的外覆類(wrapper),符合單例模式,即系統中只能有一個連接池管理類的實例。其主要用于對多個連接池對象的管理,具有以下功能:①裝載并注冊特定數據庫的JDBC驅動程序;②根據屬性文件給定的信息,創建連接池對象;③為方便管理多個連接池對象,為每一個連接池對象取一個名字,實現連接池名字與其實例之間的映射;④跟蹤客戶使用連接情況,以便需要是關閉連接釋放資源。連接池管理類的引入主要是為了方便對多個連接池的使用和管理,如系統需要連接不同的數據庫,或連接相同的數據庫但由于安全性問題,需要不同的用戶使用不同的名稱和密碼。
2、連接池實現
下面給出連接池類和連接池管理類的主要屬性及所要實現的基本接口:
public class DBConnectionPool implements TimerListener{ private int checkedOut;//已被分配出去的連接數 private ArrayList freeConnections = new ArrayList();//容器,空閑池,根據//創建時間順序存放已創建但尚未分配出去的連接 private int minConn;//連接池里連接的最小數量 private int maxConn;//連接池里允許存在的最大連接數 private String name;//為這個連接池取個名字,方便管理 private String password;//連接數據庫時需要的密碼 private String url;//所要創建連接的數據庫的地址 private String user;//連接數據庫時需要的用戶名 public Timer timer;//定時器 public DBConnectionPool(String name, String URL, String user, String password, int maxConn)//公開的構造函數 public synchronized void freeConnection(Connection con) //使用完畢之后,//把連接返還給空閑池 public synchronized Connection getConnection(long timeout)//得到一個連接,//timeout是等待時間 public synchronized void release()//斷開所有連接,釋放占用的系統資源 private Connection newConnection()//新建一個數據庫連接 public synchronized void TimerEvent() //定時器事件處理函數
}
public class DBConnectionManager { static private DBConnectionManager instance;//連接池管理類的唯一實例 static private int clients;//客戶數量 private ArrayList drivers = new ArrayList();//容器,存放數據庫驅動程序
private HashMap pools = new HashMap ();//以name/value的形式存取連接池//對象的名字及連接池對象 static synchronized public DBConnectionManager getInstance()//如果唯一的//實例instance已經創建,直接返回這個實例;否則,調用私有構造函數,創//建連接池管理類的唯一實例
private DBConnectionManager()//私有構造函數,在其中調用初始化函數init()
public void freeConnection(String name, Connection con)// 釋放一個連接,//name是一個連接池對象的名字
public Connection getConnection(String name)//從名字為name的連接池對象//中得到一個連接
public Connection getConnection(String name, long time)//從名字為name
//的連接池對象中取得一個連接,time是等待時間
public synchronized void release()//釋放所有資源
private void createPools(Properties props)//根據屬性文件提供的信息,創建//一個或多個連接池
private void init()//初始化連接池管理類的唯一實例,由私有構造函數調用
private void loadDrivers(Properties props)//裝載數據庫驅動程序
} |
3、連接池使用
上面所實現的連接池在程序開發時如何應用到系統中呢?下面以Servlet為例說明連接池的使用。
Servlet的生命周期是:在開始建立servlet時,調用其初始化(init)方法。之后每個用戶請求都導致一個調用前面建立的實例的service方法的線程。最后,當服務器決定卸載一個servlet時,它首先調用該servlet的 destroy方法。
根據servlet的特點,我們可以在初始化函數中生成連接池管理類的唯一實例(其中包括創建一個或多個連接池)。如:
public void init() throws ServletException { connMgr = DBConnectionManager.getInstance(); } |
然后就可以在service方法中通過連接池名稱使用連接池,執行數據庫操作。最后在destroy方法中釋放占用的系統資源,如:
public void destroy() { connMgr.release(); super.destroy(); } |
結束語 在使用JDBC進行與數據庫有關的應用開發中,數據庫連接的管理是一個難點。很多時候,連接的混亂管理所造成的系統資源開銷過大成為制約大型企業級應用效率的瓶頸。對于眾多用戶訪問的Web應用,采用數據庫連接技術的系統在效率和穩定性上比采用傳統的其他方式的系統要好很多。本文闡述了使用JDBC訪問數據庫的技術﹑討論了基于連接池技術的數據庫連接管理的關鍵問題并給出了一個實現模型。文章所給出的是連接池管理程序的一種基本模式,為提高系統的整體性能,在此基礎上還可以進行很多有意義的擴展。