連接池用法

2019-11-18 13:26:09

字體：大中小

來源：轉載

供稿：網友

　　JDBC
　　java Servlet作為首選的服務器端數據處理技術，正在迅速取代CGI腳本。Servlet超越CGI的優勢之一在于，不僅多個請求可以共享公用資源，而且還可以在不同用戶請求之間保留持續數據。本文介紹一種充分發揮該特色的實用技術，即數據庫連接池。
　　
　　一、實現連接池的意義
　　
　　動態Web站點往往用數據庫存儲的信息生成Web頁面，每一個頁面請求導致一次數據庫訪問。連接數據庫不僅要開銷一定的通訊和內存資源，還必須完成用戶驗證、安全上下文配置這類任務，因而往往成為最為耗時的操作。當然，實際的連接時間開銷千變萬化，但1到2秒延遲并非不常見。假如某個基于數據庫的Web應用只需建立一次初始連接，不同頁面請求能夠共享同一連接，就能獲得顯著的性能改善。
　　Servlet是一個Java類。Servlet引擎（它可能是Web服務軟件的一部分，也可能是一個獨立的附加模塊）在系統啟動或Servlet第一次被請求時將該類裝入Java虛擬機并創建它的一個實例。不同用戶請求由同一Servlet實例的多個獨立線程處理。那些要求在不同請求之間持續有效的數據既可以用Servlet的實例變量來保存，也可以保存在獨立的輔助對象中。
　　用JDBC訪問數據庫首先要創建與數據庫之間的連接，獲得一個連接對象（Connection），由連接對象提供執行SQL語句的方法。本文介紹的數據庫連接池包括一個治理類DBConnectionManager，負責提供與多個連接池對象（DBConnectionPool類）之間的接口。每一個連接池對象治理一組JDBC連接對象，每一個連接對象可以被任意數量的Servlet共享。
　　類DBConnectionPool提供以下功能：
　　
　　1) 從連接池獲?。ɑ騽摻ǎ┛捎眠B接。
　　2) 把連接返回給連接池。
　　3) 在系統關閉時釋放所有資源，關閉所有連接。
　　
　　此外， DBConnectionPool類還能夠處理無效連接（原來登記為可用的連接，由于某種原因不再可用，如超時，通訊問題），并能夠限制連接池中的連接總數不超過某個預定值。
　　治理類DBConnectionManager用于治理多個連接池對象，它提供以下功能：
　　
　　1) 裝載和注冊JDBC驅動程序。
　　2) 根據在屬性文件中定義的屬性創建連接池對象。
　　3) 實現連接池名字與其實例之間的映射。
　　4) 跟蹤客戶程序對連接池的引用，保證在最后一個客戶程序結束時安全地關閉所有連接池。
　　
　　本文余下部分將具體說明這兩個類，最后給出一個示例演示Servlet使用連接池的一般過程。
　　
　　二、具體實現
　　
　　DBConnectionManager.java程序清單如下：
　　
　　001 import java.io.*;
　　002 import java.sql.*;
　　003 import java.util.*;
　　004 import java.util.Date;
　　005
　　006 /**
　　007 * 治理類DBConnectionManager支持對一個或多個由屬性文件定義的數據庫連接
　　008 * 池的訪問.客戶程序可以調用getInstance()方法訪問本類的唯一實例.
　　009 */
　　010 public class DBConnectionManager {
　　011 static PRivate DBConnectionManager instance; // 唯一實例
　　012 static private int clients;
　　013
　　014 private Vector drivers = new Vector();
　　015 private PrintWriter log;
　　016 private Hashtable pools = new Hashtable();
　　017
　　018 /**
　　019 * 返回唯一實例.假如是第一次調用此方法,則創建實例
　　020 *
　　021 * @return DBConnectionManager 唯一實例
　　022 */
　　023 static synchronized public DBConnectionManager getInstance() {
　　024 if (instance == null) {
　　025 instance = new DBConnectionManager();
　　026 }
　　027 clients++;
　　028 return instance;
　　029 }
　　030
　　031 /**
　　032 * 建構函數私有以防止其它對象創建本類實例
　　033 */
　　034 private DBConnectionManager() {
　　035 init();
　　036 }
　　037
　　038 /**
　　039 * 將連接對象返回給由名字指定的連接池
　　040 *
　　041 * @param name 在屬性文件中定義的連接池名字
　　042 * @param con 連接對象
　　043 */
　　044 public void freeConnection(String name, Connection con) {
　　045 DBConnectionPool pool = (DBConnectionPool) pools.get(name);
　　046 if (pool != null) {
　　047 pool.freeConnection(con);
　　048 }
　　049 }
　　050
　　051 /**
　　052 * 獲得一個可用的(空閑的)連接.假如沒有可用連接,且已有連接數小于最大連接數
　　053 * 限制,則創建并返回新連接
　　054 *
　　055 * @param name 在屬性文件中定義的連接池名字
　　056 * @return Connection 可用連接或null
　　057 */
　　058 public Connection getConnection(String name) {
　　059 DBConnectionPool pool = (DBConnectionPool) pools.get(name);
　　060 if (pool != null) {
　　061 return pool.getConnection();
　　062 }
　　063 return null;
　　064 }
　　065
　　066 /**
　　067 * 獲得一個可用連接.若沒有可用連接,且已有連接數小于最大連接數限制,
　　068 * 則創建并返回新連接.否則,在指定的時間內等待其它線程釋放連接.
　　069 *
　　070 * @param name 連接池名字
　　071 * @param time 以毫秒計的等待時間
　　072 * @return Connection 可用連接或null
　　073 */
　　074 public Connection getConnection(String name, long time) {
　　075 DBConnectionPool pool = (DBConnectionPool) pools.get(name);
　　076 if (pool != null) {
　　077 return pool.getConnection(time);
　　078 }
　　079 return null;
　　080 }
　　081
　　082 /**
　　083 * 關閉所有連接,撤銷驅動程序的注冊
　　084 */
　　085 public synchronized void release() {
　　086 // 等待直到最后一個客戶程序調用
　　087 if (--clients != 0) {
　　088 return;
　　089 }
　　090
　　091 Enumeration allPools = pools.elements();
　　092 while (allPools.hasMoreElements()) {
　　093 DBConnectionPool pool = (DBConnectionPool) allPools.nextElement();
　　094 pool.release();
　　095 }
　　096 Enumeration allDrivers = drivers.elements();
　　097 while (allDrivers.hasMoreElements()) {
　　098 Driver driver = (Driver) allDrivers.nextElement();
　　099 try {
　　100 DriverManager.deregisterDriver(driver);
　　101 log("撤銷JDBC驅動程序 " + driver.getClass().getName()+"的注冊");
　　102 }
　　103 catch (SQLException e) {
　　104 log(e, "無法撤銷下列JDBC驅動程序的注冊: " + driver.getClass().getName());
　　105 }
　　106 }
　　107 }
　　108
　　109 /**
　　110 * 根據指定屬性創建連接池實例.
　　111 *
　　112 * @param props 連接池屬性
　　113 */
　　114 private void createPools(Properties props) {
　　115 Enumeration propNames = props.propertyNames();
　　116 while (propNames.hasMoreElements()) {
　　117 String name = (String) propNames.nextElement();
　　118 if (name.endsWith(".url")) {
　　119 String poolName = name.substring(0, name.lastIndexOf("."));
　　120 String url = props.getProperty(poolName + ".url");
　　121 if (url == null) {
　　122 log("沒有為連接池" + poolName + "指定URL");
　　123 continue;
　　124 }
　　125 String user = props.getProperty(poolName + ".user");
　　126 String passWord = props.getProperty(poolName + ".password");
　　127 String maxconn = props.getProperty(poolName + ".maxconn", "0");
　　128 int max;
　　129 try {
　　130 max = Integer.valueOf(maxconn).intValue();
　　131 }
　　132 catch (NumberFormatException e) {
　　133 log("錯誤的最大連接數限制: " + maxconn + " .連接池: " + poolName);
　　134 max = 0;
　　135 }
　　136 DBConnectionPool pool =
　　137 new DBConnectionPool(poolName, url, user, password, max);
　　138 pools.put(poolName, pool);
　　139 log("成功創建連接池" + poolName);
　　140 }
　　141 }
　　142 }
　　143
　　144 /**
　　145 * 讀取屬性完成初始化
　　146 */
　　147 private void init() {
　　148 InputStream is = getClass().getResourceAsStream("/db.properties");
　　149 Properties dbProps = new Properties();
　　150 try {
　　151 dbProps.load(is);
　　152 }
　　153 catch (Exception e) {
　　154 System.err.println("不能讀取屬性文件. " +
　　155 "請確保db.properties在CLASSPATH指定的路徑中");
　　156 return;
　　157 }
　　158 String logFile = dbProps.getProperty("logfile", "DBConnectionManager.log");
　　159 try {
　　160 log = new PrintWriter(new FileWriter(logFile, true), true);
　　161 }
　　162 catch (I

上一篇：Reference 不為人知的一面

下一篇：垃圾自動收集系統指導 (2)