Glassfish EJB容器中多线程调用EntityManager遇空指针异常求助

你遇到的NullPointerException完全是因为多线程脱离了EJB容器的上下文管理。这里的关键是：容器管理的EntityManager（也就是你注入的那个）是和当前线程的EJB上下文绑定的——当你通过Callable+ForkJoinPool手动开启新线程时，这个新线程并没有被EJB容器接管，也就没有对应的上下文信息。EntityManagerWrapper在尝试获取委托的EntityManager时，找不到当前线程关联的上下文，就抛出了NPE，哪怕你看到EntityManager对象本身不为空也没用，它的内部依赖的上下文已经丢失了。

而单线程场景下，所有操作都在EJB容器维护的线程上下文中，容器会自动处理EntityManager的上下文绑定，所以一切正常。

针对这个问题，有几个靠谱的解决方向，按推荐程度排序：

1. 改用EJB原生的异步机制（最推荐） #

EJB规范本身提供了异步方法支持，容器会帮你管理线程池和上下文，完全不需要手动处理线程。只需要把你原来放在Callable里的逻辑抽成一个独立的方法，加上@Asynchronous注解，并且返回Future<T>类型：

@Stateless
public class LogisticsEngineSessionBean {
    @PersistenceContext
    private EntityManager em;

    // 原来的方法，调用异步方法
    public void updateSKULocationStatusOnSell() {
        Future<List<PackSerial>> future = getAllPackSerialsForProcessAsync();
        // 后续处理Future结果
    }

    // 异步方法，由容器管理线程和上下文
    @Asynchronous
    public Future<List<PackSerial>> getAllPackSerialsForProcessAsync() {
        // 这里可以安全使用em，容器会确保上下文在异步线程中可用
        List<PackSerial> result = em.createQuery("SELECT p FROM PackSerial p WHERE ...", PackSerial.class).getResultList();
        return new AsyncResult<>(result);
    }
}

这种方式完全符合EJB规范，容器会自动处理线程的上下文传递，EntityManager可以正常使用，还不用自己管理线程池的生命周期。

2. 手动创建应用管理的EntityManager（适合必须用自定义线程池的场景） #

如果你确实需要用自己的线程池，那么不能直接使用容器注入的EntityManager，而是要通过EntityManagerFactory手动创建应用管理的EntityManager，并且手动管理事务：

@Stateless
public class LogisticsEngineSessionBean {
    @PersistenceUnit
    private EntityManagerFactory emf;

    public void updateSKULocationStatusOnSell() {
        ForkJoinPool pool = new ForkJoinPool();
        Future<List<PackSerial>> future = pool.submit(() -> {
            // 手动创建EntityManager
            EntityManager em = emf.createEntityManager();
            List<PackSerial> result = null;
            try {
                // 手动开启事务
                em.getTransaction().begin();
                result = em.createQuery("SELECT p FROM PackSerial p WHERE ...", PackSerial.class).getResultList();
                em.getTransaction().commit();
            } catch (Exception e) {
                if (em.getTransaction().isActive()) {
                    em.getTransaction().rollback();
                }
                throw e;
            } finally {
                // 手动关闭EntityManager，避免资源泄漏
                em.close();
            }
            return result;
        });
        // 后续处理结果
    }
}

注意这种方式下，EntityManager是应用管理的，每个线程自己创建一个（线程安全），但你需要手动处理事务的开启、提交/回滚，以及EntityManager的关闭，避免资源泄漏。

3. 使用消息驱动Bean（MDB）处理异步任务（适合复杂异步场景） #

如果你的异步任务不需要立即获取结果，而是可以异步处理，那么可以考虑使用消息驱动Bean。你可以把任务封装成消息发送到JMS队列，MDB监听队列并处理任务，容器会自动为MDB分配线程，并且维护上下文和事务：

@MessageDriven(mappedName = "jms/PackSerialProcessingQueue")
public class PackSerialProcessorMDB implements MessageListener {
    @PersistenceContext
    private EntityManager em;

    @Override
    public void onMessage(Message message) {
        // 这里可以安全使用em处理任务
        List<PackSerial> result = em.createQuery("SELECT p FROM PackSerial p WHERE ...", PackSerial.class).getResultList();
        // 执行后续业务逻辑
    }
}

然后在你的EJB里发送消息：

@Stateless
public class LogisticsEngineSessionBean {
    @Resource(mappedName = "jms/PackSerialProcessingQueue")
    private Queue processingQueue;

    @Resource
    private ConnectionFactory connectionFactory;

    public void updateSKULocationStatusOnSell() {
        try (Connection conn = connectionFactory.createConnection();
             Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE)) {
            MessageProducer producer = session.createProducer(processingQueue);
            TextMessage taskMessage = session.createTextMessage("Trigger pack serial processing");
            producer.send(taskMessage);
        } catch (JMSException e) {
            throw new EJBException("Failed to send processing task", e);
        }
    }
}

这种方式适合解耦异步任务，尤其是任务比较耗时、不需要同步等待结果的场景。

• 容器管理的EntityManager是线程不安全的，绝对不能在多个线程之间共享，哪怕你能传递对象，也会因为上下文绑定问题出故障。
• 手动创建线程的方式违反EJB规范（EJB不允许应用程序自己创建线程），可能会导致容器的资源管理、事务管理出现问题，所以尽量用容器提供的异步机制。

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