第一次发布问题。谢谢大家!
我遇到的问题已经存在了一段时间,我们找不到解决方案。简而言之,使用Java 8,Spring,Hibernate,PostgreSQL,JSF(PrimeFaces(,Webflow构建应用程序。 问题与连接被关闭有关,但似乎应用程序仍在使用它,因此下次某些逻辑借用相同的连接时,它只是"偶然"了它,并抛出异常:
Caused by: org.hibernate.exception.GenericJDBCException: could not prepare statement
at org.hibernate.exception.internal.StandardSQLExceptionConverter.convert(StandardSQLExceptionConverter.java:47)
Caused by: java.sql.SQLException: Connection has already been closed.
at org.apache.tomcat.jdbc.pool.ProxyConnection.invoke(ProxyConnection.java:117)
at org.apache.tomcat.jdbc.pool.JdbcInterceptor.invoke(JdbcInterceptor.java:108)
应用程序可以毫无问题地工作几天,直到发生某些事情,它从 tomcat 收到连接放弃警告。从那里开始就无法正常工作,许多进程会得到关闭的连接并且会失败,因为连接已经关闭:
WARNING [Tomcat JDBC Pool Cleaner[1989780873:1502425160484]] org.apache.tomcat.jdbc.pool.ConnectionPool.abandon Connection has been abandoned PooledConnection[org.postgresql.jdbc.PgConnection@234be71f]:java.lang.Exception
at org.apache.tomcat.jdbc.pool.ConnectionPool.getThreadDump(ConnectionPool.java:1093)
我们的团队在这个问题上花费了数小时,在网上搜索,并咨询其他开发人员,一开始这一切都归结为试图调整Tomcat服务器.xml,但没有任何成功。它可以再运行几天,然后因同样的问题而失败,服务器将变得不一致,因此唯一要做的就是重新启动它。我们添加的拦截器没有帮助,只是作为解决问题的一部分。
直到后来我们才能可靠地复制这个问题,而且这个问题本身就很有趣。因此,当在事务、自定义或常规 Java 中抛出任何异常时,Tomcat 会抛出放弃的连接(关闭它(,例如如果有 NoResultException 或一些基于断言的 MyCustomException;60 秒后(删除放弃超时(Tomcat 将显示警告消息,连接将关闭。但是逻辑的问题仍然是指它,更多的连接关闭了,更多的东西在执行业务逻辑时中断了。
服务器中配置了两个数据源.xml(一个用于业务逻辑,另一个用于作业(,如下所示:
<Resource auth="Container" driverClassName="org.postgresql.Driver"
factory="org.apache.tomcat.jdbc.pool.DataSourceFactory"
initialSize="5"
jdbcInterceptors=
"org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;
org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer;
org.apache.tomcat.jdbc.pool.interceptor.SlowQueryReportJmx (threshold=10000)"
logAbandoned="true"
maxActive="30"
minEvictableIdleTimeMillis="30000"
minIdle="5"
name="jdbc/my-app-db"
password=""
removeAbandoned="true"
removeAbandonedTimeout="60"
testOnBorrow="true"
testOnReturn="false"
testWhileIdle="true"
timeBetweenEvictionRunsMillis="5000"
type="javax.sql.DataSource"
url="jdbc:postgresql://mydb.rds.amazonaws.com:5432/mydb_db"
username=""
validationInterval="30000"
validationQuery="SELECT 1" />
<Resource auth="Container"
driverClassName="org.postgresql.Driver"
factory="org.apache.tomcat.jdbc.pool.DataSourceFactory"
initialSize="5"
jdbcInterceptors=
"org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;
org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer;
org.apache.tomcat.jdbc.pool.interceptor.SlowQueryReportJmx (threshold=10000)"
logAbandoned="true"
maxActive="30"
minEvictableIdleTimeMillis="30000"
minIdle="5"
name="jdbc/my-app-db-for-jobs"
password=""
removeAbandoned="true"
removeAbandonedTimeout="60"
testOnBorrow="true"
testOnReturn="false"
testWhileIdle="true"
timeBetweenEvictionRunsMillis="5000"
type="javax.sql.DataSource"
url="jdbc:postgresql://mydb.rds.amazonaws.com:5432/myapp_db"
username=""
validationInterval="30000"
validationQuery="SELECT 1" />
和 xml 配置:
<bean id="entityManagerFactory"
class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
<property name="persistenceUnitName" value="acme"></property>
<property name="jpaVendorAdapter">
<bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
<property name="showSql" value="true" />
<property name="databasePlatform" value="org.hibernate.dialect.PostgreSQLDialect" />
</bean>
</property>
</bean>
<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
<property name="dataSource" ref="dataSource"></property>
<property name="entityManagerFactory" ref="entityManagerFactory"></property>
</bean>
和 POM.xml具有一些依赖项:
<dependency>
<groupId>org.hibernate</groupId>
<artifactId>hibernate-validator</artifactId>
<version>5.2.4.Final</version>
</dependency>
<dependency>
<groupId>org.springframework.webflow</groupId>
<artifactId>spring-faces</artifactId>
<version>2.4.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.webflow</groupId>
<artifactId>spring-webflow</artifactId>
<version>2.4.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>4.1.6.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
</dependency>
<dependency>
<groupId>org.hibernate</groupId>
<artifactId>hibernate-entitymanager</artifactId>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
<version>42.1.1</version>
</dependency>
以下是一段可能会失败的代码,但实际上任何具有事务的内容,或者查询数据库的任何内容都可能在关闭的池连接中偶然发现:
PromoCode promoCodeEntity = null;
try {
JpaTransactionManager transactionManager = (JpaTransactionManager) ApplicationContextProvider
.getApplicationContext().getBean("transactionManager");
TransactionDefinition def = new DefaultTransactionDefinition();
TransactionStatus status = transactionManager.getTransaction(def);
String jpql = "select p from PromoCode p where p.code = :code";
Query query = em.createQuery(jpql).setParameter("code", promoCode);
promoCodeEntity = (PromoCode) query.getSingleResult();
if (promoCodeEntity.getQuantyOfUses() >= promoCodeEntity.getTotalOfUses()) {
MyCustomException myCustomException = new MyCustomException("This promo code is not valid: [" + promoCode + "]");
MyCustomException.setCode("PROMO_CODE");
throw myCustomException;
}
if (!promoCodeEntity.getActive() || promoCodeEntity.getFinish()) {
MyCustomException myCustomException = new MyCustomException("This promo code is not valid: [" + promoCode + "]");
myCustomException.setCode("PROMO_CODE");
throw myCustomException;
}
if (!(promoCodeEntity.getStartDateValid().before(new Date())
&& promoCodeEntity.getEndDateValid().after(new Date()))) {
MyCustomException myCustomException = new MyCustomException("This promo code is expired: [" + promoCode + "]");
myCustomException.setCode("PROMO_CODE");
throw myCustomException;
}
promoCodeEntity.setQuantyOfUses(promoCodeEntity.getQuantyOfUses() + 1);
transactionManager.commit(status);
} catch (NoResultException e) {
MyCustomException myCustomException = new MyCustomException("Promo code not found: [" + promoCode + "]");
myCustomException.setCode("PROMO_CODE");
throw myCustomException;
}
有没有人遇到过这样的问题,或者我应该在哪里进一步寻找?我们进行了一些驱动程序更新(例如postgres jdbc(,目前正在评估c3p0 Pool,以查看这是否与Tomcat Pool错误相关。但真的会很高兴了解出了什么问题。
经过数小时的调试和其他事情,解决了问题。
我应该发布一些与原始问题一起截取的代码,这可以帮助其他 Stackoverflow 用户正确理解问题。
该问题的解决方案是我们使用 TransactionManager 作为实例化对象,并在发生异常时捕获异常
JpaTransactionManager txManager = (JpaTransactionManager) context.getBean("transactionManager");
TransactionDefinition def = new DefaultTransactionDefinition();
TransactionStatus status = txManager.getTransaction(def);
try {
String jpql = "query";
Query query = em.createQuery(jpql).setParameter("id", id);
User singleResult = (User) query.getSingleResult();
singleResult.setActive(false);
this.em.merge(singleResult);
this.em.flush();
txManager.commit(status);
} catch (Exception e) {
logger.error("lockUser(Long)", e);
throw e;
}
}
但是在 catch 块中,我们从未在发生异常时回滚事务,因此 Tomcat 池管理器基本上关闭了连接,因为它被放弃了。
在 catch 块中添加它解决了这个特定问题:
txManager.rollback(status);
或者对我们来说,另一个解决方案是使用 Spring @Transactional注释,让 Spring 在出错时处理回滚事务。
谢谢大家关注这个问题!
您需要将connectionTimeout
用于dataSources
属性。 现在您使用的是默认超时,超时后它会强制会话关闭。 因此,您可以尝试将以下代码添加到dataSources
属性中:
connectionTimeout="300000"
尝试更改 c3p0 属性。 unreturnConnectionTimeout 处理挂起的连接。如果某些查询花费太多时间,则连接可能会超时,从而使数据库连接挂起。您的连接有限,因此,如果此过程重复,可能会耗尽您的连接。 testConnectionOnCheckout 检查连接是否已关闭,如果没有,则关闭它。
c3p0.unreturnedConnectionTimeout=2000
c3p0.testConnectionOnCheckout=true