java 常见连接池性能测试

本文主要是介绍java 常见连接池性能测试，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！
使用druid官方的 Case1 测试，但是不好用，我需要改造一下源码：
/*
 * Copyright 1999-2018 Alibaba Group Holding Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.alibaba.druid.benckmark.pool;

import java.lang.management.ManagementFactory;
import java.lang.management.ThreadInfo;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.text.NumberFormat;
import java.util.Properties;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicLong;

import javax.sql.DataSource;

import com.zaxxer.hikari.HikariDataSource;
import junit.framework.TestCase;

import org.apache.commons.dbcp.BasicDataSource;

import com.alibaba.druid.TestUtil;
import com.alibaba.druid.mock.MockDriver;
import com.alibaba.druid.pool.DruidDataSource;
import com.jolbox.bonecp.BoneCPDataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
 * TestOnBo 类Case1.java的实现描述：TODO 类实现描述
 * 
 * @author admin 2011-5-28 下午03:47:40
 */
public class Case1 extends TestCase {

    private String            jdbcUrl;
    private String            user;
    private String            password;
    private String            driverClass;
    private int               initialSize      = 10;
    private int               minPoolSize      = 10;
    private int               maxPoolSize      = 100;
    private int               maxActive        = 50;// 貌似已经废弃
    private String            validationQuery  = "SELECT 1";
    private int               threadCount      = 100;
    private int               loopCount        = 100;
//    final int                 LOOP_COUNT       = 1000 * 1 * 1 / threadCount;
    final int                 LOOP_COUNT       = 100 * 1 * 1;

    private static AtomicLong physicalConnStat = new AtomicLong();

    public static class TestDriver extends MockDriver {

        public static TestDriver instance = new TestDriver();

        public boolean acceptsURL(String url) throws SQLException {
            if (url.startsWith("jdbc:test:")) {
                return true;
            }
            return super.acceptsURL(url);
        }

        public Connection connect(String url, Properties info) throws SQLException {
            physicalConnStat.incrementAndGet();
            return super.connect("jdbc:mock:case1", info);
        }
    }

    protected void setUp() throws Exception {
        DriverManager.registerDriver(TestDriver.instance);

        user = "dragoon25";
        password = "dragoon25";

        // jdbcUrl = "jdbc:h2:mem:";
        // driverClass = "org.h2.Driver";
        jdbcUrl = "jdbc:test:case1:";
        driverClass = "com.alibaba.druid.benckmark.pool.Case1$TestDriver";

        physicalConnStat.set(0);
    }

    public void test_druid() throws Exception {
        DruidDataSource dataSource = new DruidDataSource();

        dataSource.setInitialSize(initialSize);
        dataSource.setMaxActive(maxActive);
        dataSource.setMinIdle(minPoolSize);
        dataSource.setMaxIdle(maxPoolSize);
        dataSource.setPoolPreparedStatements(true);
        dataSource.setDriverClassName(driverClass);
        dataSource.setUrl(jdbcUrl);
        dataSource.setPoolPreparedStatements(true);
        dataSource.setUsername(user);
        dataSource.setPassword(password);
        dataSource.setValidationQuery(validationQuery);
        dataSource.setTestOnBorrow(false);

        long startMillis = System.currentTimeMillis();
        for (int i = 0; i < loopCount; ++i) {
            p0(dataSource, "druid", threadCount);
        }
        long millis = System.currentTimeMillis() - startMillis;
        System.out.println("elipse druid millis = " + millis);
        System.out.println();
    }

    public void test_dbcp() throws Exception {
        final BasicDataSource dataSource = new BasicDataSource();

        dataSource.setInitialSize(initialSize);
        dataSource.setMaxActive(maxActive);
        dataSource.setMinIdle(minPoolSize);
        dataSource.setMaxIdle(maxPoolSize);
        dataSource.setPoolPreparedStatements(true);
        dataSource.setDriverClassName(driverClass);
        dataSource.setUrl(jdbcUrl);
        dataSource.setPoolPreparedStatements(true);
        dataSource.setUsername(user);
        dataSource.setPassword(password);
        dataSource.setValidationQuery("SELECT 1");
        dataSource.setTestOnBorrow(false);

        long startMillis = System.currentTimeMillis();
        for (int i = 0; i < loopCount; ++i) {
            p0(dataSource, "dbcp", threadCount);
        }
        long millis = System.currentTimeMillis() - startMillis;
        System.out.println("elipse dbcp millis = " + millis);
        System.out.println();
    }

