学步园

3.2 数据库连接池 例2：

package shop;</p> <p>import java.sql.Connection;<br /> import java.sql.Driver;<br /> import java.sql.DriverManager;<br /> import java.sql.SQLException;</p> <p>/*<br /> java数据库连接池实现</p> <p>作用:<br /> 在数据库存取中,数据库连接池是不可缺少的,它可以提高连接利用率<br /> 减少连接等待,对于提高数据存储性能会有不小的作用.<br /> 原理:<br /> 连接池相当于连接的集合,在连接池初始化时先实例化一定数量的空闲连接<br /> 等待用户使用,用户使用完连接再将其返回连接池,这样就免去了最耗时的<br /> 创建连接的开销在没有空闲连接的情况下,连接池将自动生成连接再分配给<br /> 用户请求.<br /> 实例:<br /> */<br /> /*<br /> * 我的数据库连接池<br /> *<br /> * **********模块说明**************<br /> *<br /> * getInstance()返回POOL唯一实例,第一次调用时将执行构造函数<br /> * 构造函数Pool()调用驱动装载loadDrivers()函数;连接池创建createPool()函数 loadDrivers()装载驱动<br /> * createPool()建连接池 getConnection()返回一个连接实例 getConnection(long time)添加时间限制<br /> * freeConnection(Connection con)将con连接实例返回到连接池 getnum()返回空闲连接数<br /> * getnumActive()返回当前使用的连接数<br /> *<br /> */<br /> public class Pool {<br /> private static Pool instance = null; // 定义唯一实例</p> <p> private int maxConnect = 100;// 最大连接数</p> <p> private int normalConnect = 10;// 保持连接数</p> <p> private String password = "";// 密码</p> <p> private String url = "jdbc:mysql://localhost/shop";// 连接URL</p> <p> private String user = "root";// 用户名</p> <p> private String driverName = "com.mysql.jdbc.Driver";// 驱动类</p> <p> Driver driver = null;// 驱动变量</p> <p> DBConnectionPool pool = null;// 连接池实例变量</p> <p> // 将构造函数私有,不允许外界访问<br /> private Pool() {<br /> loadDrivers(driverName);<br /> createPool();<br /> }</p> <p> // 装载和注册所有JDBC驱动程序<br /> private void loadDrivers(String dri) {<br /> String driverClassName = dri;<br /> try {<br /> driver = (Driver) Class.forName(driverClassName).newInstance();<br /> DriverManager.registerDriver(driver);<br /> System.out.println("成功注册JDBC驱动程序" + driverClassName);<br /> } catch (Exception e) {<br /> System.out.println("无法注册JDBC驱动程序:" + driverClassName + ",错误:" + e);<br /> }<br /> }</p> <p> // 创建连接池<br /> private void createPool() {<br /> pool = new DBConnectionPool(password, url, user, normalConnect,<br /> maxConnect);<br /> if (pool != null) {<br /> System.out.println("创建连接池成功");<br /> } else {<br /> System.out.println("创建连接池失败");<br /> }<br /> }</p> <p> // 返回唯一实例<br /> public static synchronized Pool getInstance() {<br /> if (instance == null) {<br /> instance = new Pool();<br /> }<br /> return instance;<br /> }</p> <p> // 获得一个可用的连接,如果没有则创建一个连接,且小于最大连接限制<br /> public Connection getConnection() {<br /> if (pool != null) {<br /> return pool.getConnection();<br /> }<br /> return null;<br /> }</p> <p> // 获得一个连接,有时间限制<br /> public Connection getConnection(long time) {<br /> if (pool != null) {<br /> return pool.getConnection(time);<br /> }<br /> return null;<br /> }</p> <p> // 将连接对象返回给连接池<br /> public void freeConnection(Connection con) {<br /> if (pool != null) {<br /> pool.freeConnection(con);<br /> }<br /> }</p> <p> // 返回当前空闲连接数<br /> public int getnum() {<br /> return pool.getnum();<br /> }</p> <p> // 返回当前连接数<br /> public int getnumActive() {<br /> return pool.getnumActive();<br /> }</p> <p> // 关闭所有连接,撤销驱动注册<br /> public synchronized void release() {<br /> // /关闭连接<br /> pool.release();<br /> // /撤销驱动<br /> try {<br /> DriverManager.deregisterDriver(driver);<br /> System.out.println("撤销JDBC驱动程序 " + driver.getClass().getName());<br /> } catch (SQLException e) {<br /> System.out<br /> .println("无法撤销JDBC驱动程序的注册:" + driver.getClass().getName());<br /> }<br /> }<br /> }<br />

 package shop;</p> <p>//数据池文件<br /> import java.sql.*;<br /> import java.util.*;<br /> import java.util.Date;</p> <p>public class DBConnectionPool {<br /> private int checkedOut;</p> <p> private Vector<Connection> freeConnections = new Vector<Connection>();</p> <p> private int maxConn;</p> <p> // private int normalConn;</p> <p> private String password;</p> <p> private String url;</p> <p> private String user;</p> <p> private static int num = 0;// 空闲的连接数</p> <p> private static int numActive = 0;// 当前的连接数</p> <p> public DBConnectionPool(String password, String url, String user,<br /> int normalConn, int maxConn) {<br /> this.password = password;<br /> this.url = url;<br /> this.user = user;<br /> this.maxConn = maxConn;<br /> // this.normalConn = normalConn;<br /> for (int i = 0; i < normalConn; i++) { // 初始normalConn个连接<br /> Connection c = newConnection();<br /> if (c != null) {<br /> freeConnections.addElement(c);<br /> num++;<br /> }<br /> }<br /> }</p> <p> // 释放不用的连接到连接池<br /> public synchronized void freeConnection(Connection con) {<br /> freeConnections.addElement(con);<br /> num++;<br /> checkedOut--;<br /> numActive--;<br /> notifyAll();<br /> }</p> <p> // 创建一个新连接<br /> private Connection newConnection() {<br /> Connection con = null;<br /> try {<br /> if (user == null) { // 用户,密码都为空<br /> con = DriverManager.getConnection(url);<br /> } else {<br /> con = DriverManager.getConnection(url, user, password);<br /> }<br /> System.out.println("连接池创建一个新的连接");<br /> } catch (SQLException e) {<br /> System.out.println("无法创建这个URL的连接" + url);<br /> return null;<br /> }<br /> return con;<br /> }</p> <p> // 返回当前空闲连接数<br /> public int getnum() {<br /> return num;<br /> }</p> <p> // 返回当前连接数<br /> public int getnumActive() {<br /> return numActive;<br /> }</p> <p> // 获取一个可用连接<br /> public synchronized Connection getConnection() {<br /> Connection con = null;<br /> if (freeConnections.size() > 0) { // 还有空闲的连接<br /> num--;<br /> con = (Connection) freeConnections.firstElement();<br /> freeConnections.removeElementAt(0);<br /> try {<br /> if (con.isClosed()) {<br /> System.out.println("从连接池删除一个无效连接");<br /> con = getConnection();<br /> }<br /> } catch (SQLException e) {<br /> System.out.println("从连接池删除一个无效连接");<br /> con = getConnection();<br /> }<br /> } else if (maxConn == 0 || checkedOut < maxConn) { // 没有空闲连接且当前连接小于最大允许值,最大值为0则不限制<br /> con = newConnection();<br /> }<br /> if (con != null) { // 当前连接数加1<br /> checkedOut++;<br /> }<br /> numActive++;<br /> return con;<br /> }</p> <p> // 获取一个连接,并加上等待时间限制,时间为毫秒<br /> public synchronized Connection getConnection(long timeout) {<br /> long startTime = new Date().getTime();<br /> Connection con;<br /> while ((con = getConnection()) == null) {<br /> try {<br /> wait(timeout);<br /> } catch (InterruptedException e) {<br /> }<br /> if ((new Date().getTime() - startTime) >= timeout) {<br /> return null; // 超时返回<br /> }<br /> }<br /> return con;<br /> }</p> <p> // 关闭所有连接<br /> public synchronized void release() {<br /> Enumeration allConnections = freeConnections.elements();<br /> while (allConnections.hasMoreElements()) {<br /> Connection con = (Connection) allConnections.nextElement();<br /> try {<br /> con.close();<br /> num--;<br /> } catch (SQLException e) {<br /> System.out.println("无法关闭连接池中的连接");<br /> }<br /> }<br /> freeConnections.removeAllElements();<br /> numActive = 0;<br /> }<br /> }<br />