как использовать c3p0 с отказоустойчивым тестом узла

Мы настроили MySQL NDB Cluster с тремя узлами, и вот подробности установки.
Node1 — MultithreadedDataNode1, SQLNode1
Node2 — MultithreadedDataNode2, SQLNode2
Node3 — Management Node

мы тестируем несколько сценариев отработки отказа, чтобы убедиться, что установка работает. На стороне клиента мы используем MySQLConnector v5.1.30 вместе с пулом соединений c3p0. Клиент настроен с параметрами Multimaster. Поэтому, если один из узлов или приложений выходит из строя, запросы JDBC должны выполняться на другом узле и продолжать отвечать.

Но мы наблюдаем ненормальное поведение, когда SQLNode (порт: 3306) выходит из строя. Соединения не переключаются на другой узел.

Конфигурации приведены ниже:

<bean id="myDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
                destroy-method="close">
        <property name="driverClass" value="com.mysql.jdbc.ReplicationDriver" />                            <!-- useConfigs=clusterBase -->
        <property name="jdbcUrl" value="jdbc:mysql:replication://192.168.102.22,192.168.102.23/hhmefep?autoReconnect=true&amp;failOverReadOnly=false&amp;roundRobinLoadBalance=true" /> 
        <property name="user" value="root"/>
        <property name="password" value="changeit"/>
        <property name="acquireIncrement" value="2" />
        <property name="minPoolSize" value="50" />
        <property name="maxPoolSize" value="100" />
        <property name="maxStatements" value="2000" />
        <property name="maxIdleTime" value="3600" />
        <property name="connectionTesterClassName" value="com.mysql.jdbc.integration.c3p0.MysqlConnectionTester" />
        <property name="testConnectionOnCheckin" value="true" />
        <property name="testConnectionOnCheckout" value="false" />
        <property name="idleConnectionTestPeriod" value="30" />
    </bean>

Когда я запускаю клиент, эти два узла работают. После этого я убиваю процесс mysqld с первого узла (192.168.102.22), получаю следующий stackTrace,

