PostgreSQL JDBC 驱动程序 logUnclosedConnections 不工作

Question

我正在测试 PostgreSQL JDBC 驱动程序的附加属性，以检查它是否有助于找出连接泄漏。即使我特意不关闭Connection、PreparedStatement、ResultSet，也没有报错。

我怎样才能使logUnclosedConnections 工作。

这是我的示例程序

public static void main( String[] args ) throws Exception {

    Properties dbProps = new Properties();
    dbProps.setProperty( "user", "xxxxxxx" );
    dbProps.setProperty( "password", "xxxxxxxxxx" );
    dbProps.setProperty( "logServerErrorDetail", "true" );
    dbProps.setProperty( "logUnclosedConnections", "true" );
    dbProps.setProperty( "loggerLevel", "DEBUG" );

    Connection conn = DriverManager.getConnection( "jdbc:postgresql://xxxxx.xxxxx.xxx:xxx/xxxxx", dbProps );

    try {
        PreparedStatement pstmt = conn.prepareStatement( "select count(*) from xx.xx limit 10" );

        ResultSet rSet = pstmt.executeQuery();

        while ( rSet.next() ) {
            System.out.println( "count is " + rSet.getInt( 1 ) );

        }

    } catch ( Exception e ) {

        e.printStackTrace();
    }
}

结果是

count is 687
Sep 08, 2021 12:21:44 PM org.postgresql.Driver connect
FINE: Connecting with URL: jdbc:postgresql://xxxxx.xxxx.xxxx:xxx/xxxx
Sep 08, 2021 12:21:44 PM org.postgresql.jdbc.PgConnection <init>
FINE: PostgreSQL JDBC Driver 42.2.23
Sep 08, 2021 12:21:44 PM org.postgresql.jdbc.PgConnection setDefaultFetchSize
FINE:   setDefaultFetchSize = 0
Sep 08, 2021 12:21:44 PM org.postgresql.jdbc.PgConnection setPrepareThreshold
FINE:   setPrepareThreshold = 5
Sep 08, 2021 12:21:44 PM org.postgresql.core.v3.ConnectionFactoryImpl openConnectionImpl
FINE: Trying to establish a protocol version 3 connection to xxxx.xxxx.xxx:xxx
Sep 08, 2021 12:21:44 PM org.postgresql.core.v3.ConnectionFactoryImpl tryConnect
FINE: Receive Buffer Size is 65,536
Sep 08, 2021 12:21:44 PM org.postgresql.core.v3.ConnectionFactoryImpl tryConnect
FINE: Send Buffer Size is 65,536
Sep 08, 2021 12:21:44 PM org.postgresql.ssl.MakeSSL convert
FINE: converting regular socket connection to ssl

编辑 1

@Scary Wombat 和 @Stephen C 建议的更改，但结果相同。

未报告未关闭的连接。

public static void main( String[] args ) throws Exception {

    Properties dbProps = new Properties();
    dbProps.setProperty( "user", "postgres" );
    dbProps.setProperty( "password", "AuR0ra$dba#$" );
    dbProps.setProperty( "logServerErrorDetail", "true" );
    dbProps.setProperty( "logUnclosedConnections", "true" );
    dbProps.setProperty( "loggerLevel", "DEBUG" );

    Connection conn = DriverManager.getConnection( "jdbc:postgresql://devdbmaster.koncert.com:5499/dev_koncert_v10.5", dbProps );

    try {

        for ( int i = 0; i < 100; i++ ) {
            PreparedStatement pstmt = conn.prepareStatement( "select count(*) from cl.users limit 10" );

            ResultSet rSet = pstmt.executeQuery();

            while ( rSet.next() ) {
                System.out.println( "count is " + rSet.getInt( 1 ) );

            }

            Thread.sleep( 10 );
        }

    } catch ( Exception e ) {

        e.printStackTrace();
    }
    conn = null;
    System.gc();
    Thread.sleep( 1 );
}

编辑 2

按照 @Gus 和 @Stephen C

的建议，在 System.gc(); 之前添加了 conn = null;

Answer 1

根据 PostgreSQL JDBC 驱动文档：

logUnclosedConnections = boolean

客户端可能会因未能调用其close() 方法而泄漏Connection 对象。最终这些对象将被垃圾回收并调用finalize() 方法，如果调用者自己忽略了这将关闭Connection。使用终结器只是权宜之计。

为了帮助开发人员检测和纠正这些泄漏的来源，添加了logUnclosedConnections URL 参数。它会在每次打开 Connection 时捕获一个堆栈跟踪，如果在未关闭的情况下到达 finalize() 方法，则堆栈跟踪将打印到日志中。

因此，您在这里测试的是一种机制，用于调试泄漏Connection 对象的错误代码。

问题在于您没有以正确的方式对其进行测试。如描述所述，该机制依赖 垃圾收集器发现无法访问的Connection 对象。为此，需要完成 3 件事：

1. GC 需要运行。
2. GC 需要找到无法访问的Connection。请注意，GC 并不保证每次运行时都能找到所有无法访问的对象。
3. GC 运行后，它发现的不可达的Connection 对象需要被终结。

在您的测试中，您创建并使用Connection，然后main 结束，终止JVM。到main 结束时，GC 还没有运行。所以泄露的Connection没有被检测到。

要使这个测试“工作”，您需要在循环体的末尾添加以下内容；

  rRet = null;
  pstmt = null;

然后在main方法的末尾添加：

  conn = null;
  System.gc();
  Thread.sleep(1);

空分配使Connection 无法访问。 （注意PreparedStatement 和ResultSet 都将引用Connection。我们需要销毁所有可以使Connection 可访问的引用。）

System.gc() 语句要求 JVM 运行 GC。

Thread.sleep(1) 语句再等待一秒钟...以便 JVM 有机会在 JVM 结束之前运行连接终结器。

---

我在引号中说“工作”有几个原因：

1. 您不应该在生产代码中做这种事情。调用System.gc() 效率低下。更好的办法是让 GC 在 JVM 认为有必要时运行。

2. 事实上，System.gc() 根本不能保证做任何事情。同样，您不能依赖立即运行的终结器。因此，在某些情况下，添加的两个语句将不起作用。