數據庫連接池的基本原理
傳統的數據庫連接方式(指通過DriverManager和基本實現DataSource進行連接)中,一個數據庫連接對象均對應一個物理數據庫連接,數據庫連接的建立以及關閉對系統而言是耗費系統資源的操作,在多層結構的應用程序環境中這種耗費資源的動作對系統的性能影響尤為明顯。
在多層結構的應用程序中通過連接池(connection pooling)技術可以使系統的性能明顯得到提到,連接池意味著當應用程序需要調用一個數據庫連接的時,數據庫相關的接口通過返回一個通過重用數據庫連接來代替重新創建一個數據庫連接。通過這種方式,應用程序可以減少對數據庫連接操作,尤其在多層環境中多個客戶端可以通過共享少量的物理數據庫連接來滿足系統需求。通過連接池技術Java應用程序不僅可以提高系統性能同時也為系統提高了可測量性。
數據庫連接池是運行在後台的而且應用程序的編碼沒有任何的影響。此中狀況存在的前提是應用程序必須通過DataSource對象(一個實現javax.sql.DataSource接口的實例)的方式代替原有通過DriverManager類來獲得數據庫連接的方式。一個實現javax.sql.DataSource接口的類可以支持也可以不支持數據庫連接池,但是兩者獲得數據庫連接的代碼基本是相同的。
代碼如下:
一個DataSource對象通常注冊在JNDI命名服務上,應用程序可以通過標准的方式獲得到注冊在JNDI服務上的DataSource對象。
Context ctx = new InitialContext();
DataSource ds = (DataSource) ctx.lookup("jdbc/openbase");
如果當前DataSource不支持數據庫連接池,應用程序將獲得一個和物理數據庫連接對應的Connection對象。而如果當前的DataSource對象支持數據庫連接池,應用程序自動獲得重用的數據庫連接而不用創建新的數據庫連接。重用的數據庫連接和新建立連接的數據庫連接使用上沒有任何不同。應用程序可以通過重用的連接正常的訪問數據庫,進行訪問數據的操作,完成操作後應顯式的調用close()關閉數據庫連接。
Connection con = ds.getConnection("User", "Pwd");
相關數據庫的操作;
con.close();
當關閉數據連接後,當前使用的數據庫連接將不會被物理關閉,而是放回到數據庫連接池中進行重用。
JDBC3.0規范中數據庫連接池框架
JDBC3.0規范中通過提供了一個支持數據庫連接池的框架,這個框架僅僅規定了如何支持連接池的實現,而連接池的具體實現JDBC 3.0規范並沒有做相關的規定。通過這個框架可以讓不同角色的開發人員共同實現數據庫連接池。
通過JDBC3.0規范可以知道具體數據庫連接池的實現可以分為JDBC Driver級和Application Server級。在JDBC Driver級的實現中任何相關的工作均由特定數據庫廠商的JDBC Drvier的開發人員來具體實現,即JDBC Driver既需要提供對數據庫連接池的支持同時也必須對數據庫連接池進行具體實現。而在Application Server級中數據庫連接池的實現中特定數據庫廠商的JDBC Driver開發人員和Application Server開發人員來共同實現數據庫連接池的實現(但是現在大多數Application Server廠商實現的連接池的機制和規范中提到有差異),其中特定數據庫廠商的JDBC Driver提供數據庫連接池的支持而特定的Application Server廠商提供數據庫連接池的具體實現。
JDBC3.0規范規定了如下的類和接口來支持數據庫連接池的實現。
javax.sql.ConnectionEvent
javax.sql.ConnectionPoolDataSource
javax.sql.PooledConnection
javax.sql.ConnectionEventListener
其中除javax.sql.ConnectionEvent是類,其它的均為接口。
JDBC3.0連接池框架的關系圖
通過此圖可以大概的了解相關接口在一個典型的三層環境中應用程序的位置。
數據庫連接池實現層次中,由特定數據庫廠商的JDBC Driver開發人員提供連接池支持,而特定Application Server提供連接池實現的情況比較復雜,其它的實現層次均可視為其簡化情況的一種。下面將針對這種情況進行說明。
在這個框架主要有兩個用戶角色存在,它們分別是:
特定數據庫廠商的JDBC Driver開發人員,之後將簡稱為Driver Vendor
特定Application Server中連接池開發人員,之後將簡稱為Pooling Vendor
JDBC3.0規范中在上述情況下各個接口和類之間的UML圖
下面對幾個關鍵模塊進行詳細的說明:
Driver Vendor DataSource:
Driver Vendor必須提供一個ConnectionPoolDataSource 接口的具體實現,通過這個接口Pooling Vendor可以得到一個PooledConnection對象,從而使第三方實現的連接池可以使用特定數據庫廠商得到JDBC Driver產生的數據庫連接。在這裡ConnectionPoolDataSource接口扮演的角色可以視為產生PooledConnection 對象的工廠。
Driver Vendor PooledConnection:
Driver Vendor必須提供標准PooledConnection 接口實現的類,這個接口允許Pooling Vendor在JDBC Driver提供連接池支持的基礎上實現連接池。一個具體PooledConnection對象代表了一個物理的數據庫連接;由PooledConnection對象創建Connection對象僅僅只是一個指向PooledConnetion對象的句柄。在JDBC 3.0連接池實現框架中PooledConnection對象扮演的角色可以視為產生Connection對象的工廠。
Pooling Vendor DataSource:
Pooling Vendor必須實現DataSource接口,這個接口是和連接池實現模塊進行交互的入口點。ConnectionPoolDataSource根據需要創建PooledConnection對象。
Pooling Vendor Connection Cache:
此模塊是Pooling Vendor對連接池的具體實現。JDBC 3.0 規范沒有規定在DataSource對象和數據庫連接池實現之間的需要實現的接口,所以它們之間的交互由Pooling Vendor自己定義。一般而言,一個數據庫連接池的具體實現包含了一個或若干個具體的類,但是在連接池實現模塊中必須包含一個類實現標准ConnectionEventListener接口。當一個PooledConnectiond對象被關閉或者出現異常的時候,PooledConnection對象將會向ConnectionEventListener接口發送ConnectionEvent對象,連接池實現模塊將會根據返回的ConnectionEvent對象對PooledConnection進行關閉或者重用操作。
ConnectionEvent:
實現連接池時,當應用程序調用Connection.close()試圖去關閉數據庫連接時,這時需要有一個通告給連接池實現模塊,通告對當前的數據庫物理連接(PooledConnection 對象)進行重用。為了使連接池實現模塊能得到這種"通告",連接池實現模塊必須實現ConnectionEventListener接口,而且同時需要注冊成為PooledConnection對象的監聽者。連接池實現模塊通過PooledConnection.addConnectionEventListener()方法注冊自己成為一個監聽者。
在典型三層環境中具體調用流程:
當應用程序通過調用DataSource.getConnection()得到一個數據庫連接。
Pooling Vendor實現的DataSource對象在連接池中進行查找看當前是否有有效的PooledConnection對象,如果連接池中有可用的PooledConnection,則進行檢查,如果當前的PooledConnection可用則使用。
如果如果連接池中沒有可用的PooledConnection對象,或者當前的PooledConnection對象不正確,那麼Pooling Vendor調用ConnectionPoolDataSource.getPooledConnection類創建一個新的PooledConnection對象,這時由Driver Vendor實現的ConnectionPoolDataSource將會創建一個滿足要求新的PooledConnection對象,並將其返回給連接池實現模塊進行管理。
然後,Pooling Vendor會調用PooledConnection.getConnection()獲得一個邏輯的Connection對象,這個邏輯的Connection對象將會象正常的Connection對象返回給應用程序。這個邏輯Connection對象實際上是連接池中PooledConnection對象的一個句柄,當連接池有效時,應用程序調用DataSource.getConnection()就會得到這個句柄。簡而言之,應用程序此時使用的Connection對象僅僅是其創建者PooledConnection對象的句柄而已。
連接池實現模塊調用PooledConnection.addConnectionEventListener()將自己注冊成為一個PooledConnection對象的監聽者,當數據庫連接需要重用或者關閉的時候連接池實現模塊可以得到通告。
當應用程序通過調用Connection.close()來關閉數據庫連接,這時一個ConnectionEvent對象被創建並被返回到連接池實現模塊,連接池實現模塊接受到此通告後,將PooledConnection對象返回到池中進行重用。這些過程中其它角色都不能訪問PooledConnection.close()方法,能訪問這個方法的只有Pooling Vendor,它們使用這個方法對連接池中的對象進行操作,通過PooledConnection.close()方法可以關閉物理數據庫連接。