0

我有一个简单的应用程序来监听 UDP 消息。该应用程序需要无限期地运行。它通过实例化我创建的 MySQLConnect 对象来实例化单个 jdbc 数据库连接它看起来像这样：

 public MySQLConnect() {
    this.instantiateConnection();
}

//Open the database connection.  Done iniitally in 
//the main class and only called again if the connection 
//is closed due to an error in processing a message
public Connection instantiateConnection() {

    try {

        Class.forName("com.mysql.jdbc.Driver");

        connection = DriverManager
                .getConnection("jdbc:mysql://localhost:3306/mydb?"
                        + "user=user&password=pwd");
    } catch (Exception e) {
        e.printStackTrace();
    }

    return connection;
}

一旦启动应用程序，就会从 UDPReceiver 类调用 MySQLConnect 类构造函数。然后只有在出现错误处理并且数据库连接关闭时才会再次调用它。这个类看起来像：

 public class UDPReceiver {

private static int port = 2140;
private static int byteSize = 1024;
private static int timeOut = 5000;
@SuppressWarnings("unused")
private static int count;
static MySQLConnect dbConnect;


   public static void main(String[] args) {

    recvUDPMessage();
}

public static String recvUDPMessage() {
    DataTransferService dts = new DataTransferServiceImp();
    dbConnect = new MySQLConnect();

    try {

        DatagramSocket dsocket = null;
        if (dsocket == null) {
            dsocket = new DatagramSocket(port);
            dsocket.setBroadcast(true);
            dsocket.setReuseAddress(false);
        }
        byte[] inbuf = new byte[byteSize];
        byte[] rcvMsg;
        InetAddress fromIP;

        DatagramPacket receivepacket = new DatagramPacket(inbuf,
                inbuf.length);
        dsocket.setSoTimeout(timeOut);

        //Infinitely loop and listen for UDP messages

        count = 0;
        boolean loopRecv = true;
        while (loopRecv) {
            try {
                count++;
                dsocket.receive(receivepacket);
                // temp = receivepacket.getAddress().toString();
                fromIP = receivepacket.getAddress();
                String fromIPString = fromIP.toString();
                rcvMsg = receivepacket.getData();
                String rcvString = new String(rcvMsg, 0, rcvMsg.length);
                String rcvMessage = "Message Received from:  "
                        + fromIPString + " Message:  " + rcvString + "\n";
                System.out.println(rcvMessage);



                ArrayList<String> al = getMessageElements(rcvString);



                //Send array of message elements to service layer
                dts.saveUDPMessage(dbConnect, al, Utils.getTimeStamp());

                loopRecv = true;
            } catch (IOException e) {
                System.out.println("Listening . . .");



                loopRecv = true;
            }
        }
    } catch (SocketException e) {
        System.err.println("Sockets Exception: " + e.getMessage());
    } catch (Exception e) {
        System.err.println(" Exception: " + e.getMessage());

    } finally {
        System.out.println(". . . Close DB");
        dts.closeDBConnection(dbConnect);


                    // I added the creation MySQLConnect object after I was getting an error that the database was closed when trying to insert.
        dbConnect = new MySQLConnect();
    }
    return "end of routine";
}

//Extract comma delimited message elements into an array
private static ArrayList<String> getMessageElements(String rcvString) {
    StringTokenizer st = new StringTokenizer(rcvString, ",");

    ArrayList<String> al = new ArrayList<String>();

    while (st.hasMoreElements()) {
        String messageElement = (String) st.nextElement();
        al.add(messageElement);

    }



    return al;
}

}

这运行了大约 8 小时，然后我收到以下错误：

线程主 java.lang.stackoverflowerror 中的异常

异常：从线程主线程中的 uncaughtexceptionhandler 抛出 java.lang.outofmemoryerror

以前，我没有在数据库关闭后重新实例化 MySQLConnect 对象。问题是我收到数据库连接已关闭的错误，但我的程序仍在尝试执行 jdbc 插入。jdbc 插入首先检查是否有实例化的连接，如果没有实例化它。MySQLConnect 类中的这段代码如下所示：

 PreparedStatement prep = null;

    if (connection == null) {
        connection = this.instantiateConnection();
    }

    try {

        prep = connection
                .prepareStatement("insert into MyTable (UDPMessage)"
                        + "values (?);");

        prep.setString(1, udpMessage);




        prep.addBatch();

        prep.executeBatch();

即使发生错误，如何构建此过程以正确处理无限期传入的 UDP 消息并写入数据库？

另外，当我在处理数据时出现异常时重新实例化 MySQLConnect 类时，如何解决内存不足错误？

如果异常后实例化这个类不正确，如何重新实例化与数据库的连接以继续处理数据？

谢谢你的帮助！

4

3 回答 3

1

您没有在代码中的任何地方设置布尔值loopRecv，false这会导致无限循环（while 条件总是解析为true）。无限/递归循环继续填充堆栈，但不删除任何堆栈帧并导致StackOVerflowError.

于 2012-08-10T17:57:27.117 回答
1

让循环终止

while (loopRecv) {
...
}

你应该在loopRecv=false;某个不是案例的地方做标记。

于 2012-08-10T18:18:18.227 回答
0

如果您不担心同步性，为什么不将循环的内容放在另一个线程中。执行一次该线程，然后将其处理掉。然后在无限循环中，创建另一个线程并执行它。这些线程将自行处理并从堆栈中删除。

于 2012-08-10T18:08:36.103 回答