1.为什么要使用连接池
(1)对于开发者而言,通过JDBC获取数据连接,然后执行SQL,是很简单的事情
(2)对于JDBC Driver而言:具体到每一个数据库厂商的驱动实现
- 首先建立应用服务器到数据库服务器之间的连接也就是Socket Connection
- 接下来应用服务器和数据库服务器之间还有很多次数据交换,比如用户密码校验、权限认证等
- 最后数据库应用服务器要初始化连接会话句柄,记录联机日志,并为这一次连接分配进程和系统资源
也就是说:建立一次连接可能花费500毫秒,而你执行一个SQL,很可能只花费50毫秒!!!可以看出来,系统如此忙碌,如果开发者只是执行一个简单的SQL,然后就把此次连接抛弃关闭了,浪费了很多系统资源
2.连接池应该具备什么样的特性
(1)能满足分布式数据源,比如一个应用可能连接多个数据库,或者一个数据库不能的权限
(2)具备事务处理能力,每一个事务独占一个连接来实现,降低事务管理的复杂性
(3)连接池的分配与释放,提高连接的复用度,从而降低建立新连接的开销
(4)连接池的配置与维护,设置最小连接数(minConn)和最大连接数(maxConn)来控制连接池中的连接
3.最基本连接池实现
package com.yli.dal; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; /** * 最基本连接池实现,本例使用静态单例,不使用多数据源<br> * 要使用多数据源,将单例改成普通模式即可 * @author yli * */ public class ConnectionPool { private static ConnectionPool pool = null; private String poolName; private String driver; private String url; private String user; private String password; private final static int defaultMin = 5; private final static int defaultMax = 10; private int minConn = defaultMin; private int maxConn = defaultMax; private List<Connection> usedConnections = new ArrayList<Connection>(); private List<Connection> freeConnections = new ArrayList<Connection>(); /** * 私有构造方法,初始化最小连接数 * @param poolName * @param driver * @param url * @param user * @param password * @param minConn * @param maxConn */ private ConnectionPool(String poolName, String driver, String url, String user, String password, int minConn, int maxConn) { this.poolName = poolName; this.driver = driver; this.url = url; this.user = user; this.password = password; this.minConn = minConn; this.maxConn = maxConn; initDriver(); initPool(); } /** * 单例模式,构造连接池,使用默认的最小最大连接数 * @param poolName * @param driver * @param url * @param user * @param password * @return */ public static ConnectionPool newInstanceDefault(String poolName, String driver, String url, String user, String password) { return newInstanceFull(poolName, driver, url, user, password, defaultMin, defaultMax); } /** * 单例模式,构造连接池,指定最小最大连接数 * @param poolName * @param driver * @param url * @param user * @param password * @param minConn * @param maxConn * @return */ public static ConnectionPool newInstanceFull(String poolName, String driver, String url, String user, String password, int minConn, int maxConn) { if (null == pool) { pool = new ConnectionPool(poolName, driver, url, user, password, minConn, maxConn); } return pool; } /** * 获取连接 * @return */ public synchronized Connection getConnection() { Connection conn = null; if (freeConnections.size() > 0) { System.out.println("======================>当前闲置连接数为:[" + freeConnections.size() + "]个"); System.out.println("======================>从闲置连接中获取一个连接"); conn = freeConnections.get(0); freeConnections.remove(0); System.out.println("======================>当前闲置连接减少一个,还剩余[" + freeConnections.size() + "]个"); System.out.println("======================>将获取的闲置连接加入到使用中列表"); usedConnections.add(conn); System.out.println("======================>当前使用中连接数为:[" + usedConnections.size() + "]个"); } else { if (usedConnections.size() >= maxConn) { System.out.println("======================>警告:线程池连接数已经达到最大[" + maxConn + "]个!"); System.out.println("======================>不允许再创建新连接"); } else { System.out.println("======================>当前使用中连接数为:[" + usedConnections.size() + "]个"); System.out.println("======================>已经没有闲置连接,重新创建一个连接"); conn = newConnection(); System.out.println("======================>将新创建的连接状态置为使用中"); usedConnections.add(conn); System.out.println("======================>当前使用中连接数为:[" + freeConnections.size() + "]个"); } } return conn; } /** * 获取连接,指定超时时间 * @param time * @return */ public synchronized Connection getConnection(long time) { Connection conn = null; if (freeConnections.size() > 0) { conn = freeConnections.get(0); freeConnections.remove(0); usedConnections.add(conn); this.notifyAll(); } else { if (usedConnections.size() >= maxConn) { System.out.println("======================>警告:线程池连接数已经达到最大[" + maxConn + "]个!"); System.out.println("======================>不允许再创建新连接"); try { this.wait(time); conn = getConnection(); } catch (InterruptedException e) { e.printStackTrace(); } } else { conn = newConnection(); usedConnections.add(conn); this.notifyAll(); } } return conn; } /** * 释放连接 * * @param conn */ public synchronized void releaseConnection(Connection conn) { System.out.println("======================>释放当前连接"); usedConnections.remove(conn); System.out.println("======================>使用中连接减少一个"); freeConnections.add(conn); System.out.println("======================>闲置连接增加一个"); } /** * 关闭连接:一旦关闭,使用中的连接数应该减少一个 * * @param conn */ public synchronized void closeConnection(Connection conn) { try { if (usedConnections.size() > 0) { usedConnections.remove(conn); } if (null != conn) { conn.close(); } } catch (SQLException e) { e.printStackTrace(); } } /** * 关闭连接池 */ public synchronized void closePool() { System.out.println("======================>开始初关闭连接池"); System.out.println("======================>当前使用中连接数总共有[" + usedConnections.size() + "]个"); clearListConnection(usedConnections); System.out.println("======================>当前闲置连接数总共有[" + freeConnections.size() + "]个"); clearListConnection(freeConnections); System.out.println("======================>关闭连接池成功"); } private void clearListConnection(List<Connection> list) { Connection itemConn; try { for (int i = 0; i < list.size(); i++) { itemConn = list.get(i); list.remove(i); if (null != itemConn) { itemConn.close(); } } } catch (SQLException e) { e.printStackTrace(); } } private void initDriver() { try { Class.forName(driver); } catch (ClassNotFoundException e) { e.printStackTrace(); } } private void initPool() { System.out.println("======================>开始初始化最少个数连接数"); for (int i = 0; i < minConn; i++) { Connection conn = newConnection(); freeConnections.add(conn); } System.out.println("======================>初始化成功,当前闲置连接数剩余[" + minConn + "]个"); } private Connection newConnection() { Connection conn = null; try { conn = DriverManager.getConnection(url, user, password); } catch (SQLException e) { e.printStackTrace(); } return conn; } public String getPoolName() { return poolName; } public String getDriver() { return driver; } public String getUrl() { return url; } public String getUser() { return user; } public String getPassword() { return password; } public int getMinConn() { return minConn; } public int getMaxConn() { return maxConn; } }
4.连接池简单测试
package com.yli.dal; import java.sql.Connection; /** * 连接池简单测试 * @author yli * */ public class PoolTest implements Runnable { private ConnectionPool pool; public PoolTest(ConnectionPool pool) { this.pool = pool; } @Override public void run() { Connection conn = pool.getConnection(); // 超时机制获取 // Connection conn = pool.getConnection(200); int threadName = Integer.valueOf(Thread.currentThread().getName()); // 测试释放链接 if (threadName >= 8) { pool.releaseConnection(conn); } } public static void main(String[] args) { String poolName = "MySQL-Connection-Pool"; String driver = "com.mysql.jdbc.Driver"; String url = "jdbc:mysql://localhost:3306/world"; String user = "root"; String password = "123456"; ConnectionPool pool = ConnectionPool.newInstanceDefault(poolName, driver, url, user, password); System.out.println(); for (int i = 0; i < 20; i++) { PoolTest poolTarget = new PoolTest(pool); new Thread(poolTarget, "" + i).start(); System.out.println(); } try { // 等待5秒再关闭连接池 Thread.sleep(5*1000); pool.closePool(); } catch (InterruptedException e) { e.printStackTrace(); } } }
相关推荐
java jdbc 连接池实例 项目只要配数据源就可以直接启用, 也可以整合到你个项目里面, 可oracle、mysql、sqlserver自由切换方言。
java jdbc 连接池,代码从网上找的
包括JDBC连接池的相关代码和xml配置文件。
完美的java jdbc连接池实例.zip
在Java语言中,JDBC(Java DataBase Connection)是应用程序与数据库沟通的桥梁
这是我写的一个对JDBC连接池的实现,高手见了可不要笑啊!!!! 程序是在linux下用Eclipse下编写的. 用Jude进行建模,数据库使用了mysql. 程序自带了MySql的Connection连接驱动类,你也可以使用别的驱动类和数据库, 在src/...
jdbc 连接池 c3p0 dbcp dbutils mysql jar包和指导文档
此类非常简单,免去了网上众多资料里所说的麻烦的tomcat配置,更强...不仅oracle,mysql,sqlserver2000都行,因为它依据的是你自己连接数据库的驱动。当然首先你要保证你拥有一个能连接自己数据库的对应驱动类。如下面以
Java-JDBC【源码】数据库连接池技术、常规操作与Durid对比、测试(20-200)不同连接数下,10万记录,1万并发,CPU磁盘占用情况 1.数据库连接池 2.Durid介绍(官方文档) 3.编码,问题,常规并发操作 3.1.JDBCUtil....
java_jdbc数据库连接池总结 有讲原理,不错
Java jdbc数据库连接池Java jdbc数据库连接池Java jdbc数据库连接池Java jdbc数据库连接池
JDBC - Java 连接Mysql JDBC连接池使用工具 C3P0 连接池 and druid-1.0.9
JDBC连接池的jar包
Java连接池 JDBC连接池(通用basedao)可直接用的模板
使用java技术实现jdbc连接池 包括了全面的jar和cp30,commons-DBCP,c3p0 for linux的包,以及jdbc jars
java使用jdbc连接池时所使用的dbcp工具包,也可在官网下载
Java应用程序访问数据库的基本原理 在Java语言中,JDBC(Java ...JDBC提供两种API,分别是面向开发人员的API和面向底层的JDBC驱动程序API,底层主要通过直接的JDBC驱动和JDBC-ODBC桥驱动实现与数据库的连接。
JDBC连接池java类,直接导入就可以使用的java类
JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种...通过pool连接池提高性能,并将数据库数据直接转成json对象,且封装了几种取值方式。比传统的ojdbc性能更快更高效
本源码为基于Java的小型JDBC连接池组件BeeCP设计,包含177个Java文件、12个PNG文件等,共225个文件。该项目旨在为用户提供一个全面、便捷的小型JDBC连接池解决方案,通过Java技术的结合,为用户带来高效的使用体验。