新聞中心
隨著現(xiàn)代應(yīng)用程序的發(fā)展,許多應(yīng)用都需要與數(shù)據(jù)庫(kù)進(jìn)行交互。數(shù)據(jù)庫(kù)連接是應(yīng)用程序與數(shù)據(jù)庫(kù)進(jìn)行通信的核心部分。在高并發(fā)環(huán)境下,連接的獲取和釋放會(huì)導(dǎo)致性能問(wèn)題,此時(shí)連接池就變得至關(guān)重要了。連接池是一種存儲(chǔ)和管理數(shù)據(jù)庫(kù)連接的技術(shù),可以提高數(shù)據(jù)庫(kù)的性能和可靠性。

創(chuàng)新互聯(lián)堅(jiān)持“要么做到,要么別承諾”的工作理念,服務(wù)領(lǐng)域包括:網(wǎng)站制作、成都網(wǎng)站設(shè)計(jì)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù),滿足客戶于互聯(lián)網(wǎng)時(shí)代的龍勝網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求,幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴!
Java數(shù)據(jù)庫(kù)連接池是Java應(yīng)用的一種流行的技術(shù),它可以在應(yīng)用程序和數(shù)據(jù)庫(kù)之間建立維護(hù)連接的池子。在此池中,連接可以被預(yù)先分配給應(yīng)用程序,應(yīng)用程序只需從連接池中獲取連接,而不必等待連接的創(chuàng)建。連接池還可以優(yōu)化數(shù)據(jù)庫(kù)連接的使用,減少重復(fù)建立和銷毀連接的開(kāi)銷,并保證連接的有效性和穩(wěn)定性。本文將深入探討Java數(shù)據(jù)庫(kù)連接池的工作原理。
一、Java數(shù)據(jù)庫(kù)連接池的概述
Java數(shù)據(jù)庫(kù)連接池是Java應(yīng)用程序的關(guān)鍵組件之一。它可以在程序和數(shù)據(jù)庫(kù)之間管理數(shù)據(jù)庫(kù)連接。Java數(shù)據(jù)庫(kù)連接池包含以下幾種類型的連接:
1. 普通連接:需要對(duì)每個(gè)請(qǐng)求創(chuàng)建一個(gè)新的連接。
2. 復(fù)雜連接:在啟動(dòng)時(shí)會(huì)被創(chuàng)建,并可以由多個(gè)客戶共享。
3. 容器連接:在服務(wù)器中運(yùn)行,并可以由多個(gè)客戶共享。
Java數(shù)據(jù)庫(kù)連接池同樣包含管理連接池的核心組件,如:
1. 連接管理器:負(fù)責(zé)創(chuàng)建、維護(hù)和限制連接的數(shù)量。
2. 真實(shí)連接:代表連接池中真正的連接。
3. 連接池參數(shù):控制連接池的性能和管理方式。
二、Java數(shù)據(jù)庫(kù)連接池的工作原理
Java數(shù)據(jù)庫(kù)連接池是由連接池管理組件和連接池組件組成的。連接池管理組件負(fù)責(zé)管理連接池的維護(hù)和使用,連接池組件負(fù)責(zé)創(chuàng)建和釋放連接。
1. 連接池的管理
連接池管理組件通過(guò)三個(gè)主要階段管理連接池:
a. 連接池初始化:連接池初始化過(guò)程中,連接池?cái)?shù)量被設(shè)置為更大值。如果有必要,會(huì)創(chuàng)建一些連接。
b. 請(qǐng)求連接:連接池管理組件需要為連接請(qǐng)求進(jìn)行選擇連接的操作。連接可復(fù)用并可以獲取到連接。如果連接池中沒(méi)有連接,則需要?jiǎng)?chuàng)建連接。
c. 連接釋放:連接池管理組件還能夠接收連接的釋放,將連接放回連接池中。
在連接池的使用過(guò)程中,管理組件還要維護(hù)連接的使用狀態(tài)和連接的有效性檢查。連接的有效性檢查可以防止因長(zhǎng)時(shí)間無(wú)操作而導(dǎo)致的連接失效,并及時(shí)釋放連接。
2. 連接池的使用
當(dāng)應(yīng)用程序需要與數(shù)據(jù)庫(kù)進(jìn)行通信時(shí),連接池管理組件會(huì)根據(jù)策略從連接池中選擇連接提供給應(yīng)用程序。連接池組件會(huì)檢查連接是否被標(biāo)記為忙,如果是,則會(huì)重新選擇連接。應(yīng)用程序需要關(guān)閉連接后將其返回到連接池中。
Java數(shù)據(jù)庫(kù)連接池在連接獲取和釋放的過(guò)程中,還支持以下幾種方式:
a. 延遲初始化:連接池不會(huì)在應(yīng)用程序啟動(dòng)時(shí)創(chuàng)建所有連接,而是在實(shí)際需要時(shí)才創(chuàng)建。
b. 連接的自動(dòng)獲取與釋放:連接池可以自動(dòng)獲取和釋放連接。
c. 連接的管理:連接池可以控制連接的數(shù)量和性能,確保連接的可靠性和更佳性能。
三、如何選擇適合的Java數(shù)據(jù)庫(kù)連接池
1. 性能考慮:
在選擇連接池時(shí),考慮連接池的性能,如連接池的速度、技術(shù)支持、占用內(nèi)存等因素。通常,連接池可以支持多種連接技術(shù),熟悉這些技術(shù)可以幫助快速調(diào)整連接池的性能。
2. 穩(wěn)定性考慮:
連接池組件的可靠性是選擇連接池時(shí)考慮的另一個(gè)重要因素。連接池組件應(yīng)該能夠支持故障恢復(fù)、連接不可用的處理等功能。
3. 軟件開(kāi)源性:
開(kāi)源軟件通常比私有軟件更加突出,更容易獲取技術(shù)支持,因此連接池的開(kāi)源性也是選擇連接池時(shí)考慮的因素之一。
4. 集成和轉(zhuǎn)換:
連接池應(yīng)該能夠集成和轉(zhuǎn)換到Java應(yīng)用中,并能夠兼容應(yīng)用中的其他技術(shù)。
5. 安全性:
連接池應(yīng)該能夠具有安全性,能夠在互聯(lián)網(wǎng)上可靠地工作,并能夠通過(guò)適當(dāng)?shù)氖跈?quán)和驗(yàn)證保護(hù)免受攻擊。
四、Java數(shù)據(jù)庫(kù)連接池的優(yōu)缺點(diǎn)
Java數(shù)據(jù)庫(kù)連接池具有以下優(yōu)點(diǎn):
1. 連接池可以減少重復(fù)的連接開(kāi)銷,提高性能和可靠性。
2. 連接池可以控制連接的數(shù)量和性能,確保應(yīng)用程序可以使用更佳性能的連接。
3. 連接池可以緩存新創(chuàng)建的連接,并在需要時(shí)重復(fù)使用。
4. 連接池可以減少與數(shù)據(jù)庫(kù)服務(wù)器之間的網(wǎng)絡(luò)通信量。
但是,Java數(shù)據(jù)庫(kù)連接池也存在以下缺點(diǎn):
1. 連接池需要額外的內(nèi)存用于維護(hù)連接和連接池的狀態(tài)。對(duì)于高并發(fā)應(yīng)用程序,這可能對(duì)內(nèi)存使用造成不利影響。
2. 連接池可能無(wú)法處理關(guān)鍵的異常,如數(shù)據(jù)庫(kù)不可用或網(wǎng)絡(luò)中斷。
3. 連接池需要額外的處理和管理,這可能也會(huì)增加系統(tǒng)開(kāi)銷。
五、Java數(shù)據(jù)庫(kù)連接池的更佳實(shí)踐
Java數(shù)據(jù)庫(kù)連接池是一個(gè)強(qiáng)有力的工具,它能夠提高應(yīng)用程序的性能和可靠性。為了從連接池中獲取更大的好處,我們需要采用以下更佳實(shí)踐:
1. 選擇正確的連接池:選擇適合我們應(yīng)用程序的連接池軟件。
2. 正確配置連接池參數(shù):連接池的參數(shù)應(yīng)該按照業(yè)務(wù)需求進(jìn)行優(yōu)化調(diào)整。
3. 控制連接類型:為了避免應(yīng)用程序和數(shù)據(jù)庫(kù)之間的通信問(wèn)題,應(yīng)用程序和數(shù)據(jù)庫(kù)應(yīng)該使用相同的協(xié)議和驅(qū)動(dòng)程序。
4. 使用連接池的日志輸出:連接池的日志文件可以幫助我們檢測(cè)和分析應(yīng)用程序和數(shù)據(jù)庫(kù)之間的通信問(wèn)題。
5. 關(guān)閉數(shù)據(jù)庫(kù)連接:應(yīng)用程序必須正確關(guān)閉數(shù)據(jù)庫(kù)的連接,否則大量的閑置連接可能導(dǎo)致性能受損。
六、
Java數(shù)據(jù)庫(kù)連接池是現(xiàn)代Java應(yīng)用程序的核心組件之一。連接池的作用是管理連接的數(shù)量和使用,提高數(shù)據(jù)庫(kù)的性能和可靠性。通過(guò)本文,我們深入探討了Java連接池的工作原理,包括連接池的管理、使用、優(yōu)缺點(diǎn)和更佳實(shí)踐等方面。我們還討論了如何選擇適合我們應(yīng)用程序的連接池,并提供了相關(guān)技術(shù)支持。
相關(guān)問(wèn)題拓展閱讀:
- [高分]java方面的問(wèn)題:請(qǐng)教高手db.properties連接池的用法
[高分]java方面的問(wèn)題:請(qǐng)教高手db.properties連接池的用法
Properties文件,其實(shí)僅僅是鍵值對(duì)配置文件。下面介紹如何讀取properties文件以及如何用JDBC連接數(shù)據(jù)庫(kù)。
1.:
比如你的properties文件叫做mysql.properties,并且放在com.test包下:
java.net.URL url = Thread.currentThread().getContextClassLoader().getResource(“com/test/mysql.properties”);
注意路徑和包名一致,在你的提問(wèn)中,我們知道是放在classes目錄下,則直接
…getResource(“mysql.properties”); 即可
Properties p = new Properties();
p.load(url.openStream()); //由URL載入配置文件
這樣你就得到一個(gè)Properties的實(shí)例
2. :
比如你要讀取drivers的值,只需:
String theDriver = p.get(“drivers”);
根據(jù)配置文件,這樣你就得到了”org.gjt.mm.mysql.Driver”
3.
首先你要保證你有MySQL的Jdbc驅(qū)動(dòng)程序,即包含org.gjt.mm.mysql.Driver的jar包,并放在應(yīng)兆檔舉用的classpath里。你可以搜索一下,很多地方有下的:
mysql-connector-java-3.0.15-ga-bin.jar
然后用同樣的方法得到url, mysql.user, mysql.password的值,比如分別為
url, user, pass
然后建立連接:
Class.forName(“com.mysql.jdbc.Driver”);
java.sql.Connection conn = java.sql.DriverManager.getConnection(url, user, pass);
如果不出意外,你就得到連接數(shù)據(jù)庫(kù)的Connection了,注意用完了別忘了關(guān)啊。(conn.close();)
4.
properties文件只是一個(gè)鍵-值對(duì)的配置文件(而且鍵和值都是可以自己寫(xiě)的,并沒(méi)有固定格式,要看程序需求),從它“本身”只能得到鍵對(duì)應(yīng)的值。具體這個(gè)值用來(lái)干什么,那是程序的事情。比如logfile和maxconn,我只能猜是用來(lái)處理log和建立連接池時(shí)標(biāo)記更大連接數(shù)的,具體怎么實(shí)現(xiàn),需要研究它的代碼族碧,因?yàn)椴](méi)有固定寫(xiě)法。(而上面用jdbc建立連接的寫(xiě)法是固定的)。因?yàn)槟阒唤o了個(gè)properties文件,所以我只能寫(xiě)一個(gè)jdbc的連接程序,但這并不是連接池的實(shí)現(xiàn)。
這里有個(gè)連接池的實(shí)現(xiàn),你可以參考下:
希望對(duì)你蠢戚有所幫助!
連接池用法JDBC
Java Servlet作為首選的服務(wù)器端數(shù)據(jù)處理技術(shù),正在迅速取代CGI腳本。Servlet超越CGI的優(yōu)勢(shì)之一在于,不僅多個(gè)請(qǐng)求可以共享公用資源,而且還可以在不同用戶請(qǐng)求之間保留持續(xù)數(shù)據(jù)。本文介紹一種充分發(fā)揮該特色的實(shí)用技術(shù),即數(shù)據(jù)庫(kù)連接池。
一、實(shí)現(xiàn)連接池的意義
動(dòng)態(tài)Web站點(diǎn)往往用數(shù)據(jù)庫(kù)存儲(chǔ)的信息生成Web頁(yè)面,每一個(gè)頁(yè)面請(qǐng)求導(dǎo)致一次數(shù)據(jù)庫(kù)訪問(wèn)。連接數(shù)據(jù)庫(kù)不僅要開(kāi)銷一定的通訊和內(nèi)存資源,還必須完成用戶驗(yàn)證、安全上下文配置這類任務(wù),因而往往成為最為耗時(shí)的操作。當(dāng)然,實(shí)際的連接時(shí)間開(kāi)銷千變?nèi)f化,但1到2秒延遲并非不常見(jiàn)。如果某個(gè)基于數(shù)據(jù)庫(kù)的Web應(yīng)用只需建立一次初始連接,不同頁(yè)面請(qǐng)求能夠共享同一連接,就能獲得顯著的性能改善。
Servlet是一個(gè)Java類。Servlet引擎(它可能是Web服務(wù)軟件的一部分,也可能是一個(gè)獨(dú)立的附加模塊)在系統(tǒng)穗改冊(cè)啟動(dòng)或Servlet之一次被請(qǐng)殲禪求時(shí)將該類裝入Java虛擬機(jī)并創(chuàng)建它的一個(gè)實(shí)例。不同用戶請(qǐng)求由同一Servlet實(shí)例的多個(gè)獨(dú)立線程處理。那些要求在不同請(qǐng)求之間持續(xù)有效的數(shù)據(jù)既可以用Servlet的實(shí)例變量來(lái)保存,也可以保存在獨(dú)立的輔助對(duì)象中。
用JDBC訪問(wèn)數(shù)據(jù)庫(kù)首先要?jiǎng)?chuàng)建與數(shù)據(jù)庫(kù)之間的連接,獲得一個(gè)連接對(duì)象(Connection),由連接對(duì)象提供執(zhí)行SQL語(yǔ)句的方法。本文介紹的數(shù)據(jù)庫(kù)連接池包括一個(gè)管理類DBConnectionManager,負(fù)責(zé)提供與多個(gè)連接池對(duì)象(DBConnectionPool類)之間的接口。每一個(gè)連接池對(duì)象管理一組JDBC連接對(duì)象,每一個(gè)連接對(duì)象可以被任意數(shù)量的Servlet共享。
類DBConnectionPool提供以下功能:
1) 從連接池獲?。ɑ騽?chuàng)建)可用連接。
2) 把連接返回給連接池。
3) 在系統(tǒng)關(guān)閉時(shí)釋放所有資源,關(guān)閉所有連接。
此外, DBConnectionPool類還能夠處理無(wú)效連接(原來(lái)登記為可用的連接,由于某種原因不再可用,如超時(shí),通訊問(wèn)題),并能夠限制連接池中的連接總數(shù)不超過(guò)某個(gè)預(yù)定值。
管理類DBConnectionManager用于管理多個(gè)連接池對(duì)象,它提供以下功能:
1) 裝載和注冊(cè)JDBC驅(qū)動(dòng)程序。
2) 根據(jù)在屬性文件中定義的屬性創(chuàng)建連接池對(duì)象。
3) 實(shí)現(xiàn)連接池名字與其實(shí)例之間的映射。
4) 跟蹤客戶程序?qū)B接池的引用猜宏,保證在最后一個(gè)客戶程序結(jié)束時(shí)安全地關(guān)閉所有連接池。
本文余下部分將詳細(xì)說(shuō)明這兩個(gè)類,最后給出一個(gè)示例演示Servlet使用連接池的一般過(guò)程。
二、具體實(shí)現(xiàn)
DBConnectionManager.java程序清單如下:
001 import java.io.*;
002 import java.sql.*;
003 import java.util.*;
004 import java.util.Date;
005
006 /**
007 * 管理類DBConnectionManager支持對(duì)一個(gè)或多個(gè)由屬性文件定義的數(shù)據(jù)庫(kù)連接
008 * 池的訪問(wèn).客戶程序可以調(diào)用getInstance()方法訪問(wèn)本類的唯一實(shí)例.
009 */
010 public class DBConnectionManager {
011 static private DBConnectionManager instance; // 唯一實(shí)例
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 * 返回唯一實(shí)例.如果是之一次調(diào)用此方法,則創(chuàng)建實(shí)例
020 *
021 * @return DBConnectionManager 唯一實(shí)例
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 * 建構(gòu)函數(shù)私有以防止其它對(duì)象創(chuàng)建本類實(shí)例
033 */
034 private DBConnectionManager() {
035 init();
036 }
037
038 /**
039 * 將連接對(duì)象返回給由名字指定的連接池
040 *
041 * @param name 在屬性文件中定義的連接池名字
042 * @param con 連接對(duì)象
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 * 獲得一個(gè)可用的(空閑的)連接.如果沒(méi)有可用連接,且已有連接數(shù)小于更大連接數(shù)
053 * 限制,則創(chuàng)建并返回新連接
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 * 獲得一個(gè)可用連接.若沒(méi)有可用連接,且已有連接數(shù)小于更大連接數(shù)限制,
068 * 則創(chuàng)建并返回新連接.否則,在指定的時(shí)間內(nèi)等待其它線程釋放連接.
069 *
070 * @param name 連接池名字
071 * @param time 以毫秒計(jì)的等待時(shí)間
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 * 關(guān)閉所有連接,撤銷驅(qū)動(dòng)程序的注冊(cè)
084 */
085 public synchronized void release() {
086 // 等待直到最后一個(gè)客戶程序調(diào)用
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驅(qū)動(dòng)程序 ” + driver.getClass().getName()+”的注冊(cè)”);
102 }
103 catch (SQLException e) {
104 log(e, “無(wú)法撤銷下列JDBC驅(qū)動(dòng)程序的注冊(cè): ” + driver.getClass().getName());
105 }
106 }
107 }
108
109 /**
110 * 根據(jù)指定屬性創(chuàng)建連接池實(shí)例.
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(“沒(méi)有為連接池” + 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(“錯(cuò)誤的更大連接數(shù)限制: ” + maxconn + ” .連接池: ” + poolName);
134 max = 0;
135 }
136 DBConnectionPool pool =
137 new DBConnectionPool(poolName, url, user, password, max);
138 pools.put(poolName, pool);
139 log(“成功創(chuàng)建連接池” + 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 “請(qǐng)確保db.properties在CLASSPATH指定的路徑中”);
156 return;
157 }
158 String logFile = dbProps.getProperty(“l(fā)ogfile”, “DBConnectionManager.log”);
159 try {
160 log = new PrintWriter(new FileWriter(logFile, true), true);
161 }
162 catch (IOException e) {
163 System.err.println(“無(wú)法打開(kāi)日志文件: ” + logFile);
164 log = new PrintWriter(System.err);
165 }
166 loadDrivers(dbProps);
167 createPools(dbProps);
168 }
169
170 /**
171 * 裝載和注冊(cè)所有JDBC驅(qū)動(dòng)程序
172 *
173 * @param props 屬性
174 */
175 private void loadDrivers(Properties props) {
176 String driverClasses = props.getProperty(“drivers”);
177 StringTokenizer st = new StringTokenizer(driverClasses);
178 while (st.hasMoreElements()) {
179 String driverClassName = st.nextToken().trim();
180 try {
181 Driver driver = (Driver)
182 Class.forName(driverClassName).newInstance();
183 DriverManager.registerDriver(driver);
184 drivers.addElement(driver);
185 log(“成功注冊(cè)JDBC驅(qū)動(dòng)程序” + driverClassName);
186 }
187 catch (Exception e) {
188 log(“無(wú)法注冊(cè)JDBC驅(qū)動(dòng)程序: ” +
189 driverClassName + “, 錯(cuò)誤: ” + e);
190 }
191 }
192 }
193
194 /**
195 * 將文本信息寫(xiě)入日志文件
196 */
197 private void log(String msg) {
198 log.println(new Date() + “: ” + msg);
199 }
200
201 /**
202 * 將文本信息與異常寫(xiě)入日志文件
203 */
204 private void log(Throwable e, String msg) {
205 log.println(new Date() + “: ” + msg);
206 e.printStackTrace(log);
207 }
208
209 /**
210 * 此內(nèi)部類定義了一個(gè)連接池.它能夠根據(jù)要求創(chuàng)建新連接,直到預(yù)定的最
211 * 大連接數(shù)為止.在返回連接給客戶程序之前,它能夠驗(yàn)證連接的有效性.
212 */
213 class DBConnectionPool {
214 private int checkedOut;
215 private Vector freeConnections = new Vector();
216 private int maxConn;
217 private String name;
218 private String password;
219 private String URL;
220 private String user;
221
222 /**
223 * 創(chuàng)建新的連接池
224 *
225 * @param name 連接池名字
226 * @param URL 數(shù)據(jù)庫(kù)的JDBC URL
227 * @param user 數(shù)據(jù)庫(kù)帳號(hào),或 null
228 * @param password 密碼,或 null
229 * @param maxConn 此連接池允許建立的更大連接數(shù)
230 */
231 public DBConnectionPool(String name, String URL, String user, String password,
232 int maxConn) {
233 this.name = name;
234 this.URL = URL;
235 this.user = user;
236 this.password = password;
237 this.maxConn = maxConn;
238 }
239
240 /**
241 * 將不再使用的連接返回給連接池
242 *
243 * @param con 客戶程序釋放的連接
244 */
245 public synchronized void freeConnection(Connection con) {
246 // 將指定連接加入到向量末尾
247 freeConnections.addElement(con);
248 checkedOut–;
249 notifyAll();
250 }
251
252 /**
253 * 從連接池獲得一個(gè)可用連接.如沒(méi)有空閑的連接且當(dāng)前連接數(shù)小于更大連接
254 * 數(shù)限制,則創(chuàng)建新連接.如原來(lái)登記為可用的連接不再有效,則從向量刪除之,
255 * 然后遞歸調(diào)用自己以嘗試新的可用連接.
256 */
257 public synchronized Connection getConnection() {
258 Connection con = null;
259 if (freeConnections.size() > 0) {
260 // 獲取向量中之一個(gè)可用連接
261 con = (Connection) freeConnections.firstElement();
262 freeConnections.removeElementAt(0);
263 try {
264 if (con.isClosed()) {
265 log(“從連接池” + name+”刪除一個(gè)無(wú)效連接”);
266 // 遞歸調(diào)用自己,嘗試再次獲取可用連接
267 con = getConnection();
268 }
269 }
270 catch (SQLException e) {
271 log(“從連接池” + name+”刪除一個(gè)無(wú)效連接”);
272 // 遞歸調(diào)用自己,嘗試再次獲取可用連接
273 con = getConnection();
274 }
275 }
276 else if (maxConn == 0 || checkedOut = timeout) {
300 // wait()返回的原因是超時(shí)
301 return null;
302 }
303 }
304 return con;
305 }
306
307 /**
308 * 關(guān)閉所有連接
309 */
310 public synchronized void release() {
311 Enumeration allConnections = freeConnections.elements();
312 while (allConnections.hasMoreElements()) {
313 Connection con = (Connection) allConnections.nextElement();
314 try {
315 con.close();
316 log(“關(guān)閉連接池” + name+”中的一個(gè)連接”);
317 }
318 catch (SQLException e) {
319 log(e, “無(wú)法關(guān)閉連接池” + name+”中的連接”);
320 }
321 }
322 freeConnections.removeAllElements();
323 }
324
325 /**
326 * 創(chuàng)建新的連接
327 */
328 private Connection newConnection() {
329 Connection con = null;
330 try {
331 if (user == null) {
332 con = DriverManager.getConnection(URL);
333 }
334 else {
335 con = DriverManager.getConnection(URL, user, password);
336 }
337 log(“連接池” + name+”創(chuàng)建一個(gè)新的連接”);
338 }
339 catch (SQLException e) {
340 log(e, “無(wú)法創(chuàng)建下列URL的連接: ” + URL);
341 return null;
342 }
343 return con;
344 }
345 }
346 }
三、類DBConnectionPool說(shuō)明
該類在209至345行實(shí)現(xiàn),它表示指向某個(gè)數(shù)據(jù)庫(kù)的連接池。數(shù)據(jù)庫(kù)由JDBC URL標(biāo)識(shí)。一個(gè)JDBC URL由三部分組成:協(xié)議標(biāo)識(shí)(總是jdbc),驅(qū)動(dòng)程序標(biāo)識(shí)(如 odbc、idb、oracle等),數(shù)據(jù)庫(kù)標(biāo)識(shí)(其格式依賴于驅(qū)動(dòng)程序)。例如,jdbcdbc:demo,即是一個(gè)指向demo數(shù)據(jù)庫(kù)的JDBC URL,而且訪問(wèn)該數(shù)據(jù)庫(kù)要使用JDBC-ODBC驅(qū)動(dòng)程序。每個(gè)連接池都有一個(gè)供客戶程序使用的名字以及可選的用戶帳號(hào)、密碼、更大連接數(shù)限制。如果Web應(yīng)用程序所支持的某些數(shù)據(jù)庫(kù)操作可以被所有用戶執(zhí)行,而其它一些操作應(yīng)由特別許可的用戶執(zhí)行,則可以為兩類操作分別定義連接池,兩個(gè)連接池使用相同的JDBC URL,但使用不同的帳號(hào)和密碼。
類DBConnectionPool的建構(gòu)函數(shù)需要上述所有數(shù)據(jù)作為其參數(shù)。如222至238行所示,這些數(shù)據(jù)被保存為它的實(shí)例變量:
如252至283行、285至305行所示, 客戶程序可以使用DBConnectionPool類提供的兩個(gè)方法獲取可用連接。兩者的共同之處在于:如連接池中存在可用連接,則直接返回,否則創(chuàng)建新的連接并返回。如果沒(méi)有可用連接且已有連接總數(shù)等于更大限制數(shù),之一個(gè)方法將直接返回null,而第二個(gè)方法將等待直到有可用連接為止。
所有的可用連接對(duì)象均登記在名為freeConnections的向量(Vector)中。如果向量中有多于一個(gè)的連接,getConnection()總是選取之一個(gè)。同時(shí),由于新的可用連接總是從尾部加入向量,從而使得數(shù)據(jù)庫(kù)連接由于長(zhǎng)時(shí)間閑置而被關(guān)閉的風(fēng)險(xiǎn)減低到最小程度。
之一個(gè)getConnection()在返回可用連接給客戶程序之前,調(diào)用了isClosed()方法驗(yàn)證連接仍舊有效。如果該連接被關(guān)閉或觸發(fā)異常,getConnection()遞歸地調(diào)用自己以嘗試獲取另外的可用連接。如果在向量freeConnections中不存在任何可用連接,getConnection()方法檢查是否已經(jīng)指定更大連接數(shù)限制。如已經(jīng)指定,則檢查當(dāng)前連接數(shù)是否已經(jīng)到達(dá)極限。此處maxConn為0表示沒(méi)有限制。如果沒(méi)有指定更大連接數(shù)限制或當(dāng)前連接數(shù)小于該值,該方法嘗試創(chuàng)建新的連接。如創(chuàng)建成功,則增加已使用連接的計(jì)數(shù)并返回,否則返回空值。
如325至345行所示,創(chuàng)建新連接由newConnection()方法實(shí)現(xiàn)。創(chuàng)建過(guò)程與是否已經(jīng)指定數(shù)據(jù)庫(kù)帳號(hào)、密碼有關(guān)。
JDBC的DriverManager類提供多個(gè)getConnection()方法,這些方法要用到JDBC URL與其它一些參數(shù),如用戶帳號(hào)和密碼等。DriverManager將使用指定的JDBC URL確定適合于目標(biāo)數(shù)據(jù)庫(kù)的驅(qū)動(dòng)程序及建立連接。
在285至305行實(shí)現(xiàn)的第二個(gè)getConnection()方法需要一個(gè)以毫秒為單位的時(shí)間參數(shù),該參數(shù)表示客戶程序能夠等待的最長(zhǎng)時(shí)間。建立連接的具體操作仍舊由之一個(gè)getConnection()方法實(shí)現(xiàn)。
該方法執(zhí)行時(shí)先將startTime初始化為當(dāng)前時(shí)間。在while循環(huán)中嘗試獲得一個(gè)連接。如果失敗,則以給定的時(shí)間值為參數(shù)調(diào)用wait()。wait()的返回可能是由于其它線程調(diào)用notify()或notifyAll(),也可能是由于預(yù)定時(shí)間已到。為找出wait()返回的真正原因,程序用當(dāng)前時(shí)間減開(kāi)始時(shí)間(startTime),如差值大于預(yù)定時(shí)間則返回空值,否則再次調(diào)用getConnection()。
把空閑的連接登記到連接池由240至250行的freeConnection()方法實(shí)現(xiàn),它的參數(shù)為返回給連接池的連接對(duì)象。該對(duì)象被加入到freeConnections向量的末尾,然后減少已使用連接計(jì)數(shù)。調(diào)用notifyAll()是為了通知其它正在等待可用連接的線程。
許多Servlet引擎為實(shí)現(xiàn)安全關(guān)閉提供多種方法。數(shù)據(jù)庫(kù)連接池需要知道該事件以保證所有連接能夠正常關(guān)閉。DBConnectionManager類負(fù)協(xié)調(diào)整個(gè)關(guān)閉過(guò)程,但關(guān)閉連接池中所有連接的任務(wù)則由DBConnectionPool類負(fù)責(zé)。在307至323行實(shí)現(xiàn)的release()方法供DBConnectionManager調(diào)用。該方法遍歷freeConnections向量并關(guān)閉所有連接,然后從向量中刪除這些連接。
四、類DBConnectionManager 說(shuō)明
該類只能創(chuàng)建一個(gè)實(shí)例,其它對(duì)象能夠調(diào)用其靜態(tài)方法(也稱為類方法)獲得該唯一實(shí)例的引用。如031至036行所示,DBConnectionManager類的建構(gòu)函數(shù)是私有的,這是為了避免其它對(duì)象創(chuàng)建該類的實(shí)例。
DBConnectionManager類的客戶程序可以調(diào)用getInstance()方法獲得對(duì)該類唯一實(shí)例的引用。如018至029行所示,類的唯一實(shí)例在getInstance()方法之一次被調(diào)用期間創(chuàng)建,此后其引用就一直保存在靜態(tài)變量instance中。每次調(diào)用getInstance()都增加一個(gè)DBConnectionManager的客戶程序計(jì)數(shù)。即,該計(jì)數(shù)代表引用DBConnectionManager唯一實(shí)例的客戶程序總數(shù),它將被用于控制連接池的關(guān)閉操作。
該類實(shí)例的初始化工作由146至168行之間的私有方法init()完成。其中 getResourceAsStream()方法用于定位并打開(kāi)外部文件。外部文件的定位方法依賴于類裝載器的實(shí)現(xiàn)。標(biāo)準(zhǔn)的本地類裝載器查找操作總是開(kāi)始于類文件所在路徑,也能夠搜索CLASSPATH中聲明的路徑。db.properties是一個(gè)屬性文件,它包含定義連接池的鍵-值對(duì)。可供定義的公用屬性如下:
drivers 以空格分隔的JDBC驅(qū)動(dòng)程序類列表
logfile 日志文件的絕對(duì)路徑
其它的屬性和特定連接池相關(guān),其屬性名字前應(yīng)加上連接池名字:
.url 數(shù)據(jù)庫(kù)的 JDBC URL
.maxconn 允許建立的更大連接數(shù),0表示沒(méi)有限制
.user 用于該連接池的數(shù)據(jù)庫(kù)帳號(hào)
.password 相應(yīng)的密碼
其中url屬性是必需的,而其它屬性則是可選的。數(shù)據(jù)庫(kù)帳號(hào)和密碼必須合法。用于Windows平臺(tái)的db.properties文件示例如下:
drivers=sun.jdbc.odbc.JdbcOdbcDriver jdbc.idbDriver
logfile=D:\user\src\java\DBConnectionManager\log.txt
idb.url=jdbc:idb:c:\local\javawebserver1.1\db\db.prp
idb.maxconn=2
access.url=jdbcdbc:demo
access.user=demo
access.password=demopw
注意在Windows路徑中的反斜杠必須輸入2個(gè),這是由于屬性文件中的反斜杠同時(shí)也是一個(gè)轉(zhuǎn)義字符。
init()方法在創(chuàng)建屬性對(duì)象并讀取db.properties文件之后,就開(kāi)始檢查logfile屬性。如果屬性文件中沒(méi)有指定日志文件,則默認(rèn)為當(dāng)前目錄下的DBConnectionManager.log文件。如日志文件無(wú)法使用,則向System.err輸出日志記錄。
裝載和注冊(cè)所有在drivers屬性中指定的JDBC驅(qū)動(dòng)程序由170至192行之間的loadDrivers()方法實(shí)現(xiàn)。該方法先用StringTokenizer將drivers屬性值分割為對(duì)應(yīng)于驅(qū)動(dòng)程序名稱的字符串,然后依次裝載這些類并創(chuàng)建其實(shí)例,最后在 DriverManager中注冊(cè)該實(shí)例并把它加入到一個(gè)私有的向量drivers。向量drivers將用于關(guān)閉服務(wù)時(shí)從DriverManager取消所有JDBC 驅(qū)動(dòng)程序的注冊(cè)。
init()方法的最后一個(gè)任務(wù)是調(diào)用私有方法createPools()創(chuàng)建連接池對(duì)象。如109至142行所示,createPools()方法先創(chuàng)建所有屬性名字的枚舉對(duì)象(即Enumeration對(duì)象,該對(duì)象可以想象為一個(gè)元素系列,逐次調(diào)用其nextElement()方法將順序返回各元素),然后在其中搜索名字以“.url”結(jié)尾的屬性。對(duì)于每一個(gè)符合條件的屬性,先提取其連接池名字部分,進(jìn)而讀取所有屬于該連接池的屬性,最后創(chuàng)建連接池對(duì)象并把它保存在實(shí)例變量pools中。散列表(Hashtable類 )pools實(shí)現(xiàn)連接池名字到連接池對(duì)象之間的映射,此處以連接池名字為鍵,連接池對(duì)象為值。
為便于客戶程序從指定連接池獲得可用連接或?qū)⑦B接返回給連接池,類DBConnectionManager提供了方法getConnection()和freeConnection()。所有這些方法都要求在參數(shù)中指定連接池名字,具體的連接獲取或返回操作則調(diào)用對(duì)應(yīng)的連接池對(duì)象完成。它們的實(shí)現(xiàn)分別在051至064行、066至080行、038至049行。
如082至107行所示,為實(shí)現(xiàn)連接池的安全關(guān)閉,DBConnectionManager提供了方法release()。在上面我們已經(jīng)提到,所有DBConnectionManager的客戶程序都應(yīng)該調(diào)用靜態(tài)方法getInstance()以獲得該管理器的引用,此調(diào)用將增加客戶程序計(jì)數(shù)??蛻舫绦蛟陉P(guān)閉時(shí)調(diào)用release()可以遞減該計(jì)數(shù)。當(dāng)最后一個(gè)客戶程序調(diào)用release(),遞減后的引用計(jì)數(shù)為0,就可以調(diào)用各個(gè)連接池的release()方法關(guān)閉所有連接了。管理類release()方法最后的任務(wù)是撤銷所有JDBC驅(qū)動(dòng)程序的注冊(cè)。
五、Servlet使用連接池示例
Servlet API所定義的Servlet生命周期類如:
1) 創(chuàng)建并初始化Servlet(init()方法)。
2) 響應(yīng)客戶程序的服務(wù)請(qǐng)求(service()方法)。
3) Servlet終止運(yùn)行,釋放所有資源(destroy()方法)。
本例演示連接池應(yīng)用,上述關(guān)鍵步驟中的相關(guān)操作為:
1) 在init(),用實(shí)例變量connMgr 保存調(diào)用DBConnectionManager.getInstance()所返回的引用。
2) 在service(),調(diào)用getConnection(),執(zhí)行數(shù)據(jù)庫(kù)操作,用freeConnection()將連接返回給連接池。
3) 在destroy(),調(diào)用release()關(guān)閉所有連接,釋放所有資源。
示例程序清單如下:
import java.io.*;
import java.sql.*;
import javax.servlet.*;
import javax.servlet.http.*;
public class TestServlet extends HttpServlet {
private DBConnectionManager connMgr;
public void init(ServletConfig conf) throws ServletException {
super.init(conf);
connMgr = DBConnectionManager.getInstance();
}
public void service(HttpServletRequest req, HttpServletResponse res)
throws IOException {
res.setContentType(“text/html”);
PrintWriter out = res.getWriter();
Connection con = connMgr.getConnection(“idb”);
if (con == null) {
out.println(“不能獲取數(shù)據(jù)庫(kù)連接.”);
return;
}
ResultSet rs = null;
ResultSetMetaData md = null;
Statement stmt = null;
try {
stmt = con.createStatement();
rs = stmt.executeQuery(“SELECT * FROM EMPLOYEE”);
md = rs.getMetaData();
out.println(“職工數(shù)據(jù)”);
while (rs.next()) {
out.println(“”);
for (int i = 1; i
3、程序調(diào)用:
1、初始化命名空間上下文 ——> 2、(tomcat)查找J2EE的資源定位上下文(世廳java:comp/env)—檔告—> 3、查找在tomcat下的命名資源 ——> 4、DataSource ——> 5、Connection ——> 實(shí)例化Statement
過(guò)JNDI Datasource方式可以實(shí)現(xiàn)此功能,實(shí)現(xiàn)之后,只要鍵值不變則數(shù)據(jù)庫(kù)可以任意改變,而不用更改程序。
/*
連接數(shù)據(jù)庫(kù),關(guān)閉數(shù)據(jù)庫(kù)
*/
package org.lxh.orm.db;
import java.sql.Connection;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;
public class DataBaseConnection {
// Tomcat連接
private final String CTXNAME = “java:comp/env”;
private final String JNDINAME = “jdbc/mssql”;
private Connection conn = null;
// 在構(gòu)造方法之中連接數(shù)據(jù)庫(kù)
public DataBaseConnection() {
try {
Context ctx = new InitialContext() ;
ctx = (Context)ctx.lookup(CTXNAME) ;
DataSource ds = (DataSource)ctx.lookup(JNDINAME) ;
conn = ds.getConnection() ;
} catch (Exception e) {
System.out.println(e);
}
}
// 取得連接
public Connection getConnection() {
return this.conn;
}
// 關(guān)閉連接
public void closeConnection() {
try {
this.conn.close();
} catch (Exception e) {
}
}
}
mysql.url=jdbc:
//數(shù)據(jù)庫(kù)為mysql 服務(wù)器 //默認(rèn)談戚敗網(wǎng)頁(yè)編碼為GBK
useUnicode=true&characterEncoding =gbk
mysql.maxconn=1000 //更大連接數(shù)
mysql.user=root //數(shù)據(jù)庫(kù)帳號(hào)
mysql.password= //數(shù)據(jù)庫(kù)密碼
drivers=org.gjt.mm.mysql.Driver
//MySQL的驅(qū)含顫動(dòng)文仔野件
在Windows路徑中的反斜杠必須輸消慧入2個(gè),這是由于屬性文件中的反斜杠同時(shí)也是一個(gè)轉(zhuǎn)義字符。
init()方法在創(chuàng)建屬性對(duì)象并讀取db.properties文件之后,就開(kāi)始檢查logfile屬性。如果屬性文件中沒(méi)有指定日志文件,則默認(rèn)為當(dāng)前目錄下的DBConnectionManager.log文件。如日志文件無(wú)法使用,則向System.err輸出日志記錄。
裝載和注冊(cè)所有在者含drivers屬性中指定的JDBC驅(qū)動(dòng)程序由170至192行之間的loadDrivers()方法實(shí)現(xiàn)。該方法先用StringTokenizer將drivers屬性值分割為對(duì)應(yīng)于驅(qū)動(dòng)程序名稱的字符串,然后依次裝載這些類并創(chuàng)建其實(shí)例,最后在 DriverManager中注冊(cè)該實(shí)例并把它加入到一個(gè)私有的向量drivers。向量drivers將用于關(guān)閉服務(wù)時(shí)從DriverManager取消所有JDBC 驅(qū)動(dòng)程序的注冊(cè)。
java數(shù)據(jù)庫(kù)連接池原理的介紹就聊到這里吧,感謝你花時(shí)間閱讀本站內(nèi)容,更多關(guān)于java數(shù)據(jù)庫(kù)連接池原理,深入探析Java數(shù)據(jù)庫(kù)連接池的工作原理,[高分]java方面的問(wèn)題:請(qǐng)教高手db.properties連接池的用法的信息別忘了在本站進(jìn)行查找喔。
創(chuàng)新互聯(lián)成都網(wǎng)站建設(shè)公司提供專業(yè)的建站服務(wù),為您量身定制,歡迎來(lái)電(028-86922220)為您打造專屬于企業(yè)本身的網(wǎng)絡(luò)品牌形象。
成都創(chuàng)新互聯(lián)品牌官網(wǎng)提供專業(yè)的網(wǎng)站建設(shè)、設(shè)計(jì)、制作等服務(wù),是一家以網(wǎng)站建設(shè)為主要業(yè)務(wù)的公司,在網(wǎng)站建設(shè)、設(shè)計(jì)和制作領(lǐng)域具有豐富的經(jīng)驗(yàn)。
分享文章:深入探析Java數(shù)據(jù)庫(kù)連接池的工作原理(java數(shù)據(jù)庫(kù)連接池原理)
網(wǎng)頁(yè)鏈接:http://www.dlmjj.cn/article/cogpsig.html


咨詢
建站咨詢
