closeCurrentEntityManager

closeCurrentEntityManager

我正在服务器上使用Hibernate(tomcat8、Hibernate、postgresql)。
每天我的代码运行(使用Quartz)一些代码,这些代码调用存储过程(hibernate):

public void execute(JobExecutionContext context)
        throws JobExecutionException {
    log.info("=========Start daily update==========");
    long startTime = System.currentTimeMillis();
    boolean transactionCompleted = false;
    int retryCount = HibernateUtil.RETRY_COUNT;

    HibernateUtil.closeCurrentEntityManager();

    EntityManager em = HibernateUtil.currentEntityManager();

    while (!transactionCompleted)
    {
        try {
            em.getTransaction().begin();
            dailyUpdateDao.dailyUpdate();
            em.getTransaction().commit();
            transactionCompleted = true;
        } catch (PersistenceException ex) {
            if (!HibernateUtil.isDeadlockException(ex) || retryCount == 0) {
                log.error("non deadlock error", ex);
                throw ex;
            }

            log.error("deadlock detected. Retrying {}", HibernateUtil.RETRY_COUNT - retryCount);
            retryCount--;
            if (em.getTransaction().isActive()) {
                em.getTransaction().rollback();
            }
            try {
                Thread.sleep(HibernateUtil.sleepIntervalWhenDeadlockDetected(retryCount));
            } catch(Exception sleepex) {
                log.error("non deadlock sleep ex", ex);
                throw ex;
            }
        }
    }

    log.info("===========Daily Update Job Completed ============== It took {} ms", System.currentTimeMillis() - startTime);
}

上面代码中的dailyUpdate函数正在执行以下操作:
public void dailyUpdate() {
    String sql = "select count(*) FROM daily_update()";
    EntityManager em = HibernateUtil.currentEntityManager();
    em.createNativeQuery(sql).getSingleResult();
}

(通过hibernate使用本机sql调用存储过程)。
当我运行服务器时,它通常会执行前2或3个调用。下一个电话永远打不完。我在本地复制了这个问题,而不是每天我都把日程安排在每1分钟开始任务。它给我看了这样的日志:
每日更新作业完成时间=7338毫秒
每日更新作业已完成======6473毫秒
...
每日更新作业完成时间=183381毫秒
所以延迟时间增加了,我决定看看里面发生了什么。
在上面的代码中,当它试图执行
em.getTransaction().begin();

它永远不会结束,堆栈跟踪显示为图像:
java -  hibernate 冻结在事务开始功能-LMLPHP
原因是什么,如何解决问题?
编辑1:currentEntityManager和closeCurrentEntityManager代码:
public class HibernateUtil {
...
private static EntityManagerFactory entityManagerFactory = Persistence.createEntityManagerFactory(PERSISTENT_UNIT);
public static EntityManager currentEntityManager(EntityManagerFactory emf)
        throws HibernateException {
    EntityManager em = (EntityManager) entityManager.get();
    if (em == null||!em.isOpen()) {

        em = emf.createEntityManager();

        entityManager.set(em);
    }
    return em;
}

public static void closeCurrentEntityManager() {
    EntityManager s = (EntityManager) entityManager.get();
    try {
        if (s != null) {
            if (s.getTransaction().isActive()) {
                if (s.getTransaction().getRollbackOnly()) {
                    s.getTransaction().rollback();
                } else {
                    s.getTransaction().commit();
                }
            }
            s.close();
        }
    } finally {
        entityManager.remove();
    }
}

最佳答案

好的,很好,在发布了关于什么是HibernateUtil的详细信息,如何closeCurrentEntityManager()currentEntityManager()工作,以及这个类中的entityManager字段之后,一切都变得清晰了。
看看你的代码。首先关闭“当前”实体管理器:
HibernateUtil.closeCurrentEntityManager();
但是您应该考虑到quartz scheduller在不同线程中启动任务的事实。所以

public static void closeCurrentEntityManager() {
    EntityManager s = (EntityManager) entityManager.get();

将返回null(如果是新线程)。
下一步你调用
 EntityManager em = HibernateUtil.currentEntityManager();

这也将创建新的EntityManager作为新线程:
em = emf.createEntityManager();

现在看看你的截图:你的beginTransaction()方法正在等待新的连接。这里发生的事情是您创建了新的entitmanager,它打开了新的连接,但没有关闭它。所以基本上你的池里没有空闲的连接。
只需尝试将HibernateUtil.closeCurrentEntityManager();移动到final { ... }块并再次测试。

07-26 01:13