Servlet中容器管理事务内调用EntityManager方法是否线程安全？

存在的问题 #

1. @Transactional注解完全无效 #

Servlet由Tomcat这类Web容器负责实例化和生命周期管理，而@Transactional是Spring或JTA事务容器的专属注解，Web容器无法识别该注解的作用。因此runTransaction()方法上的事务注解不会触发任何事务管理逻辑，merge和remove操作会在无事务的环境下执行——一旦中间出现异常，无法触发回滚，必然导致数据不一致。

2. 严重的线程安全隐患 #

Servlet是单实例多线程运行模式，所有并发请求会共用同一个Servlet实例的entityManager变量。但EntityManager本身并非线程安全组件，它内部维护的持久化上下文是与线程绑定的状态。多个请求同时调用runTransaction()时，会出现不同线程的操作共用同一个EntityManager实例的情况，直接导致持久化上下文混乱、数据篡改或并发异常。

解决方案 #

方案一：用Spring容器管理事务与业务逻辑 #

把事务逻辑抽离到Spring管理的Service Bean中，借助Spring的事务能力解决问题：

// 定义Spring管理的Service类
@Service
public class EntityOperationService {
    @PersistenceContext
    private EntityManager entityManager;

    @Transactional
    public void executeTransaction(EntityA entityA, EntityC entityC) {
        entityManager.merge(entityA);
        entityManager.remove(entityC);
    }
}

// 修改原Servlet
public class MyServlet extends HttpServlet {
    // 通过Spring注入Service Bean
    @Autowired
    private EntityOperationService operationService;

    @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        // 从请求中获取需要操作的实体对象
        EntityA entityA = ...;
        EntityC entityC = ...;
        operationService.executeTransaction(entityA, entityC);
    }
}

• Spring会为带@Transactional注解的方法生成代理，自动完成事务的开启、提交或回滚；
• @PersistenceContext注入的EntityManager是线程安全的代理对象，会自动绑定到当前请求线程的持久化上下文，避免线程冲突。

方案二：手动管理事务（无Spring环境） #

如果不使用Spring框架，需要手动控制事务边界，并保证每个请求使用独立的EntityManager实例：

public class MyServlet extends HttpServlet {
    // 注入EntityManagerFactory，而非直接注入EntityManager
    @Resource
    private EntityManagerFactory emf;

    @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        EntityManager entityManager = null;
        UserTransaction tx = null;
        try {
            // 获取JTA事务对象
            tx = (UserTransaction) new InitialContext().lookup("java:comp/UserTransaction");
            tx.begin();
            
            // 为当前请求创建独立的EntityManager
            entityManager = emf.createEntityManager();
            // 从请求中获取实体对象
            EntityA entityA = ...;
            EntityC entityC = ...;
            
            entityManager.merge(entityA);
            entityManager.remove(entityC);
            
            tx.commit();
        } catch (Exception e) {
            // 异常时回滚事务
            if (tx != null) {
                try {
                    tx.rollback();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
            throw new ServletException("事务执行失败", e);
        } finally {
            // 用完关闭EntityManager，释放资源
            if (entityManager != null && entityManager.isOpen()) {
                entityManager.close();
            }
        }
    }
}

• 每次请求创建独立的EntityManager实例，避免线程间共享状态；
• 通过JTA的UserTransaction手动控制事务的开启、提交与回滚，保证操作的原子性。

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