数据库连接池的使用
關(guān)于數(shù)據(jù)庫連接池的使用,首先我們要明白我們?yōu)槭裁匆盟?#xff0c;對應(yīng)普通的數(shù)據(jù)庫連接操作,通常會涉及到以下一些操作是比較耗時的:
網(wǎng)絡(luò)通訊,涉及到網(wǎng)絡(luò)延時及協(xié)議通訊身份驗(yàn)證,涉及安全性檢查
連接合法性檢查,主要是檢查所連接的數(shù)據(jù)庫是否存在
并發(fā)控制機(jī)制
構(gòu)造并初始化輸出緩沖區(qū)
連接成功后的信息保存,日志存儲
服務(wù)器性能
數(shù)據(jù)庫配置優(yōu)化
系統(tǒng)分配內(nèi)存資源
等等~~~狀況,導(dǎo)致數(shù)據(jù)庫連接操作比較耗時,~~~而且每次都得花費(fèi)0.05s~1s的時間
但是使用連接池技術(shù),本質(zhì)上就是在一個請求對應(yīng)的連接,都由一個線程池來維護(hù)著,也就是說“上下文切換”的代價是線程級別(所謂的納秒級),對于大規(guī)模的并發(fā)訪問,就算以每秒幾億級別的訪問量都是不成問題的。
一、在Java平臺
之前一段時間曾經(jīng)弄過數(shù)據(jù)庫連接池,使用的是c3p0這個工具包,
簡單記錄下c3p0的使用,當(dāng)作學(xué)習(xí)的一個鞏固;
第一步導(dǎo)入jar包;
第二步:
把jar包導(dǎo)入進(jìn)來:
import com.mchange.v2.c3p0.ComboPooledDataSource;
import com.mchange.v2.c3p0.DataSources;
第三步:定義變量
private ComboPooledDataSource cpds;?
然后在DbUtil里面使用:
private DbUtil() {?
cpds = new ComboPooledDataSource();
try {
cpds.setDriverClass( driver);
cpds.setJdbcUrl( url );
cpds.setUser(user);?
cpds.setPassword(passwd);?
cpds.setMinPoolSize(5);?
cpds.setAcquireIncrement(5);
cpds.setMaxPoolSize(30);
cpds.setMaxIdleTime(60);
} catch (PropertyVetoException e) {
e.printStackTrace();
}?
}
最后每個連接里面都可以用上了:
public Connection getConn() {?
try {
return cpds.getConnection();
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
完整的使用類:
package util;import java.beans.PropertyVetoException; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;import com.mchange.v2.c3p0.ComboPooledDataSource; import com.mchange.v2.c3p0.DataSources;public class DbUtil {private static String url = "jdbc:mysql://localhost:3306/zdbang_net";private static String user = "root";private static String passwd = "admin";private static String driver = "com.mysql.jdbc.Driver";private ComboPooledDataSource cpds; private static DbUtil db = new DbUtil();public static DbUtil getInstance() {return db;}private DbUtil() { cpds = new ComboPooledDataSource();try {cpds.setDriverClass( driver);cpds.setJdbcUrl( url );cpds.setUser(user); cpds.setPassword(passwd); cpds.setMinPoolSize(5); cpds.setAcquireIncrement(5);cpds.setMaxPoolSize(30);cpds.setMaxIdleTime(60);} catch (PropertyVetoException e) {e.printStackTrace();} }public Connection getConn() { try {return cpds.getConnection();} catch (SQLException e) {e.printStackTrace();}return null;}protected void finalize() throws Throwable {DataSources.destroy(cpds);super.finalize();}public static void closeConn(Connection conn) {try {if (conn != null)conn.close();} catch (SQLException e) {e.printStackTrace();}}public static Statement getStmt(Connection conn) {Statement stmt = null;try {stmt = conn.createStatement();return stmt;} catch (SQLException e) {e.printStackTrace();}return null;}public static void closeStmt(Statement stmt) {try {if (stmt != null)stmt.close();} catch (SQLException e) {e.printStackTrace();}}public static PreparedStatement getPs(Connection conn, String sql) {PreparedStatement ps = null;try {ps = conn.prepareStatement(sql);return ps;} catch (SQLException e) {e.printStackTrace();}return null;}public static void closePs(PreparedStatement ps) {try {if (ps != null)ps.close();} catch (SQLException e) {e.printStackTrace();}}public static ResultSet doQuery(Statement stmt, String sql) {try {ResultSet rs = stmt.executeQuery(sql);return rs;} catch (SQLException e) {e.printStackTrace();}return null;}public static void closeRs(ResultSet rs) {try {if (rs != null)rs.close();} catch (SQLException e) {e.printStackTrace();}} }具體的源碼還沒具體看,不過估計(jì)實(shí)現(xiàn)上也不會太難,爭取這段時間看一下源代碼。~~~~~
?二、在.Net
沒有使用數(shù)據(jù)庫連接池的情況是這樣的:每當(dāng)一個請求過來根據(jù)連接字符串新建一個連接,請求結(jié)束,數(shù)據(jù)庫連接關(guān)閉。
例如:
public static int ExecuteSql(string SQLString){using (SqlConnection connection = new SqlConnection(connectionString)){using (SqlCommand cmd = new SqlCommand(SQLString, connection)){try{connection.Open();cmd.CommandTimeout = 600;int rows = cmd.ExecuteNonQuery();return rows;}catch (System.Data.SqlClient.SqlException e){LogHelper.Log("sqlexception;sql:" + SQLString, e);log.Error("\r\n客戶機(jī)IP:" + HttpContext.Current.Request.UserHostAddress+ "\r\n錯誤地址:" + HttpContext.Current.Request.Url + "\r\n", e);connection.Close();throw e;}}}}請求的字符串就是:connectionString
然后每一個連接字符串都會當(dāng)作是一個新的連接請求。
這樣子對于一些小型的web項(xiàng)目還是可以的,畢竟并發(fā)量不會太大。但是對于大型網(wǎng)站,訪問量很大,切換連接的開銷就會非常的大,對系統(tǒng)而言是一個很大的瓶頸;而使用連接池比較只是在線程基本把連接給屏蔽掉(納秒級),所以使用連接池對整個網(wǎng)站而言是有很大的好處的;
總結(jié)
- 上一篇: javaweb之Filter详解
- 下一篇: ubuntu中启动oracle数据库