Блог

Мы работаем над электронной коммерцией, созданной с помощью Hybris Framework, и в настоящее время у нас проблема с подключением к базе данных (я полагаю), и мы понятия не имеем, как ее решить. Это происходит только в производственной среде и только на серверах, которые используются ESB (2 сервера в общей сложности 40).

В принципе, иногда (1-3 в день) мы обнаруживаем сеансы, ожидающие некоторого незанятого сеанса (сообщение SEL * NET от клиента). Мы можем только вручную уничтожить владельца, чтобы освободить эти сеансы.

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

Сервер ESB: 10 запросов в минуту Сервер внешнего интерфейса: 300 запросов в минуту

В журнале приложений я обнаружил много ошибок закрытого соединения на этих 2 серверах, и я думаю, что это связано с нашей проблемой, но на самом деле я не знаю почему. В access.войдите, у меня есть этот запрос:

 [26/Mar/2019:09:04:39  0100] "GET /blockorder?orderCode=XXXXamp;access_token=XXXX HTTP/1.1" 400 122 "-" "AHC/1.0"
  

и в консоли.войти У меня есть это:

 hybrisHTTP8 2019-03-26 09:04:39,184 ERROR [[10.125.31.2] ] () [de.hybris.platform.jdbcwrapper.ConnectionImpl] error resetting AutoCommit
java.sql.SQLRecoverableException: Closed Connection
        at oracle.jdbc.driver.PhysicalConnection.setAutoCommit(PhysicalConnection.java:3763)
        at de.hybris.platform.jdbcwrapper.ConnectionImpl.doSetAutoCommit(ConnectionImpl.java:431)
        at de.hybris.platform.jdbcwrapper.ConnectionImpl.restoreAutoCommit(ConnectionImpl.java:185)
        at de.hybris.platform.jdbcwrapper.ConnectionImpl.unsetTxBound(ConnectionImpl.java:175)
        at de.hybris.platform.tx.Transaction.unsetTxBoundConnection(Transaction.java:920)
        at de.hybris.platform.tx.Transaction.clearTxBoundConnectionAndNotify(Transaction.java:897)
        at de.hybris.platform.tx.Transaction.clearTxBoundConnectionAndNotifyRollback(Transaction.java:887)
        at de.hybris.platform.tx.Transaction.rollbackOuter(Transaction.java:1084)
        at de.hybris.platform.tx.Transaction.rollback(Transaction.java:1028)
        at de.hybris.platform.tx.Transaction.commit(Transaction.java:690)
        at de.hybris.platform.tx.Transaction.finishExecute(Transaction.java:1218)
        at de.hybris.platform.tx.Transaction.execute(Transaction.java:1205)
        at de.hybris.platform.tx.Transaction.execute(Transaction.java:1160)
        at de.hybris.platform.jalo.Item.setAllAttributes(Item.java:2082)
        at de.hybris.platform.jalo.Item.setAllAttributes(Item.java:2057)
        at de.hybris.platform.servicelayer.internal.converter.impl.ItemModelConverter.storeAttributes(ItemModelConverter.java:1503)
        at de.hybris.platform.servicelayer.internal.converter.impl.ItemModelConverter.save(ItemModelConverter.java:730)
        at de.hybris.platform.servicelayer.internal.model.impl.wrapper.ModelWrapper.save(ModelWrapper.java:336)
        at de.hybris.platform.servicelayer.internal.model.impl.ResolvingModelPersister.saveOthers(ResolvingModelPersister.java:64)
        at de.hybris.platform.servicelayer.internal.model.impl.ResolvingModelPersister.persist(ResolvingModelPersister.java:49)
        at de.hybris.platform.servicelayer.internal.model.impl.DefaultModelService.saveViaJalo(DefaultModelService.java:1059)
        at de.hybris.platform.servicelayer.internal.model.impl.DefaultModelService.doJaloPersistence(DefaultModelService.java:648)
        at de.hybris.platform.servicelayer.internal.model.impl.DefaultModelService.persistWrappers(DefaultModelService.java:1002)
        at de.hybris.platform.servicelayer.internal.model.impl.DefaultModelService.performPersistenceOperations(DefaultModelService.java:626)
        at de.hybris.platform.servicelayer.internal.model.impl.DefaultModelService.saveAllInternal(DefaultModelService.java:620)
        at de.hybris.platform.servicelayer.internal.model.impl.DefaultModelService.saveAll(DefaultModelService.java:600)
        at de.hybris.platform.servicelayer.internal.model.impl.DefaultModelService.save(DefaultModelService.java:548)
        at com.test.fulfilment.process.impl.DefaultOrderProcessService.requestForcedOrderCancellation(DefaultOrderProcessService.java:131)
        at com.test.application.order.facades.impl.DefaultOrderFacade.forcedOrderCancel(DefaultOrderFacade.java:62)
        at com.test.application.controllers.OrderController.blockOrder(OrderController.java:520)
  