    public void test_bonecp() throws Exception {
        BoneCPDataSource dataSource = new BoneCPDataSource();
        // dataSource.(10);
        // dataSource.setMaxActive(50);
        dataSource.setMinConnectionsPerPartition(minPoolSize);
        dataSource.setMaxConnectionsPerPartition(maxPoolSize);

        dataSource.setDriverClass(driverClass);
        dataSource.setJdbcUrl(jdbcUrl);
        dataSource.setStatementsCacheSize(100);
        dataSource.setServiceOrder("LIFO");
        // dataSource.setMaxOpenPreparedStatements(100);
        dataSource.setUsername(user);
        dataSource.setPassword(password);
        // dataSource.setConnectionTestStatement("SELECT 1");
        dataSource.setPartitionCount(1);
        dataSource.setAcquireIncrement(5);
        dataSource.setIdleConnectionTestPeriod(0L);
        // dataSource.setDisableConnectionTracking(true);

        long startMillis = System.currentTimeMillis();
        for (int i = 0; i < loopCount; ++i) {
            p0(dataSource, "boneCP", threadCount);
        }
        long millis = System.currentTimeMillis() - startMillis;
        System.out.println("elipse boneCP millis = " + millis);
        System.out.println();
    }

    public void test_c3p0() throws Exception {
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        // dataSource.(10);
        // dataSource.setMaxActive(50);
        dataSource.setMinPoolSize(minPoolSize);
        dataSource.setMaxPoolSize(maxPoolSize);

        dataSource.setDriverClass(driverClass);
        dataSource.setJdbcUrl(jdbcUrl);
        // dataSource.setPoolPreparedStatements(true);
        // dataSource.setMaxOpenPreparedStatements(100);
        dataSource.setUser(user);
        dataSource.setPassword(password);

        long startMillis = System.currentTimeMillis();
        for (int i = 0; i < loopCount; ++i) {
            p0(dataSource, "c3p0", threadCount);
        }
        long millis = System.currentTimeMillis() - startMillis;
        System.out.println("elipse c3p0 millis = " + millis);
        System.out.println();
    }

    public void test_tomcat_jdbc() throws Exception {
        org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource();
        // dataSource.(10);
        dataSource.setMaxIdle(maxPoolSize);
        dataSource.setMinIdle(minPoolSize);
        dataSource.setMaxActive(maxPoolSize);

        dataSource.setDriverClassName(driverClass);
        dataSource.setUrl(jdbcUrl);
        // dataSource.setPoolPreparedStatements(true);
        // dataSource.setMaxOpenPreparedStatements(100);
        dataSource.setUsername(user);
        dataSource.setPassword(password);

        long startMillis = System.currentTimeMillis();
        for (int i = 0; i < loopCount; ++i) {
            p0(dataSource, "tomcat-jdbc", threadCount);
        }
        long millis = System.currentTimeMillis() - startMillis;
        System.out.println("elipse tomcat millis = " + millis);
        System.out.println();
    }

    public void test_hikari() throws Exception {
        HikariDataSource dataSource = new HikariDataSource();
        // dataSource.(10);
        dataSource.setMaximumPoolSize(maxPoolSize);
        dataSource.setMinimumIdle(minPoolSize);
        dataSource.setMaximumPoolSize(maxPoolSize);

        dataSource.setDriverClassName(driverClass);
        dataSource.setJdbcUrl(jdbcUrl);
        // dataSource.setPoolPreparedStatements(true);
        // dataSource.setMaxOpenPreparedStatements(100);
        dataSource.setUsername(user);
        dataSource.setPassword(password);

        long startMillis = System.currentTimeMillis();
        for (int i = 0; i < loopCount; ++i) {
            p0(dataSource, "hikari", threadCount);
        }
        long millis = System.currentTimeMillis() - startMillis;
        System.out.println("elipse hikari millis = " + millis);
        System.out.println();
    }