org.hibernate.exception.JDBCConnectionException: could not execute query
at org.hibernate.exception.SQLStateConverter.convert(SQLStateConverter.java:99)
at org.hibernate.exception.JDBCExceptionHelper.convert(JDBCExceptionHelper.java:66)
at org.hibernate.loader.Loader.doList(Loader.java:2536)
at org.hibernate.loader.Loader.listIgnoreQueryCache(Loader.java:2276)
at org.hibernate.loader.Loader.list(Loader.java:2271)
at org.hibernate.loader.criteria.CriteriaLoader.list(CriteriaLoader.java:119)
at org.hibernate.impl.SessionImpl.list(SessionImpl.java:1716)
at org.hibernate.impl.CriteriaImpl.list(CriteriaImpl.java:347)
at com.mi.persistence.dao.cdr.BganActiveCallsDaoImpl.findBganActiveCallsBy_Imsi_Nsapi_Apn(BganActiveCallsDaoImpl.java:53)
at sun.reflect.GeneratedMethodAccessor283.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:317)
at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:183)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:150)
at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:96)
at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:260)
at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:94)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:91)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:204)
at $Proxy23.findBganActiveCallsBy_Imsi_Nsapi_Apn(Unknown Source)
at com.mi.persistence.service.cdr.BganActiveCallsServiceImpl.findBganActiveCallsBy_Imsi_Nsapi_Apn(BganActiveCallsServiceImpl.java:22)
at sun.reflect.GeneratedMethodAccessor282.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:317)
at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:183)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:150)
at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:96)
at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:260)
at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:94)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:96)
at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:260)
at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:94)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:91)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:204)
at $Proxy24.findBganActiveCallsBy_Imsi_Nsapi_Apn(Unknown Source)
at com.mi.persistence.service.callhandler.BganAccessRequestServiceImpl.getPreeptedCalls(BganAccessRequestServiceImpl.java:384)
at com.mi.taskobjects.externalsigobj.radiusobj.BGANAccessRequest.process(BGANAccessRequest.java:175)
at com.mi.entities.scheduler.SchWorkerThread.run(SchWorkerThread.java:165)
Caused by: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure
The last packet successfully received from the server was 19,578 milliseconds ago.  The last packet sent successfully to the server was 0 milliseconds ago.
at sun.reflect.GeneratedConstructorAccessor66.newInstance(Unknown Source)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
at java.lang.reflect.Constructor.newInstance(Constructor.java:513)
at com.mysql.jdbc.Util.handleNewInstance(Util.java:409)
at com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1127)
at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3715)
at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3604)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4155)
at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2615)
at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2776)
at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2838)
at com.mysql.jdbc.LoadBalancedMySQLConnection.execSQL(LoadBalancedMySQLConnection.java:159)
at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:2082)
at com.mysql.jdbc.PreparedStatement.executeQuery(PreparedStatement.java:2212)
at com.mchange.v2.c3p0.impl.NewProxyPreparedStatement.executeQuery(NewProxyPreparedStatement.java:76)
at org.hibernate.jdbc.AbstractBatcher.getResultSet(AbstractBatcher.java:208)
at org.hibernate.loader.Loader.getResultSet(Loader.java:1953)
at org.hibernate.loader.Loader.doQuery(Loader.java:802)
at org.hibernate.loader.Loader.doQueryAndInitializeNonLazyCollections(Loader.java:274)
at org.hibernate.loader.Loader.doList(Loader.java:2533)
... 42 more
Caused by: java.io.EOFException: Can not read response from server. Expected to read 4 bytes, read 0 bytes before connection was unexpectedly lost.
at com.mysql.jdbc.MysqlIO.readFully(MysqlIO.java:3161)
at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3615)
... 56 more
Apr 24, 2014 2:13:13 PM com.mchange.v2.async.ThreadPoolAsynchronousRunner$DeadlockDetector run
WARNING: com.mchange.v2.async.ThreadPoolAsynchronousRunner$DeadlockDetector@18138d9 -- APPARENT DEADLOCK!!! Creating emergency threads for unassigned pending tasks!
Apr 24, 2014 2:13:13 PM com.mchange.v2.async.ThreadPoolAsynchronousRunner$DeadlockDetector run
WARNING: com.mchange.v2.async.ThreadPoolAsynchronousRunner$DeadlockDetector@18138d9 -- APPARENT DEADLOCK!!! Complete Status: 
Managed Threads: 3
Active Threads: 3
Active Tasks: 
    com.mchange.v2.resourcepool.BasicResourcePool$1RefurbishCheckinResourceTask@2dbdcf (com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#2)
    com.mchange.v2.resourcepool.BasicResourcePool$1RefurbishCheckinResourceTask@1088a28 (com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#1)
    com.mchange.v2.resourcepool.BasicResourcePool$1RefurbishCheckinResourceTask@1a67efd (com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#0)
Pending Tasks: 
    com.mchange.v2.resourcepool.BasicResourcePool$1RefurbishCheckinResourceTask@1db547d
    com.mchange.v2.resourcepool.BasicResourcePool$1RefurbishCheckinResourceTask@87fa45
    com.mchange.v2.c3p0.stmt.GooGooStatementCache$1StatementCloseTask@13fcd69
    com.mchange.v2.resourcepool.BasicResourcePool$AcquireTask@1c6dc6d
    com.mchange.v2.resourcepool.BasicResourcePool$1DestroyResourceTask@b198d1
    com.mchange.v2.resourcepool.BasicResourcePool$AcquireTask@1a7ce01
    com.mchange.v2.resourcepool.BasicResourcePool$1DestroyResourceTask@1c5be25
    com.mchange.v2.resourcepool.BasicResourcePool$AcquireTask@1469706
    com.mchange.v2.resourcepool.BasicResourcePool$1DestroyResourceTask@1654503
    com.mchange.v2.resourcepool.BasicResourcePool$AcquireTask@195f1b4
    com.mchange.v2.resourcepool.BasicResourcePool$1DestroyResourceTask@12f893d
    com.mchange.v2.resourcepool.BasicResourcePool$AcquireTask@1db4400
    com.mchange.v2.resourcepool.BasicResourcePool$1DestroyResourceTask@4d7ab3
    com.mchange.v2.resourcepool.BasicResourcePool$AcquireTask@b29aa5
    com.mchange.v2.resourcepool.BasicResourcePool$1DestroyResourceTask@1c6fb4f
    com.mchange.v2.resourcepool.BasicResourcePool$AcquireTask@9d2c8e
    com.mchange.v2.resourcepool.BasicResourcePool$1DestroyResourceTask@d843e0
    com.mchange.v2.c3p0.stmt.GooGooStatementCache$1StmtAcquireTask@504b76
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@18a408c
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@193e4a4
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@87d60d
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@1f6002a
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@184e113
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@d4bbb0
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@6e4a4c
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@cfc9f4
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@1d3c0f3
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@120989c
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@1034f45
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@497a1b
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@1ef8e0b
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@568dc9
    com.mchange.v2.resourcepool.BasicResourcePool$AsyncTestIdleResourceTask@76bb9c
Pool thread stack traces:
Thread[com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#2,5,main]
    java.lang.Thread.sleep(Native Method)
    com.mysql.jdbc.ConnectionImpl.connectWithRetries(ConnectionImpl.java:2396)
    com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2326)
    com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:832)
    com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:46)
    sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source)
    sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
    java.lang.reflect.Constructor.newInstance(Constructor.java:513)
    com.mysql.jdbc.Util.handleNewInstance(Util.java:409)
    com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:417)
    com.mysql.jdbc.LoadBalancingConnectionProxy.createConnectionForHost(LoadBalancingConnectionProxy.java:383)
    com.mysql.jdbc.RandomBalanceStrategy.pickConnection(RandomBalanceStrategy.java:75)
    com.mysql.jdbc.LoadBalancingConnectionProxy.pickNewConnection(LoadBalancingConnectionProxy.java:711)
    com.mysql.jdbc.LoadBalancingConnectionProxy.dealWithInvocationException(LoadBalancingConnectionProxy.java:415)
    com.mysql.jdbc.LoadBalancingConnectionProxy.invoke(LoadBalancingConnectionProxy.java:654)
    com.mysql.jdbc.LoadBalancingConnectionProxy.invoke(LoadBalancingConnectionProxy.java:549)
    $Proxy22.ping(Unknown Source)
    com.mysql.jdbc.ReplicationConnection.ping(ReplicationConnection.java:986)
    sun.reflect.GeneratedMethodAccessor13.invoke(Unknown Source)
    sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    java.lang.reflect.Method.invoke(Method.java:597)
    com.mchange.v2.c3p0.impl.NewProxyConnection.rawConnectionOperation(NewProxyConnection.java:1315)
    com.mysql.jdbc.integration.c3p0.MysqlConnectionTester.activeCheckConnection(MysqlConnectionTester.java:78)
    com.mchange.v2.c3p0.impl.C3P0PooledConnectionPool$1PooledConnectionResourcePoolManager.testPooledConnection(C3P0PooledConnectionPool.java:368)
    com.mchange.v2.c3p0.impl.C3P0PooledConnectionPool$1PooledConnectionResourcePoolManager.refurbishResourceOnCheckin(C3P0PooledConnectionPool.java:301)
    com.mchange.v2.resourcepool.BasicResourcePool.attemptRefurbishResourceOnCheckin(BasicResourcePool.java:1606)
    com.mchange.v2.resourcepool.BasicResourcePool.access$200(BasicResourcePool.java:32)
    com.mchange.v2.resourcepool.BasicResourcePool$1RefurbishCheckinResourceTask.run(BasicResourcePool.java:1228)
    com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run(ThreadPoolAsynchronousRunner.java:547)
