【问题标题】:how to check whether a connection is closed or not in java connection pooling如何在java连接池中检查连接是否关闭
【发布时间】:2013-02-20 07:46:29
【问题描述】:

在下面的程序中,我一直在睡眠模式下执行。但是con obj仍然没有关闭。

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import org.apache.tomcat.jdbc.pool.DataSource;
import org.apache.tomcat.jdbc.pool.PoolProperties;
public class ConnPool {

public static void main(String[] args) throws Exception {
    PoolProperties p = new PoolProperties();
    p.setUrl("jdbc:mysql://localhost:3306/users");
    p.setDriverClassName("com.mysql.jdbc.Driver");
    p.setUsername("root");
    p.setPassword("root1");
    p.setJmxEnabled(true);
    p.setTestWhileIdle(false);
    p.setTestOnBorrow(true);
    p.setValidationQuery("SELECT 1");
    p.setTestOnReturn(false);
    p.setValidationInterval(10000);
    p.setTimeBetweenEvictionRunsMillis(10000);
    p.setMaxActive(100);
    p.setInitialSize(10);
    p.setMaxWait(10000);
    p.setRemoveAbandonedTimeout(60);
    p.setMinEvictableIdleTimeMillis(10000);
    p.setMinIdle(10);
    p.setLogAbandoned(true);
    p.setRemoveAbandoned(true);
    p.setJdbcInterceptors("org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;"
            + "org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer");
    DataSource datasource = new DataSource();
    datasource.setPoolProperties(p);

    Connection con = null;
    try {
        con = datasource.getConnection();
        Statement st = con.createStatement();
        ResultSet rs = st.executeQuery("select * from emp");
        int cnt = 1;
        while (rs.next()) {
            System.out.println( "Name:" + rs.getString(1)+ " Address:" + rs.getString(2) );
        }
        rs.close();
        st.close();
        Thread.sleep(40000);
        System.out.print(con.isClosed());
    } finally {
       /* if (con != null) {
            try {
                con.close();
            } catch (Exception ignore) {
            }
        }*/
    }
}

}

【问题讨论】:

    标签: java jdbc connection-pooling


    【解决方案1】:

    当您使用连接池时,您仍然需要通过调用Connection.close() 来显式关闭连接。这将向连接池发出信号,表明连接再次空闲,可以返回连接池。

    您从连接池中获得的Connection 不是与数据库的实际物理连接,而是一个逻辑连接,它是实际物理连接的包装器或代理。对于某些任务(最值得注意的close()),它将实现稍微不同的行为(以便连接池可以重用它),但对于最终用户来说,它的行为就像是一个正常的连接(例如,所有依赖对象都应该关闭)。

    您的问题不是很明确,但我假设您的意思是问为什么即使您设置了超时连接池还没有回收连接。我能想到几个原因:

    1. 您将 removeAbandonedTimeout 设置为 60 秒,而您的睡眠时间仅为 40000 毫秒(40 秒),
    2. 实现可能使用协作方式回收“废弃”连接(例如,它可能只检查何时请求新的Connection,或者当池中的可用连接不足时)

    【讨论】:

      猜你喜欢
      • 2013-01-07
      • 1970-01-01
      • 2010-11-26
      • 1970-01-01
      • 1970-01-01
      • 2011-03-22
      • 2018-12-10
      • 1970-01-01
      相关资源
      最近更新 更多