    private void p0(final DataSource dataSource, String name, int threadCount) throws Exception {

        final CountDownLatch startLatch = new CountDownLatch(1);
        final CountDownLatch endLatch = new CountDownLatch(threadCount);
        final CountDownLatch dumpLatch = new CountDownLatch(1);

        Thread[] threads = new Thread[threadCount];
        for (int i = 0; i < threadCount; ++i) {
            Thread thread = new Thread() {

                public void run() {
                    try {
                        startLatch.await();

                        for (int i = 0; i < LOOP_COUNT; ++i) {
                            Connection conn = dataSource.getConnection();
                            conn.close();
                        }
                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }
                    endLatch.countDown();

//                    try {
//                        dumpLatch.await();
//                    } catch (InterruptedException e) {
//                        e.printStackTrace();
//                    }
                }
            };
            threads[i] = thread;
            thread.start();
        }
//        long startMillis = System.currentTimeMillis();
//        long startYGC = TestUtil.getYoungGC();
//        long startFullGC = TestUtil.getFullGC();
        startLatch.countDown();
        endLatch.await();

//        long[] threadIdArray = new long[threads.length];
//        for (int i = 0; i < threads.length; ++i) {
//            threadIdArray[i] = threads[i].getId();
//        }
//        ThreadInfo[] threadInfoArray = ManagementFactory.getThreadMXBean().getThreadInfo(threadIdArray);
//
//        dumpLatch.countDown();
//
//        long blockedCount = 0;
//        long waitedCount = 0;
//        for (int i = 0; i < threadInfoArray.length; ++i) {
//            ThreadInfo threadInfo = threadInfoArray[i];
//            blockedCount += threadInfo.getBlockedCount();
//            waitedCount += threadInfo.getWaitedCount();
//        }

//        long millis = System.currentTimeMillis() - startMillis;
//        long ygc = TestUtil.getYoungGC() - startYGC;
//        long fullGC = TestUtil.getFullGC() - startFullGC;

//        System.out.println("thread " + threadCount + " " + name + " millis : "
//                           + NumberFormat.getInstance().format(millis)
////                            + "; YGC " + ygc + " FGC " + fullGC
//                           + " blocked "
////                           + NumberFormat.getInstance().format(blockedCount) //
////                           + " waited " + NumberFormat.getInstance().format(waitedCount) + " physicalConn "
//                           + physicalConnStat.get());

        /**
         *
         * 线程数： 10； 10 * 1000  * 10000  = 1亿
         tomcat 66533

         c3p0 292533

         dbcp 164118

         boneCP 37919

         druid 52299


         * 线程数： 20;
         tomcat 138724

         c3p0 652946

         dbcp 322209

         boneCP 79210

         druid 107242




         * 线程数： 1； 1 * 1000  * 10000  = 1000 w
         tomcat 4592

         c3p0 29852

         dbcp 5648

         boneCP 2612

         druid 3793






         * 线程数： 50  5亿
         tomcat 392707


        10 * 1000 * 1000
         tomcat 6668

         c3p0 30236

         dbcp 15214

         boneCP 3626

         druid 5168


         10 * 100 * 1000
         tomcat 700

         c3p0 2897

         dbcp 1607

         boneCP 403

         druid 536




         10 * 1000 * 100
         tomcat 1021

         c3p0 3190

         dbcp 1891

         boneCP 742

         druid 878




         50 * 1000 * 100
         tomcat 5659

         c3p0 23309

         dbcp 8999

         boneCP 3688

         druid 4255


         100 * 1000 * 100
         tomcat 20876

         c3p0 61648

         dbcp 35920

         boneCP 8028

         druid 9519


         100 * 100 * 100
         tomcat 1949

         c3p0 6404

         dbcp 3488

         boneCP 798

         druid 956



         100 * 10 * 100
         tomcat 228

         c3p0 655

         dbcp 424

         boneCP 113

         druid 121

         100 * 1000 * 100             maxPoolSize 100
         tomcat 13702

         c3p0 62240

         dbcp 36138

         boneCP 8004

         druid 9724



         100 * 100 * 100   maxPoolSize 100
         tomcat 1350

         c3p0 6051

         dbcp 3538

         boneCP 817

         druid 997



         */
    }
}
View Code
执行结果：
可见
就性能而言，其实是 boneCP 最好的， druid 其次，相差无几。但是c3p0 真的就太差了，几乎是 druid 的6倍！
虽然 boneCP 最好，但是它已经没人维护了，而且druid 的监控功能真太强大了！一般都会选择 druid 吧！
这篇关于java 常见连接池性能测试的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
Java教程

java 常见连接池性能测试

前端开发

后端开发

移动端开发

数据库

服务器运维

人工智能

区块链

游戏开发

网站运营

大数据/云计算

软件工程

软件/开发工具使用

资讯