Thread[com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#1,5,main]
    java.lang.Thread.sleep(Native Method)
    com.mysql.jdbc.ConnectionImpl.connectWithRetries(ConnectionImpl.java:2396)
    com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2326)
    com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:832)
    com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:46)
    sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source)
    sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
    java.lang.reflect.Constructor.newInstance(Constructor.java:513)
    com.mysql.jdbc.Util.handleNewInstance(Util.java:409)
    com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:417)
    com.mysql.jdbc.LoadBalancingConnectionProxy.createConnectionForHost(LoadBalancingConnectionProxy.java:383)
    com.mysql.jdbc.RandomBalanceStrategy.pickConnection(RandomBalanceStrategy.java:75)
    com.mysql.jdbc.LoadBalancingConnectionProxy.pickNewConnection(LoadBalancingConnectionProxy.java:711)
    com.mysql.jdbc.LoadBalancingConnectionProxy.dealWithInvocationException(LoadBalancingConnectionProxy.java:415)
    com.mysql.jdbc.LoadBalancingConnectionProxy.invoke(LoadBalancingConnectionProxy.java:654)
    com.mysql.jdbc.LoadBalancingConnectionProxy.invoke(LoadBalancingConnectionProxy.java:549)
    $Proxy22.ping(Unknown Source)
    com.mysql.jdbc.ReplicationConnection.ping(ReplicationConnection.java:986)
    sun.reflect.GeneratedMethodAccessor13.invoke(Unknown Source)
    sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    java.lang.reflect.Method.invoke(Method.java:597)
    com.mchange.v2.c3p0.impl.NewProxyConnection.rawConnectionOperation(NewProxyConnection.java:1315)
    com.mysql.jdbc.integration.c3p0.MysqlConnectionTester.activeCheckConnection(MysqlConnectionTester.java:78)
    com.mchange.v2.c3p0.impl.C3P0PooledConnectionPool$1PooledConnectionResourcePoolManager.testPooledConnection(C3P0PooledConnectionPool.java:368)
    com.mchange.v2.c3p0.impl.C3P0PooledConnectionPool$1PooledConnectionResourcePoolManager.refurbishResourceOnCheckin(C3P0PooledConnectionPool.java:301)
    com.mchange.v2.resourcepool.BasicResourcePool.attemptRefurbishResourceOnCheckin(BasicResourcePool.java:1606)
    com.mchange.v2.resourcepool.BasicResourcePool.access$200(BasicResourcePool.java:32)
    com.mchange.v2.resourcepool.BasicResourcePool$1RefurbishCheckinResourceTask.run(BasicResourcePool.java:1228)
    com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run(ThreadPoolAsynchronousRunner.java:547)
