Как отследить утечки соединения с базой данных - PullRequest
Новая
       27

Как отследить утечки соединения с базой данных

7 голосов
/ 21 апреля 2011

У нас есть приложение с утечками соединения (SQL Server сообщает, что достигнут максимальный размер пула).Я один на своем компьютере разработчика (очевидно), и просто перемещаясь по приложению, я вызываю эту ошибку.Монитор активности SQL Server показывает большое количество процессов, использующих мою базу данных.

Я хочу найти, какие файлы открывают соединения, но не используют их.Я думал об использовании чего-то вроде grep, чтобы для каждого файла подсчитать количество «.Open ()» и число «.Close ()» и получить файл, для которого числа не равны.Реально ли это?

Дополнительный вопрос: соответствуют ли процессы, обнаруженные в SQL Server Activity Monitor, соединениям?Если нет, как я могу узнать, сколько соединений открыто в моей базе данных?

Приложение находится на asp.net (vb) 3.5 с SQL Server 2005. В настоящее время мы не используем LINQ (пока) иличто-нибудь подобное.

Спасибо

Ответы [ 2 ]

9 голосов
/ 21 апреля 2011

При просмотре кода со стороны SQL Server вы можете выполнить следующий запрос, чтобы получить представление о том, какие запросы в последний раз выполнялись для спящих соединений. (открытые соединения, которые ничего не делают) 

SELECT ec.session_id, last_read, last_write, text, client_net_address, program_name, host_process_id, login_name
FROM sys.dm_exec_connections  ec
JOIN sys.dm_exec_sessions es
  ON ec.session_id = es.session_id
CROSS APPLY sys.dm_exec_sql_text(ec.most_recent_sql_handle) AS dest
where es.status = 'sleeping'

Со стороны приложения вы можете отлаживать с sos.dll, как описано в следующих статьях:

Если вам нужна дополнительная информация о том, как использовать windbg, эти статьи являются хорошим введением:

2 голосов
/ 12 июля 2016

Лучший способ устранить утечки в соединении - это сделать во время тестирования .

Вы можете использовать автоматизированную утилиту, чтобы каждый тест проверял наличие утечки соединения. 

@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 );
        }
    }
}

Теперь, когда вы запустите свои тесты, вы получите ошибку при утечке соединения: 

:hibernate-core:test

org.hibernate.jpa.test.EntityManagerFactoryClosedTest > classMethod FAILED
    org.hibernate.testing.jdbc.leak.ConnectionLeakException
...