因為工作需要要使用到連接池，所以拜讀了互聯網上眾多前輩的文章，學了不少經驗，這里想做一個小結，加上自己的想法和在一起，希望能給大家一些幫助。
目的：
解決方案：
- 不過多的限制用戶的使用，既不能太多的要求用戶按規定的方法得到和使用數據庫連
目前的很多方法都是要求用戶只能按規定方法使用連接，不能使用直接關閉數據連接的方法。解決辦法就是使用代理類，來中間解決。可以參考http://www-900.ibm.com/developerWorks/cn/java/l-connpoolproxy/index.shtml
因為針對數據庫連接創建的資源，如果不能及時的釋放，就會影響下一次數據連接的使用。例如在sql 2k中，一個連接不同創建多條Statement否則操作時會有數據連接占線的異常，所以必須在歸還連接以后釋放這些資源。
//判斷是使用了createStatement語句
if (CREATESTATE.equals(method.getName()))
{
obj = method.invoke(conn, args);
statRef = (Statement)obj;//記錄語句
return obj;
}
|
//判斷是否調用了close的方法，如果調用close方法則把連接置為無用狀態
if(CLOSE.equals(method.getName()))
{
//設置不使用標志
setIsFree(false);
//檢查是否有后續工作，清除該連接無用資源
if (statRef != null)
statRef.close();
if (prestatRef != null)
prestatRef.close();
return null;
}
|
一個考慮就是不能讓用戶隨便使用代理類，而只能自己使用，一個就是用內部私有類，一個就是使用只有指定類才能調用的標志。我的實現就是采用后者。
/**
* 創建連接的工廠，只能讓工廠調用
* @param factory 要調用工廠，并且一定被正確初始化
* @param param 連接參數
* @return 連接
*/
static public _Connection getConnection(ConnectionFactory factory, ConnectionParam param)
{
if (factory.isCreate())//判斷是否正確初始化的工廠
{
_Connection _conn = new _Connection(param);
return _conn;
}
else
return null;
}
|
使用靜態方法創建工廠，然后來得到連接，使用完全和普通的Connection方法一樣，沒有限制。同時為了方便，設置了連接參數類和工廠參數類。
ConnectionParam param = new ConnectionParam(driver,url,user,password);
ConnectionFactory cf = null;//new ConnectionFactory(param, new FactoryParam());
try{
cf = new ConnectionFactory(param,new FactoryParam());
Connection conn1 = cf.getFreeConnection();
Connection conn2 = cf.getFreeConnection();
Connection conn3 = cf.getFreeConnection();
Statement stmt = conn1.createStatement();
ResultSet rs = stmt.executeQuery("select * from requests");
if (rs.next())
{
System.out.println("conn1 y");
}
else
{
System.out.println("conn1 n");
}
stmt.close();
conn1.close();
|
- 為了實現連接池的正常運作，使用了單態模
/**
* 使用指定的參數創建一個連接池
*/
public ConnectionFactory(ConnectionParam param, FactoryParam fparam)
throws SQLException
{
//不允許參數為空
if ((param == null)||(fparam == null))
throw new SQLException("ConnectionParam和FactoryParam不能為空");
if (m_instance == null)
{
synchronized(ConnectionFactory.class){
if (m_instance == null)
{
//new instance
//參數定制
m_instance = new ConnectionFactory();
m_instance.connparam = param;
m_instance.MaxConnectionCount = fparam.getMaxConn();
m_instance.MinConnectionCount = fparam.getMinConn();
m_instance.ManageType = fparam.getType();
m_instance.isflag = true;
//初始化，創建MinConnectionCount個連接
System.out.println("connection factory 創建！");
try{
for (int i=0; i < m_instance.MinConnectionCount; i++)
{
_Connection _conn = _Connection.getConnection(m_instance, m_instance.connparam);
if (_conn == null) continue;
System.out.println("connection創建");
m_instance.FreeConnectionPool.add(_conn);//加入空閑連接池
m_instance.current_conn_count ++;
//標志是否支持事務
m_instance.supportTransaction = _conn.isSupportTransaction();
}
}
catch(Exception e)
{
e.printStackTrace();
}
//根據策略判斷是否需要查詢
if (m_instance.ManageType != 0)
{
Thread t = new Thread(new FactoryMangeThread(m_instance));
t.start();
}
}
}
}
}
|
對于連接池的管理，我是設想使用靜態管理和動態管理兩種策略，設置了最大限制，和恒定的連接數。使用了2個池，一個空閑池，一個使用池。靜態就是使用的時候發現空閑連接不夠再去檢查。動態就是使用了一個線程定時檢查。
//根據策略判斷是否需要查詢
if (m_instance.ManageType != 0)
{
Thread t = new Thread(new FactoryMangeThread(m_instance));
t.start();
}
//連接池調度線程
public class FactoryMangeThread implements Runnable {
ConnectionFactory cf = null;
long delay = 1000;
public FactoryMangeThread(ConnectionFactory obj)
{
cf = obj;
}
/* (non-Javadoc)
* @see java.lang.Runnable#run()
*/
public void run() {
while(true){
try{
Thread.sleep(delay);
}
catch(InterruptedException e){}
System.out.println("eeeee");
//判斷是否已經關閉了工廠，那就退出監聽
if (cf.isCreate())
cf.schedule();
else
System.exit(1);
}
}
}
|
作者：http://www.zhujiangroad.com
來源：http://www.zhujiangroad.com
※以上資訊由網路資料整理而成，若有遺誤概以來源為準，本站不負任何相關責任。
※如果您認為網站上資訊侵犯了您的版權，請告訴我們
按這裡，我們將即時將您的版權資料移除。