Thread[com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#0,5,main]
    java.lang.Thread.sleep(Native Method)
    com.mysql.jdbc.ConnectionImpl.connectWithRetries(ConnectionImpl.java:2396)
    com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2326)
    com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:832)
    com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:46)
    sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source)
    sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
    java.lang.reflect.Constructor.newInstance(Constructor.java:513)
    com.mysql.jdbc.Util.handleNewInstance(Util.java:409)
    com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:417)
    com.mysql.jdbc.LoadBalancingConnectionProxy.createConnectionForHost(LoadBalancingConnectionProxy.java:383)
    com.mysql.jdbc.RandomBalanceStrategy.pickConnection(RandomBalanceStrategy.java:75)
    com.mysql.jdbc.LoadBalancingConnectionProxy.pickNewConnection(LoadBalancingConnectionProxy.java:711)
    com.mysql.jdbc.LoadBalancingConnectionProxy.dealWithInvocationException(LoadBalancingConnectionProxy.java:415)
    com.mysql.jdbc.LoadBalancingConnectionProxy.invoke(LoadBalancingConnectionProxy.java:654)
    com.mysql.jdbc.LoadBalancingConnectionProxy.invoke(LoadBalancingConnectionProxy.java:549)
    $Proxy22.ping(Unknown Source)
    com.mysql.jdbc.ReplicationConnection.ping(ReplicationConnection.java:986)
    sun.reflect.GeneratedMethodAccessor13.invoke(Unknown Source)
    sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    java.lang.reflect.Method.invoke(Method.java:597)
    com.mchange.v2.c3p0.impl.NewProxyConnection.rawConnectionOperation(NewProxyConnection.java:1315)
    com.mysql.jdbc.integration.c3p0.MysqlConnectionTester.activeCheckConnection(MysqlConnectionTester.java:78)
    com.mchange.v2.c3p0.impl.C3P0PooledConnectionPool$1PooledConnectionResourcePoolManager.testPooledConnection(C3P0PooledConnectionPool.java:368)
    com.mchange.v2.c3p0.impl.C3P0PooledConnectionPool$1PooledConnectionResourcePoolManager.refurbishResourceOnCheckin(C3P0PooledConnectionPool.java:301)
    com.mchange.v2.resourcepool.BasicResourcePool.attemptRefurbishResourceOnCheckin(BasicResourcePool.java:1606)
    com.mchange.v2.resourcepool.BasicResourcePool.access$200(BasicResourcePool.java:32)
    com.mchange.v2.resourcepool.BasicResourcePool$1RefurbishCheckinResourceTask.run(BasicResourcePool.java:1228)
    com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run(ThreadPoolAsynchronousRunner.java:547)

