众所周知,无论现在是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.
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包。
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"); } }
通过以上两个程序可见,DBCP有着比C3P0更高的效率,但是实际应用中,DBCP可能出现丢失
连接的可能,而C3P0稳定性较高。因此在实际应用中,C3P0使用较为广泛。