JPA中的事务使用多个线程
我的目标是使用unit testing在我的应用程序中激发一个乐观的锁定exception。 我已经理解了如何在理论上做到这一点。 但我在实践中的问题是如何在两个线程之间维护一个事务?
所以,这就是我到目前为止所做的:
我正在使用JUnit测试:
@RunWith(SpringJUnit4ClassRunner.class)
使用EntityManager org.springframework.orm.jpa.JpaTransactionManager
其中每个方法的定义都是@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
并使用entityManager.getTransaction().begin();
启动事务entityManager.getTransaction().begin();
并以entityManager.getTransaction().rollback());
结束entityManager.getTransaction().rollback());
这在单线程测试中运行良好,保存,更新等。
要创建多个线程,我使用Springs TaskExecutor(类似于这里所描述的: 使用TaskExecutor示例的任何好的Spring线程? )
但是我需要做些什么来维护两个线程之间的事务呢? 我尝试过使用@Transactional注释run() – 方法之类的东西,但这不起作用。
想到的几个问题 –
全球交易
您的所有线程是否应该属于同一个事务? 这意味着,如果一个线程抛出exception,你想要回滚其他线程中的更改吗?
本地事务每个线程是否应该拥有自己的事务边界而不影响其他线程? 在这种情况下,一个线程中的exception和回滚不会影响其他线程。
要实现全局事务,您很可能必须使用具有适当资源驱动程序的JTA事务管理器。 Spring没有对全局事务的默认支持。 如果您的应用程序在Java EE应用程序服务器(Jboss,Weblogic)中运行,则默认情况下您将获得JTA支持,您可以配置spring以使用应用程序服务器的事务管理function。 如果你在tomcat中运行,你可以插入一个开源的JTA实现,如 –
Atomikos公司
Jboss交易
为了实现本地事务(即每个线程都有自己的事务边界),我认为除了使用spring transactional annotations之外你不会做任何事情。 在下面的示例中,只需确保’service’是一个spring bean并且doSomething()被适当地注释。
taskExecutor.execute( new Runnable() { public void run() { service.doSomething( ); } });