ObjectInputStream 异常答案

【问题标题】：Exception with ObjectInputStreamObjectInputStream 异常
【发布时间】：2011-10-08 21:46:03
【问题描述】：

我有三个类，客户端、服务器和处理程序（将处理服务器连接），如下所示：

// The Client
    public void sendSomePackage() {
        try {
            socket = new Socket("localhost", 54321);
            sos = socket.getOutputStream();
            oos = new ObjectOutputStream(sockOutput);
        } catch (IOException e) {
            e.printStackTrace(System.err);
            return;
        }

        // About to start reading/writing to/from socket

        try {
            Package package = new Package(100);
            oos.writeObject(pacote);

        } catch (IOException e) {
            e.printStackTrace(System.err);
        }

        try {
            Thread.sleep(50);
        } catch (Exception e) {
            e.printStackTrace();
        }

        // Done reading/writing to/from socket, closing socket.

        try {
            sock.close();
        } catch (IOException e) {
            System.err.println("Exception closing socket.");
            e.printStackTrace(System.err);
        }
        //Exiting
    }

现在是服务器类：

// The Server - with a method that just wait for connections

    public void waitForConnections() {
        while (true) {
            try {
                socket = serverSocket.accept();

                // Server:Accepted new socket, creating new handler for it
                SimpleHandler handler = new SimpleHandler(socket);
                handler.start();

                // Server:Finished with socket, waiting for next connection
            }
            catch (IOException e){
                e.printStackTrace(System.err);
            }
        }
    }

我的处理程序，它只处理服务器连接：

@Override
public void run() {
    //Handler: Handler run() starting
    while (true) {
        try {
            package = (Package) ois.readObject();
            if (pacote != null) {
                System.out.println("Package received " + pacote.getSourceid());
            }
        } catch (Exception e) {
            e.printStackTrace(System.err);
            break;
        }
    }

    try {
        // SimpleHandler:Closing socket
        sock.close();
        ois.close();
    } catch (Exception e) {
        // Handler: Exception while closing socket, e=" + e);
        e.printStackTrace(System.err);
    }

}

这个想法是客户端向我的服务器发送一些“包”对象，该服务器将随时运行接收“包”对象。连接工作正常，但在程序结束时会启动一个异常，这就是：

Package received 100
java.io.EOFException
    at java.io.ObjectInputStream$BlockDataInputStream.peekByte(Unknown Source)
    at java.io.ObjectInputStream.readObject0(Unknown Source)
    at java.io.ObjectInputStream.readObject(Unknown Source)
    at br.ufscar.socket.SimpleHandler.run(SimpleHandler.java:45)
    at java.lang.Thread.run(Unknown Source)

我已经在 Google 上搜索了一些东西，但目前还没有。有什么想法吗？

【问题讨论】：

您是否考虑在 Javadoc 中查找 EOFException？

标签： java sockets stream inputstream outputstream

【解决方案1】：

这完全符合您的要求（可能）。它读取 100 然后再次通过循环（while(true) 永远不会停止循环，直到一个 break 语句）并抛出一个异常，因为没有更多的数据被发送，它进入 catch 语句并在退出你的 while 循环之前打印错误.

【讨论】：

即使没有更多数据要发送，也有办法不启动任何异常？

【解决方案2】：

EOFException 是一个指示流结束的 IOException。

【讨论】：

【解决方案3】：

这里我们说如果没有更多字节要读取，那么我们应该在尝试读取对象之前跳出 while 循环，等等。

while (true) {
   if (ois.read() == -1) break;
   //...rest of the code
}

【讨论】：

你刚刚丢掉了一个字节的输入。以下 readObject() 将因此失败。

【解决方案4】：

好的，这就是对象流的工作方式以及适用于任何地方的解决方案。

对象流数据前面有一个 4 字节的“神奇”序列AC ED 00 05。 ObjectInputStream 将在构建时而不是在第一次读取之前查看此数据。这是合乎逻辑的：人们想在应用程序中太过分之前确保它是一个正确的流。该序列在构造时由ObjectOutputStream 缓冲，以便在第一次写入时将其推送到流上。

这种方法在缓冲情况或通过套接字传输时会产生复杂性。幸运的是，所有这些问题都有一个简单而有效的解决方案：

构建后立即刷新ObjectOutputStream！

ObjectOutputStream myStream =  new ObjectOutputStream ( anotherStream );
myStream.flush();

【讨论】：

这没有解决 EOFException。