5

有没有办法检查 Java EE 应用程序中的连接泄漏？

该应用程序正在我的本地计算机上运行。它使用 MySQL 数据库，用户将他的详细信息输入到该数据库中。

在我看来，连接泄漏意味着没有正确关闭连接对象。我在我的应用程序中创建了太多的数据库连接。我想检查数据库连接中是否有任何连接泄漏。

4

5 回答 5

13

log4jdbc是一个 Java JDBC 驱动程序，可以为其他 JDBC 驱动程序记录 SQL 和/或 JDBC 调用，它有一个记录器，用于记录连接打开和关闭事件以及转储所有打开的连接号。这对于查找连接泄漏问题非常有用。

您可能想要检查的另一个工具是ConnLeakFinder，它是一个用于查明 java 代码中 jdbc 连接泄漏的简单工具。我没有任何经验。

于 2010-06-19T12:53:33.287 回答
1

如果您使用的是 Java EE 应用程序服务器，您应该能够将其配置为在连接断开时检查连接，并在它们不回来时回收陈旧的连接。

连接泄漏确实是个问题。如果您将连接管理分散在代码中的很多地方，那么我会担心要找到所有这些地方是个大问题。我希望看到一个仅在定义良好的持久层中使用的 Java EE 连接池。连接应该由管理该工作单元的事务的服务层打开，并在用例结束后立即关闭它，在 finally 块的方法范围内。

如果这不是真的，我认为是时候重构了。

于 2010-06-19T14:23:25.443 回答
0

尝试使用FindBug。它是一个静态代码分析工具，可作为 eclipse 插件和独立应用程序使用。除了连接泄漏之外，它还会在您的应用程序中发现其他问题

于 2010-06-19T13:18:01.540 回答
0

使用连接工厂，例如：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class ConnectionFactory {
    private static Connection connection;

    public static synchronized Connection getConnection() throws SQLException {
        if (connection == null || connection.isClosed()) {
            connection = DriverManager.getConnection("url");
        }
        return connection;
    }
}

这样，您就永远不会留下无人看管的连接。如果您需要多个连接（出于性能考虑），请使用连接池。大多数应用服务器都有 JDBC 连接池工具。

于 2010-06-19T15:19:52.967 回答
0

解决连接泄漏的最佳方法是在测试期间进行。

您可以使用自动化实用程序，以便每个测试都验证是否存在连接泄漏。

@BeforeClass
public static void initConnectionLeakUtility() {
    if ( enableConnectionLeakDetection ) {
        connectionLeakUtil = new ConnectionLeakUtil();
    }
}

@AfterClass
public static void assertNoLeaks() {
    if ( enableConnectionLeakDetection ) {
        connectionLeakUtil.assertNoLeaks();
    }
}

ConnectionLeakUtil看起来像这样：

public class ConnectionLeakUtil {

    private JdbcProperties jdbcProperties = JdbcProperties.INSTANCE;

    private List idleConnectionCounters = 
        Arrays.asList(
            H2IdleConnectionCounter.INSTANCE,
            OracleIdleConnectionCounter.INSTANCE,
            PostgreSQLIdleConnectionCounter.INSTANCE,
            MySQLIdleConnectionCounter.INSTANCE
    );

    private IdleConnectionCounter connectionCounter;

    private int connectionLeakCount;

    public ConnectionLeakUtil() {
        for ( IdleConnectionCounter connectionCounter : 
            idleConnectionCounters ) {
            if ( connectionCounter.appliesTo( 
                Dialect.getDialect().getClass() ) ) {
                this.connectionCounter = connectionCounter;
                break;
            }
        }
        if ( connectionCounter != null ) {
            connectionLeakCount = countConnectionLeaks();
        }
    }

    public void assertNoLeaks() {
        if ( connectionCounter != null ) {
            int currentConnectionLeakCount = countConnectionLeaks();
            int diff = currentConnectionLeakCount - connectionLeakCount;
            if ( diff > 0 ) {
                throw new ConnectionLeakException( 
                    String.format(
                        "%d connection(s) have been leaked! Previous leak count: %d, Current leak count: %d",
                        diff,
                        connectionLeakCount,
                        currentConnectionLeakCount
                    ) 
                );
            }
        }
    }

    private int countConnectionLeaks() {
        try ( Connection connection = newConnection() ) {
            return connectionCounter.count( connection );
        }
        catch ( SQLException e ) {
            throw new IllegalStateException( e );
        }
    }

    private Connection newConnection() {
        try {
            return DriverManager.getConnection(
                jdbcProperties.getUrl(),
                jdbcProperties.getUser(),
                jdbcProperties.getPassword()
            );
        }
        catch ( SQLException e ) {
            throw new IllegalStateException( e );
        }
    }
}

IdleConnectionCounter可以在这篇博文中找到实现，MySQL版本如下：

public class MySQLIdleConnectionCounter implements IdleConnectionCounter {

    public static final IdleConnectionCounter INSTANCE = 
        new MySQLIdleConnectionCounter();

    @Override
    public boolean appliesTo(Class<? extends Dialect> dialect) {
        return MySQL5Dialect.class.isAssignableFrom( dialect );
    }

    @Override
    public int count(Connection connection) {
        try ( Statement statement = connection.createStatement() ) {
            try ( ResultSet resultSet = statement.executeQuery(
                    "SHOW PROCESSLIST" ) ) {
                int count = 0;
                while ( resultSet.next() ) {
                    String state = resultSet.getString( "command" );
                    if ( "sleep".equalsIgnoreCase( state ) ) {
                        count++;
                    }
                }
                return count;
            }
        }
        catch ( SQLException e ) {
            throw new IllegalStateException( e );
        }
    }
}

现在，当您运行测试时，当连接泄漏时您将失败。

于 2016-07-12T13:08:44.900 回答