2013-07-19 53 views
18

我的应用程序(JAVA的弹簧芯)有多个线程同时运行和访问数据库,我在一些peaktime获得“死锁发现试图获取锁时,请尝试重新启动交易”

07:43:33,400 WARN [org.hibernate.util.JDBCExceptionReporter] SQL Error: 1213, SQLState: 40001 
07:43:33,808 ERROR [org.hibernate.util.JDBCExceptionReporter] Deadlock found when trying to get lock; try restarting transaction 
07:43:33,808 ERROR [org.hibernate.event.def.AbstractFlushingEventListener] Could not synchronize database state with session 
org.hibernate.exception.LockAcquisitionException: could not insert: [com.xminds.bestfriend.frontend.model.Question] 
    at org.hibernate.exception.SQLStateConverter.convert(SQLStateConverter.java:107) 
    at org.hibernate.exception.JDBCExceptionHelper.convert(JDBCExceptionHelper.java:66) 
    at org.hibernate.persister.entity.AbstractEntityPersister.insert(AbstractEntityPersister.java:2436) 
    at org.hibernate.persister.entity.AbstractEntityPersister.insert(AbstractEntityPersister.java:2856) 
    at org.hibernate.action.EntityInsertAction.execute(EntityInsertAction.java:79) 
    at org.hibernate.engine.ActionQueue.execute(ActionQueue.java:273) 
    at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:265) 
    at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:184) 
    at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:321) 
    at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:51) 
    at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1216) 
    at org.hibernate.impl.SessionImpl.managedFlush(SessionImpl.java:383) 
    at org.hibernate.transaction.JDBCTransaction.commit(JDBCTransaction.java:133) 
    at org.springframework.orm.hibernate3.HibernateTransactionManager.doCommit(HibernateTransactionManager.java:656) 
    at org.springframework.transaction.support.AbstractPlatformTransactionManager.processCommit(AbstractPlatformTransactionManager.java:754) 
    at org.springframework.transaction.support.AbstractPlatformTransactionManager.commit(AbstractPlatformTransactionManager.java:723) 
    at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:147) 
    at com.xminds.bestfriend.consumers.Base.onMessage(Base.java:96) 
    at org.springframework.jms.listener.adapter.MessageListenerAdapter.onMessage(MessageListenerAdapter.java:339) 
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:535) 
    at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:495) 
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467) 
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325) 
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263) 
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058) 
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050) 
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947) 
    at java.lang.Thread.run(Thread.java:662) 
Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLTransactionRollbackException: Deadlock found when trying to get lock; try restarting transaction 
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) 
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39) 
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) 
    at java.lang.reflect.Constructor.newInstance(Constructor.java:513) 
    at com.mysql.jdbc.Util.handleNewInstance(Util.java:411) 
    at com.mysql.jdbc.Util.getInstance(Util.java:386) 
    at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1065) 
    at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4074) 
    at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4006) 
    at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2468) 
    at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2629) 
    at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2719) 
    at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:2155) 
    at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2450) 
    at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2371) 
    at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2355) 
    at com.mchange.v2.c3p0.impl.NewProxyPreparedStatement.executeUpdate(NewProxyPreparedStatement.java:105) 
    at org.hibernate.jdbc.NonBatchingBatcher.addToBatch(NonBatchingBatcher.java:46) 
    at org.hibernate.persister.entity.AbstractEntityPersister.insert(AbstractEntityPersister.java:2416) 
    ... 25 more 

我的代码变得异常看起来

try 
{ 
     this.consumerTransactionTemplate.execute(new TransactionCallbackWithoutResult(){ 

        @Override 
        protected void doInTransactionWithoutResult(
          TransactionStatus status) 
        { 
         process(); 
        } 

       }); 

    } 
    catch(Exception e){ 
    logger.error("Exception occured " , e); 
     //TODO: Exception handling 
    } 

回答

18

MySQL的InnoDB引擎的运动行级锁,从而导致即使你的代码中插入或更新单行(特别是如果有桌子上几个指标被更新)死锁。最好的办法是围绕此代码设计代码,以便在事务由于死锁而失败时重试事务。有关MySQL死锁诊断和可能的解决方法的一些有用信息可用here

在Spring中通过AOP进行死锁重试的有趣实现可用here。这样,只需要将注释添加到要在发生死锁时重试的方法。

3

埃米尔的回答非常好,它描述了你所得到的问题。不过,我建议你试试spring-retry

这是一个辉煌的框架,通过注释实现重试模式。

例子:

@Retryable(maxAttempts = 4, backoff = @Backoff(delay = 500)) 
public void doSomethingWithMysql() { 
    consumerTransactionTemplate.execute(
      new TransactionCallbackWithoutResult(){ 
       @Override 
       protected void doInTransactionWithoutResult(     
         TransactionStatus status) 
       { 
        process(); 
       } 

      }); 
} 

如果任何异常,它会当你面对这样的重试(呼叫)高达4倍的方法doSomethingWithMysql()与500ms的

-1

退避策略错误“检测到死锁”。您应该检查您的查询执行情况,并验证两个或多个并发事务是否会导致死锁。

这些事务应该以相同的顺序获取数据库锁,以避免死锁。

+0

如果问题不在代码中,但是在试图同时访问相同资源的并发系统中,该怎么办? –

相关问题