首页 ❯

休眠不从连接池释放连接

java mysql hibernate jpa c3p0
2022-09-01 23:31:01

我正在使用Hibernate JPA创建一个应用程序，并使用c3p0与MySQL进行连接池。我对MySQL数据库的连接数有一个问题，因为它击中了152个打开的连接，这是不希望的，因为我在c3p0配置文件中将最大池大小定义为20，当然，我在提交每个事务后关闭了从中获得的每个实体管理器。EntityManagerFactory

每次执行控制器时，我注意到打开了超过7个连接，如果我刷新，则会再次打开7个连接，而不会关闭过去的空闲连接。在我调用的每个DAO函数中，都会执行em.close（）。我在这里承认问题出在我的代码中，但我不知道我在这里做错了什么。

这是 Sondage.java实体：

@Entity
@NamedQuery(name="Sondage.findAll", query="SELECT s FROM Sondage s")
public class Sondage implements Serializable {

    private static final long serialVersionUID = 1L;

    public Sondage() {}

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private int id;

    private String name;

    private byte needLocation;

    //bi-directional many-to-one association to ResultatSondage
    @OneToMany(mappedBy = "sondage", cascade = CascadeType.ALL)
    @OrderBy("sondage ASC")
    private List<ResultatSondage> resultatSondages;

    //bi-directional many-to-one association to SondageSection
    @OneToMany(mappedBy = "sondage", cascade = CascadeType.ALL)
    private List<SondageSection> sondageSections;
}

这是我的DAO课程：

@SuppressWarnings("unchecked")
public static List<Sondage> GetAllSondage() {
    EntityManager em = PersistenceManager.getEntityManager();
    List<Sondage> allSondages = new ArrayList<>();
    try {
        em.getTransaction().begin();
        Query query = em.createQuery("SELECT s FROM Sondage s");
        allSondages = query.getResultList();
        em.getTransaction().commit();
    } catch (Exception ex) {
        if (em.getTransaction().isActive()) {
            em.getTransaction().rollback();
        }
        allSondages = null;
    } finally {
        em.close();
    }
    return allSondages;
}

如您所见，已关闭。在我的JSP中，我这样做：我知道这不是在视图方面做事的好方法。em

<body>
    <div class="header">
        <%@include file="../../../Includes/header.jsp" %>
    </div>
    <h2 style="color: green; text-align: center;">الاستمارات</h2>
    <div id="allsurveys" class="pure-menu custom-restricted-width">
        <%
            List<Sondage> allSondages = (List<Sondage>) request.getAttribute("sondages");

            for (int i = 0; i < allSondages.size(); i++) {
        %>
        <a  href="${pageContext.request.contextPath }/auth/dosurvey?id=<%= allSondages.get(i).getId()%>"><%= allSondages.get(i).getName()%></a> &nbsp;
        <%
            if (request.getSession().getAttribute("user") != null) {
                Utilisateur user = (Utilisateur) request.getSession().getAttribute("user");
                if (user.getType().equals("admin")) {
        %>
        <a href="${pageContext.request.contextPath }/aauth/editsurvey?id=<%= allSondages.get(i).getId()%>">تعديل</a>
        <%
                }
            }
        %>
        <br />
        <%
            }
        %>
    </div>
</body>

我猜每次我打电话，都会建立一个请求？如果是这样，我该如何防止这种情况？user.getType()

对于c4p0配置文件，我将其包含在持久性中.xml，我看到几个帖子说我需要将c3p0配置文件放在c3p0-config中.xml，但是通过我的设置，c3p0是使用我在持久性文件中传递的值初始化的.xml，mysql连接也达到152个连接，但20，这是持久性.xml文件maxpoolsize

<persistence version="2.1"
             xmlns="http://xmlns.jcp.org/xml/ns/persistence"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence
             http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd">

    <persistence-unit name="CAOE" transaction-type="RESOURCE_LOCAL">
        <class>com.caoe.Models.ChoixQuestion</class>
        <class>com.caoe.Models.Question</class>
        <class>com.caoe.Models.Reponse</class>
        <class>com.caoe.Models.ResultatSondage</class>
        <class>com.caoe.Models.Section</class>
        <class>com.caoe.Models.Sondage</class>
        <class>com.caoe.Models.SondageSection</class>
        <class>com.caoe.Models.SousQuestion</class>
        <class>com.caoe.Models.Utilisateur</class>
        <properties>
            <property name="hibernate.connection.provider_class"
                      value=" org.hibernate.service.jdbc.connections.internal.C3P0ConnectionProvider" />

            <property name="hibernate.connection.driver_class" value="com.mysql.jdbc.Driver"/>
            <property name="hibernate.connection.password" value=""/>

            <property name="hibernate.connection.url"
                      value="jdbc:mysql://localhost:3306/caoe?useUnicode=yes&amp;characterEncoding=UTF-8"/>

            <property name="hibernate.connection.username" value="root"/>
            <property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect"/>
            <property name="hibernate.show_sql" value="true" />

            <property name="hibernate.c3p0.max_size" value="50" />
            <property name="hibernate.c3p0.min_size" value="3" />
            <property name="hibernate.c3p0.max_statements" value="20" />
            <property name="hibernate.c3p0.acquire_increment" value="1" />
            <property name="hibernate.c3p0.idle_test_period" value="30" />
            <property name="hibernate.c3p0.timeout" value="35" />
            <property name="hibernate.c3p0.checkoutTimeout" value="60000" />
            <property name="hibernate.connection.release_mode" value="after_statement" />

            <property name="debugUnreturnedConnectionStackTraces"
                      value="true" />
        </properties>
    </persistence-unit>
