JPA 锁定 PESSIMISTIC_WRITE 和 FEW 事务

Question

我在我的存储库方法上使用 PESSEMSTIC_WRITE 锁。这就是锁定我的对象直到交易结束。但是，我遇到了一个问题，在一个端点内，控制器-> 服务-> 我开始事务然后我需要更新我的对象并将消息发送到 kafka，之后我需要在此方法中再次更新我的对象并发送到 kafka .因此，因为它是一个事务，所以更改仅在缓存中本地起作用。但是我需要保存在数据库中然后发送到 kafka，然后再次更改我的对象并保存到数据库并发送到 kafka 消息，我不能使用 REQUIRES_NEW 并以任何方式创建新事务，因为我的对象被锁定。那么我该如何处理呢？ 这个锁在我的项目的许多部分中用于修复并行事务。

Answer 1

您应该创建将协调流程的新服务。这样你就可以在第二次操作中再次获得同样的悲观锁。

@Service
class OrchestratorService {
   ...

   void executeFlow() {
       someService.executeFirstOperationAndSendKafkaEvent()
       someService.executeSecondOperationAndSendKafkaEvent()       
   }
}

@Service
class SomeService {

   @Transactional(REQUIRES_NEW)
   void executeFirstOperationAndSendKafkaEvent() {
       // any lock which obtained inside this method will be released once this method finishes
       ...       
   }

   @Transactional(REQUIRES_NEW)
   void executeSecondOperationAndSendKafkaEvent() {
       // any lock which obtained inside this method will be released once this method finishes
       ...       
   }
}

还有一个更重要的方面值得一提——发送 kafka 事件不是事务性的。 @Transactional 只保证对数据源所做的更改将是事务性的（在本例中为数据库）。因此，以下情况是可能的：

• 如果在事务范围内发送事件，则在成功发送 kafka 事件后可以回滚事务
• 如果在事务提交之外发送事件，成功提交事务后事件发送可能会失败

由于这种性质，最好将流程分成几个阶段：

1. 在 DB 中应用业务更改并在 DB 中存储一个应该发送 kafka 事件的标志，但尚未完成，
2. TX 范围外向 kafka 发送事件
3. 在新的 TX 中更改事件已发送的标志，或在发送事件期间发生错误时安排重试。