Jooq，Spring和BonECP连接关闭了两次错误

Question

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

我的persistenceContext配置与本指南相同（请浏览阅读，这是在这里粘贴的太多代码）

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

，但具有较小数量的最大连接，并且CloseConnectionWatch = true检查错误。

根据我可以推断的，本指南是JOOQ网站自己指南的非XML版本

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

我的问题可能来自不知道如何使用JOOQ生成的Daos或 @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像这样将bean存储在PersistenceContext中。我正在自动作为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";
    }
}

用户服务不是我唯一获得错误的服务 - 我所有的服务都相似，因为它们包含一个/a a a dao和dslContext自动对象，具有相同的dao配置构造函数与usersdao（）（）。产品服务具有此DAO和一个DSLContext对象，与对数据库进行调用的用户服务几乎相同。

有时我会登录这个连接问题，其他时候会没事的，我可以浏览网站并查看产品一会儿，但是随机随机我将获得"连接已关闭！"来自另一个服务的错误（大约有5条以相同的方式编写）。

所以我的问题是

1. 我在哪里使用 @transactional注释，以及它实际做什么。我省略 @transactional注释是否意味着我正在引起自己的问题？我以前曾在使用DB的所有位置中添加它，但是我不能确定它实际上是否有帮助，因为我仍然遇到相同的错误。

2. 我的范围有问题吗？我知道bean默认为singleton-我已经写了我的控制器，以使他们使用会话存储的属性传递到服务（全部均为默认单例），以便他们只能选择某个用户的数据被允许看到。

3. 由于连接池正在关闭连接两次，这是否意味着问题是线程A和线程B同时进行连接，对其进行操作，然后都关闭？为什么使用上述指南中的配置会发生这种情况？我如何确保线程安全性或不是问题？

4. dao bean应该是界面，因为从我与春天的简短历史中，我被带到了很多（很多/全部？）@Autowired Bean应该是？我是否应该使用界面org.jooq.daoimpl，所有jooq生成的daos似乎都可以实现哪个接口？

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

Answer 1

重新阅读您的问题和聊天后，我可以说这确实是由于您使用的版本 3.2.0 这里的严重错误：

• https://github.com/jooq/jooq/issues/2863

该错误是在 3.2.2 中固定的，您应该升级（或以后）。