Java Socket - Разбитая ошибка трубы

Question

Я пытаюсь отправить INT значения, долгого значения, длинного массива и 2d двойных массива через сокет от клиента к серверу.

Я успешно отправлены Int, длинные значения и длинный массив, однако, когда речь идет о двойном массиве (output.writeObject (server_ind) - см на сторону клиента коды ниже), я получаю следующее сообщение об ошибке:

ОШИБКА:

java.net.SocketException: Broken pipe 
    at java.net.SocketOutputStream.socketWrite0(Native Method) 
    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:113) 
    at java.net.SocketOutputStream.write(SocketOutputStream.java:159) 
    at java.io.ObjectOutputStream$BlockDataOutputStream.drain(ObjectOutputStream.java:1876) 
    at java.io.ObjectOutputStream$BlockDataOutputStream.writeByte(ObjectOutputStream.java:1914) 
    at java.io.ObjectOutputStream.writeFatalException(ObjectOutputStream.java:1575) 
    at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:350) 
    at clientSide.ClientSocket.connectionProtocol(ClientSocket.java:36) 
    at clientSide.clientMain.main(clientMain.java:97) 

Мой код выглядит следующим образом:

стороне клиента:

Side

 ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream()); 

     output.writeObject(num_doc); //int value 
     output.flush(); 

     output.writeObject(num); //long value 
     output.flush(); 

     output.writeObject(queryTDs); //long[] array 
     output.flush(); 

     output.writeObject(server_ind); //double[][] 
     output.flush(); 

Сервер:

input = new ObjectInputStream(clientSocket.getInputStream()); 

    num_doc = input.readInt(); 
    num = input.readLong(); 
    TDs = (long[]) input.readObject(); 
    server_ind = (double[][]) input.readObject(); 

    output = new ObjectOutputStream(clientSocket.getOutputStream()); 
    output.writeObject("Received"); 

Спасибо!

Answer 1

Я рекомендую вам преобразовать двойное значение в массив из 4 байтов (64 бит) и отправить его методом write (byte []) вместо writeObject. Будьте осторожны с порядком байта, который возвращает другую часть.

Кроме того, на Java существует другой тип потоковых писателей, которые обрабатывают числовые типы данных, они лучше, чем пытаться отправить объект.

Answer 2

Вы пишете объекты, но читаете примитивы. Поэтому в конечном итоге вы читаете меньше данных, чем на самом деле, не говоря уже о совершенно неправильных данных; то вы закрываете сокет, пока в нем еще нет непрочитанных ожидающих данных; и это приводит к тому, что сброс соединения будет передаваться автору; который вызывает «сломанную трубу».

Если вы пишете данные с помощью writeObject(), вы должны прочитать его с помощью readObject(). Если вы пишете данные с writeInt(), вы должны прочитать его с помощью readInt(). И так далее.

Answer 3

Broken pipe Exception происходит, когда соединение между отправителем и приемником закрыто ресивером (в данном случае стороной с сервером) до завершения отправления для отправки всего потока.

Проверка кода я замечаю, что:

В первом случае, вы отправляете и объект 32 бит (int):

output.writeObject(num_doc); //int value output.flush();

И ждать 32 бит:

num_doc = input.readInt();

То же самое для второго случая, когда вы отправляете и получаете 64 b его (long тип)

В случае long[] вы отправляете объект Wich его размер зависит от количества и типа данных, согласно ти оракула документации для `ObjectOutputStream:

Write the specified object to the ObjectOutputStream. The class of the object, the signature of the class, and the values of the non-transient and non-static fields of the class and all of its supertypes are written

Но в случае double[][], вы отправляете (double[]), что каждый элемент имеет еще один double[]. По какой-то причине это не ясно для меня, ObjectInputStream не может прочитать все объекты, которые были отправлены вашим клиентом.

Таким образом, может случиться так, что получатель не знает, сколько байтов необходимо прочитать для создания двойного массива.

Один вопрос для вас (@ Liutauras94): Есть ли исключения на стороне сервера?