Java Connection Pooling mejores prácticas?

Question

Después de conseguir harto con la constante de c3p0 bloqueo Estoy girando a BoneCP de una piscina conexión alternativa para mi base de datos. Tengo una aplicación de servidor que procesa alrededor de 7.000 piezas por minuto y las necesidades de registro de esos elementos en nuestra base de datos MySQL. Actualmente tengo 100 subprocesos de trabajo y de haber puesto por mi piscina como por ejemplo:

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

¿Son esos valores aceptables para este tipo de aplicación? Lo digo porque después de un minuto o dos para que ejecute me estaba excepciones BoneCP al intentar llamar getConnection en la piscina. Gracias por la ayuda.

Este es el código que estaba usando para las llamadas db en mis subprocesos de trabajo, no puede fallar en la línea dbConn = this.dbPool.getConnection(). ¿No estoy cerrando las conexiones correctamente?

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

Este es el error que estaba viendo:

 [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)

Answer 1

  

¿Son esos valores aceptables para este tipo de aplicación? Lo digo porque después de un minuto o dos para que ejecute me estaba excepciones boneCP al intentar llamar getConnection en la piscina. gracias por la ayuda.

Si usted tiene 100 trabajadores, ¿por qué limitar la piscina a 50 conexiones (número de particiones x número máximo de conexiones por partición es decir, 5 x 10 en su caso)?

  

¿No soy el cierre de las conexiones correctamente?

se ve bien (pero tal vez permita connectionWatch como se insinuó a ver lo que la alerta se trata exactamente). Personalmente, cerca de todos los recursos que utilizo, que incluye la declaración y conjuntos de resultados. Por si acaso, aquí está el uso de lenguaje I:

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) {}
}

Se puede agrupar las llamadas anteriores en un método estático de una clase de utilidad.

O puede utilizar DbUnit.closeQuietly(Connection, Statement, ResultSet) de Commons dbUtils que ya hace esto.