在服务中处理StaleObjectException

Question

我有一个场景，当一个对象被两个不同的线程更新。下面是grails服务类中的代码。我能够捕捉StaleObject异常，但当我试图从数据库中再次获取它并重试保存值时，它不起作用。

public long updateTimer(Long timeLeft, TestAttempted testAttempted){
    // Let's say testAttempted.version() is now 5
    // It is concurrently updated by other thread, version is now 6
    ........
    ............
    testAttempted.setTimer(someCalculatedValue)
    try{
        testAttempted.save(failOnError: true,flush:true) // StaleObject exception occurs
    }catch(OptimisticLockingFailureException e){
        testAttempted.refresh()
        testAttempted.setTimer(someCalculatedValue)
        testAttempted.save(failOnError:true)
    }
}

为什么上面的代码不更新/保存catch块中的值？我也试过了。get（id）方法从数据库中获取最新的，但它不起作用。

但当我尝试此操作时，它会更新最新的计时器值：

在控制器中：-

    try{
         timeLeft = assessmentService.updateTimer(timeLeft,testAttempted)
    }catch(OptimisticLockingFailureException e){
        testAttempted = TestAttempted.get(session['testAttemptedId'])
        ........
        testAttempted.setTimer(someCalculatedValue)
        testAttempted.save(failOnError: true)
    }

在职：

 public long updateTimer(Long timeLeft, TestAttempted testAttempted){
    ........
    .................
    testAttempted.setTimer(someValue)
    testAttempted.save(failOnError: true)
    return timeLeft
}

如果在控制器/服务中抛出和处理它，则它不起作用。它在投入服务并在控制器中处理时工作。怎么可能呢？

Answer 1

重试方法的问题是，重试多少次就足够了？试试这个：

class AssessmentService {

    /*
     * Services are transactional by default.
     * I'm just making it explicit here. 
    */
    static transactional = true

    public long updateTimer(Long timeLeft, Long testAttemptedId) {
        def testAttempted = TestAttempted.lock(testAttemptedId)

        testAttempted.setTimer(someCalculatedValue)
        testAttempted.save()
    }
} 

传递TestAttempted ID而不是实例，以便服务可以使用自己的事务自行检索实例。

如果您想传入TestAttemted实例，我认为在对实例进行更改之前，您必须在服务方法中调用testAttempted.merge（）。

这里有类似的问题。

Answer 2

很可能，当您在catch块中执行refresh（）然后执行save（）时，testAttempted的实例在刷新和保存之间发生了更改，因此它会失败，并出现相同的异常，现在您无法捕获该异常，因为它已经在catch块中。

域的get（）方法afaik被缓存在会话中，因此被测试。get（id）将从会话而不是数据库返回实例。

Merge（）在这种情况下是不必要的，因为您在刷新后和保存前手动设置值。

使用Domain.lock（）可能是一个解决方案，但它会影响您如何处理代码的其他部分中的TesttAttemture，因为现在您可能会在您试图检索一个实例，它被这部分代码锁定。

问题是——什么是冲突解决战略？如果是“last writer wins”，则只需为域设置version=false。或者，您可以使用TestAttemted。executeUpdate（'set timer=..，其中id=..）在不增加版本的情况下进行更新。

如果我想了解更复杂的场景，请查阅马克·帕尔默对该问题的深入报道。http://www.anyware.co.uk/2005/2012/11/12/the-false-optimism-of-gorm-and-hibernate/

Answer 3

关键是您应该始终重试整个事务。让事务回滚并在新事务中重复所有操作，因为旧事务是脏的（Hibernate会话无效，可能有一些未提交的更改已刷新到数据库）。