在EJB 3.0+JPA环境下如何向Callable传递事务上下文

这个问题的核心原因很明确：Java EE容器默认不会将调用者的事务上下文传递给ManagedExecutorService提交的异步任务。因为事务是线程绑定的，当你的Callable在独立线程中执行时，没有活跃的容器管理事务，所以JPA的refresh/merge/persist这些需要事务支持的操作就会抛出TransactionRequiredException。

结合你使用的EclipseLink JPA和GlassFish 4.1环境，这里有几个可行的解决方案：

方案1：用容器管理事务的EJB方法封装JPA操作 #

最推荐的方式是把需要事务的JPA操作封装到一个带有事务属性的EJB中，然后在Callable里调用这个EJB的方法。EJB容器会自动为这些方法创建或加入事务，无需手动管理。

步骤： #

1. 创建一个Stateless EJB，封装所有需要事务的JPA操作，并指定REQUIRES_NEW事务属性（确保每次调用都有独立事务，避免和调用者事务耦合）：

@Stateless
public class EntityTransactionService {
    @PersistenceContext(unitName = "YourPU") // 替换成你的持久化单元名
    private EntityManager em;

    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    public void refreshEntity(Object entity) {
        em.refresh(entity);
    }

    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    public <T> T mergeEntity(T entity) {
        return em.merge(entity);
    }

    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    public void persistEntity(Object entity) {
        em.persist(entity);
    }
}

2. 在你的Callable中注入这个EJB（确保Callable是被容器管理的，比如通过EJB注入，而不是手动new），然后调用对应的方法：

public class MyEntityCallable implements Callable<Boolean> {
    @EJB
    private EntityTransactionService txService;

    private YourEntity targetEntity; // 要操作的实体

    // 构造函数传入实体
    public MyEntityCallable(YourEntity targetEntity) {
        this.targetEntity = targetEntity;
    }

    @Override
    public Boolean call() throws Exception {
        try {
            txService.refreshEntity(targetEntity);
            // 或者执行merge/persist
            // txService.mergeEntity(targetEntity);
            return true;
        } catch (Exception e) {
            // 处理异常
            return false;
        }
    }
}

方案2：手动管理UserTransaction #

如果需要更细粒度的事务控制，或者不想额外创建EJB，可以在Callable中手动获取UserTransaction来管理事务生命周期。

示例代码： #

public class MyManualTxCallable implements Callable<Void> {
    @Resource
    private UserTransaction utx;

    @PersistenceContext(unitName = "YourPU")
    private EntityManager em;

    private YourEntity entity;

    public MyManualTxCallable(YourEntity entity) {
        this.entity = entity;
    }

    @Override
    public Void call() throws Exception {
        utx.begin();
        try {
            // 执行JPA操作
            em.merge(entity);
            em.flush(); // 可选，根据需要
            utx.commit();
        } catch (Exception e) {
            // 确保事务回滚
            if (utx.getStatus() == Status.STATUS_ACTIVE) {
                utx.rollback();
            }
            throw new RuntimeException("事务执行失败", e);
        }
        return null;
    }
}

注意事项： #

• 确保Callable是容器管理的（比如通过EJB的@Resource注入ManagedExecutorService，然后提交这个Callable），否则UserTransaction和EntityManager无法被正确注入。
• 手动管理事务一定要做好异常处理，避免事务悬挂。

关键注意点 #

• 不要在Callable中手动创建EntityManager（比如Persistence.createEntityManagerFactory().createEntityManager()），这种应用管理的EntityManager不会和容器事务关联，同样会抛出事务异常。
• GlassFish 4.1支持Java EE 7，ManagedExecutorService是Java EE 7的标准特性，确保你的项目部署描述符（web.xml/ejb-jar.xml）是Java EE 7或更高版本。
• 如果你的业务逻辑需要共享调用者的事务，不推荐异步执行（因为事务会等待异步任务完成，极易导致超时），这种情况下建议调整设计，改用同步调用。

内容的提问来源于stack exchange，提问作者Vicky Rathee