Пожалуйста, поправьте меня, если я что-то упустил ..
Спасибо,
Parimal


mysql mysql-connector c3p0 connector-j mysql-cluster
person Patel Parimal    schedule 24.04.2014    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Итак, что происходит, понятно: c3p0 тестирует Connections при регистрации. эти тесты зависают, ни успешно, ни неудачно с исключением, в конечном итоге насыщая и блокируя пул потоков.

На вопрос, на который я не могу ответить точно, почему тесты Connection зависают. Из трассировки стека видно, что они пытаются переподключиться, что вы и хотите, но к вашему реплицированному (подчиненному) серверу. Вместо этого переподключения терпят неудачу, и потоки засыпают. Глядя на исходный код класса ConnectionImpl mysql, connectWithRetry приостанавливает initialTimout секунд (по умолчанию 2) и повторяет попытки до времени maxReconnects (по умолчанию 3). по умолчанию это означает, что все должно зависать только до 6 секунд. Однако похоже, что вы можете испытывать более длительные зависания, чем это.

Одним из обходных путей было бы просто установить autoReconnect=false. Тогда тесты подключения, вероятно, просто не пройдут, c3p0 попытается получить новое подключение, которое, как мы надеемся, будет успешным с отказоустойчивого сервера.

Другие вещи, которые можно попробовать, - это уменьшить initialTimeout и maxConnects, чтобы ускорить сбои. Опять же, если внутреннее переподключение завершится ошибкой, c3p0 повторно получит неработающие подключения, которые теперь должны указывать на отказоустойчивый сервер.

В конечном счете, здесь есть пара неизвестных: (1) Ваш сервер репликации, тот, с которым ваши Connections должны переподключаться, работает и работает? Поскольку явная проблема заключается в том, что драйвер mysql не может установить новое соединение после сбоя, реальный вопрос заключается в том, почему com.mysql.jdbc.ReplicationDriver не ведет себя так, как рекламируется, и подключается к альтернативному серверу. Одна возможность состоит в том, что есть просто проблема с альтернативным сервером. Убедитесь, что вы можете напрямую подключиться к этому [ jdbc:mysql://192.168.102.23/hhmefep ]. Если нет, то это ваши проблемы! (2) Если вы можете подключиться к альтернативному серверу, мы все еще не знаем, действительно ли работает логика отработки отказа до connectWithRetries(...), то есть пытается ли она подключиться к реплицированному серверу? (Одна вещь, которую, возможно, стоит сделать, — это намеренно отключить реплицированный сервер, чтобы не было ничего, что можно было бы переключить при сбое. Сбоит ли приложение более чисто?)

Думаю, с практической точки зрения я бы проверил, работает ли сервер репликации, уменьшив initialTimout и maxReconnects (возможно, к 1 и 1), и повторите попытку. Если это не сработает, я бы установил для autoReconnect значение false. Если вы установили для autoReconnect значение false, вы можете использовать параметр c3p0 maxConnectionAge, чтобы гарантировать, что, когда основной сервер вернется, соединения будут (справедливо) быстро заменены соединениями обратно к мастеру. Установите для параметра maxCoonnectionAge значение, например, несколько минут (а не несколько секунд, иначе вы будете перегружать подключения и снизите производительность).

удачи!

person Steve Waldman    schedule 24.04.2014
comment
Я пробовал оба подхода (1) уменьшая initialTimeout и maxReconnects до 1 и (2) устанавливая autoReconnect=false и maxConnectionAge=600 sec. Но все же производительность драйвера не улучшается. Я также получаю сообщения WARN из кеша hazelcast Apr 25, 2014 3:36:34 PM com.mi.persistence.model.network.Ggsn WARNING: [192.168.6.192]:5701 [NY-HHMEA] [3.2-RC2] Cache lock could not be acquired! - person Patel Parimal; 25.04.2014
comment
Эта запись в блоге помогла добиться лучших результатов. - person Patel Parimal; 25.04.2014