Лучшие практики создания пулов соединений Java?
-
30-09-2019 - |
Вопрос
После того, как мне надоели постоянные блокировки c3p0, я обратился к BoneCP за альтернативным пулом соединений для моей базы данных.У меня есть серверное приложение, которое обрабатывает около 7000 элементов в минуту и нуждается в регистрации этих элементов в нашей базе данных MySQL.Сейчас у меня 100 рабочих потоков, и я настроил свой пул следующим образом:
BoneCPConfig config = new BoneCPConfig();
config.setJdbcUrl("jdbc:mysql://"+Settings.MYSQL_HOSTNAME+"/"+Settings.MYSQL_DATABASE+"?autoReconnectForPools=true" );
config.setUsername(Settings.MYSQL_USERNAME);
config.setPassword(Settings.MYSQL_PASSWORD);
config.setMinConnectionsPerPartition(5);
config.setMaxConnectionsPerPartition(10);
config.setPartitionCount(5);
config.setAcquireIncrement(5);
connectionPool = new BoneCP(config); // setup the connection pool
Это приемлемые настройки для такого приложения?Я спрашиваю, потому что через минуту или две после начала работы я получал исключения BoneCP при попытке позвонить getConnection
в бассейне.Спасибо за помощь.
Вот код, который я использовал для вызовов БД в своих рабочих потоках, он не может выйти из строя в dbConn = this.dbPool.getConnection()
линия.Я неправильно закрываю соединения?
private void insertIntoDb() {
try {
Connection dbConn = this.dbPool.getConnection();
try {
PreparedStatement ps3 = dbConn.prepareStatement("INSERT IGNORE INTO test_table1 SET test1=?, test2=?, test3=?");
ps3.setString(1, "some string");
ps3.setString(2, "some other string");
ps3.setString(3, "more strings");
ps3.execute();
ps3.close();
PreparedStatement ps4 = dbConn.prepareStatement("INSERT IGNORE INTO test_table2 SET test1=?, test2=?, test3=?");
ps4.setString(1, "some string");
ps4.setString(2, "some other string");
ps4.setString(3, "more strings");
ps4.execute();
ps4.close();
} catch(SQLException e) {
logger.error(e.getMessage());
} finally {
try {
dbConn.close();
} catch (SQLException e) {
logger.error(e.getMessage());
}
}
} catch(SQLException e) {
logger.error(e.getMessage());
}
}
Это ошибка, которую я видел:
[java] WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java] WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java] WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java] WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java] WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java] WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
[java] WARN [com.google.common.base.internal.Finalizer] (ConnectionPartition.java:141) - BoneCP detected an unclosed connection and will now attempt to close it for you. You should be closing this connection in your application - enable connectionWatch for additional debugging assistance.
ERROR pool-2-thread-39 2010-09-04 13:36:19,798 com.test.testpackage.MyTask - null
java.sql.SQLException
at com.jolbox.bonecp.BoneCP.getConnection(BoneCP.java:381)
Решение
Это приемлемые настройки для такого приложения?Я спрашиваю, потому что через минуту или две после запуска я получал исключенияboneCP при попытке вызвать getConnection в пуле.Спасибо за помощь.
Если у вас 100 рабочих, почему вы ограничиваете пул 50 подключениями (количество разделов x максимальное количество подключений на раздел, т.е.5 х 10 в вашем случае)?
Я неправильно закрываю соединения?
Выглядит нормально (но, возможно, включить connectionWatch
как намекнули, чтобы увидеть, о чем именно идет предупреждение).Лично я закрываю все ресурсы, которые использую, включая наборы операторов и результатов.На всякий случай вот идиома, которую я использую:
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
conn = pool.getConnection();
pstmt = conn.prepareStatement(SOME_SQL);
pstmt.setFoo(1, foo);
...
rs = pstmt.executeQuery();
...
} finally {
if (rs != null) try { rs.close(); } catch (SQLException quiet) {}
if (pstmt != null) try { pstmt.close(); } catch (SQLException quiet) {}
if (conn != null) try { conn.close(); } catch (SQLException quiet) {}
}
Вы можете сгруппировать приведенные выше вызовы в статический метод служебного класса.
Или вы можете использовать DbUnit.closeQuietly(Connection, Statement, ResultSet)
из Commons DbUtils, который уже делает это.