
  jdbc作為一種數據庫訪問技術,具有簡單易用的優點。但使用這種模式進行web應用
  程序開發,存在很多問題:首先,每一次web請求都要建立一次數據庫連接。建立連接是一個費時的活動,每次都得花費0.05s~1s的時間,而且系統還要分配內存資源。這個時間對于一次或幾次數據庫操作,或許感覺不出系統有多大的開銷。可是對于現在的web應用,尤其是大型電子商務網站,同時有幾百人甚至幾千人在線是很正常的事。在這種情況下,頻繁的進行數據庫連接操作勢必占用很多的系統資源,網站的響應速度必定下降,嚴重的甚至會造成服務器的崩潰。不是危言聳聽,這就是制約某些電子商務網站發展的技術瓶頸問題。其次,對于每一次數據庫連接,使用完后都得斷開。否則,如果程序出現異常而未能關閉,將會導致數據庫系統中的內存泄漏,最終將不得不重啟數據庫。還有,這種開發不能控制被創建的連接對象數,系統資源會被毫無顧及的分配出去,如連接過多,也可能導致內存泄漏,服務器崩潰。
  數據庫連接池(connection pool)的工作原理
  1、基本概念及原理
  由上面的分析可以看出,問題的根源就在于對數據庫連接資源的低效管理。我們知道,
  對于共享資源,有一個很著名的設計模式:資源池(resource pool)。該模式正是為了解決資源的頻繁分配﹑釋放所造成的問題。為解決上述問題,可以采用數據庫連接池技術。數據庫連接池的基本思想就是為數據庫連接建立一個“緩沖池”。預先在緩沖池中放入一定數量的連接,當需要建立數據庫連接時,只需從“緩沖池”中取出一個,使用完畢之后再放回去。我們可以通過設定連接池最大連接數來防止系統無盡的與數據庫連接。更為重要的是我們可以通過連接池的管理機制監視數據庫的連接的數量﹑使用情況,為系統開發﹑測試及性能調整提供依據。連接池的基本工作原理見下圖2。

public synchronized connection getconnection()
  連接池的實現
  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)//裝載數據庫驅動程序
} 
public void init() throws servletexception
{
 connmgr = dbconnectionmanager.getinstance(); 
} 
public void destroy() { 
 connmgr.release(); super.destroy(); 
}
| 
 
 | 
新聞熱點
疑難解答