该帖已经被评为隐藏帖
|
|
---|---|
作者 | 正文 |
发表时间:2006-10-04
首先简单的说明一下SysBillManage,它的功能是根据传递参数分配单据号,并且实现自增。比如是出库通知单,那么参数是OUT_DO_INFORM_ORDER,那么得到的结果是OutB0000001这样的形式的单据号,每一次增加出库通知单则单据号增1,既是OutB0000002。其中参数OUT_DO_INFORM_ORDER对应于数据库SysBillManage表中的一条记录的ID。 在用silkperformer 6.5做压力测试的时候,则出现一下异常,测试用例就是并发生成出库通知单: 11:06:10,609 ERROR JDBCExceptionReporter:72 - [Microsoft][SQLServer 2000 Driver for JDBC][SQLServer]事务(进程 ID 98)与另一个进程已被死锁在 lock 资源上,且该事务已被选作死锁牺牲品。请重新运行该事务。 11:06:10,609 ERROR AbstractFlushingEventListener:299 - Could not synchronize database state with session org.hibernate.exception.GenericJDBCException: could not update: [com.bnu.put.base.billmanage.model.SysBillManage#OUT_DO_INFORM_ORDER] at org.hibernate.exception.SQLStateConverter.handledNonSpecificException(SQLStateConverter.java:91) at org.hibernate.exception.SQLStateConverter.convert(SQLStateConverter.java:79) at org.hibernate.exception.JDBCExceptionHelper.convert(JDBCExceptionHelper.java:43) at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2222) at org.hibernate.persister.entity.AbstractEntityPersister.updateOrInsert(AbstractEntityPersister.java:2118) at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2374) at org.hibernate.action.EntityUpdateAction.execute(EntityUpdateAction.java:84) at org.hibernate.engine.ActionQueue.execute(ActionQueue.java:243) at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:227) at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:141) at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:296) at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:27) at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1009) at org.hibernate.impl.SessionImpl.managedFlush(SessionImpl.java:356) at org.hibernate.transaction.JDBCTransaction.commit(JDBCTransaction.java:106) at org.springframework.orm.hibernate3.HibernateTransactionManager.doCommit(HibernateTransactionManager.java:584) at org.springframework.transaction.support.AbstractPlatformTransactionManager.processCommit(AbstractPlatformTransactionManager.java:500) at org.springframework.transaction.support.AbstractPlatformTransactionManager.commit(AbstractPlatformTransactionManager.java:473) at org.springframework.transaction.interceptor.TransactionAspectSupport.doCommitTransactionAfterReturning(TransactionAspectSupport.java:266) at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:106) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:170) at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:176) at $Proxy23.auditCoConsignOrder(Unknown Source) at com.bnu.put.order.consign.view.action.OutConsignOrderAction.audit(OutConsignOrderAction.java:280) at sun.reflect.GeneratedMethodAccessor374.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) at java.lang.reflect.Method.invoke(Unknown Source) at org.apache.struts.actions.DispatchAction.dispatchMethod(DispatchAction.java:276) at org.apache.struts.actions.DispatchAction.execute(DispatchAction.java:196) at org.apache.struts.action.RequestProcessor.processActionPerform(RequestProcessor.java:421) at net.sf.struts.saif.SAIFTilesRequestProcessor.processActionPerform(SAIFTilesRequestProcessor.java:91) at org.apache.struts.action.RequestProcessor.process(RequestProcessor.java:226) at org.apache.struts.action.ActionServlet.process(ActionServlet.java:1158) at com.bnu.put.view.util.stationListener.process(stationListener.java:52) at org.apache.struts.action.ActionServlet.doGet(ActionServlet.java:397) at javax.servlet.http.HttpServlet.service(HttpServlet.java:689) at javax.servlet.http.HttpServlet.service(HttpServlet.java:802) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:252) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173) at org.springframework.orm.hibernate3.support.OpenSessionInViewFilter.doFilterInternal(OpenSessionInViewFilter.java:174) at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:76) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:202) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173) at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:75) at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:76) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:202) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:292) at org.acegisecurity.intercept.web.FilterSecurityInterceptor.invoke(FilterSecurityInterceptor.java:116) at org.acegisecurity.intercept.web.FilterSecurityInterceptor.doFilter(FilterSecurityInterceptor.java:79) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:143) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.switchuser.SwitchUserProcessingFilter.doFilter(SwitchUserProcessingFilter.java:382) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.providers.anonymous.AnonymousProcessingFilter.doFilter(AnonymousProcessingFilter.java:138) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.rememberme.RememberMeProcessingFilter.doFilter(RememberMeProcessingFilter.java:174) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.basicauth.BasicProcessingFilter.doFilter(BasicProcessingFilter.java:214) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.AbstractProcessingFilter.doFilter(AbstractProcessingFilter.java:246) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.context.HttpSessionContextIntegrationFilter.doFilter(HttpSessionContextIntegrationFilter.java:220) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.util.FilterChainProxy.doFilter(FilterChainProxy.java:173) at org.acegisecurity.util.FilterToBeanProxy.doFilter(FilterToBeanProxy.java:120) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:202) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173) at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:213) at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:178) at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:126) at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:105) at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:107) at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:148) at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:856) at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.processConnection(Http11Protocol.java:744) at org.apache.tomcat.util.net.PoolTcpEndpoint.processSocket(PoolTcpEndpoint.java:527) at org.apache.tomcat.util.net.LeaderFollowerWorkerThread.runIt(LeaderFollowerWorkerThread.java:80) at org.apache.tomcat.util.threads.ThreadPool$ControlRunnable.run(ThreadPool.java:684) at java.lang.Thread.run(Unknown Source) Caused by: java.sql.SQLException: [Microsoft][SQLServer 2000 Driver for JDBC][SQLServer]事务(进程 ID 98)与另一个进程已被死锁在 lock 资源上,且该事务已被选作死锁牺牲品。请重新运行该事务。 at com.microsoft.jdbc.base.BaseExceptions.createException(Unknown Source) at com.microsoft.jdbc.base.BaseExceptions.getException(Unknown Source) at com.microsoft.jdbc.sqlserver.tds.TDSRequest.processErrorToken(Unknown Source) at com.microsoft.jdbc.sqlserver.tds.TDSRequest.processReplyToken(Unknown Source) at com.microsoft.jdbc.sqlserver.tds.TDSRPCRequest.processReplyToken(Unknown Source) at com.microsoft.jdbc.sqlserver.tds.TDSRequest.processReply(Unknown Source) at com.microsoft.jdbc.sqlserver.SQLServerImplStatement.getNextResultType(Unknown Source) at com.microsoft.jdbc.base.BaseStatement.commonTransitionToState(Unknown Source) at com.microsoft.jdbc.base.BaseStatement.postImplExecute(Unknown Source) at com.microsoft.jdbc.base.BasePreparedStatement.postImplExecute(Unknown Source) at com.microsoft.jdbc.base.BaseStatement.commonExecute(Unknown Source) at com.microsoft.jdbc.base.BaseStatement.executeUpdateInternal(Unknown Source) at com.microsoft.jdbc.base.BasePreparedStatement.executeUpdate(Unknown Source) at org.apache.commons.dbcp.DelegatingPreparedStatement.executeUpdate(DelegatingPreparedStatement.java:101) at org.hibernate.jdbc.NonBatchingBatcher.addToBatch(NonBatchingBatcher.java:23) at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2204) ... 77 more 11:06:10,625 WARN RequestProcessor:509 - Unhandled Exception thrown: class org.springframework.dao.DeadlockLoserDataAccessException 11:06:10,625 ERROR [action]:253 - Servlet.service() for servlet action threw exception org.springframework.dao.DeadlockLoserDataAccessException: Hibernate operation: could not update: [com.bnu.put.base.billmanage.model.SysBillManage#OUT_DO_INFORM_ORDER]; SQL [update dbo.SYS_BILL_MANAGE set TYPE_PREFIX=?, START_NUMBER=?, CODE_FORMAT=?, CURRENT_NUMBER=?, REMARK=? where BILL_TYPE=?]; [Microsoft][SQLServer 2000 Driver for JDBC][SQLServer]事务(进程 ID 98)与另一个进程已被死锁在 lock 资源上,且该事务已被选作死锁牺牲品。请重新运行该事务。; nested exception is java.sql.SQLException: [Microsoft][SQLServer 2000 Driver for JDBC][SQLServer]事务(进程 ID 98)与另一个进程已被死锁在 lock 资源上,且该事务已被选作死锁牺牲品。请重新运行该事务。 java.sql.SQLException: [Microsoft][SQLServer 2000 Driver for JDBC][SQLServer]事务(进程 ID 98)与另一个进程已被死锁在 lock 资源上,且该事务已被选作死锁牺牲品。请重新运行该事务。 at com.microsoft.jdbc.base.BaseExceptions.createException(Unknown Source) at com.microsoft.jdbc.base.BaseExceptions.getException(Unknown Source) at com.microsoft.jdbc.sqlserver.tds.TDSRequest.processErrorToken(Unknown Source) at com.microsoft.jdbc.sqlserver.tds.TDSRequest.processReplyToken(Unknown Source) at com.microsoft.jdbc.sqlserver.tds.TDSRPCRequest.processReplyToken(Unknown Source) at com.microsoft.jdbc.sqlserver.tds.TDSRequest.processReply(Unknown Source) at com.microsoft.jdbc.sqlserver.SQLServerImplStatement.getNextResultType(Unknown Source) at com.microsoft.jdbc.base.BaseStatement.commonTransitionToState(Unknown Source) at com.microsoft.jdbc.base.BaseStatement.postImplExecute(Unknown Source) at com.microsoft.jdbc.base.BasePreparedStatement.postImplExecute(Unknown Source) at com.microsoft.jdbc.base.BaseStatement.commonExecute(Unknown Source) at com.microsoft.jdbc.base.BaseStatement.executeUpdateInternal(Unknown Source) at com.microsoft.jdbc.base.BasePreparedStatement.executeUpdate(Unknown Source) at org.apache.commons.dbcp.DelegatingPreparedStatement.executeUpdate(DelegatingPreparedStatement.java:101) at org.hibernate.jdbc.NonBatchingBatcher.addToBatch(NonBatchingBatcher.java:23) at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2204) at org.hibernate.persister.entity.AbstractEntityPersister.updateOrInsert(AbstractEntityPersister.java:2118) at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2374) at org.hibernate.action.EntityUpdateAction.execute(EntityUpdateAction.java:84) at org.hibernate.engine.ActionQueue.execute(ActionQueue.java:243) at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:227) at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:141) at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:296) at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:27) at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1009) at org.hibernate.impl.SessionImpl.managedFlush(SessionImpl.java:356) at org.hibernate.transaction.JDBCTransaction.commit(JDBCTransaction.java:106) at org.springframework.orm.hibernate3.HibernateTransactionManager.doCommit(HibernateTransactionManager.java:584) at org.springframework.transaction.support.AbstractPlatformTransactionManager.processCommit(AbstractPlatformTransactionManager.java:500) at org.springframework.transaction.support.AbstractPlatformTransactionManager.commit(AbstractPlatformTransactionManager.java:473) at org.springframework.transaction.interceptor.TransactionAspectSupport.doCommitTransactionAfterReturning(TransactionAspectSupport.java:266) at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:106) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:170) at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:176) at $Proxy23.auditCoConsignOrder(Unknown Source) at com.bnu.put.order.consign.view.action.OutConsignOrderAction.audit(OutConsignOrderAction.java:280) at sun.reflect.GeneratedMethodAccessor374.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) at java.lang.reflect.Method.invoke(Unknown Source) at org.apache.struts.actions.DispatchAction.dispatchMethod(DispatchAction.java:276) at org.apache.struts.actions.DispatchAction.execute(DispatchAction.java:196) at org.apache.struts.action.RequestProcessor.processActionPerform(RequestProcessor.java:421) at net.sf.struts.saif.SAIFTilesRequestProcessor.processActionPerform(SAIFTilesRequestProcessor.java:91) at org.apache.struts.action.RequestProcessor.process(RequestProcessor.java:226) at org.apache.struts.action.ActionServlet.process(ActionServlet.java:1158) at com.bnu.put.view.util.stationListener.process(stationListener.java:52) at org.apache.struts.action.ActionServlet.doGet(ActionServlet.java:397) at javax.servlet.http.HttpServlet.service(HttpServlet.java:689) at javax.servlet.http.HttpServlet.service(HttpServlet.java:802) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:252) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173) at org.springframework.orm.hibernate3.support.OpenSessionInViewFilter.doFilterInternal(OpenSessionInViewFilter.java:174) at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:76) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:202) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173) at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:75) at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:76) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:202) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:292) at org.acegisecurity.intercept.web.FilterSecurityInterceptor.invoke(FilterSecurityInterceptor.java:116) at org.acegisecurity.intercept.web.FilterSecurityInterceptor.doFilter(FilterSecurityInterceptor.java:79) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:143) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.switchuser.SwitchUserProcessingFilter.doFilter(SwitchUserProcessingFilter.java:382) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.providers.anonymous.AnonymousProcessingFilter.doFilter(AnonymousProcessingFilter.java:138) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.rememberme.RememberMeProcessingFilter.doFilter(RememberMeProcessingFilter.java:174) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.basicauth.BasicProcessingFilter.doFilter(BasicProcessingFilter.java:214) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.ui.AbstractProcessingFilter.doFilter(AbstractProcessingFilter.java:246) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.context.HttpSessionContextIntegrationFilter.doFilter(HttpSessionContextIntegrationFilter.java:220) at org.acegisecurity.util.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:303) at org.acegisecurity.util.FilterChainProxy.doFilter(FilterChainProxy.java:173) at org.acegisecurity.util.FilterToBeanProxy.doFilter(FilterToBeanProxy.java:120) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:202) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173) at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:213) at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:178) at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:126) at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:105) at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:107) at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:148) at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:856) at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.processConnection(Http11Protocol.java:744) at org.apache.tomcat.util.net.PoolTcpEndpoint.processSocket(PoolTcpEndpoint.java:527) at org.apache.tomcat.util.net.LeaderFollowerWorkerThread.runIt(LeaderFollowerWorkerThread.java:80) at org.apache.tomcat.util.threads.ThreadPool$ControlRunnable.run(ThreadPool.java:684) at java.lang.Thread.run(Unknown Source) 看到这个错误,就想到可能是代码没有同步,但是事实上代码已经做了简单的同步。 在SysBillManageServiceImpl中,既是service的实现代码,其中getOrderNO(String billsort)是获得单据号的方法。 private SysBillManageDAO sysbillmanagedao; private SysBillManage sysbillmanage; //...其他处理 public synchronized String getOrderNO(String billsort) { if (sysbillmanagedao.findById(billsort) != null) { this.sysbillmanage = sysbillmanagedao.findById(billsort); int currentnumber = Integer.parseInt(sysbillmanage .getCurrentNumber()); currentnumber++; String factcurrentnumber = "" + currentnumber; String billtypeprefix = sysbillmanage.getTypePrefix(); String billcodeformat = sysbillmanage.getCodeFormat(); String factbillcodeformat = leftAppend(billcodeformat, factcurrentnumber); sysbillmanage.setCurrentNumber(factcurrentnumber); this.save(sysbillmanage); return billtypeprefix + factbillcodeformat; } else { sysbillmanage = new SysBillManage(); sysbillmanage.setBillType(billsort); sysbillmanage.setTypePrefix(this.getbillprefix(billsort)); sysbillmanage.setStartNumber("1"); sysbillmanage.setCurrentNumber("1"); sysbillmanage.setCodeFormat("0000000"); sysbillmanage.setRemark(""); this.save(sysbillmanage); String factcurrentnumber = sysbillmanage.getCurrentNumber(); String billcodeformat = sysbillmanage.getCodeFormat(); String factbillcodeformat = leftAppend(billcodeformat, factcurrentnumber); return this.getbillprefix(billsort) + factbillcodeformat; } } public String getbillprefix(String billsort) { for (int i = 0; i < ordernoprix.length; i++) { if (billsort == ordernoprix[i][0]) { return ordernoprix[i][1]; } } return null; } 在SysBillManageDAO中的代码: /** * Data access object (DAO) for domain model class SysBillManage. * @see model.SysBillManage * @author MyEclipse - Hibernate Tools */ public class SysBillManageDAO extends HibernateDaoSupport { private static final Log log = LogFactory.getLog(SysBillManageDAO.class); protected void initDao() { //do nothing } public void save(SysBillManage transientInstance) { log.debug("saving SysBillManage instance"); try { getHibernateTemplate().saveOrUpdate(transientInstance); System.out.println("OK"); log.debug("save successful"); } catch (RuntimeException re) { log.error("save failed", re); System.out.println("Error"); throw re; } } public void delete(SysBillManage persistentInstance) { log.debug("deleting SysBillManage instance"); try { getHibernateTemplate().delete(persistentInstance); log.debug("delete successful"); } catch (RuntimeException re) { log.error("delete failed", re); throw re; } } public SysBillManage findById( java.lang.String id) { log.debug("getting SysBillManage instance with id: " + id); try { SysBillManage instance = (SysBillManage) getHibernateTemplate() .get("com.bnu.put.base.billmanage.model.SysBillManage", id); // SysBillManage instance2 = (SysBillManage) getHibernateTemplate().load(SysBillManage.class,id); return instance; } catch (RuntimeException re) { log.error("get failed", re); throw re; } } public List findByExample(SysBillManage instance) { log.debug("finding SysBillManage instance by example"); try { List results = getSession() .createCriteria("model.SysBillManage") .add(Example.create(instance)) .list(); log.debug("find by example successful, result size: " + results.size()); return results; } catch (RuntimeException re) { log.error("find by example failed", re); throw re; } } public SysBillManage merge(SysBillManage detachedInstance) { log.debug("merging SysBillManage instance"); try { SysBillManage result = (SysBillManage) getHibernateTemplate() .merge(detachedInstance); log.debug("merge successful"); return result; } catch (RuntimeException re) { log.error("merge failed", re); throw re; } } public void attachDirty(SysBillManage instance) { log.debug("attaching dirty SysBillManage instance"); try { getHibernateTemplate().saveOrUpdate(instance); log.debug("attach successful"); } catch (RuntimeException re) { log.error("attach failed", re); throw re; } } public void attachClean(SysBillManage instance) { log.debug("attaching clean SysBillManage instance"); try { getHibernateTemplate().lock(instance, LockMode.NONE); log.debug("attach successful"); } catch (RuntimeException re) { log.error("attach failed", re); throw re; } } public void update(SysBillManage persistentInstance) { log.debug("deleting SysBillManage instance"); try { getHibernateTemplate().update(persistentInstance); log.debug("delete successful"); } catch (RuntimeException re) { log.error("delete failed", re); throw re; } } } 请各位大大看看到底是哪里出了问题 声明:ITeye文章版权属于作者,受法律保护。没有作者书面许可不得转载。
推荐链接
|
|
返回顶楼 | |
发表时间:2006-10-04
private SysBillManage sysbillmanage;
有什么作用? singleton否? |
|
返回顶楼 | |
发表时间:2006-10-04
其中SysBillManage就是POJO,是实体类,属性如下。
public class SysBillManage implements java.io.Serializable { private String billType;//主健 private String typePrefix;//前缀 private String startNumber;//开始号 private String codeFormat;//格式 private String currentNumber;//当前数量 private String remark; /** default constructor */ public SysBillManage() { } //getter... //setter... } 为了保证单例,我把service中的SysBillManage变量简单的改成了static 既是 ->private static SysBillManage sysBillManage; 但是问题依旧存在,同时并发时候getOrderNO()方法取得的单据号依然还是存在相同,既一个单号会被多次取出去,并没有同步。 另外,spring中的bean默认是单例模式,对吧?既然是,方法又做了同步,那为什么还是无法同步呢? |
|
返回顶楼 | |
发表时间:2006-10-05
关键字:Sql Server, 默认驱动,String类型的PK
在高并发下的page lock(而不是row lock)会出现死锁 和spring/hibernate没有任何关系 解决方法: 1. 换数据库...... 2. 用jtds试试看 3. 用数字类型的PK试试看 |
|
返回顶楼 | |
发表时间:2006-10-05
Readonly 写道 关键字:Sql Server, 默认驱动,String类型的PK
在高并发下的page lock(而不是row lock)会出现死锁 和spring/hibernate没有任何关系 解决方法: 1. 换数据库...... 2. 用jtds试试看 3. 用数字类型的PK试试看 page lock?不是很清楚引发它的原因!你可以不可以说得再仔细点呢?学习一下^^ 换数据库是不能了,数据库和测试数据是检测中心给定的,现今就没办法改动了.因为时间也很紧张! 换jtds驱动包和改成int类pk,这个稍后去试试...待会看下结果.一直都知道string类型慢,但是引起并发lock那么严重就不知道了...经验尚浅 |
|
返回顶楼 | |
发表时间:2006-10-06
pagelock在我做的sql server项目中也经常碰到,想象就是明明用了rowlock,但是往往不是lock住一行,而且一个page内的row都被lock住了
象你这个需求,从实现方式上面就已经形成了一个瓶颈,所有的操作都集中在一个表上,要在上面取ID,并发的时候出现deadlock或者取出同一个id就是必然了,建议采用缓冲的机制,对于每个用户,他每次到ID表中取的ID的时候,都是取回一批ID,另外一个session来取得时候,拿到的是另外一批,然后这个用户在生成ID的时候,从这个缓冲中取,取尽的时候才重新去表中得到另外一批ID。 |
|
返回顶楼 | |
发表时间:2006-10-06
string类型PK改到数字类型PK只能减少page lock,但是不能消除。
根本的解决方法是改序列号生成方法,像你这种在一个表里面记录最大值,然后不停累加,然后再更新到其他表,很容易出deadlock。 你可以将这个最大值在系统启动的时候从各个表读取,然后更新,并且把这个值放到内存中,这样在系统运行中的时候就不需要和这个表打交道了。 这里有一些其他技巧减少lock的资料,也可以参考一下: http://www.sql-server-performance.com/reducing_locks.asp |
|
返回顶楼 | |
发表时间:2006-10-07
谢谢各位了,唉,被投成垃圾贴了。是我的问题太菜了还是?
|
|
返回顶楼 | |
发表时间:2006-10-08
问题解决了,现在可以支持100个用户并发了,操作流程比较多,数据量为8W条单据。只在Dao层update方法中加多了一行代码getHibernateTemplate().flush();马上就写入数据库,就不会出现不同步和记录重复的情况了。花了好久才试出这个解决方法。
public void update(SysBillManage persistentInstance) { log.debug("deleting SysBillManage instance"); try { getHibernateTemplate().update(persistentInstance); getHibernateTemplate().flush(); log.debug("delete successful"); } catch (RuntimeException re) { log.error("delete failed", re); throw re; } } 并发情况下,首先是某用户A取得单据号001,然后将sysBillMange update,执行getHibernateTemplate().update(persistentInstance);这个方法。此时getOrderNO这个方法结束,同步完成,下一个用户B进入方法,执行get取得单据号的操作,但是这个时候,用户A的update动作还未真正写入数据库,此时用户B取得的还是001而不是002。所以就出错了,所以我尝试着将它立即写入数据库,系统压力测试就正常了。 其他代码都没有在执行动作之后立即flush,系统瓶颈在这里,所有操作都要涉及到这个表,虽然这种写法比较慢…… spring的配置应该保证了事务的原子性,但是还是出现这样的事务问题,到底是为什么呢?难道是粒度问题? 事务A开始 { 事务B... }事务A结束 难道是保证了事务A而在事务A中的事务B(既是这里的取得更新单据号)没有保证? 引用 象你这个需求,从实现方式上面就已经形成了一个瓶颈,所有的操作都集中在一个表上,要在上面取ID,并发的时候出现deadlock或者取出同一个id就是必然了,建议采用缓冲的机制,对于每个用户,他每次到ID表中取的ID的时候,都是取回一批ID,另外一个session来取得时候,拿到的是另外一批,然后这个用户在生成ID的时候,从这个缓冲中取,取尽的时候才重新去表中得到另外一批ID。 缓存是一个很好的方案,hibernate的缓存机制还没用上,找个时间研究下。^^ |
|
返回顶楼 | |
发表时间:2007-02-09
Readonly 写道 string类型PK改到数字类型PK只能减少page lock,但是不能消除。
根本的解决方法是改序列号生成方法,像你这种在一个表里面记录最大值,然后不停累加,然后再更新到其他表,很容易出deadlock。 你可以将这个最大值在系统启动的时候从各个表读取,然后更新,并且把这个值放到内存中,这样在系统运行中的时候就不需要和这个表打交道了。 这里有一些其他技巧减少lock的资料,也可以参考一下: http://www.sql-server-performance.com/reducing_locks.asp 请问为什么INT类型的PK比STRING类型引发的死锁要少呢? |
|
返回顶楼 | |