开发者社区> 技术小甜> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

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的文件位置如上图,文件内容如下:
 


  1. #log4j.rootLogger=DEBUG,CONSOLE,A1,im   
  2. log4j.rootLogger=DEBUG,CONSOLE  
  3. log4j.addivity.org.apache=true   
  4. # 应用于控制台   
  5. log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender   
  6. log4j.appender.Threshold=DEBUG   
  7. log4j.appender.CONSOLE.Target=System.out   
  8. log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout   
  9. log4j.appender.CONSOLE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n   
  10. #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   
  11. #应用于文件   
  12. #log4j.appender.FILE=org.apache.log4j.FileAppender   
  13. #log4j.appender.FILE.File=file.log   
  14. #log4j.appender.FILE.Append=false   
  15. #log4j.appender.FILE.layout=org.apache.log4j.PatternLayout   
  16. #log4j.appender.FILE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n   
  17. # Use this layout for LogFactor 5 analysis   
  18. # 应用于文件回滚   
  19. # log4j.appender.ROLLING_FILE=org.apache.log4j.RollingFileAppender   
  20. # log4j.appender.ROLLING_FILE.Threshold=ERROR   
  21. # log4j.appender.ROLLING_FILE.File=rolling.log  //????,??????${java.home}?rolling.log  
  22. # log4j.appender.ROLLING_FILE.Append=true       //true\:??  false\:??  
  23. # log4j.appender.ROLLING_FILE.MaxFileSize=10KB   //??????  
  24. # log4j.appender.ROLLING_FILE.MaxBackupIndex=1  //???  
  25. # log4j.appender.ROLLING_FILE.layout=org.apache.log4j.PatternLayout   
  26. # log4j.appender.ROLLING_FILE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n   
  27. #应用于socket    
  28. #log4j.appender.SOCKET=org.apache.log4j.RollingFileAppender   
  29. #log4j.appender.SOCKET.RemoteHost=localhost   
  30. #log4j.appender.SOCKET.Port=5001   
  31. #log4j.appender.SOCKET.LocationInfo=true   
  32. Set up for Log Facter 5   
  33. #log4j.appender.SOCKET.layout=org.apache.log4j.PatternLayout   
  34. #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   
  35. # Log Factor 5 Appender   
  36. #log4j.appender.LF5_APPENDER=org.apache.log4j.lf5.LF5Appender   
  37. #log4j.appender.LF5_APPENDER.MaxNumberOfRecords=2000   
  38. # 发送日志给邮件   
  39. #log4j.appender.MAIL=org.apache.log4j.net.SMTPAppender   
  40. #log4j.appender.MAIL.Threshold=FATAL   
  41. #log4j.appender.MAIL.BufferSize=10   
  42.  
  43. #[email=log4j.appender.MAIL.To\=web@www.wusetu.com]log4j.appender.MAIL.To\=web@www.wusetu.com[/email]  
  44.  
  45. #log4j.appender.MAIL.SMTPHost=www.wusetu.com   
  46. #log4j.appender.MAIL.Subject=Log4J Message   
  47.  
  48. #log4j.appender.MAIL.layout=org.apache.log4j.PatternLayout   
  49. #log4j.appender.MAIL.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n   
  50. # 用于数据库   
  51. log4j.appender.DATABASE=org.apache.log4j.jdbc.JDBCAppender   
  52. log4j.appender.DATABASE.URL=jdbc:mysql://localhost:3306/test  
  53. log4j.appender.DATABASE.driver=com.mysql.jdbc.Driver   
  54. log4j.appender.DATABASE.user=root   
  55. log4j.appender.DATABASE.password=jeri   
  56. log4j.appender.DATABASE.sql=INSERT INTO LOG4J (Message) VALUES ('[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n')   
  57. log4j.appender.DATABASE.layout=org.apache.log4j.PatternLayout   
  58. log4j.appender.DATABASE.layout.ConversionPattern=[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n   
  59. #log4j.appender.A1=org.apache.log4j.DailyRollingFileAppender   
  60. #log4j.appender.A1.File=SampleMessages.log4j   
  61. #log4j.appender.A1.DatePattern=yyyyMMdd-HH'.log4j'   
  62. #log4j.appender.A1.layout=org.apache.log4j.xml.XMLLayout   
  63. #自定义Appender   
  64. #log4j.appender.im = net.cybercorlin.util.logger.appender.IMAppender   
  65. #log4j.appender.im.host = mail.cybercorlin.net   
  66. #log4j.appender.im.username = username   
  67. #log4j.appender.im.password = password   
  68. #log4j.appender.im.recipient = corlin@cybercorlin.net  
  69.  
  70. #log4j.appender.im.layout=org.apache.log4j.PatternLayout   
  71. #log4j.appender.im.layout.ConversionPattern =[framework] %d - %c -%-4r [%t] %-5p %c %x - %m%n 

 

  • 在JDBC中使用BoneCP

在JDBC中使用BoneCP相当简单,设置一些关于数据库连接池的参数信息,比如连接池的最大、最小连接数等。下面是一个简单的例子:
 


  1. package com.netskycn;  
  2. import java.sql.Connection;  
  3. import java.sql.ResultSet;  
  4. import java.sql.SQLException;  
  5. import java.sql.Statement;  
  6.  
  7. import com.jolbox.bonecp.BoneCP;  
  8. import com.jolbox.bonecp.BoneCPConfig;  
  9.    
  10. /** 测试bonecp数据库连接池的工具  
  11.  * @author zhoufoxcn 周公  
  12.  * @version 0.1  
  13.  * 说明:这是一个在JDBC中使用BoneCP的例子  
  14.  * 2010-11-23  
  15.  */ 
  16. public class MainClass {  
  17.     public static void main(String[] args) {  
  18.         BoneCP connectionPool = null;  
  19.         Connection connection = null;  
  20.    
  21.         try {  
  22.             //加载JDBC驱动  
  23.             Class.forName("com.mysql.jdbc.Driver");  
  24.         } catch (Exception e) {  
  25.             e.printStackTrace();  
  26.             return;  
  27.         }  
  28.           
  29.         try {  
  30.             //设置连接池配置信息  
  31.             BoneCPConfig config = new BoneCPConfig();  
  32.             //数据库的JDBC URL  
  33.             config.setJdbcUrl("jdbc:mysql:///jobeet");   
  34.             //数据库用户名  
  35.             config.setUsername("root");   
  36.             //数据库用户密码  
  37.             config.setPassword("jeri");  
  38.             //数据库连接池的最小连接数  
  39.             config.setMinConnectionsPerPartition(5);  
  40.             //数据库连接池的最大连接数  
  41.             config.setMaxConnectionsPerPartition(10);  
  42.             //  
  43.             config.setPartitionCount(1);  
  44.             //设置数据库连接池  
  45.             connectionPool = new BoneCP(config);  
  46.             //从数据库连接池获取一个数据库连接  
  47.             connection = connectionPool.getConnection(); // fetch a connection  
  48.               
  49.             if (connection != null){  
  50.                 System.out.println("Connection successful!");  
  51.                 Statement stmt = connection.createStatement();  
  52.                 ResultSet rs = stmt.executeQuery("SELECT * FROM customer");   
  53.                 while(rs.next()){  
  54.                     System.out.println(rs.getInt(1)+":"+rs.getString("firstname")+","+rs.getString("lastname"));   
  55.                 }  
  56.             }  
  57.             //关闭数据库连接池  
  58.             connectionPool.shutdown();   
  59.         } catch (SQLException e) {  
  60.             e.printStackTrace();  
  61.         } finally {  
  62.             if (connection != null) {  
  63.                 try {  
  64.                     connection.close();  
  65.                 } catch (SQLException e) {  
  66.                     e.printStackTrace();  
  67.                 }  
  68.             }  
  69.         }  
  70.     }  


这个例子相当简单,但是是利用BoneCP提供的连接池而不是直接使用JDBC来管理连接的。

  • 使用DataSource

使用DataSource的话,代码如下:
 


  1. //加载数据库驱动  
  2. Class.forName("com.mysql.jdbc.Driver");  
  3. //创建一个DataSource对象  
  4. BoneCPDataSource ds = new BoneCPDataSource();  
  5. //设置JDBC URL  
  6. ds.setJdbcUrl("jdbc:mysql:///jobeet");  
  7. //设置用户名  
  8. ds.setUsername("sa");  
  9. //设置密码  
  10. ds.setPassword("jeri");  
  11. //下面的代码是设置其它可选属性  
  12. //ds.setXXXX(...);  
  13.           
  14. Connection connection;  
  15. connection = ds.getConnection();  
  16.           
  17. //这里操作数据库  
  18. //...  
  19. //关闭数据库连接  
  20. connection.close();  
  21. 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
除此之外,还需要做如下配置:
 


  1. <!-- Hibernate SessionFactory --> 
  2. <bean id="sessionFactory" class="org.springframework.orm.hibernate.LocalSessionFactoryBean" autowire="autodetect"> 
  3.     <property name="hibernateProperties"> 
  4.         <props> 
  5.             <prop key="hibernate.connection.provider_class">com.jolbox.bonecp.provider.BoneCPConnectionProvider</prop> 
  6.             <prop key="hibernate.connection.driver_class">com.mysql.jdbc.Driver</prop> 
  7.             <prop key="hibernate.connection.url">jdbc:mysql://127.0.0.1/yourdb</prop> 
  8.             <prop key="hibernate.connection.username">root</prop> 
  9.             <prop key="hibernate.connection.password">abcdefgh</prop> 
  10.             <prop key="bonecp.idleMaxAge">240</prop> 
  11.             <prop key="bonecp.idleConnectionTestPeriod">60</prop> 
  12.             <prop key="bonecp.partitionCount">3</prop> 
  13.             <prop key="bonecp.acquireIncrement">10</prop> 
  14.             <prop key="bonecp.maxConnectionsPerPartition">60</prop> 
  15.             <prop key="bonecp.minConnectionsPerPartition">20</prop> 
  16.             <prop key="bonecp.statementsCacheSize">50</prop> 
  17.             <prop key="bonecp.releaseHelperThreads">3</prop> 
  18.         </props> 
  19.     </property> 
  20. </bean> 


这样就可以在Hibernate中使用BoneCP了。

周公没有真实去测试BoneCP的性能,个人觉得它的用法确实比较简单,并且和不再维护的Proxool相比至少它还在一直更新和维护,不失为一个不错的备选方案。附件是本文提到的一些必备的jar包。

 















本文转自周金桥51CTO博客,原文链接:http://blog.51cto.com/zhoufoxcn/438277 ,如需转载请自行联系原作者




版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
ZeroMQ(java)之I/O线程的实现与组件间的通信
算是开始读ZeroMQ(java)的代码实现了吧,现在有了一个大体的了解,看起来实现是比较的干净的,抽象什么的不算复杂。。。 这里先来看看它的I/O线程的实现吧,顺带看看是如何实现组件的通信的。。。。
1366 0
ZeroMQ(java)中组件间数据传输(Pipe的实现)
在ZeroMQ(java)中,整个IO的处理流程都是分层来进行的,当然处于最下端的肯定是前面介绍过的poller以及StreamEngin了。。。。涉及到上层的话就还有session,以及socket,先用一张图来大概的描述一下整个层次关系吧。
878 0
生产者/消费者问题的多种Java实现方式
实质上,很多后台服务程序并发控制的基本原理都可以归纳为生产者/消费者模式,而这是恰恰是在本科操作系统课堂上老师反复讲解,而我们却视而不见不以为然的。在博文《一种面向作业流(工作流)的轻量级可复用的异步流水开发框架的设计与实现》中将介绍一种生产者/消费者模式的具体应用。
614 0
Java实现敏感词过滤
1.读取敏感数据,构建DFA算法 package com.iris.nsonline.nsoweb.utils; import java.
1599 0
JAVA模拟PostObject表单上传OSS,实现签名直传
从multipart/form-data编码的标准定义和OSS系统解析POST请求的实现两个方面,阐述OSS官网中的PostObject文档内容,最后给出JAVA实现PostObject直传OSS的代码参考。
16909 0
辗转相除法_欧几里得算法_java的实现(求最大公约数)
辗转相除法,又被称为欧几里德(Euclidean)算法, 是求最大公约数的算法。 当然也可以求最小公倍数。 算法描述   两个数a,b的最大公约数记为GCD(a,b)。a,b的最大公约数是两个数的公共素因子的乘积。
1569 0
+关注
文章
问答
文章排行榜
最热
最新
相关电子书
更多
MySQL Java开发实战
立即下载
Java Spring Boot开发实战系列课程【第6讲】:Spring Boot 2.0实战MyBatis与优化(Java面试题)
立即下载
Java基础入门(四)-泛型、反射、注解
立即下载