Transactional 事务 锁机制

Posted 2020-11-28 guoleidd

问题代码:

@Transactional
def stop(Long id) {
　　.......

　　// M5系列去停止充电
　　pileJmsService.stopCharge(chargePile, chargeRecord.port, chargeRecord)
　　// 停止充电后续处理
 　def lockNames = LockNames.stop(chargePile.id, chargeRecord.port)
　　syncLock.lock(lockNames)
　　try {
   　　 chargeDoneService.processChargeDone(chargeRecord.id, ChargeDone.STATUS__MANUALLY, 0)
　　} finally {
 　　   syncLock.release(lockNames)
　　}
}
问题:  事务隔离级别为(串行化)

syncLock.lock() 加的锁在 事务范围之内, 导致 解锁过后 该事物在还未提交的过程中 ,新的线程在极短时间内 走同样的 方法, 但因为事务未提交 所以查询的方法是 数据未提交前 的数据,
导致查询数据的状态判断未通过, 从而引发运行时执行2次方法 而抛出异常

解决方法: grails框架 添加一个新的事务

ChargeRecord.withNewTransaction {
　　
}

更改后代码:

def lockName = LockNames.stop(chargePile.id, chargeRecord.port)
syncLock.lock(lockName)
try {
    ChargeRecord.withNewTransaction {
        // M5系列去停止充电
        pileJmsService.stopCharge(chargePile, chargeRecord.port, chargeRecord)
        // 停止充电后续处理
        chargeDoneService.processChargeDone(chargeRecord.id, ChargeDone.STATUS__MANUALLY, 0)
        log.info("订单[${chargeRecord.id}, lock: ${lockName}]结束处理完成")
    }
} finally {
    syncLock.release(lockName)
}