当前位置：首页 >应用开发 >为什么说Druid是目前最好的数据库连接池？

为什么说Druid是目前最好的数据库连接池？

发表于 2025-11-04 00:05:05 来源：全栈开发

一、目前介绍

数据库连接是最好一项非常关键的、有限的据库、昂贵的连接资源，这一点在多用户的目前网页应用程序中体现得尤为突出。

记得之前做的最好一个项目，当时的据库应用程序配置的数据库连接池，最大允许的连接连接数是500，结果上线没多久，目前并发量直接上来了，最好导致大量的据库数据插入失败，当晚的连接心情可想而知～

从那一次事故之后，让我对应用程序的目前数据库连接数有了一次深刻的认识，为了防止再次栽跟头，最好之后特意抽了一个时间来编写程序测试案例，据库用于测试各个数据源连接池的稳定性!

话不多说，直接撸起来!

二、程序实例

熟悉 web 系统开发的同学，亿华云基本都知道，在 Java 生态中开源的常用数据库连接池有以下几种：

dbcp：DBCP是一个依赖Jakarta commons-pool对象池机制的数据库连接池，DBCP可以直接的在应用程序中使用，Tomcat的数据源使用的就是DBCP。c3p0：c3p0是一个开放源代码的JDBC连接池，它在lib目录中与Hibernate一起发布，包括了实现jdbc3和jdbc2扩展规范说明的Connection和Statement池的DataSources对象。druid：阿里出品，淘宝和支付宝专用数据库连接池，但它不仅仅是一个数据库连接池，它还包含一个ProxyDriver，一系列内置的JDBC组件库，一个SQL Parser。支持所有JDBC兼容的数据库，包括Oracle、MySql、Derby、Postgresql、SQL Server、WordPress模板H2等等。

今天我们就一起来对比一下，这三种数据源连接池的稳定性。

2.1、创建测试表

下面以 mysql 数据库为例，创建一个t_test表，方面后续进行插入数据操作。

复制CREATE TABLE t_test ( id bigint(20) unsigned NOT NULL COMMENT 主键ID, name varchar(32) NOT NULL COMMENT 名称, PRIMARY KEY (id)) ENGINE=InnoDB COMMENT=测试表;1.2.3.4.5. 2.2、编写测试用例

以dbcp为例，首先创建一个dbcp-jdbc.properties配置文件。

复制username=

root

password=

Hello@123456

driverClassName=com.mysql.jdbc.Driverurl=jdbc:mysql://192.168.31.200:3306/testdb?useUnicode=true&characterEncoding=UTF-8initialSize=5maxActive=1000maxIdle=5removeAbandoned=

ture

removeAbandonedTimeout=20logAbandoned=truemaxWait=1001.2.3.4.5.6.7.8.9.10.11.

接着，创建一个连接池工具DbcpJdbcUtil。