Наша конфигурация пула следующая:

 {
    "maxIdle": 90,
    "minIdle": 2,
    "maxActive": 90,
    "maxWait": 10000,
    "whenExhaustedAction": 1,
    "testOnBorrow": true,
    "testOnReturn": true,
    "testWhileIdle": true,
    "timeBetweenEvictionRunsMillis": 10000,
    "numTestsPerEvictionRun": 100,
    "minEvictableIdleTimeMillis": 300000,
    "softMinEvictableIdleTimeMillis": -1,
    "lifo": true
}
  

Наша конфигурация tomcat:

 tomcat.generaloptions.JDBC=-Doracle.jdbc.ReadTimeout=60000
tomcat.generaloptions.TIMEOUT=-Dsun.net.client.defaultConnectTimeout=60000 -Dsun.net.client.defaultReadTimeout=60000
tomcat.ajp.acceptCount=100
tomcat.ajp.maxThreads=400
tomcat.maxthreads=400
tomcat.minsparethreads=50
tomcat.maxidletime=10000
tomcat.connectiontimeout=120000
tomcat.acceptcount=100
  

Мы попытались удалить oracle.jdbc.ReadTimeout, но в результате мы начали видеть закрытые соединения на других серверах.

Код, который вызывает эту ошибку, довольно прост (и он работает в 95% случаев):

     @Override
    public boolean requestForcedOrderCancellation(final OrderModel order) {
        Transaction.current().begin();
        try {
            modelService.lock(order.getPk());
            modelService.refresh(order);
            order.setForcedCancelled(true);
            modelService.save(order);
            Transaction.current().commit();
            return true;
        catch (Exception e) {
            LOG.error(e.getMessage(), e);
            Transaction.current().rollback();
            return false;
        }
    }
  

Мы пробовали также без явной блокировки, и проблема точно такая же.
Похоже, что соединение уже закрыто, и мы не можем откатить (или зафиксировать) транзакции, которые все еще ожидают в БД.

Я ожидаю избежать этой блокировки и этих ошибок закрытого соединения.

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

Предыстория: Базы данных ненавидят длительные соединения, потому что это может привести к их истощению. Таким образом, они имеют тенденцию закрывать соединение через некоторое время. Другим виновником являются брандмауэры, которые имеют тенденцию удалять незанятые соединения из своих таблиц. Пулы соединений знают, как справиться с этим, протестировав соединения (все эти test* параметры в вашей конфигурации выше).

Иногда вам нужно сообщить своему пулу, как протестировать соединение. Проверьте документацию. Для Oracle хорошим тестом является select 1 from dual .

Я думаю, что ваша настоящая проблема — это застрявшие сеансы. Узнайте, чего они ждут, просмотрев дамп потока Java, который вы можете создать с помощью инструмента jstack , который поставляется с Java SDK.

Мы обнаружили, что проблема возникла из-за неперехваченного исключения / ошибки в транзакционном коде.

Сервер ответил с ошибкой, и Hybris не откатил транзакцию, которая все еще открыта. Тот же поток повторно используется некоторое время спустя (возможно, несколько дней), и старая транзакция все еще открыта.

Когда этот поврежденный поток используется для блокировки некоторых строк в базе данных, даже если мы фиксируем транзакцию в коде, она не фиксируется в базе данных, потому что внутри Hybris есть счетчик транзакций для обработки внутренних транзакций (возможно, используемый в вызываемых методах). Транзакция фиксируется / откатывается в БД только тогда, когда мы используем метод фиксации / отката, а счетчик транзакций равен 1.

 Request1:
    Transaction.begin() // Hybris Counter = 1
    doSomething() // This throws Exception, Application Exit, Hybris Counter is still 1
    try {
        Transaction.commit()
    } catch (Exception e) {
        Transaction.rollback();
    }

Request2 on same thread:
    Transaction.begin() // Hybris Counter now is 2
    doSomething() // Works OK, Hybris Counter is still 2
    try {       
        Transaction.commit() // HybrisCounter -= 1
        // Transaction is not commited to DB because Hybris counter now is 1
    } catch (Exception e) {
        Transaction.rollback();
    }

Request3 on same thread:
    Transaction.begin() // Hybris Counter now is 2
    lockRow() 
    // Row is locked for the whole transaction (the same opened in R1)
    // Everything is OK
    try {       
        Transaction.commit() // HybrisCounter -= 1
        // Transaction is not commited to DB because Hybris counter now is 1
        // Row is still locked
        // Next requests to the same row will wait lock forever
    } catch (Exception e) {
        Transaction.rollback();
    }