Исключение с ObjectInputStream

Question

У меня есть три класса, клиент, сервер и обработчик (который будет обрабатывать подключения к серверу), как показано ниже:

// 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' на мой сервер, который будет продолжать получать объект 'package' в любое время. Соединение работает нормально, но в конце программы запускается исключение:

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, но пока ничего. Есть идеи?

Answer 1

Это работает именно так, как вы хотите (вероятно).Он читает 100, затем проходит цикл снова (хотя (true) никогда не прекращает цикл до оператора break) и выдает исключение, потому что больше не было отправлено данных, и переходит в оператор catch и печатает ошибку перед выходом из цикла while.

Answer 2

EOFException - это IOException, указывающее конец потока.

Answer 3

Хорошо, это то, как работают потоки объектов и решение, которое работает везде.

Перед данными потока объектов предшествует 4-байтовая «магическая» последовательность AC ED 00 05.ObjectInputStream будет запрашивать эти данные во время построения, а не перед первым чтением.И это логично: нужно быть уверенным, что это правильный поток, прежде чем заходить слишком далеко в приложение.Последовательность буферизируется ObjectOutputStream во время построения, поэтому она передается в поток при первой записи.

Этот метод вызывает сложности в буферизованных ситуациях или передаче через сокеты.К счастью, существует простое и эффективное решение всех этих проблем:

Сброс ObjectOutputStream сразу после строительства!

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

Answer 4

Здесь мы говорим, что если больше нет байтов для чтения, то мы должны выйти из цикла while перед попыткой чтения объекта и т. Д.

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