java數(shù)據(jù)庫連接池畢業(yè)論文(編輯修改稿)
2025-07-21 18:37 本頁面
【文章內(nèi)容簡介】 3. 連接池的分配與釋放 連接池的分配與釋放，對系統(tǒng)的性能有很大的影響。合理的分配與釋放，可以提高連接的復(fù)用度，從而降低建立新連接的開銷，同時(shí)還可以加快用戶的訪問速度?！ τ谶B接的管理可使用空閑池。即把已經(jīng)創(chuàng)建但尚未分配出去的連接按創(chuàng)建時(shí)間存放到一個(gè)空閑池中。每當(dāng)用戶請求一個(gè)連接時(shí)，系統(tǒng)首先檢查空閑池內(nèi)有沒有空閑連接。如果有就把建立時(shí)間最長(通過容器的順序存放實(shí)現(xiàn))的那個(gè)連接分配給他(實(shí)際是先做連接是否有效的判斷，如果可用就分配給用戶，如不可用就把這個(gè)連接從空閑池刪掉，重新檢測空閑池是否還有連接)。如果沒有則檢查當(dāng)前所開連接池是否達(dá)到連接池所允許的最大連接數(shù)(maxConn),如果沒有達(dá)到，就新建一個(gè)連接，如果已經(jīng)達(dá)到，就等待一定的時(shí)間(timeout)。如果在等待的時(shí)間內(nèi)有連接被釋放出來就可以把這個(gè)連接分配給等待的用戶，如果等待時(shí)間超過預(yù)定時(shí)間timeout,則返回空值(null)。系統(tǒng)對已經(jīng)分配出去正在使用的連接只做計(jì)數(shù)，當(dāng)使用完后再返還給空閑池。對于空閑連接的狀態(tài)，可開辟專門的線程定時(shí)檢測，這樣會(huì)花費(fèi)一定的系統(tǒng)開銷，但可以保證較快的響應(yīng)速度。也可采取不開辟專門線程，只是在分配前檢測的方法。4. 連接池的關(guān)閉 public synchronized boolean destory() throws SQLException并發(fā)控制關(guān)閉連接池資源.public synchronized boolean destory() throws SQLException { if (null == ) throw new SQLException(Connection UnInitializing)。 for (ConnectionInfo con : ) { ().close()。 (0)。 } if (null != ) ()。 = null。 = null。 return == null amp。amp。 == null。 }第六章 設(shè)計(jì)流程流程和實(shí)現(xiàn) package 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。/** * span css=39。package_style39。連接池總控制器/span * @author 孟德軍 * */public class DriverManager implements Serializable{ private static DriverManager manager = null。 private VectorConnectionInfo connectionPool = null。 private ISQLBase dataSource = null。 private ListIValidate validateLink = null。 private ConnectionInfo info=null。 //private Transaction transaction=null。 public DriverManager(ISQLBase base) throws SQLException { = base。 //(). =()。 } public DriverManager(IConnectionPoolLoader loader) throws SQLException { =(loader)。 } public DriverManager(String path) throws SQLException, LoadErrorException { =(path)。 } /** * 添加驗(yàn)證聯(lián) * @param v 驗(yàn)證程序 * @return 驗(yàn)證后的集合 * @throws NullPointerException */ public synchronized int addValidate(IValidate v) throws NullPointerException { if (null == ) = new ArrayListIValidate()。 (v)。 return ()。 } private VectorConnectionInfo InitFromDataSource() throws SQLException { VectorConnectionInfo tv = new VectorConnectionInfo(())。 if (null == ) throw new SQLException(DataSource Initializing Failture)。 for (int i = 0。 i ()。 i++) { try { Connection temp = ()。 if (null != temp amp。amp。 !()) { ConnectionInfo info=new ConnectionInfo()。 (())。 (temp)。 (()+1)。 (info)。 } } catch (SQLException e) { ()。 } } return tv。 } private VectorConnectionInfo InitFromConnectionPoolLoader(IConnectionPoolLoader loader) throws SQLException { VectorConnectionInfo tv =()。 return tv。 } private VectorConnectionInfo InitFromProperties(String path) throws SQLException, LoadErrorException { Information ti=new PerpertiesLoader().Init(path)。 if (null == ti)throw new SQLException(PerpertiesLoader Initializing Failture)。 VectorConnectionInfo tv = new VectorConnectionInfo(())。 IConnectionLoader tl=new DefaultConnection
環(huán)評公示相關(guān)推薦
鄂ICP備17016276號(hào)-1