</persistence>

编辑：我正在将应用程序部署到安装了Tomcat和MySQL的红帽服务器上。我只是想知道为什么Hibernate打开了太多与MySQL的连接，所有实体管理器都关闭了，没有连接将保持打开状态，但事实并非如此。我正在猜测并纠正我，如果我真的是在我做这样的事情时打开了连接：

List<Sondage> allSondages = SondageDao.getAllSondages();

for (Sondage sondage : allSondages) {
    List<Question> questions = sondage.getQuestions();
    //code to display questions for example
}

在这里，当我使用时，Hibernate是否打开了与数据库的连接，并且在之后没有关闭它，我是否在配置文件中缺少一些东西，这些内容在完成后关闭或返回与池的连接。提前感谢您的任何帮助。sondage.getQuestions()

EDIT2 ： 由于人们要求版本，这里他们是： JAVA jre 1.8.0_25 Apache Tomcat v7.0 hibernate-core-4.3.10 hibernate c3p0 4.3.10.final hibernate-jpa 2.1 提前致谢

mysql版本是Mysql 5.6.17，如果这可以提供帮助...

编辑4：由于人们对我发布的代码的女巫版本感到困惑，请让我编辑它，这样你就会知道到底发生了什么：

首先，我将首先展示什么是错误的代码，因为你们并不关心什么是有效的：

@SuppressWarnings("unchecked")
public static List<Sondage> GetAllSondage() {
    EntityManager em = PersistenceManager.getEntityManager();
    List<Sondage> allSondages = new ArrayList<>();
    try {
       em.getTransaction().begin();
       Query query = em.createQuery("SELECT s FROM Sondage s");
       allSondages = query.getResultList();
       em.getTransaction().commit();
    } catch (Exception ex) {
    if (em.getTransaction().isActive()) {
        em.getTransaction().rollback();
    }
    allSondages = null;
    } finally {
        em.close();
    }
    return allSondages;
  }

所以这基本上就是我为所有dao函数所做的，我知道这里不需要交易，因为我看到问题指出交易对于连接关闭很重要。除此之外，我从 PersistenceManager 类中获取了EntityManager，它有一个 EntityManagerFactory 单例对象，因此 getEntityManager 从 EntityManagerFactory 单例 Object：=> 代码优于 1000 字：PesistenceManager.java：

import javax.persistence.EntityManager;
    import javax.persistence.EntityManagerFactory;
    import javax.persistence.Persistence;

    public class PersistenceManager 
    {
    private static EntityManagerFactory emf = null;

    public static EntityManager getEntityManager()
    {
        return getEntityManagerFactory().createEntityManager();     
    }

    public static EntityManagerFactory getEntityManagerFactory()
    {
            if(emf == null) {
                    emf = Persistence.createEntityManagerFactory("CAOE");
                    return emf;
        }
            else
                    return emf;
        }
}

是的，这很酷，一切都很好，但问题出在哪里？

这里的问题是，这个版本打开连接，从不关闭它们，em.close（）没有效果，它使连接保持对数据库的打开。

菜鸟修复：

我解决这个问题的方法是为每个请求创建一个EntityManagerFactory，这意味着dao看起来像这样：

    @SuppressWarnings("unchecked")
public static List<Sondage> GetAllSondage() {
    //this is the method that return the EntityManagerFactory Singleton Object
    EntityManagerFactory emf = PersistenceManager.getEntitManagerFactory();
    EntityManager em = emf.createEntityManager();
        List<Sondage> allSondages = new ArrayList<>();
        try {
            em.getTransaction().begin();
            Query query = em.createQuery("SELECT s FROM Sondage s");
            allSondages = query.getResultList();
            em.getTransaction().commit();
    } catch (Exception ex) {
        if (em.getTransaction().isActive()) {
            em.getTransaction().rollback();
        }
        allSondages = null;
        } finally {
        em.close();
        emf.close();
    }
    return allSondages;
}

现在这很糟糕，我会在我没有这个问题的答案时保留它（似乎forver :D）。因此，使用此代码，基本上所有连接在休眠后都关闭，不需要它们。提前感谢您在这个问题上所做的任何努力:)


答案 1

我认为Hibernate和C3P0在这里表现正确。实际上，您应该看到，根据 C3P0 配置，始终至少有三个与数据库的连接处于打开状态。

执行查询时，Hibernate 将使用池中的连接，然后在完成后返回该连接。它不会关闭连接。如果超过最小大小并且某些连接超时，C3P0 可能会缩小池。

在最后一个示例中，你看到连接已关闭，因为你已关闭实体管理器工厂，因此也关闭了连接池。


答案 2

你每次都打电话。这是错误的。每次调用都会创建新的（独立）连接池。您应该将EntityManagerFactory对象缓存在某个地方。Persistence.createEntityManagerFactory("CAOE")createEntityManagerFactory

编辑：

此外，您还应该手动关闭EntityManagerFactory。您可以在@WebListener中执行此操作：

@WebListener
public class AppInit implements ServletContextListener {

    public void contextInitialized(ServletContextEvent sce) {}

    public void contextDestroyed(ServletContextEvent sce) {
         PersistenceManager.closeEntityMangerFactory();
    }
}

否则，每个重新部署的情况都是连接泄漏的来源。


推荐
更多 »
标签
更多 »
php pass-by-reference optional-parameters default-value javascript arrays dom function string object serialization tostring visibility syntax jslint use-strict operators equality equality-operator identity-operator datetime timestamp date-arithmetic redirect angularjs loops foreach iteration scope variables
推荐
更多 »