连接池异常: errorType:SDB_NETWORK,Network error

使用更先进的浏览器访问效果更佳。

连接池异常: errorType:SDB_NETWORK,Network error

zhaoxiaoye

情况是这样的:

1.我使用了官方的连接池方法:

ArrayList urls = new ArrayList<>();

ConfigOptions nwOpt = new ConfigOptions(); // 定义连接选项

SequoiadbOption dsOpt = new SequoiadbOption(); // 定义连接池选项

urls.add("www.dbbase.com:11810");

System.out.println(urls);

nwOpt.setConnectTimeout(10 * 1000); // 设置若连接失败，超时时间（ms）

nwOpt.setMaxAutoConnectRetryTime(1); // 设置若连接失败，重试次数

// 以下设置的都是 SequoiadbOption 的默认值

dsOpt.setMaxConnectionNum(50); // 设置连接池最大连接数

dsOpt.setInitConnectionNum(10); // 初始化连接池时，创建连接的数量

dsOpt.setDeltaIncCount(10); // 当池中没有可用连接时，增加连接的数量

dsOpt.setMaxIdeNum(10); // 周期清理多余的空闲连接时，应保留连接的数量

dsOpt.setTimeout(5 * 10); // 当已使用的连接数到达设置的最大连接数时（500），请求连接的等待时间。

dsOpt.setAbandonTime(10 * 60 * 1000); // 连接存活时间，当连接空闲时间超过连接存活时间，将被连接池丢弃

dsOpt.setRecheckCyclePeriod(1 * 60 * 1000); // 清除多余空闲连接的周期

dsOpt.setRecaptureConnPeriod(10 * 60 * 1000); // 检测并取回异常地址的周期

ds = new SequoiadbDatasource(urls, "sdbadmin", "abc1234", nwOpt, dsOpt); // 创建连接池

2.当我的页面上存在请求并发在6个以上时,随机(随机,不是某一个固定的请求)的一个会出现以下的异常.

QQ截图20150829210027.png

出现异常后,再次重新发送又正常了.见最后一条记录.实际上是我重新发送的请求,正常响应了.

com.sequoiadb.exception.BaseException: errorType:SDB_NETWORK,Network error Exception Detail: at com.sequoiadb.net.ConnectionTCPImpl.receiveMessage(ConnectionTCPImpl.java:281) at com.sequoiadb.base.CollectionSpace.adminCommand(CollectionSpace.java:255) at com.sequoiadb.base.CollectionSpace.isCollectionExist(CollectionSpace.java:108) at com.sequoiadb.base.CollectionSpace.getCollection(CollectionSpace.java:86) at com.gamei.market.sequoiadb.trans.SequoiaDBDataService.getDBCollection(SequoiaDBDataService.java:32) at com.gamei.market.sequoiadb.trans.SequoiaDBDataService.find(SequoiaDBDataService.java:74) at com.gamei.market.basic.tree.aspect.QueryTreeChildWithPidAspect.execute(QueryTreeChildWithPidAspect.java:29) at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:621) at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:603) at org.springframework.aop.aspectj.AspectJMethodBeforeAdvice.before(AspectJMethodBeforeAdvice.java:40) at org.springframework.aop.framework.adapter.MethodBeforeAdviceInterceptor.invoke(MethodBeforeAdviceInterceptor.java:51) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:653) at com.gamei.market.basic.tree.action.TreeChildListAction$$EnhancerBySpringCGLIB$$cee5762.execute() at sun.reflect.GeneratedMethodAccessor39.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:221) at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:137) at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:111) at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:806) at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:729) at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85) at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:959) at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:893) at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:970) at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:861) at javax.servlet.http.HttpServlet.service(HttpServlet.java:687) at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:846) at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:816) at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1684) at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:85) at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1667) at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:581) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143) at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:548) at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:226) at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1114) at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:511) at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185) at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1048) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:213) at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:109) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:119) at org.eclipse.jetty.server.Server.handle(Server.java:517) at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:302) at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:242) at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:245) at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:95) at org.eclipse.jetty.io.SelectChannelEndPoint$2.run(SelectChannelEndPoint.java:75) at org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceAndRun(ExecuteProduceConsume.java:213) at org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.run(ExecuteProduceConsume.java:147) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:654) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572) at java.lang.Thread.run(Thread.java:745)

Tanzhaobo

感觉像是一个socket被多个线程使用，而导致的问题。可以参考http://blog.csdn.net/shanks2048/article/details/47660371 看看是不是这个原因。还有疑问的话，再贴出了讨论一下吧。

zhaoxiaoye

多谢,我先看看;

关于多线程,我使用的是spring mvc的aop;

查询动作时确实是单例的,不知道会不会出现这个问题;

只有更新动作的时候是score=request,应该不会出现这个问题;

zhaoxiaoye

你好,这个问题产生的原因确实是这个问题.

我将查询对象修改成score=request.立马问题没了;

请问如果需要用单例模式,这个问题怎么解决呢?

如果查询也声明为score=request,这个后台内存消耗量在高并发时,岂不是成倍增长?

sequoiadb不是为企业级准备而不考虑互联网应用吧?

请问sequoiadb在支持单例模式这方面有考虑吗?

许建辉

SequoiaDB会把企业和社区都作为战略路线；而且现在社区的推广、宣传、问题反馈、需求收集以及服务支撑已经开始全面铺开。本论坛也是作为支撑社区的一个入口，在产品使用和需求方面有问题都可以提出并得到及时解答，谢谢。

zhaoxiaoye

非常感谢各位的关注,特别是 Tanzhaobo,bingo,Diablo.

现在问题解决了.其实sequoiadb的API驱动没有问题.

问题在于我的connection对象,将conn对象存储起来了.由于是单例模式,新产生的conn对象覆盖了前一个对象.

public T getConnection() throws Exception {

logger.debug("请求新的CONN连接对象!");

return getDataFactory().RandConnection();

//以前的方式

//conn=getDataFactory().RandConnection();

//return (T) conn;

}

//关闭连接池

public void close() {

this.dataFactory.close(conn);

logger.debug("已经将连接放回连接池!");

}

关闭的时候使用了变量进行关闭,导致了随机出现的链接异常;

其实是每次关闭都关闭了最后一个变量对象;

希望各位不要出现这样的问题;

为了避免这种很难发现的问题也给sequoiadb提一个建议:关闭的conn,再次关闭的时候可以抛一个异常给客户端.这样让开发者能发现自己在重复关闭conn,从而可以检查到问题所在