复制public class DbcpJdbcUtil { private static final Logger logger = LoggerFactory.getLogger(DbcpJdbcUtil.class); /**jdbc配置文件*/ private static Properties prop = new Properties(); private static BasicDataSource dataSource = null; //

它是事务专用连接！

private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>(); static { classPathSourceRead(); } private static void classPathSourceRead(){ //读取指定位置的配置文档(读取class目录文件) try { logger.info("jdbc路径:" + SysConstants.getValue()); prop.load(DbcpJdbcUtil.class.getClassLoader().getResourceAsStream(SysConstants.getValue())); logger.info("数据配置信息" + JSON.toJSONString(prop)); logger.info("初始化默认jdbc配置文件成功!"); } catch (Exception e) { logger.error("初始化默认jdbc文件失败!",e); } } /** * 从连接池获取数据源 * @return * @throws Exception */ public static BasicDataSource getDataSource() throws Exception { try { if (dataSource == null) { synchronized (DbcpJdbcUtil.class) { if (dataSource == null) { dataSource = new BasicDataSource(); dataSource.setUsername(prop.getProperty("username")); dataSource.setPassword(prop.getProperty("password")); dataSource.setDriverClassName(prop.getProperty("driverClassName")); dataSource.setUrl(prop.getProperty("url")); dataSource.setInitialSize(Integer.valueOf(prop.getProperty("initialSize"))); dataSource.setMaxActive(Integer.valueOf(prop.getProperty("maxActive"))); dataSource.setMaxIdle(Integer.valueOf(prop.getProperty("maxIdle"))); dataSource.setRemoveAbandoned(Boolean.valueOf(prop.getProperty("removeAbandoned"))); dataSource.setRemoveAbandonedTimeout(Integer.valueOf(prop.getProperty("removeAbandonedTimeout"))); dataSource.setLogAbandoned(Boolean.valueOf(prop.getProperty("logAbandoned"))); dataSource.setMaxWait(Integer.valueOf(prop.getProperty("maxWait"))); } } } return dataSource; } catch (Exception e) { logger.error("根据数据库名称获取数据库资源失败，" , e); throw new Exception("根据数据库名称获取数据库资源失败"); } } /** * 使用连接池返回一个连接对象 * * @return * @throws SQLException */ public static Connection getConnection() throws Exception { try { Connection con = tl.get(); // 当con不等于null，说明已经调用过beginTransaction()

，表示开启了事务！

if (con != null) return con; return getDataSource().getConnection(); } catch (Exception e) { logger.error("获取数据库连接失败！", e); throw new SQLException("获取数据库连接失败！"); } } /** * 开启事务 1. 获取一个Connection，设置它的setAutoComnmit(false) * 2. 还要保证dao中使用的连接是我们刚刚创建的！ -------------- * 3. 创建一个Connection，设置为手动提交 * 4. 把这个Connection给dao用！ * 5. 还要让commitTransaction或rollbackTransaction可以获取到！ * * @throws SQLException */ public static void beginTransaction() throws Exception { try { Connection con = tl.get(); if (con != null) { con.close(); tl.remove(); //throw new SQLException("已经开启了事务，就不要重复开启了！服务器租用"); } con = getConnection(); con.setAutoCommit(false); tl.set(con); } catch (Exception e) { logger.error("数据库事物开启失败！", e); throw new SQLException("数据库事物开启失败！"); } } /** * 提交事务 1. 获取beginTransaction提供的Connection，然后调用commit方法 * * @throws SQLException */ public static void commitTransaction() throws SQLException { Connection con = tl.get(); try { if (con == null) throw new SQLException("还没有开启事务，不能提交！"); con.commit(); } catch (Exception e) { logger.error("数据库事物提交失败！", e); throw new SQLException("数据库事物提交失败！"); } finally { if (con != null) { con.close(); } tl.remove(); } } /** * 回滚事务 1. 获取beginTransaction提供的Connection，然后调用rollback方法 * * @throws SQLException */ public static void rollbackTransaction() throws SQLException { Connection con = tl.get(); try { if (con == null) throw new SQLException("还没有开启事务，不能回滚！"); con.rollback(); } catch (Exception e) { logger.error("数据库事物回滚失败！", e); throw new SQLException("数据库事物回滚失败！"); } finally { if (con != null) { con.close(); } tl.remove(); } } /** * 释放连接 * @param connection * @throws SQLException */ public static void releaseConnection(Connection connection) throws SQLException { try { Connection con = tl.get(); //

判断它是不是事务专用，如果是，就不关闭！如果不是事务专用，那么就要关闭！

// 如果con == null

，说明现在没有事务，那么connection一定不是事务专用的！

//如果con != null

，说明有事务，那么需要判断参数连接是否与con相等，若不等，说明参数连接不是事务专用连接

if (con == null || con != connection) connection.close(); } catch (Exception e) { logger.error("数据库连接释放失败！", e); throw new SQLException("数据库连接释放失败！"); } }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45.46.47.48.49.50.51.52.53.54.55.56.57.58.59.60.61.62.63.64.65.66.67.68.69.70.71.72.73.74.75.76.77.78.79.80.81.82.83.84.85.86.87.88.89.90.91.92.93.94.95.96.97.98.99.100.101.102.103.104.105.106.107.108.109.110.111.112.113.114.115.116.117.118.119.120.121.122.123.124.125.126.127.128.129.130.131.132.133.134.135.136.137.138.139.140.141.142.143.144.145.146.147.148.149.150.151.152.153.154.155.156.157.158.159.160.161.162.163.164.165.166.167.168.

最后，编写单元测试程序DBCPTest。

复制public class DBCPTest { private static final int sumCount = 1000000; private static final int threadNum = 600; private void before(String path) { SysConstants.putValue(path); new DBCPService().insert("delete from t_test"); }

@Test

public void testMysql() { long start = System.currentTimeMillis(); String path = "config/mysql/dbcp-jdbc.properties"; before(path); for (int i =0; i < 1; i++) { String sql = "insert into t_test(id,name) values(" +i+ ",dbcp-mysql-" + i + ")"; new DBCPService().insert(sql); } System.out.println("耗时：" + (System.currentTimeMillis() - start)); }

@Test

public void testThreadMysql() throws InterruptedException { String path = "config/mysql/dbcp-jdbc.properties"; before(path); BlockingQueue<String> queue = new LinkedBlockingQueue<String>(); for (int i = 0; i < sumCount; i++) { String sql = "insert into t_test(id,name) values(" +i+ ",dbcp-mysql-" + i + ")"; queue.put(sql); } long start = System.currentTimeMillis(); final CountDownLatch countDownLatch = new CountDownLatch(threadNum); for (int i = 0; i < threadNum; i++) { final int finalI = i + 1; new Thread(new Runnable() {

@Override

public void run() { System.out.println("thread " + finalI + " start"); boolean isGo = true; while (isGo) { String sql = queue.poll(); if(sql != null) { new DBCPService().insert(sql); }else { isGo =false; System.out.println("thread " + finalI + " finish"); countDownLatch.countDown(); } } } }).start(); } countDownLatch.await(); System.out.println("耗时：" + (System.currentTimeMillis() - start)); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45.46.47.48.49.50.51.52.53.54.55.56.57.58.59.

c3p0、druid的配置也类似，这里就不在重复介绍了!