带有 2 个数据库的休眠随机“会话已关闭错误”

Posted 2023-04-18

【中文标题】带有 2 个数据库的休眠随机“会话已关闭错误”

【英文标题】：Hibernate random "Session is closed error" with 2 databases

【发布时间】：2018-07-02 13:46:55

【问题描述】：

我需要在单个 DAO 类中使用 2 个不同的数据库。其中一个数据库是读/写的，而另一个是只读的。

我为这些数据库创建了 2 个数据源、2 个会话工厂和 2 个事务管理器（读/写数据库的事务管理器是平台事务管理器）。我在服务方法上使用@Transactional 来配置Spring 进行事务管理。

当我们在 DAO 类中调用 sessionFactory.getCurrentSession() 时，我们得到随机 Session is closed! 异常（我不能总是生成它，它有时可以正常工作，有时会出错）：

org.hibernate.SessionException: Session is closed!
at org.hibernate.internal.AbstractSessionImpl.errorIfClosed(AbstractSessionImpl.java:133)
at org.hibernate.internal.SessionImpl.setFlushMode(SessionImpl.java:1435)
at org.springframework.orm.hibernate4.SpringSessionContext.currentSession(SpringSessionContext.java:99)
at org.hibernate.internal.SessionFactoryImpl.getCurrentSession(SessionFactoryImpl.java:1014)

我不需要使用全局事务 (XA)，我只想查询 2 个不同的数据库。

我已经阅读了这个帖子，它建议像我们现在一样在 DAO 层中注入两个单独的会话工厂：Session factories to handle multiple DB connections

根据这个答案，AbstractRoutingDataSource 也不适用于单个 Dao 类：https://***.com/a/7379048/572380

我的 dao 中的示例代码如下所示：

Criteria criteria = sessionFactory1.getCurrentSession().createCriteria(MyClass.class);
criteria.add(Restrictions.eq("id", id));
criteria.list();

criteria = sessionFactory2.getCurrentSession().createCriteria(MyClass2.class); // generates random "Session is closed!" error.
criteria.add(Restrictions.eq("id", id));
criteria.list();

我也尝试过使用“doInHibernate”方法。但是传递给它的会话也随机抛出“会话已关闭！”例外：

    @Autowired
    protected HibernateTemplate hibernateTemplate;

    @SuppressWarnings("unchecked")
    protected List<Map<String, Object>> executeStaticQuery(final String sql) 
        HibernateCallback<List<Map<String, Object>>> hibernateCallback = new HibernateCallback<List<Map<String, Object>>>() 
            @Override
            public List<Map<String, Object>> doInHibernate(Session session) throws HibernateException 
                SQLQuery query = session.createSQLQuery(sql);
                query.setResultTransformer(CriteriaSpecification.ALIAS_TO_ENTITY_MAP);
                return query.list();
            
        ;
        return hibernateTemplate.execute(hibernateCallback);
    

【问题讨论】：

你能发布你的代码吗？为什么不使用注入两个 DAO 的单一事务服务？出于兴趣，您为什么要调用 getCurrentSession() ？

@PaulNUK 我已经用我的代码更新了这个问题。您所说的“拥有注入两个 DAO 的单一事务服务”是什么意思？我有 2 个数据库，所以我需要 2 个事务或 1 个全局事务。 XA 很难实现，在这种情况下不需要。

【参考方案1】：

那么您的应用程序中有以下代码吗？如果你不添加它，可能是它导致了问题。

<bean id="transactionManager"   
class="org.springframework.orm.hibernate3.HibernateTransactionManager">    
<property name="sessionFactory" ref="sessionFactory"/>    
</bean>    
<tx:annotation-driven/>

删除该属性，如下所述

<property name="current_session_context_class">thread</property>

您正在覆盖将其设置为 SpringSessionContext.class 的 Spring。几乎可以肯定，这至少是您问题的一部分。

Spring 管理您的会话对象。它管理的这些会话对象与 Spring 事务相关联。因此，您收到该错误的事实对我来说意味着这很可能是由于您处理交易的方式。

换句话说，不要这样做

Transaction tx = session.beginTransaction();

除非你想自己管理会话的生命周期，在这种情况下你需要调用 session.open() 和 session.close()

改为使用框架来处理事务。我会利用 Spring 方面和使用 @Transactional 的声明性方法，就像我之前描述的那样，它既干净又简单，但是如果你想务实地做到这一点，你也可以使用 Spring 来做到这一点。按照参考手册中概述的示例进行操作。请看以下链接：

http://static.springsource.org/spring/docs/3.1.x/spring-framework-reference/html/orm.html#orm-hibernate-tx-programmatic

【讨论】：

我正在使用@Transactional，它只为平台事务管理器管理事务，而另一个则抛出错误。我不会编写代码来手动开始事务。

【参考方案2】：

以上错误提示，您无法获取会话，因为会话有时会关闭。您可以使用 openSession() 方法代替 getCurrentSession() 方法。

Session session = this.getSessionFactory().openSession();
session.beginTransaction();
// Your Code Here.
 session.close();

这种方法的缺点是您将明确需要关闭会话。 在单线程环境中，它比 getCurrentSession() 慢。

也请检查此链接：- Hibernate Session is closed

【讨论】：

如果我找不到 Spring 托管事务的解决方案，我会尝试。正如你所说，这有一个慢的缺点。

【参考方案3】：

问题是您有一个休眠会话和两个数据存储。会话绑定到事务。如果您向另一个数据库打开一个新事务，这将有效地为该数据库和该实体管理器打开一个新会话。

这相当于@Transactional(propagation = Propagation.REQUIRES_NEW)

您需要确保有两个不同的事务/会话绑定到对两个数据库的每个持久操作。

【讨论】：

当我用@Transactional 注释我的服务类时，它只适用于平台事务管理器。如何将我的服务注释为 @Transactional 以供 2 个不同的事务管理器使用？

【参考方案4】：

如果所有配置都正确，那么一切都应该正常工作而不会出错

我认为你在 DAO 中错过了 @Qualifier(value="sessionFactory1") and @Qualifier(value="sessionFactory2")

请看这些例子

Hibernate configuring multiple datasources and multiple session factories

https://medium.com/@joeclever/using-multiple-datasources-with-spring-boot-and-spring-data-6430b00c02e7

【讨论】：

感谢汉尼的回答。实际上，我相信我没有错过这一点，因为当没有抛出会话关闭错误时，查询会在正确的数据库上运行。否则它们会以错误的数据源结束。

【参考方案5】：

不鼓励使用 HibernateTemplate。这里给出了明确的解释https://***.com/a/18002931/1840818

如上所述，必须使用声明式事务管理。

【讨论】：

谢谢 Vigneshwaran。关键是我不能以声明的方式将 2 个事务管理器关联到一个请求。或者我做了，但第二次会议有时会关闭。