数据库连接池 dbcp与c3p0的使用

众所周知，无论现在是B/S或者是C/S应用中，都免不了要和数据库打交道。在与数据库交

互过程中，往往需要大量的连接。对于一个大型应用来说，往往需要应对数以千万级的用户连

接请求，如果高效相应用户请求，对应用开发者而言是一个很重要的问题。下面就我所接触到

的解决方法分享给大家。

学过计算机网络的都知道，在一个内部局域网中，大部分用的都是私有地址，要想和外部

打交道，必须要有相应的合法外部地址相对应。然而内部用户数量巨大，一台机子一个外部IP

是不现实的。这样就有了一种叫做连接池的概念。因为不是每一个用户都要同时上网，当一个

用户需要上网的时候，他就可以从连接池中取得一个外部IP地址，从而对外网进行访问。当这

个用户不再需要上网的时候，这一个IP地址被放回连接池中，又可以给其他的用户访问。这里

的连接池是主要是为了解决IP地址数量问题的。而在数据库中，也有连接池的概念。我觉得这

个连接池主要是通过对连接的复用，从而更加高效的实现了对用户请求的响应。常见的供java

开发的连接池主要有DBCP和c3p0，当然在了解了连接池的原理后，用户也可以开发并创建自

己连接池。

数据库连接池的原理：可以参考这篇文章，不再赘述。。
http://www.kuqin.com/database/20080903/16384.html
下面主要通过两个例子描述下DBCP和c3p0的使用，同时给以比较。

1 DBCP。

DBCP是 apache 上的一个 java 连接池项目，也是 tomcat 使用的连接池组件。单独使

用DBCP需要3个包：common-dbcp.jar,common-pool.jar,common-collections.jar.

Java代码



