Java中的BoneCP数据库连接池用法
在 2006 年 8 月的时候我在项目中使用过 Proxool 这个 Java 数据库连接池，在当时的使用过程中遇到了一些问题，为此曾写过一篇名为《关于 Proxool 使用的一点问题》的博客，网址是http://blog.csdn.net/zhoufoxcn/archive/2006/08/30/1142685.aspx，博文发布以后有很多朋友在博文下面留言，因为它们也遇到了类似的问题。我记得我在 2006 年使用 Proxool 的时候版本就已经是 0.8.3 了，最近在 Hibernate 中发现它也带了这个 Java 数据库连接池实现，它的版本依然是 0.8.3，应该是这些年来没有更新了。前些天研究一个项目的时候发现了项目中使用了 BoneCP 这个 Java 的数据库连接池，抱着好奇的态度学习了一下，觉得还不错，所以写了这篇博文跟大家分享一下。BoneCP 也是一个开源的 Java 数据库连接池，它的官方网站网址是：http://jolbox.com/。
据 BoneCP 网站官方报告称，BoneCP 比性能排名第二的 Java 数据库连接池性高高 25 倍以上，并且支持 Hibernate 和 DataNucleus 这样的数据持久框架（当然支持 JDBC 这种直接方式了）。
使用 BoneCP 的必备条件
使用 BoneCP 需要如下类库支持：
被连接的数据库的 JDBC 驱动程序，这个可以到该数据库厂商网站下载；
Google 的集合框架 Guava，它的网址是：http://code.google.com/p/guava-libraries/，这个需要说明的是 BoneCP 官方网站说的必备框架是 Google Collect 框架，但是这个框架已经不再支持了，而是转为新的集合框架 Guava；
SLF4J 日志类库（在早期的 BoneCP 版本中直接使用了 Log4J 类库）；
JDK1.5 及更高版本。
下面是测试项目中的类库截图：
也就是需要了如下 Jar 包：
bonecp-0.7.0.jar
mysql-connector-java-5.1.13-bin.jar
slf4j-log4j12-1.6.1.jar
slf4j-api-1.6.1.jar
log4j-1.2.16.jar
guava-r07.jar
为了得到比较详细的运行过程信息，需要添加一个 log4j 的配置文件 log4j.properties，log4j.properties 的文件位置如上图，文件内容如下：
#log4j.rootLogger=DEBUG,CONSOLE,A1,im
log4j.rootLogger=DEBUG,CONSOLE
log4j.addivity.org.apache=true
# 应用于控制台
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.Threshold=DEBUG
log4j.appender.CONSOLE.Target=System.out
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n
#log4j.appender.CONSOLE.layout.ConversionPattern=[start]%d{DATE}[DATE]%n%p[PRIORITY]%n%x[NDC]%n%t[THREAD] n%c[CATEGORY]%n%m[MESSAGE]%n%n
#应用于文件
#log4j.appender.FILE=org.apache.log4j.FileAppender
#log4j.appender.FILE.File=file.log
#log4j.appender.FILE.Append=false
#log4j.appender.FILE.layout=org.apache.log4j.PatternLayout
#log4j.appender.FILE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n
# Use this layout for LogFactor 5 analysis
# 应用于文件回滚
# log4j.appender.ROLLING_FILE=org.apache.log4j.RollingFileAppender
# log4j.appender.ROLLING_FILE.Threshold=ERROR
# log4j.appender.ROLLING_FILE.File=rolling.log //????,??????${java.home}?rolling.log
# log4j.appender.ROLLING_FILE.Append=true //true/:?? false/:??
# log4j.appender.ROLLING_FILE.MaxFileSize=10KB //??????
# log4j.appender.ROLLING_FILE.MaxBackupIndex=1 //???
# log4j.appender.ROLLING_FILE.layout=org.apache.log4j.PatternLayout
# log4j.appender.ROLLING_FILE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n
#应用于 socket
#log4j.appender.SOCKET=org.apache.log4j.RollingFileAppender
#log4j.appender.SOCKET.RemoteHost=localhost
#log4j.appender.SOCKET.Port=5001
#log4j.appender.SOCKET.LocationInfo=true
# Set up for Log Facter 5
#log4j.appender.SOCKET.layout=org.apache.log4j.PatternLayout
#log4j.appender.SOCET.layout.ConversionPattern=[start]%d{DATE}[DATE]%n%p[PRIORITY]%n%x[NDC]%n%t[THREAD]%n%c[CATEGORY]%n%m[MESSAGE]%n%n
# Log Factor 5 Appender
#log4j.appender.LF5_APPENDER=org.apache.log4j.lf5.LF5Appender
#log4j.appender.LF5_APPENDER.MaxNumberOfRecords=2000
# 发送日志给邮件
#log4j.appender.MAIL=org.apache.log4j.net.SMTPAppender
#log4j.appender.MAIL.Threshold=FATAL
#log4j.appender.MAIL.BufferSize=10
<p>#[email=log4j.appender.MAIL.To/=web@www.wusetu.com]<a href="mailto:log4j.appender.MAIL.To/=web@www.wusetu.com">log4j.appender.MAIL.To/=web@www.wusetu.com</a>[/email]</p>
<p>#log4j.appender.MAIL.SMTPHost=<a href="http://www.wusetu.com">www.wusetu.com</a><br />
#log4j.appender.MAIL.Subject=Log4J Message</p>
<p>#log4j.appender.MAIL.layout=org.apache.log4j.PatternLayout<br />
#log4j.appender.MAIL.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n</p>
<h1> 用于数据库 </h1>
<p>log4j.appender.DATABASE=org.apache.log4j.jdbc.JDBCAppender<br />
log4j.appender.DATABASE.URL=jdbc:<a href="mysql://localhost:3306/test">mysql://localhost:3306/test</a><br />
log4j.appender.DATABASE.driver=com.mysql.jdbc.Driver<br />
log4j.appender.DATABASE.user=root<br />
log4j.appender.DATABASE.password=jeri<br />
log4j.appender.DATABASE.sql=INSERT INTO LOG4J (Message) VALUES ('[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n')<br />
log4j.appender.DATABASE.layout=org.apache.log4j.PatternLayout<br />
log4j.appender.DATABASE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n<br />
#log4j.appender.A1=org.apache.log4j.DailyRollingFileAppender<br />
#log4j.appender.A1.File=SampleMessages.log4j<br />
#log4j.appender.A1.DatePattern=yyyyMMdd-HH'.log4j'<br />
#log4j.appender.A1.layout=org.apache.log4j.xml.XMLLayout<br />
#自定义 Appender<br />
#log4j.appender.im = net.cybercorlin.util.logger.appender.IMAppender<br />
#log4j.appender.im.host = mail.cybercorlin.net<br />
#log4j.appender.im.username = username<br />
#log4j.appender.im.password = password<br />
#log4j.appender.im.recipient = <a href="mailto:corlin@cybercorlin.net">corlin@cybercorlin.net</a></p>
<p>#log4j.appender.im.layout=org.apache.log4j.PatternLayout<br />
#log4j.appender.im.layout.ConversionPattern =[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n
在 JDBC 中使用 BoneCP
在 JDBC 中使用 BoneCP 相当简单，设置一些关于数据库连接池的参数信息，比如连接池的最大、最小连接数等。下面是一个简单的例子：
package com.netskycn;<br />
import java.sql.Connection;<br />
import java.sql.ResultSet;<br />
import java.sql.SQLException;<br />
import java.sql.Statement;</p>
<p>import com.jolbox.bonecp.BoneCP;<br />
import com.jolbox.bonecp.BoneCPConfig;</p>
<p>/** 测试 bonecp 数据库连接池的工具 </p>
<ul>
<li>
<p>@author zhoufoxcn 周公 </p>
</li>
<li>
<p>@version 0.1</p>
</li>
<li>
<p> 说明：这是一个在 JDBC 中使用 BoneCP 的例子 </p>
</li>
<li>
<p>2010-11-23<br />
*/<br />
public class MainClass {<br />
public static void main(String[] args) {<br />
BoneCP connectionPool = null;<br />
Connection connection = null;</p>
<pre><code> try {
// 加载 JDBC 驱动
Class.forName("com.mysql.jdbc.Driver");
} catch (Exception e) {e.printStackTrace();
return;
}
try {
// 设置连接池配置信息
BoneCPConfig config = new BoneCPConfig();
// 数据库的 JDBC URL
config.setJdbcUrl("jdbc:mysql:///jobeet");
// 数据库用户名
config.setUsername("root");
// 数据库用户密码
config.setPassword("jeri");
// 数据库连接池的最小连接数
config.setMinConnectionsPerPartition(5);
// 数据库连接池的最大连接数
config.setMaxConnectionsPerPartition(10);
//
config.setPartitionCount(1);
// 设置数据库连接池
connectionPool = new BoneCP(config);
// 从数据库连接池获取一个数据库连接
connection = connectionPool.getConnection(); // fetch a connection
if (connection != null){System.out.println("Connection successful!");
Statement stmt = connection.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM customer");
while(rs.next()){System.out.println(rs.getInt(1)+":"+rs.getString("firstname")+","+rs.getString("lastname"));
}
}
// 关闭数据库连接池
connectionPool.shutdown();} catch (SQLException e) {e.printStackTrace();
} finally {if (connection != null) {
try {connection.close();
} catch (SQLException e) {e.printStackTrace();
}
}
}
</code></pre>
<p>}<br />
}
这个例子相当简单，但是是利用 BoneCP 提供的连接池而不是直接使用 JDBC 来管理连接的。
使用 DataSource
使用 DataSource 的话，代码如下：
// 加载数据库驱动 <br />
Class.forName("com.mysql.jdbc.Driver");<br />
// 创建一个 DataSource 对象 <br />
BoneCPDataSource ds = new BoneCPDataSource();<br />
// 设置 JDBC URL<br />
ds.setJdbcUrl("jdbc:<a href="mysql:///jobeet">mysql:///jobeet</a>");<br />
// 设置用户名 <br />
ds.setUsername("sa");<br />
// 设置密码 <br />
ds.setPassword("jeri");<br />
// 下面的代码是设置其它可选属性 <br />
//ds.setXXXX(...);</p>
</li>
</ul>
<p>Connection connection;<br />
connection = ds.getConnection();</p>
<p>// 这里操作数据库 <br />
//...<br />
// 关闭数据库连接 <br />
connection.close();<br />
ds.close();
在 Hibernate 中使用 BoneCP
在 Hibernate 中使用 BoneCP 除了需要上面提到的 jar 包之外，还需要下载一个名为 bonecp-provider-0.7.0.jar 的 bonecp-provider 的 jar 包，它的下载位置是：http://jolbox.com/bonecp/downloads/maven/com/jolbox/bonecp-provider/0.7.0/bonecp-provider-0.7.0.jar。
除此之外，还需要做如下配置：
<!-- Hibernate SessionFactory --><br />
<bean id="sessionFactory" class="org.springframework.orm.hibernate.LocalSessionFactoryBean" autowire="autodetect"><br />
<property name="hibernateProperties"><br />
<props><br />
<prop key="hibernate.connection.provider_class">com.jolbox.bonecp.provider.BoneCPConnectionProvider</prop><br />
<prop key="hibernate.connection.driver_class">com.mysql.jdbc.Driver</prop><br />
<prop key="hibernate.connection.url">jdbc:<a href="mysql://127.0.0.1/yourdb">mysql://127.0.0.1/yourdb</a></prop><br />
<prop key="hibernate.connection.username">root</prop><br />
<prop key="hibernate.connection.password">abcdefgh</prop><br />
<prop key="bonecp.idleMaxAge">240</prop><br />
<prop key="bonecp.idleConnectionTestPeriod">60</prop><br />
<prop key="bonecp.partitionCount">3</prop><br />
<prop key="bonecp.acquireIncrement">10</prop><br />
<prop key="bonecp.maxConnectionsPerPartition">60</prop><br />
<prop key="bonecp.minConnectionsPerPartition">20</prop><br />
<prop key="bonecp.statementsCacheSize">50</prop><br />
<prop key="bonecp.releaseHelperThreads">3</prop><br />
</props><br />
</property><br />
</bean>
这样就可以在 Hibernate 中使用 BoneCP 了。
总结
周公没有真实去测试 BoneCP 的性能，个人觉得它的用法确实比较简单，并且和不再维护的 Proxool 相比至少它还在一直更新和维护，不失为一个不错的备选方案。附件是本文提到的一些必备的 jar 包。
--------------------------------------------------------------------------------
广告：本人现在正在参加“2010 年度十大杰出 IT 博客大赛”，欢迎大家前去捧场投下您宝贵的一票！网址是：http://2010blog.51cto.com/792419