- 浏览: 751195 次
- 性别:
- 来自: 杭州
文章分类
最新评论
-
webcover:
最新的中文网络记事本: 破笔记
网络记事本:http://w ...
五个最佳的免费网络记事本 -
fred_nxh:
很好,长见识了
java中堆(heap)和堆栈(stack)有什么区别 -
efeige:
兄弟,请问一下,为什么我的2003系统 网站属性 里面没有“服 ...
启用IIS Gzip 页面压缩技术 加速网页的浏览速度 -
252401762:
同样的问题啊,不知道楼主是否已经转做售前了
售前和 开发的选择 -
yuan:
膜拜玩静电的现在呢?
来回顾一下,当年的“发烧史”吧:
Commons pool 数据库连接池实现 收藏
1,首先我们要实现一个工厂类,用于处理验证,创建对象等方法。
view plaincopy to clipboardprint?
package net.chinacsharp.jdf.pool.connectionpool;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.pool.PoolableObjectFactory;
/**
* @author keyboardsun mail: keyboardsun@163.com
* @site http://www.chinacsharp.net
*/
public class SecObjectFactory implements PoolableObjectFactory {
// private ConnectionGetter connectionGetter = new ConnectionGetter();
// private String CONNECTION_NAME="Sec";
/**
* 这里,我们在使用对象的时候,需要首先激活这个对象,但是在多线程情况下,
* 这个对象已经被别的线程借去用了,那我们就要再建立一个对象。
*/
public void activateObject(Object arg0) throws Exception {
System.out.println("activateObject"+arg0);
}
/**
* 这里我们销毁这个对象。不用这个对象了,这个方法得在业务使用过程中主动调用。
* 在调用完这个方法过后,对象已经被销毁,但是在Object pool里面还是存在这个对象的
* 只是这个对象是null而已。所以在调用完destroyObject过后,要记得把pool清空一下。
*/
public void destroyObject(Object arg) throws Exception {
System.out.println("destroyObject:"+arg);
if(((Connection)arg).isClosed()!=true){
((Connection)arg).close();
}
}
/**
* 这里,在业务中第一次借对象的时候,这里要初始化一个,如果初始的都被借了,那就要继续初始
* 这里创建的对象将被存到pool里面
*/
public Object makeObject() throws Exception {
Class.forName("com.mysql.jdbc.Driver").newInstance();
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "admin");
conn.setAutoCommit(false);
// Object o = connectionGetter.getNewConnection(CONNECTION_NAME);
// System.out.println("makeObject:"+o);
return conn;
}
/**
* 这里,在我们使用完每个对象过后,要做的就是归还,在归还后就要调用这个方法。
* 简单的说,在还款凭证上面签个大名
*/
public void passivateObject(Object arg0) throws Exception {
System.out.println("passivateObject"+arg0);
}
/**
*这个方法是验证对象,这里我们不做处理,这里在借对象和还对象的时候都要验证下的。
*/
public boolean validateObject(Object arg) {
System.out.println("validateObject:"+arg);
try {
if(((Connection)arg).isClosed()==true){
return false;
} else {
return true;
}
} catch (SQLException e) {
e.printStackTrace();
return false;
}
}
}
package net.chinacsharp.jdf.pool.connectionpool;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.commons.pool.PoolableObjectFactory;
/**
* @author keyboardsun mail: keyboardsun@163.com
* @site http://www.chinacsharp.net
*/
public class SecObjectFactory implements PoolableObjectFactory {
// private ConnectionGetter connectionGetter = new ConnectionGetter();
// private String CONNECTION_NAME="Sec";
/**
* 这里,我们在使用对象的时候,需要首先激活这个对象,但是在多线程情况下,
* 这个对象已经被别的线程借去用了,那我们就要再建立一个对象。
*/
public void activateObject(Object arg0) throws Exception {
System.out.println("activateObject"+arg0);
}
/**
* 这里我们销毁这个对象。不用这个对象了,这个方法得在业务使用过程中主动调用。
* 在调用完这个方法过后,对象已经被销毁,但是在Object pool里面还是存在这个对象的
* 只是这个对象是null而已。所以在调用完destroyObject过后,要记得把pool清空一下。
*/
public void destroyObject(Object arg) throws Exception {
System.out.println("destroyObject:"+arg);
if(((Connection)arg).isClosed()!=true){
((Connection)arg).close();
}
}
/**
* 这里,在业务中第一次借对象的时候,这里要初始化一个,如果初始的都被借了,那就要继续初始
* 这里创建的对象将被存到pool里面
*/
public Object makeObject() throws Exception {
Class.forName("com.mysql.jdbc.Driver").newInstance();
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "admin");
conn.setAutoCommit(false);
// Object o = connectionGetter.getNewConnection(CONNECTION_NAME);
// System.out.println("makeObject:"+o);
return conn;
}
/**
* 这里,在我们使用完每个对象过后,要做的就是归还,在归还后就要调用这个方法。
* 简单的说,在还款凭证上面签个大名
*/
public void passivateObject(Object arg0) throws Exception {
System.out.println("passivateObject"+arg0);
}
/**
*这个方法是验证对象,这里我们不做处理,这里在借对象和还对象的时候都要验证下的。
*/
public boolean validateObject(Object arg) {
System.out.println("validateObject:"+arg);
try {
if(((Connection)arg).isClosed()==true){
return false;
} else {
return true;
}
} catch (SQLException e) {
e.printStackTrace();
return false;
}
}
}
2,我们要做一个pool 操作类
view plaincopy to clipboardprint?
package net.chinacsharp.jdf.pool.connectionpool;
import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.PoolableObjectFactory;
import org.apache.commons.pool.impl.GenericObjectPool;
import org.apache.commons.pool.impl.StackObjectPool;
import org.apache.commons.pool.impl.GenericObjectPool.Config;
public class SecObjectPool implements ObjectPool{
private static SecObjectFactory factory = new SecObjectFactory();
private static ObjectPool pool = null;
private static GenericObjectPool.Config config = null;
private static boolean initFlag = false;//是否初始化
static {
if(!initFlag){
config = new Config();
config.maxActive = 2; //这个属性没啥用
config.maxIdle = 5; //最大连接数,就这个有用.
config.minIdle = 3; //最少连接数 ,这个也没用,哈哈.
pool = new GenericObjectPool(factory,config);
initFlag = true;
}
}
public Object borrowObject() throws Exception {
return pool.borrowObject();
}
public void returnObject(Object arg0) throws Exception {
pool.returnObject(arg0);
}
public void invalidateObject(Object arg0) throws Exception {
pool.invalidateObject(arg0);
}
public void addObject() throws Exception {
pool.addObject();
}
public int getNumIdle() throws UnsupportedOperationException {
return pool.getNumIdle();
}
public int getNumActive() throws UnsupportedOperationException {
return pool.getNumActive();
}
public void clear() throws Exception, UnsupportedOperationException {
pool.clear();
}
public void close() throws Exception {
pool.close();
}
public void setFactory(PoolableObjectFactory arg0) throws IllegalStateException, UnsupportedOperationException {
pool.setFactory(arg0);
}
}
package net.chinacsharp.jdf.pool.connectionpool;
import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.PoolableObjectFactory;
import org.apache.commons.pool.impl.GenericObjectPool;
import org.apache.commons.pool.impl.StackObjectPool;
import org.apache.commons.pool.impl.GenericObjectPool.Config;
public class SecObjectPool implements ObjectPool{
private static SecObjectFactory factory = new SecObjectFactory();
private static ObjectPool pool = null;
private static GenericObjectPool.Config config = null;
private static boolean initFlag = false;//是否初始化
static {
if(!initFlag){
config = new Config();
config.maxActive = 2; //这个属性没啥用
config.maxIdle = 5; //最大连接数,就这个有用.
config.minIdle = 3; //最少连接数 ,这个也没用,哈哈.
pool = new GenericObjectPool(factory,config);
initFlag = true;
}
}
public Object borrowObject() throws Exception {
return pool.borrowObject();
}
public void returnObject(Object arg0) throws Exception {
pool.returnObject(arg0);
}
public void invalidateObject(Object arg0) throws Exception {
pool.invalidateObject(arg0);
}
public void addObject() throws Exception {
pool.addObject();
}
public int getNumIdle() throws UnsupportedOperationException {
return pool.getNumIdle();
}
public int getNumActive() throws UnsupportedOperationException {
return pool.getNumActive();
}
public void clear() throws Exception, UnsupportedOperationException {
pool.clear();
}
public void close() throws Exception {
pool.close();
}
public void setFactory(PoolableObjectFactory arg0) throws IllegalStateException, UnsupportedOperationException {
pool.setFactory(arg0);
}
}
3,Main 函数
view plaincopy to clipboardprint?
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import net.chinacsharp.jdf.pool.connectionpool.*;
public class PoolTest {
/**
* @param args
* @throws SQLException
*/
public static void main(String[] args) throws SQLException {
SecObjectPool p = new SecObjectPool();
Connection connection = null;
try {
connection = (Connection) p.borrowObject();
PreparedStatement statement = null;
statement = connection.prepareStatement("SELECT * FROM PERSON");
ResultSet rs = statement.executeQuery();
rs.close();
System.out.println("================");
p.addObject();
System.out.println("使用中几个:"+p.getNumActive());
System.out.println("队列中还有:"+p.getNumIdle());
p.addObject();
p.addObject();
p.addObject();
p.addObject();
connection = (Connection) p.borrowObject();
connection = (Connection) p.borrowObject();
connection = (Connection) p.borrowObject();
p.addObject();
p.addObject();
p.addObject();
p.addObject();
System.out.println("使用中几个:"+p.getNumActive());
System.out.println("队列中还有:"+p.getNumIdle());
System.out.println("================");
p.returnObject(connection);
System.out.println("使用中几个:"+p.getNumActive());
System.out.println("队列中还有:"+p.getNumIdle());
System.out.println("=====clear===========");
p.clear();
System.out.println("=====close===========");
p.close();
} catch (Throwable e) {
e.printStackTrace();
connection.close();
}
}
}
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import net.chinacsharp.jdf.pool.connectionpool.*;
public class PoolTest {
/**
* @param args
* @throws SQLException
*/
public static void main(String[] args) throws SQLException {
SecObjectPool p = new SecObjectPool();
Connection connection = null;
try {
connection = (Connection) p.borrowObject();
PreparedStatement statement = null;
statement = connection.prepareStatement("SELECT * FROM PERSON");
ResultSet rs = statement.executeQuery();
rs.close();
System.out.println("================");
p.addObject();
System.out.println("使用中几个:"+p.getNumActive());
System.out.println("队列中还有:"+p.getNumIdle());
p.addObject();
p.addObject();
p.addObject();
p.addObject();
connection = (Connection) p.borrowObject();
connection = (Connection) p.borrowObject();
connection = (Connection) p.borrowObject();
p.addObject();
p.addObject();
p.addObject();
p.addObject();
System.out.println("使用中几个:"+p.getNumActive());
System.out.println("队列中还有:"+p.getNumIdle());
System.out.println("================");
p.returnObject(connection);
System.out.println("使用中几个:"+p.getNumActive());
System.out.println("队列中还有:"+p.getNumIdle());
System.out.println("=====clear===========");
p.clear();
System.out.println("=====close===========");
p.close();
} catch (Throwable e) {
e.printStackTrace();
connection.close();
}
}
}
4,输出结果
activateObjectcom.mysql.jdbc.Connection@147ee05
================
passivateObjectcom.mysql.jdbc.Connection@1960f05
使用中几个:1
队列中还有:1
passivateObjectcom.mysql.jdbc.Connection@1e04cbf
passivateObjectcom.mysql.jdbc.Connection@66e815
passivateObjectcom.mysql.jdbc.Connection@edc3a2
passivateObjectcom.mysql.jdbc.Connection@6e70c7
activateObjectcom.mysql.jdbc.Connection@1960f05
activateObjectcom.mysql.jdbc.Connection@1e04cbf
activateObjectcom.mysql.jdbc.Connection@66e815
passivateObjectcom.mysql.jdbc.Connection@1d63e39
passivateObjectcom.mysql.jdbc.Connection@d0a5d9
passivateObjectcom.mysql.jdbc.Connection@b8f82d
passivateObjectcom.mysql.jdbc.Connection@a6aeed
destroyObject:com.mysql.jdbc.Connection@a6aeed
使用中几个:4
队列中还有:5
================
passivateObjectcom.mysql.jdbc.Connection@66e815
destroyObject:com.mysql.jdbc.Connection@66e815
使用中几个:3
队列中还有:5
=====clear===========
destroyObject:com.mysql.jdbc.Connection@edc3a2
destroyObject:com.mysql.jdbc.Connection@6e70c7
destroyObject:com.mysql.jdbc.Connection@1d63e39
destroyObject:com.mysql.jdbc.Connection@d0a5d9
destroyObject:com.mysql.jdbc.Connection@b8f82d
=====close===========
通过以上结果我们可以发现,在连接池clear()的时候,调用 destroyObject 方法,我们这里把连接都关闭了
同样的道理,我们close()的时候也是如此。
而连接池的最大激活数目的设置是不起作用的,但是队列最多连接数那是有效果的,如果队列已经是最多了,它会把创建的或者归还的,调用 destroyObject 方法,释放对象。
原创作品,转载请标明出处
http://blog.csdn.net/keyboardsun
作者 keyboardsun
本文来自CSDN博客,转载请标明出处:http://blog.csdn.net/keyboardsun/archive/2009/06/17/4277592.aspx
发表评论
-
ocx插件插入网页实现自动更新与安装注册
2010-07-27 16:17 6579ocx插件插入网页实现 ... -
JIRA
2010-04-02 16:28 1180JIRA 百科名片 JIRA是集项目计划、任务分配、需求管 ... -
ArrayList和LinkedList的用法区别
2010-03-17 10:58 1840ArrayList和LinkedList的用法区别 (2 ... -
Java 中Vector、ArrayList和LinkedList 的区别时间
2010-03-17 10:25 1662Java 中Vector、ArrayList和LinkedLi ... -
多层架构的Web开发框架模型
2010-03-14 00:31 1913摘要:在经典的J2EE四层体系结构的基础上增加数据持久层,提出 ... -
Java语言编码规范(Java Code Conventions
2010-03-08 01:17 7541 介绍(Introduction)1.1 为什么要有编码规范 ... -
IT 的规划
2010-02-21 21:07 745本文说的这位网友,在I ... -
记忆学
2010-02-10 00:50 639http://bbs.jiyifa.cn/read.php?t ... -
java析构函数替代者finalize()解说
2010-01-21 22:18 2502java析构函数替代者finali ... -
Java的GC机制总结(0) ---finalize()方法
2010-01-21 22:00 1180其实了解JAVA的人,都知道JAVA的GC机制是其的一大优点, ... -
Java认证考试
2010-01-14 12:30 814Java认证考试 关于Java方面,Sun推出四项认证:Su ... -
集合框架
2010-01-13 23:24 623java 集合框架 对象的集合 如果程序的 ... -
Java集合框架使用总结
2010-01-13 21:31 640Java集合框架使用总结 ... -
关于JAVA中的线程安全
2010-01-13 10:34 1516关于JAVA中的线程安全 ... -
Java 理论与实践: 并发集合类
2010-01-13 01:27 757DougLea的 util.concurrent 包除了包含许 ... -
java main 主函数
2010-01-10 14:28 2294java主函数一般定义如下:public static ... -
java新式for循环
2009-12-29 15:51 764java新式for循环 2008-08-04 13:48:2 ... -
2009年的Java技术发展趋势展望
2009-11-08 21:28 734已经有14岁的Java在日新月异的IT技术领域内不算年轻,但它 ... -
MyEclipse要注册
2009-11-07 18:37 1671yEclipse怎么注册都不知道。我说他没有注册,他硬要说已经 ... -
浅谈设计模式在JAVA中的具体运用
2009-10-27 23:32 922浅谈设计模式在JAVA ...
相关推荐
DBCP是一个依赖Jakarta commons-pool对象池机制的数据库连接池.DBCP可以直接的在应用程序中使用,Tomcat的数据源使用的就是DBCP; 使用连接池的第一项工作就是导包,这里需要的两个jar包分别是: commons-dbcp-1.4....
包含了连接数据库连接池所需的大部分jar包
需要使用Redis连接池的话,还需commons-pool包,提供了强大的功能,包含最新的jar包
DBCP包 commons-dbcp-1.2.1.zip commons-pool-current.zip
java开发中,比如写一个DbUtil.java,需要用到数据库连接池,此时需要引入相关 jar 包:commons-dbcp.jar 、 commons-pool.jar
DBCP的工作原理是,程序首先会初始化相应的数据库连接池,以供程序访问,当某个操作需要访问数据库时,程序会首先在连接池中取得空闲连接,如没有空闲连接在创建,用完之后归还连接池,这样达到了连接的重利用,不用...
DBCP(DataBase connection pool),数据库连接池。是 apache 上的一个 java 连接池项目,也是 tomcat 使用的连接池组件。单独使用dbcp需要3个包:commons-dbcp.jar,commons-pool.jar,commons-collections.jar由于建立...
tomcat 连接数据库的jar包 commons-dpcp.jar ,commons-pool.jar 配置好了,就能解决连接池配置方面的问题
java中DBCP数据库连接池使用方法以及代码文件:(dbcpconfig.properties+JdbcPool_dbcp.java)以及jjdbc所需的ar包(commons-pool.jar+commons-dbcp-1.2.2.jar)
Apache commons-pool本质上是"对象池",即通过一定的规则来维护对象集合的容器;commos-pool在很多场景中,用来实现"连接池"/"任务worker池"等,大家常用的dbcp数据库连接池,也是基于commons-pool实现.
DBCP (Database Connection Pool)是一个依赖 Jakarta commons-pool 对象池机制的数据库连接池,Tomcat 的数据源使用的就是 DBCP。
DBCP(DataBase Connection Pool)数据库连接池,是java数据库连接池的一种
非常好用的JAVA数据库连接池!! 内容有详细说明和例子!!
commons-pool是apache基金会的一个开源对象池组件,我们常用的数据库连接池dpcp和redis的java客户端jedis都使用commons-pool来管理连接。
commons-dbcp.jar,commons-collections.jar和commons-pool-1.3.jar
dbcp所需jar包,DBCP 数据库连接池所需jar包里面有commons-dbcp-1.4.jar、commons-pool-1.5.6.jar.rar 1、首先在项目下创建一个文件夹,保存我们的jar包。在项目名上右击,依次点击【New】-->【Floder】,打开...
commons-dbcp.jar
免费下载,数据库连接池所需要的包(DBCP)包含配置文件(dbcpconfig.properties)
数据库连接池用到的commons-pool-1.6包,很多历史版本在官网找了半天没找到留个备份