Hibernate 和多线程逻辑

我正在开发一个 java 独立项目。我需要在多线程应用程序中使用休眠，但我只是不知道如何正确设置它。

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

当我以非异步方式运行它时，一切都很好，但是当我使用线程调用相同的东西时，休眠就无法正常工作。

谁能解释一下在多线程 Java 独立应用程序中使用 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();

}

有任何想法吗？

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

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

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