BONECP使用_JAVA_编程开发_程序员俱乐部

最近在使用数据库的一些操作，就顺便想仔细了解·一下JDBC连接池，和驱动程序（没有读懂，就不献丑了）

常见的数据源有dbcp,c3p0,网上资料一大把，这里就讲述BONECP，其实官网(http://www.jolbox.com/)上也有比较简单的示例，API，文档和一些常见问题，这里就写几个简单的例子，和一些我的看法

我的一个例子

package bonecptest;

?

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

?

import com.jolbox.bonecp.BoneCP;

import com.jolbox.bonecp.BoneCPConfig;

import com.jolbox.bonecp.ConnectionHandle;

?

public class TestCp {

?

public static void main(String[] args) {

// TODO Auto-generated method stub

?

try {

Class.forName("org.gjt.mm.mysql.Driver");

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

System.err.println("驱动加载失败");

}

?

try {

?

BoneCPConfig config= new BoneCPConfig();?

config.setJdbcUrl("jdbc:mysql://localhost/book");

config.setUsername("root");

config.setPassword("root");

config.setMaxConnectionsPerPartition(10);

config.setMinConnectionsPerPartition(5);

//config.setPartitionCount(2);//连接池内部连接池组数

//config.setAcquireIncrement(5);

?

?

BoneCP pool=new BoneCP(config);

ConnectionHandle connection=(ConnectionHandle) pool.getConnection();

PreparedStatement pre=connection.prepareStatement("select * from admin");

ResultSet set= pre.executeQuery();

while(set.next()) {

System.out.println(set.getString("admin_name"));

}

?

//connection.close();

?

for(int i=1;i<=13;i++){

ConnectionHandle c=(ConnectionHandle) pool.getConnection();

System.out.println(i+":"+c.getCatalog());

c.close();//使用完之后要释放，类似于对象池里面的returnobject(object o)，但是这里面的close()，只是将connection返回到连接池里面，而不是像jdbc原生connection真正关闭（如果是一样的话，那就相当与重新创建，没有重用connection，那就毫无意义，而且你可以注释掉c.close()方法，就会发现创建到第十个程序就不会继续运行，你想嘛，这里需要创建从连接池获取，但是连接池去没有空闲的连接*****前提是此连接池不进行扩容操作），而且这里的connection其实本身还是conenctionhandle，提供的close()并没有进行原生close()调用，而是释放，回归到连接池里面

?

}

?

?

?

System.out.println(pool.getTotalCreatedConnections()+";"+pool.getTotalFree()+";"+pool.getTotalLeased());//查看连接池总归创建了多少连接，空闲连接，已使用连接

pool.shutdown();

?

}?

catch(Exception e) {

?

}

?

?

?

?

}

?

}

?

这是一个非常简单的测试程序，没有什么特别的，就用来进行简单的获取connection，然后进行连数据库操作。

对于数据库操作，现在感觉是这样的

数据库->数据库驱动->获取元数据->数据库连接->数据库连接池（亦成为连接池，数据源）

而在数据库框架中配置datasource其实配置就是连接池，因为本身jdbc是一个连接方式也提供一个获取connection，像是一套java连接数据库的规范示例，而不是说针对某个数据源，所以配置dbcp，c3p0其实和数据hi有jdbc connection没有什么区别，没有其他人说什么数据源就特别之处，就是提供connection，至于怎么操作，事务管理，回滚那些就跟数据源没什么关系，嗯哪，他就是对象池，makeobject（） return connection。

我所理解的数据源就是连接池，有现成的数据源框架，也可以我们自定义实现，我觉得需要满足一些要求可以称之为一个好的连接池

1.满足基本提供connection等基本功能，即对象池,体现复用性

2.能够应对并发

3.能保证并发现象安全

4.使用多线程进行管理，使用线程池。

c3p0，dbcp数据源已经非常成熟，至于bonecp还存在，官网有解释，看了一下bonecp的源码是满足以上4个条件，前两者使用过没看源代码，但是应该也是满足的，不然大家也不会接受。

?

bonecp关键类有BoneCPConfig（配置数据库），BoneCP（提供操作的连接池，内附线程池），ConnectionPartition（进行具体管理连接的对象池），ConnectionHandle（继承与conenction的连接）,StatementReleaseHelperThread(衔接连接操作)，

?

这里是close（）方法源代码

?

public?void?close()?throws?SQLException?{ ????????try?{ ????????????if?(!this.logicallyClosed)?{ ????????????????this.logicallyClosed?=?true; ????????????????this.threadUsingConnection?=?null; ????????????????this.pool.releaseConnection(this);//释放 ? ????????????????if?(this.doubleCloseCheck){ ????????????????????this.doubleCloseException?=?this.pool.captureStackTrace(CLOSED_TWICE_EXCEPTION_MESSAGE); ????????????????} ????????????}?else?{ ????????????????if?(this.doubleCloseCheck?&&?this.doubleCloseException?!=?null){ ????????????????????String?currentLocation?=?this.pool.captureStackTrace("Last?closed?trace?from?thread?["+Thread.currentThread().getName()+"]:\n"); ????????????????????logger.error(String.format(LOG_ERROR_MESSAGE,?this.doubleCloseException,?currentLocation)); ????????????????} ????????????} ????????}?catch?(SQLException?e)?{ ????????????throw?markPossiblyBroken(e); ????????}

????}

?

?

之后释放具体行为

?

?*/ ????protected?void?releaseConnection(Connection?connection)?throws?SQLException?{ ????????ConnectionHandle?handle?=?(ConnectionHandle)connection; ? ????????//?hook?calls ????????if?(handle.getConnectionHook()?!=?null){ ????????????handle.getConnectionHook().onCheckIn(handle); ????????} ? ????????//?release?immediately?or?place?it?in?a?queue?so?that?another?thread?will?eventually?close?it.?If?we're?shutting?down, ????????//?close?off?the?connection?right?away?because?the?helper?threads?have?gone?away. ????????if?(!this.poolShuttingDown?&&?this.releaseHelperThreadsConfigured){ ????????????if?(!handle.getOriginatingPartition().getConnectionsPendingRelease().tryTransfer(handle)){ ????????????????handle.getOriginatingPartition().getConnectionsPendingRelease().put(handle);//具体操作 ????????????} ????????}?else?{ ????????????internalReleaseConnection(handle); ????????}

????}

?

?

具体上没有看懂，但肯定是回收connection，而且绝对没有对原生connection进行close()，个人对于源代码没有看懂，初测为是将blockingqueue中connection对象进行了标记，尽管是使用消费-生产，但是使用标记应该有其他的用途

?

?

?

?

?

?

?

?

?

?