首页 > 代码库 > java配置dbcp连接池,经过反复测试

java配置dbcp连接池,经过反复测试

<span style="font-size:18px;"><strong>Java代码</strong></span>
package cn.songxinqiang.samples.commonsdbcp.util;  
 import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.SQLException;
import java.util.Properties; 
 import javax.sql.DataSource; 
 import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.tomcat.dbcp.dbcp.BasicDataSourceFactory; 
 /**
 * tomcat数据库连接池管理类<br>
 * 使用为tomcat部署环境<br>
 * 需要在类路径下准备数据库连接配置文件dbcp.properties
 * 
 * 
 */
public class DBManager {
 private static final Log log = LogFactory.getLog(DBManager.class);
 private static final String configFile = "dbcp.properties"; 
  private static DataSource dataSource; 
  static {
  Properties dbProperties = new Properties();
  try {
   dbProperties.load(DBManager.class.getClassLoader()
     .getResourceAsStream(configFile));
   dataSource = BasicDataSourceFactory.createDataSource(dbProperties); 
    Connection conn = getConn();
   DatabaseMetaData mdm = conn.getMetaData();
   log.info("Connected to " + mdm.getDatabaseProductName() + " "
     + mdm.getDatabaseProductVersion());
   if (conn != null) {
    conn.close();
   }
  } catch (Exception e) {
   log.error("初始化连接池失败:" + e);
  }
 } 
  private DBManager() {
 } 
  /**
  * 获取链接,用完后记得关闭
  * 
  * @see {@link DBManager#closeConn(Connection)}
  * @return
  */
 public static final Connection getConn() {
  Connection conn = null;
  try {
   conn = dataSource.getConnection();
  } catch (SQLException e) {
   log.error("获取数据库连接失败:" + e);
  }
  return conn;
 } 
  /**
  * 关闭连接
  * 
  * @param conn
  *            需要关闭的连接
  */
 public static void closeConn(Connection conn) {
  try {
   if (conn != null && !conn.isClosed()) {
    conn.setAutoCommit(true);
    conn.close();
   }
  } catch (SQLException e) {
   log.error("关闭数据库连接失败:" + e);
  }
 } 
 }
 


properties文件

#数据库驱动
driverClassName=com.mysql.jdbc.Driver
#数据库连接地址
url=jdbc:mysql://localhost/lianjc
#用户名
username=root
#密码
password=123456 
 #连接池的最大数据库连接数。设为0表示无限制
maxActive=30
#最大空闲数,数据库连接的最大空闲时间。超过空闲时间,数据库连
#接将被标记为不可用,然后被释放。设为0表示无限制
maxIdle=10
#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制
maxWait=1000 
 #超过removeAbandonedTimeout时间后,是否进 行没用连接(废弃)的回收(默认为false,调整为true) 
removeAbandoned=true
#超过时间限制,回收没有用(废弃)的连接(默认为 300秒,调整为180)
removeAbandonedTimeout=180
 


线程测试,千万链接无压力

import java.sql.Connection;


public class TheadTest extends Thread{
	public static void main(String[] args) {
		for(int i=0;i<10000;i++){
			new TheadTest2().start();
		}
		
		
	}
	@Override
	public void run() {
		long begin=System.currentTimeMillis();
		  for(int i=0;i<100000;i++){
		   Connection conn=null;
		try {
			conn = new JDBCUtils().getConnection();
		} catch (Exception e) {
			e.printStackTrace();
		}
		  // System.out.println(i);
		   new JDBCUtils().close(null, null, conn);
		  }
		  long end=System.currentTimeMillis();
		  System.out.println("用时:"+(end-begin));
	}
}

class TheadTest2 extends Thread{
	@Override
	public void run() {
		  long begin=System.currentTimeMillis();
		  for(int i=0;i<1000;i++){
		   Connection conn=XDBManager.getConn();
		  // System.out.println(i);
		   XDBManager.closeConn(conn);
		  }
		  long end=System.currentTimeMillis();
		  System.out.println("用时:"+(end-begin));
	}
}

需要的jar包



java配置dbcp连接池,经过反复测试