多线程与连接池的应用

最近，为适应业务需要，需要在原来多线程的地方改用连接池，因为在没用连接池之前服务器上老是拿不到连接。

环境：MSsqlserver 2000+JDK1.6+resin

我用的C3p0线程池(jtds驱动)

C3p0配置如下：

 

<?xml version="1.0" encoding="UTF-8"?>

<c3p0-config>

<named-config name="userApp">

<property name="driverClass">

net.sourceforge.jtds.jdbc.Driver

</property>

<property name="jdbcUrl">

jdbc:jtds:sqlserver://localhost:1433/dbname

</property>

<property name="user">sa</property>

<property name="password">pawd</property>

 

<property name="initialPoolSize">12</property>

<property name="minPoolSize">10</property>

<property name="maxPoolSize">20</property>

        <property name="acquireIncrement">8</property>

<property name="acquireRetryDelay">1000</property>

<property name="maxStatements">50</property>

<property name="maxStatementsPerConnection">10</property>

 

        <property name="idleConnectionTestPeriod">360</property>

        <property name="checkoutTimeout">1800</property>

</named-config>

</c3p0-config>

 

 

用到这个连接池的地方为：

 

package me;

 

import java.sql.Connection;

import java.sql.SQLException;

 

import com.mchange.v2.c3p0.ComboPooledDataSource;

 

public class DbConnection {

private ComboPooledDataSource dataSource;

 

private DbConnection() {

dataSource = new ComboPooledDataSource("userApp");

}

 

public  Connection getConnection() throws SQLException {

return this.dataSource.getConnection();

}

public static DbConnection getSingleDBConnection(){

return new DbConnection();

}

 

public void close(Connection conn) throws SQLException {

 

if (conn != null) {

conn.close();

System.out.println("conn======>" + conn);

 

}

 

}

 

/* public static void main(String[] args) {

DbConnection ds= getSingleDBConnection();

try {

Connection conn=ds.getConnection();

Statement stmt = conn.createStatement();

  ResultSet rs = stmt.executeQuery("select * from flagInfo");

  while (rs.next()) {

   System.out.println("标识[" + rs.getString("flag") + "] 描述["

     + rs.getString("descs") + "] maxs:[" + rs.getString("maxs"));

  }

  rs.close();

  stmt.close();

  if(conn!=null){

  conn.close();

  conn=null;

  }

  

} catch (SQLException e) {

 

e.printStackTrace();

}

}*/

}

======上面这段是OK的，之前我是这么干的：

private static ComboPooledDataSource dataSource;

static{

dataSource = new ComboPooledDataSource("userApp");

}

想的是：在我七个线程里面共用一个 dataSource，想当然的我就把申明成了一个static的，但在运行时发现当线程池里的

connection用过之后，连接池便不再自动地去拿连接了，线程也就不再运行了，当时还老报一个MS.sqlException的异常；刚开始以为是c3p0配置问题，在网上查了好久包括上到C3p0的官方网站上也没有解决这个问题。弄了两三个小时，最后我想可能是static+多线程的锁出的问题吧，第二天上班时将其改成用单例模式实现，成功解决上述问题。

主要收获两点：

1，不要过度紧张配置文件，认为那个地方没配好就导致玩不下去了，这往往会误导你解决问题的方向发生偏离。

2，要小心static,凡是定义为static的他的内容在内存中便永久性地存在了，不会再作任何改变了。

另外：对于多线程的共用对象，也更体会深刻了。对于static的一定为切加小心。

 

 

后来又加了一个线程，它的主要目的是一次性将在一个时间段里面符合条件的记录拿出来处理后并insert到sqlserver里， 算时间段关键的地方如： DATEADD(hour, 2, starttime) as batchTime from flagInfo where flag=‘...’ 程序运行一段时间自动关闭这个线程后，但当我再次启动此线程欲重新跑时，就再次报出如下错误： ++++++java.sql.SQLException: An attempt by a client to checkout a Connection has timed out. 经过分析发现，当sqlserver一次插入过多数据时，sqlserver行锁处理不过来时就报连接超时的问题了， 将hour改为SECOND后，问题就解决了。

评论

2 楼 hunter090730 2012-02-22  

将hour改为SECOND后，问题就解决了.
但过了一段时间之后又出现该问题了，说明真正导致此问题的原因尚未找到。
后来仔细地阅读了一下代码：
错误的真正原因在于我的线程在归还conn pool.设置了一个条件
【即只在(runflag >0)才归还到conn pool,且在第二个try{}catch里面才有finally{}。】
导致connection没有如期放到conn pool中导致connection泄漏。
而当我原来的程序跑完之后我程序会自动将runflag =0,
由于在runflag =0这段期间内，程序并没有归还到缓冲池，导致在我的处理过程中过程中有connection泄漏，那么一段时间后，就会出现这个问题。
这确实是一个隐藏很深的Bug,解决办法是：
原来有两个try{}catch,而只有最后一个才有
finally{
//才归还到缓冲池
ds.close(conn);
}
将原来的两个try{}catch,合并成一个，无论runflag条件如何都将connection归还到
conn pool.

1 楼 hunter090730 2011-12-15  

后来又加了一个线程，在加的那支线程上系统报如下错误：
++++++java.sql.SQLException: An attempt by a client to checkout a Connection has timed out.
经过修改连接池配置文件问题得以解决：
主要将pool放大
<property name="initialPoolSize">25</property>
<property name="minPoolSize">20</property>
<property name="maxPoolSize">50</property>
<property name="acquireIncrement">18</property>
<property name="checkoutTimeout">18000</property>