java - TransactionAttribute 注释 (@REQUIRES_NEW) 被忽略

Question

我遇到了两个单独事务的问题，它们以与实际执行顺序相反的顺序刷新到数据库。

这是业务案例:存在 RemoteJob-RemoteJobEvent 一对多关系。每创建一个新的事件，都会获取一个时间戳，并设置在RemoteJob和RemoteJobEvent的lastModified字段中，持久化两条记录(一条update+一条insert)。

这是它在代码中的样子:

class Main {

@TransactionAttribute(TransactionAttributeType.REQUIRED)
public void mainMethod(...) {
  RemoteJob job = remoteJobDAO.findById(...);
  // ...         
  addEvent(job, EVENT_CODE_10);
  // Here the separate transaction should have ended and its results
  // permanently visible in the database. We refresh the job then
  // to update it with the added event:
  remoteJobDAO.refresh(job); // calls EntityManager.refresh()
  // ...
  boolean result = helper.addEventIfNotThere(job);
}

// Annotation REQUIRES_NEW here to enforce a new transaction; the
// RemoteJobDAO.newEvent() has REQUIRED.
@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
public void addEvent(RemoteJob job, RemoteJobEvent event) {
  remoteJobDAO.newEvent(job, event);
}

}

class Helper {
@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
public boolean addEventIfNotThere(RemoteJob job) {
  // This loads the job into the persistence context associated with a new transaction.
  job = remoteJobDAO.findById(job.getId());
  // Locking the job record – this method is using as a semaphore by 2 threads,
  // we need to make sure only one of them completes it.
  remoteJobDAO.lockJob(job, LockModeType.WRITE);
  // Refreshing after locking to be certain that we have current data.
  remoteJobDAO.refresh(job);

  // ... here comes logic for checking if EVENT_CODE_11 is not already there
  if (/* not yet present */) {
    remoteJobDAO.newEvent(job, EVENT_CODE_11);
  }

  return ...; // true - event 11 was there, false - this execution added it.
}

}

总结一下:在 mainMethod() 中，我们已经处于事务上下文中。然后我们将其挂起以生成一个新事务以在方法 addEvent() 中创建 EVENT_CODE_10。此方法返回后，我们应该提交它的结果并对所有人可见(但需要刷新 mainMethod() 的上下文)。最后，我们进入 addEventIfNotThere() 方法(又是一个新事务)，发现没有人添加 EVENT_CODE_11，所以我们这样做并返回。因此，数据库中应该有两个事件。

这就是问题所在:OpenJPA 似乎在 addEventIfNotThere() 完成后刷新两个事件添加事务!更重要的是，它以错误的顺序执行，版本列值清楚地表明第二个事务没有前一个事务的结果信息，即使第一个事务应该已经提交(注意日志顺序，lastModified 字段值和事件代码):

2011-07-08T10:45:51.386 [WorkManager.DefaultWorkManager : 7] TRACE [openjpa.jdbc.SQL] - <t 2080472065, conn 1753966731> executing prepstmnt 1859546838 INSERT INTO RemoteJobEvent (id, eventCode, lastModified, version, remotejobid) VALUES (?, ?, ?, ?, ?) [params=(long) 252, (short) 11, (Timestamp) 2011-07-08 10:45:51.381, (int) 1, (long) 111]  
2011-07-08T10:45:51.390 [WorkManager.DefaultWorkManager : 7] TRACE [openjpa.jdbc.SQL] - <t 2080472065, conn 1753966731> executing prepstmnt 60425114 UPDATE RemoteJob SET lastModified = ?, version = ? WHERE id = ? AND version = ? [params=(Timestamp) 2011-07-08 10:45:51.381, (int) 3, (long) 111, (int) 2]  
2011-07-08T10:45:51.401 [WorkManager.DefaultWorkManager : 7] TRACE [openjpa.jdbc.SQL] - <t 2080472065, conn 815411354> executing prepstmnt 923940626 INSERT INTO RemoteJobEvent (id, eventCode, lastModified, version, remotejobid) VALUES (?, ?, ?, ?, ?) [params=(long) 253, (short) 10, (Timestamp) 2011-07-08 10:45:51.35, (int) 1, (long) 111]  
2011-07-08T10:45:51.403 [WorkManager.DefaultWorkManager : 7] TRACE [openjpa.jdbc.SQL] - <t 2080472065, conn 815411354> executing prepstmnt 1215645813 UPDATE RemoteJob SET lastModified = ?, version = ? WHERE id = ? AND version = ? [params=(Timestamp) 2011-07-08 10:45:51.35, (int) 3, (long) 111, (int) 2]

这当然会产生一个 OptimisticLockException -- 它在两种环境中的行为方式相同:使用 Apache Derby/Tomcat/Atomikos Transaction Essentials 进行测试，并使用 WebSphere 7.0/Oracle 11 进行测试。

我的问题是:这怎么可能，交易边界不受尊重？我知道 JPA 提供程序可以自由选择 SQL 排序在一个事务中，但它不能重新排序整个事务，可以吗？

有关我们环境的更多信息:所提供的代码是 Spring 3.0.5 JMS 消息处理程序 (DefaultMessageListenerContainer) 的一部分； Spring 也用于 bean 注入(inject)，但是基于注释的事务管理使用系统事务管理器(Websphere 的/Atomikos，如上所述)，这就是为什么使用 EJB3 而不是 Spring 事务注释。

我希望这会引起一些兴趣，在这种情况下，如果需要，我很乐意提供更多信息。

Answer 1

我因为没有了解 Spring 代理的工作原理而成为受害者，这些代理负责基于注释的事务支持。

事实证明 addEvent当从同一个类中调用方法时，忽略 REQUIRES_NEW 注释。 在这种情况下，Spring 事务代理不起作用，因此代码在当前事务中运行——这是完全错误的，因为它在调用 helper.addEventIfNotThere() 后结束(长)完成。另一方面，后一种方法是从另一个类调用的，因此 REQUIRES_NEW 真正开始并作为单独的事务提交。

我移动了 addEvent()方法到一个单独的类，问题就消失了。另一个解决方案可能是改变 <tx:annotation-driven/> 的方式配置工作；更多信息在这里:Spring Transaction Management reference .