java - Hibernate 和多线程逻辑

Question

我正在处理一个 Java 独立项目。我需要在多线程应用程序中使用 hibernate ，但我不知道如何正确设置它。

每个线程处理与其他线程相同的进程。

当我以非异步方式运行它时一切正常，但是当我使用线程调用相同的东西时， hibernate 就不能正常工作。

谁能解释一下在多线程 Java 独立应用程序中使用 Hibernate 的正确方法是什么？

hibernate 工具

public class HibernateUtil {

private static final Session session;

static {
    try {
        SessionFactory sessionFactory;
        Properties properties = new Properties();
        properties.load(new FileInputStream("middleware.properties"));
        Configuration cfg = new Configuration().configure();
        cfg.addProperties(properties);
        ServiceRegistry serviceRegistry = new ServiceRegistryBuilder()
                .applySettings(cfg.getProperties()).build();
        sessionFactory = cfg.buildSessionFactory(serviceRegistry);
        session = sessionFactory.openSession();
    } catch (IOException | HibernateException he) {
        JOptionPane.showMessageDialog(null, DataBaseMessage.CONNECTION_ERROR.getMessage(),              DataBaseMessage.CONNECTION_ERROR.getTitle(),JOptionPane.ERROR_MESSAGE);
        throw new ExceptionInInitializerError(he);          
    }  
}
public static Session getSession() {
    return session;
}

错误出现在这里

TbHistoDespachos despacho = Dao.findDespachoByTagId(element.getChild("tagID").getText());

public synchronized List<TbHistoDespachos> ExractDespachoAndNotify(String data, String nombreConexion) {
    List<TbHistoDespachos> despachos = new ArrayList<>();
    String nombreConexionUpp = nombreConexion.toUpperCase();
    try {
        Document doc = convertStringToDocument(data);
        if (!doc.getRootElement().getChild("reply").getChild("readTagIDs")
                .getChildren().isEmpty()) {
            for (Element element : doc.getRootElement().getChild("reply").
                    getChild("readTagIDs").getChild("returnValue")
                    .getChildren()) {
                TbHistoDespachos despacho = Dao.findDespachoByTagId(element.getChild("tagID").getText());
                if (despacho != null) {
                    if(evaluateDespacho(nombreConexionUpp, despacho)){
                        despachos.add(despacho);
                    }
                }
            }
        }
    } catch (JDOMException | IOException ex) {
        JOptionPane.showMessageDialog(null, FilesMessageWarnings.NOTIFICATION_SAP_WARNING.
                getMessage().replace("&nombreConexion", nombreConexion).replace("&tagID", ""),
                FilesMessageWarnings.NOTIFICATION_SAP_WARNING.getTitle(), JOptionPane.WARNING_MESSAGE);
    }
    return despachos;
}

这是 DAO

public class Dao {

private static Session sesion;
public static TbHistoDespachos findDespachoByTagId(String tagId) {
    TbHistoDespachos despacho = null;
    try {
        startTransmission();
        despacho = (TbHistoDespachos)sesion.createQuery("FROM TbHistoDespachos WHERE TAG_ID =:tagId")
                .setParameter("tagId", tagId)
                .uniqueResult();
        stopTransmission();
    } catch (HibernateException he) {
        System.out.println("error: " + he.getMessage());
        JOptionPane.showMessageDialog(null, DataBaseMessage.QUERY_ERROR.getMessage(),
                DataBaseMessage.QUERY_ERROR.getTitle(), JOptionPane.ERROR_MESSAGE);
    }
    return despacho;
}
private static void startTransmission() {

    sesion = HibernateUtil.getSession();
    sesion.getTransaction().begin();

}
private static void stopTransmission() {

    sesion.getTransaction().commit();
    sesion.getSessionFactory().getCurrentSession().close();
    sesion.clear();

}

有什么想法吗？

Answer 1

问题源于 static Session 变量。 SessionFactory 是线程安全的，一般来说，每个数据库只需要一个(静态)实例。另一方面，Session 不是线程安全的，通常是动态创建(使用 SessionFactory)和丢弃/关闭的。

要解决您眼前的问题，请从您的 Dao 中删除 static Session sesion 变量，并“内联” startTransmission 和 stopTransmission 方法findDespachoByTagId 方法。这将确保每个调用 findDespachoByTagId 的线程都创建并使用自己的 session 实例。要分析当前问题，请想象两个线程同时调用 findDespachoByTagId。现在静态 session 变量将被 startTransmission 方法赋值两次。这意味着一个 session 实例在创建后几乎立即丢失，而另一个 session 实例同时被两个线程使用。不是什么好事。

但也存在其他问题:没有finally block 保证事务关闭和数据库连接被释放(通过关闭 session )。此外，您可能希望使用数据库池，因为 Hibernate 提供的数据库池不适合生产。我建议你看看HibHik :我创建这个项目是为了展示一个最小的独立 Java 应用程序，它使用 Hibernate 和一个使用推荐模式和实践的数据库池 (HikariCP)(主要显示在 TestDbCrud.java 中)。在你的应用程序中使用相关部分，而不是编写多线程单元测试来验证你的数据库层(DAO)是否正常工作，即使在出现故障的情况下(例如，当数据库突然不再可用时，因为网络电缆是拔掉插头)。