Jooq、Spring 和 BoneCP 连接关闭两次错误答案

【问题标题】：Jooq, Spring, And BoneCP connection closed twice errorJooq、Spring 和 BoneCP 连接关闭两次错误
【发布时间】：2014-02-19 03:32:19
【问题描述】：

我正在使用 Spring 4.0.0，以及 jOOQ 3.2.0 和 BoneCP 0.8.0 用于 Web 应用程序。

我已将 PersistenceContext 配置为与本指南相同（请略读阅读此处粘贴的代码过多）

http://www.petrikainulainen.net/programming/jooq/using-jooq-with-spring-configuration/

但最大连接数较少，并且 closeConnectionWatch = true 用于错误检查。

据我推测，本指南是此处看到的 jOOQ 网站自己的指南的非 XML 版本

http://www.jooq.org/doc/3.2/manual/getting-started/tutorials/jooq-with-spring/

我的问题可能来自于不知道如何使用 jOOQ 生成的 DAO 或 @Transactional 注释。我遇到了大量“连接关闭两次”异常，这使我的应用程序从根本上崩溃了。下面的堆栈跟踪实际上并没有说它被关闭了两次，但是 closeConnectionWatch 的输出说明了一些类似于

的内容

bonecp connection closed twice detected: first location connection was closed in thread[blah]
closed again in thread[blah2]

连接监视完成后的 SQL 异常堆栈跟踪：

Jan 28, 2014 10:51:51 AM org.apache.catalina.core.StandardWrapperValve invoke
SEVERE: Servlet.service() for servlet [appServlet] in context with path [/application] threw     exception [Request processing failed; nested exception is org.springframework.jdbc.UncategorizedSQLException: jOOQ; uncategorized SQLException for SQL 
<snip> error code [0]; Connection is closed!; nested exception is java.sql.SQLException: Connection is closed!] with root cause java.sql.SQLException: Connection is closed!
at com.jolbox.bonecp.ConnectionHandle.checkClosed(ConnectionHandle.java:459)
at com.jolbox.bonecp.ConnectionHandle.prepareStatement(ConnectionHandle.java:1011)
at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.springframework.jdbc.datasource.LazyConnectionDataSourceProxy$LazyConnectionInvocationHandler.invoke(LazyConnectionDataSourceProxy.java:376)
at com.sun.proxy.$Proxy73.prepareStatement(Unknown Source)
at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy$TransactionAwareInvocationHandler.invoke(TransactionAwareDataSourceProxy.java:240)
at com.sun.proxy.$Proxy73.prepareStatement(Unknown Source)
at org.jooq.impl.ProviderEnabledConnection.prepareStatement(ProviderEnabledConnection.java:112)
at org.jooq.impl.SettingsEnabledConnection.prepareStatement(SettingsEnabledConnection.java:76)
at org.jooq.impl.AbstractResultQuery.prepare(AbstractResultQuery.java:224)
at org.jooq.impl.AbstractQuery.execute(AbstractQuery.java:295)
at org.jooq.impl.AbstractResultQuery.fetch(AbstractResultQuery.java:324)
at org.jooq.impl.SelectImpl.fetch(SelectImpl.java:1034)
at org.jooq.impl.DAOImpl.fetch(DAOImpl.java:249)
----> at com.myapplication.spring.services.UserService.authenticate(UserService.java:32)
at com.myapplication.spring.controllers.LoginController.doLogin(LoginController.java:35)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.springframework.web.method.support.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:214)
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:132)
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:748)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:689)
at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:83)
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:945)
at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:876)
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:931)
at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:833)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:647)
at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:807)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:728)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
at com.github.dandelion.datatables.core.web.filter.DatatablesFilter.doFilter(DatatablesFilter.java:73)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:243)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:222)
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:123)
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:171)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:99)
at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:931)
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:407)
at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1004)
at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:589)
at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:312)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)

我用箭头标出的那一行是服务中调用数据库的那一行。我在服务中有@Autowired DAO 对象，如下所示

