2

我有一个名为 QueryTest 的方法，它通过网络查询 MySQL 数据库以获取名为 output 的表。从一开始，这个方法在运行时会不断消耗更多的内存，直到最终遇到内存不足的错误。我已经删除了我能想到的所有内容，甚至将查询放入一个有 500 毫秒超时的循环中，但仍然没有运气。

该程序旨在在低内存设备上运行，因此我不能让它继续增加内存使用量。

请在下面查看我的代码。这个类被另一个只包含new Thread(new QueryTest()).start()的类调用，没有其他作用。

编辑1：如果我添加 System.gc (); 就在 Thread.sleep 之前，它为我的程序增加了大约 7mb，但问题消失了。我知道该方法只能暗示垃圾收集器，所以这是一个可靠的解决方法吗？

// Add the main package
package DBTest;


// Import List
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;


public class QueryTest implements Runnable
{
    // Constant Objects
    public static Connection connection = null;
    ResultSet rs;
    ResultSetMetaData rsmd;
    Statement s;


    // Variables
    int portA = 0;
    int size = 0;
    String outputs [][] = new String [0][5];
    boolean isRunning = true;
    boolean isPaused = false;



    // The main method for starting the thread
    public void run ()
    {       
        // Try to connect to the database and query the updates
        try
        {       
            // Load the database driver
            Class.forName("com.mysql.jdbc.Driver").newInstance();       

            // Connect to the database
            connection = DriverManager.getConnection ("jdbc:mysql://192.168.1.103/noah", "root", "0004e5dcb6a");
            System.out.println ("Connection Made");

            // let the loop run while the thread is allowed to run
            while (isRunning)
            {       
                // Query the database if the thread is not paused
                if (!isPaused)
                {
                    // Create a prepared statement
                    s = connection.createStatement ();

                    // Execute the query and store the results
                    rs =  s.executeQuery ("SELECT * FROM outputs");

                    // Get the result set meta data
                    rsmd = rs.getMetaData();

                    // Set the result set to the last row
                    rs.last();

                    // Get the last row number
                    size = rs.getRow();

                    // Set the result set to the last row
                    rs.first();

                    /*// Get port A values
                    for (int a = 0; a < 8; a ++)
                    {
                        // Check if the output is active
                        if (Integer.parseInt(outputs [a][4]) == 1)
                        {
                            // Add to the port
                            portA = portA + Integer.parseInt (outputs [a][3]);
                            System.out.println (portA);
                        }
                    }*/

                    // Set the value of portA
                    portA = 0;
                }

                // Let the thread sleep
                Thread.sleep (500);
            }   

            // Close the connection
            connection.close();
            System.out.println ("Connection Closed");   
        }

        // Catch a error
        catch (Exception queryDatabaseErr)
        {
            System.out.println (queryDatabaseErr);
        }
    }
}
4

1 回答 1

1

关闭语句，并在不需要时释放结果集。在循环的 and 处。

    ...
    rs.close();  //free result set
    s.close();   //close the statement
    Thread.sleep(500)
}

我的 java 应用程序中有相同的 propbem。有时我在下面写的解决方案没有帮助。但是在我开始使用其他数据库库后：http: //sourceforge.net/projects/c3p0/，内存使用量急剧下降，应用程序运行速度更快。它使用持久连接，所以我推荐它只使用控制台或桌面应用程序，而不是 Java Servlet Pages。

我推荐阅读这个主题： Java MySQL JDBC Memory Leak ;)

After you installed or added the C3P0 lib to your project just import:

import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

After this you does not have to change your code (as i remember but you should read the manual of this lib http://www.mchange.com/projects/c3p0/apidocs/com/mchange/v2/c3p0/ComboPooledDataSource.html)

于 2013-03-30T12:23:10.493 回答