public class DBCPUtils {

private static DBCPUtils dbcputils=null;

private BasicDataSource bds=null;

private DataSourceConnectionFactory dscf=null;

private DBCPUtils(){

if(bds==null)

bds=new BasicDataSource();

bds.setUrl(DBConsts.url);

bds.setUsername(DBConsts.username);

bds.setPassword(DBConsts.password);

bds.setDriverClassName(DBConsts.driverclass);

bds.setMaxActive(100);

bds.setInitialSize(20);

bds.setMaxIdle(20);

bds.setMinIdle(10);

dscf=new DataSourceConnectionFactory(bds);

}

public synchronized static DBCPUtils getInstance(){

if(dbcputils==null)

dbcputils=new DBCPUtils();

return dbcputils;

}

public Connection getConnection(){

Connection con=null;

try {

con=(Connection)dscf.createConnection();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return con;

}

public static void main(String[] args) throws SQLException {

Connection con=null;

long begin=System.currentTimeMillis();

for(int i=0;i<1000000;i++){

con=DBCPUtils.getInstance().getConnection();

con.close();

}

long end=System.currentTimeMillis();

System.out.println("耗时为:"+(end-begin)+"ms");

}

}

结果为 :耗时为:2078ms

2 C3P0。

C3P0是一个开放源代码的JDBC连接池，它在lib目录中与Hibernate一起发布,包括了实现

jdbc3和jdbc2扩展规范说明的Connection 和Statement 池的DataSources 对象。在使用时

需要导入c3p0-*.jar包。

Java代码



public class C3P0Utils {

private static C3P0Utils dbcputils=null;

private ComboPooledDataSource cpds=null;

private C3P0Utils(){

if(cpds==null){

cpds=new ComboPooledDataSource();

}

cpds.setUser(DBConsts.username);

cpds.setPassword(DBConsts.password);

cpds.setJdbcUrl(DBConsts.url);

try {

cpds.setDriverClass(DBConsts.driverclass);

} catch (PropertyVetoException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

cpds.setInitialPoolSize(100);

cpds.setMaxIdleTime(20);

cpds.setMaxPoolSize(100);

cpds.setMinPoolSize(10);

}

public synchronized static C3P0Utils getInstance(){

if(dbcputils==null)

dbcputils=new C3P0Utils();

return dbcputils;

}

public Connection getConnection(){

Connection con=null;

try {

con=cpds.getConnection();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return con;

}

public static void main(String[] args) throws SQLException {

Connection con=null;

long begin=System.currentTimeMillis();

for(int i=0;i<1000000;i++){

con=C3P0Utils.getInstance().getConnection();

con.close();

}

long end=System.currentTimeMillis();

System.out.println("耗时为:"+(end-begin)+"ms");

}

}

结果为 ：耗时为:26094ms

此类为连接数据的常量值。

Java代码



public class DBConsts {

public static final String url="jdbc:mysql://localhost:3306/deys";

public static final String username="root";

public static final String password="";

public static final String driverclass="com.mysql.jdbc.Driver";

}

通过以上两个程序可见，DBCP有着比C3P0更高的效率，但是实际应用中，DBCP可能出现丢失

连接的可能，而C3P0稳定性较高。因此在实际应用中,C3P0使用较为广泛。

转自：/article/3904484.html

补充一部分知识：

数据库连接池基础

· 没有连接池的数据库连接方式指通过DriverManager和基本实现DataSource进行连接,但它相关连接的建立以及关闭是非常耗时的.

· 如果使用连接池，将有池来管理相关的数据库连接，减少对数据库连接操作.

· 连接池所做的操作，除了管理连接，还有就是对数据库jdbc
api的封装，但jdbc api才是根本，外面做的都是包装,再花哨都是假的。

c3p0统一概念

checkout == 从池中取得可用的连接

checkoutconnection == 被使用的连接

checkin == 把连接放回池中

checkinconnection == 没有被使用的连接

所有超时设置，相关的连接，是物理连接的关闭，而不是连接返回池中

管理的是pooledconnection，而不是物理的connection

pooledconnection是sun针对连接池的接口，它本身包含connection,和这个connection相关的所有statement,result,一个checkout的connection所作的所有数据库操作，都被pooledconnection所管理.

statement缓存，主要针对PreparedStatement和CallableStatement,statment缓存主要相对一个connection来说的,不同connection的statment不能通用.

c3p0行为

生成一个connnection

· 当池中connection没有到达最大数,当有请求出现,将会产生connection.

· 成生一个pooledconnection

· 通过pooledconnection.getConnection()得到连接(得到连接是newProxyConnection,不是物理连接)

checkin connection

· 与pooledconnection脱离关系

· 关闭与这个connection相关的resultset

· 关闭所有没有缓冲的statement.

· checkin所有缓存的statement.

· 修改pooledconnection相关信息

checkout connection

· 查看池中是否有没有使用的connection,有就返回

· 没有，如果没有达到最大数，就生成一个，或者就等待

omc中c3p0常用配置属性

automaticTestTable

automaticTestTable作为测试connection是否有效的表，如果表存在，但有记录，抛出错误，如果表不存在，则建立，并使用SELECT
* FROM automaticTestTable 作为连接测试语句

如果automaticTestTable没有设置，而preferredTestQuery设置，则使用preferredTestQuery作为连接测试语句

checkoutTimeout

从池中拿未使用的连接，超时设置，如果没有设置，就不超时.

numConnections

表明池中有多少个连接

numIdleConnections

表明池中有多少个空闲连接，它们可以被checkout

numBusyConnections

表明池中有多少个被checkout的连接，记住：numIdleConnections
+ numBusyConnections == numConnections

numUnclosedOrphanedConnections

都是checkoutconnection,但他们已经不再池中管理了.当他们checkin时候，将被destory

connectionCustomizerClassName

hook方法，在对相关资源做操作的时候，''他所操作的connection是真实的数据库连接，而不是proxy过的connection''

maxIdleTime

在checkout一个connection时候，判断这个connection没有被使用的时间是否大于maxIdleTime,来决定是关闭它，还是被checkout

maxConnectionAge

设置一个连接在池中最长的时间，如果时间超过，将会从池中清除

testConnectionOnCheckout

如果设置为true,每次从池中取一个连接，将做一下测试，使用automaticTestTable 或者 preferredTestQuery,做一条查询语句.看看连接好不好用，不好用，就关闭它，重新从池中拿一个.

unreturnedConnectionTimeout

一个checkout连接的超时设置，一旦一个checkout连接超时，他将物理的关闭，而不是返回池中，主要是防止连接被长期使用不释放，这个设置也是比较危险的

idleConnectionTestPeriod

设置在池中的没有被使用的连接，是否定时做测试，看看这个连接还可以用吗？

maxStatements,maxStatementsPerConnection

缓存statement,一个全局的，一个是针对每一个connection,个人觉得效果不是很大,而且也使用了反射机制.

c3p0 jconsole说明

· sampleThreadPoolStackTraces:打印出当前c3p0线程池的情况，默认是3个线程,c3p0很多行为异步，放到线程中做的，比如checkout,checkin,close操作，还有内部池重新整理

· sampleThreadPoolStatus:打印出当前c3p0线程池堆栈

· softResetDefaultUser:关闭所有checkinconnection,重新初始化池

· hardReset:关闭所有checkinconnection和checkoutconnection,池这个对象也不要了，全是新的.

· close:关闭所有跟c3p0相关的东西

转自：http://ruijunsuo.blog.163.com/blog/static/400596322010112911432402/

c3p0-0.9.1.jar (594.1 KB)

下载次数: 6

commons-dbcp-1.4.jar (156.8 KB)

下载次数: 2

commons-pool.jar (60.6 KB)

下载次数: 2

mysql-connector-java-5.0.3-bin.jar (481.5 KB)

下载次数: 2