@Service("UserService")
public class UserService implements UserServiceInterface{

@Autowired UsersDao userDao;
@Autowired PasswordServiceInterface passwordService;

@Override

public Users authenticate(String user,String password) {
    boolean allowedIn = false;

    List<Users> users = userDao.fetch(USERS.USERNAME, user);
            //do something here

我在类似服务中使用的其他函数包含使用 DSLContext 对象的调用，例如

DSL.select(SOMETHING).from(SOMETABLE).fetch()

DAO 和 DSLContext 像这样在 PersistenceContext 中存储为 bean。我将自动装配为 DSLContext 而不是 *Default*DSLContext，因为 jOOQ 指南底部有一个测试方法，仅显示 DSLContext。

@Bean
public DefaultDSLContext dsl() {
    return new DefaultDSLContext(configuration());
}

@Bean 
public UsersDao userDao() { //bad because UsersDao isn't an interface???
    return new UsersDao(configuration());
}

这是控制器

@Controller
public class LoginController {

@Autowired UserServiceInterface userService;

@RequestMapping(value = "/login", method = RequestMethod.GET)
public String login() {
    return "login";
}

@RequestMapping(value = "/login/doLogin", method = RequestMethod.POST)
public String doLogin(@RequestParam("username")String username, @RequestParam("password") String password, HttpSession session) {

    Users u = userService.authenticate(username, password);
    if(u == null) 
        return "redirect:/error";
    else {
        session.setAttribute("user", u.getUserid());
        session.setAttribute("role", u.getRoleid());
        session.setAttribute("retailgroup", u.getGroupid());
        return "redirect:/dashboard";
    }
}

UserService 不是我遇到错误的唯一服务——我所有的服务都相似，因为它们包含一个/两个 DAO 和一个 DSLContext Autowired 对象，具有与 usersDao() 相同的 DAO 配置构造函数，例如 productsDao ()。 Products 服务有这个 DAO 和一个 DSLContext 对象，与调用数据库的 UsersService 非常相似。

有时我会在登录时遇到此连接问题，有时会很好，我可以浏览网站并查看产品一会儿，但随后我会随机收到“连接已关闭！”来自另一个服务的错误（大约有 5 个以相同的方式编写）。

所以我的问题是

我在哪里使用@Transactional 注释，它实际上做了什么。我省略了@Transactional 注释是否意味着我给自己造成了问题？我之前在所有使用数据库的位置都添加了它，但我不能确定它是否真的有帮助，因为我仍然遇到同样的错误。
我的范围有问题吗？我知道 bean 默认为单例 - 我已经编写了我的控制器，它们使用会话存储的属性传递给服务（这些都保留为默认单例），因此它们只能选择某个用户的数据被允许看到。
既然 connectionPool 关闭了两次连接，这是否意味着问题是线程 A 和线程 B 同时进行连接，对其进行操作，然后都关闭？为什么使用上述指南中的配置会发生这种情况？我如何确保线程安全或者这不是问题？
DAO bean 是否应该是接口，从我与 Spring 的简短历史来看，我相信很多（很多/全部？）@Autowired bean 应该是？我是否应该使用接口 org.jooq.DAOImpl，这是所有 jOOQ 生成的 DAO 似乎都实现的接口？
```
@Bean
public org.jooq.impl.DAOImpl usersDao() {
    return new usersDao(configuration());
}
```

抱歉，问题很长，任何帮助将不胜感激。谢谢。

编辑：这是我在 PersistenceContext 类中的配置

@Configuration
@PropertySource("classpath:config.properties")
public class PersistenceContext {

@Autowired
private Environment env;


@Bean(destroyMethod = "close")
public DataSource dataSource() {
    BoneCPDataSource dataSource = new BoneCPDataSource();
    dataSource.setDriverClass(env.getRequiredProperty("db.driver"));
    dataSource.setJdbcUrl(env.getRequiredProperty("db.url"));
    dataSource.setUsername(env.getRequiredProperty("db.username"));
    dataSource.setPassword(env.getRequiredProperty("db.password"));
    dataSource.setMaxConnectionsPerPartition(20);
    dataSource.setPartitionCount(2);
    dataSource.setCloseConnectionWatch(true);
    return dataSource;
}

@Bean
public LazyConnectionDataSourceProxy lazyConnectionDataSource() {
    return new LazyConnectionDataSourceProxy(dataSource());
}

@Bean
public TransactionAwareDataSourceProxy transactionAwareDataSource() {
    return new TransactionAwareDataSourceProxy(lazyConnectionDataSource());
}

@Bean
public DataSourceTransactionManager transactionManager() {
    return new DataSourceTransactionManager(lazyConnectionDataSource());
}

@Bean
public DataSourceConnectionProvider connectionProvider() {
    return new DataSourceConnectionProvider(transactionAwareDataSource());
}

@Bean
public JOOQToSpringExceptionTransformer jooqToSpringExceptionTransformer() {
    return new JOOQToSpringExceptionTransformer();
}

@Bean
public DefaultConfiguration configuration() {
    DefaultConfiguration jooqConfiguration = new DefaultConfiguration();
    jooqConfiguration.set(connectionProvider());
    jooqConfiguration.set(new DefaultExecuteListenerProvider(
        jooqToSpringExceptionTransformer()
    ));

    String sqlDialectName = env.getRequiredProperty("jooq.sql.dialect");
    SQLDialect dialect = SQLDialect.valueOf(sqlDialectName);
    jooqConfiguration.set(dialect);

    return jooqConfiguration;
}

@Bean
public DefaultDSLContext dsl() {
    return new DefaultDSLContext(configuration());
}

@Bean
public UsersDao userDao() {
    return new UsersDao(configuration());
}

}

【问题讨论】：

与解决方案并不真正相关，但org.jooq.impl.DAOImpl 是一个类，而不是一个接口。有问题的接口是org.jooq.DAO...
...恐怕您还需要发布具体的Configuration 配置
感谢 Lukas 的回复，我已经添加了我的 PersistenceContext 类代码。我猜在某个地方我需要在某些 bean/服务/控制器上使用除单例范围以外的东西吗？但这充其量只是一个没有根据的猜测。干杯伙伴。

标签： spring connection jooq bonecp

【解决方案1】：

重新阅读您的问题和聊天后，我可以看出这很可能是由于您使用的版本3.2.0，这里有一个相当严重的错误：

https://github.com/jOOQ/jOOQ/issues/2863

该错误已在 3.2.2 中修复，您应该升级到（或更高版本）。

【讨论】：