结合 MDB、JPA 和 JTA

Question

我正在开发一个系统来处理消息并相应地更新数据库，但我需要在层之间保持一定程度的隔离。我想到了以下内容。

• MyDao.java：提供数据库访问的@Stateless bean。 MyDao 使用 JPA 访问数据库，EntityManager 由 @PersistenceContext 注入。
• MyMdb.java：侦听队列的 MDB。 MyMdb 通过与@EJB 注入使用MyDao。

MyMdb.onMessage() 的一次执行需要对数据库执行多次访问，包括读取和写入。

• 一方面，这让我认为@Stateless bean 不是MyDao 的正确选择：MyDao 中的EntityManager 实例可以被MyMdb.onMessage() 的不同执行随机访问，导致线程相互干扰。
• 另一方面，JPA 文档说注入的EntityManager 只是一个代理：它操作的实际持久性上下文 是绑定到 JTA 事务的。这样一切都应该没问题，因为即使 EntityManager 是“共享的”，每个 MDB 也会有不同的事务正在进行，因此可以安全隔离。

什么是正确的场景？我错过了什么吗？

Answer 1

以您描述的方式注入无状态 EJB 的实体管理器正是您应该做的。 这种类型的注入提供了一个“容器管理的实体管理器”，它是“事务范围的”。 所以在你描述的场景中。

1. onMessage MDB 调用将创建一个事务
2. 对无状态 bean 的调用将发生在相同的事务上下文中，创建一个实体管理器，该管理器将一直持续到事务完成，通常在 MDB 方法返回时。

用于同一 EJB 实例的特定类型的注入实体管理器无法生存，并且不会在不同事务中重复使用。