Клиентское приложение Java зависает при отправке объекта через сокеты

Question

У меня есть это клиент-серверное приложение, и клиентское приложение иногда полностью зависает, когда я пытаюсь отправить объект через сокеты

public Client client = new Client();
petriNetList = client.query(client.actionLoadPetriNetList, MainWindow.loginUsername);

вот код клиента

 public class Client {
    public static Socket kkSocket = null;
    public static PrintWriter out = null;
    public static BufferedReader in = null;
    public static BufferedReader stdIn = null;
    public static OutputStream outputStream = null ;
    public static ObjectOutputStream  objectOutputStream = null ; 
    public static InputStream inputStream = null ; 
    public static ObjectInputStream  objectInputStream = null ;  


    public String actionSavePetriNet = "SAVE PETRI NET START";



    /*
     * Save petri net to server
     * 
     * @param action identifies query
     * @param petriName name of the petri net
     * @param username username
     * @param xml content of the petri net
     * 
     * @return int response form server
     */
public int query (String action,String petriName,String username,String xml) throws IOException {



    int size ;
    int result = 0;
    connect();
    if (action.equals(actionSavePetriNet)) {

        out.println(action); // save petri net
        out.println(petriName); //petri net name
        out.println(username); //username
        System.out.println("(Client:)" + xml);
        objectOutputStream.writeObject(xml); //send object over the network
        System.out.println("Dostali sme sa sem ?");
        result = Integer.parseInt(in.readLine()); //read response from server
    }

       disconnect();
        return result;
}    


    /*
     * connect to server
     * TODO: ADD hostname and port as parameter
     */
    public static void connect() throws IOException {
    try {
            kkSocket = new Socket("osiris-PC", 4444);
            out = new PrintWriter(kkSocket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(kkSocket.getInputStream()));
        } catch (UnknownHostException e) {
            System.err.println("Don't know about host: taranis.");
            System.exit(1);
        } catch (IOException e) {
            System.err.println("Couldn't get I/O for the connection to: taranis.");
            System.exit(1);
        }

         stdIn = new BufferedReader(new InputStreamReader(System.in));

          outputStream = kkSocket.getOutputStream();  
          objectOutputStream = new ObjectOutputStream(outputStream);  

          inputStream = kkSocket.getInputStream();
          objectInputStream = new ObjectInputStream(inputStream);

    }

    /*
     * Disconnect from server
     * close all input/output streams
     * 
     */
    public static void disconnect() throws IOException {
        out.close();
        in.close();
        stdIn.close();
        objectOutputStream.close();
        outputStream.close();
        objectInputStream.close();
        inputStream.close();
        kkSocket.close();

    }
}

а это код сервера

public class PetriServer {
    public static Protocol kkp = new Protocol();

    public static   InputStream inputStream = null ;
    public static   ObjectInputStream objectInputStream = null ; 
    public static   OutputStream outputStream = null ;
    public static   ObjectOutputStream objectOutputStream = null ;



    public static void main(String[] args) throws IOException, ClassNotFoundException {
        kkp.loadUsers();

     while(true) {
         ServerSocket serverSocket = null;

            inputStream = null ;
            objectInputStream = null ; 
            outputStream = null ;
            objectOutputStream = null ;

        try {
            serverSocket = new ServerSocket(4444);
        } catch (IOException e) {
            System.err.println("Could not listen on port: 4444.");
            System.exit(1);
        }

        Socket clientSocket = null;
        try {
            clientSocket = serverSocket.accept();
        } catch (IOException e) {
            System.err.println("Accept failed.");
            System.exit(1);
        }

        PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
        BufferedReader in = new BufferedReader(
                new InputStreamReader(
                clientSocket.getInputStream()));

        inputStream = clientSocket.getInputStream();  
       objectInputStream = new ObjectInputStream(inputStream);  

        outputStream = clientSocket.getOutputStream();
       objectOutputStream = new ObjectOutputStream(outputStream);
       inputLine = in.readLine();

        String inputLine;
 if (inputLine.equals("SAVE PETRI NET START")) {

            String petriName;
            String username;
            String xml ;
            String input;
            int result;
            int size ;

            petriName = in.readLine(); //read petri name

            System.out.println("(Server): prijali sme poziadavok na ulozenie " + petriName );


            username = in.readLine(); //read username
            System.out.println("(Server): poziadavok ide od usera: " + username);

          while(true) {

//this is the line where is occasionally freezes 
                xml = (String)objectInputStream.readObject(); //read object over the network
           if (!xml.isEmpty()) break; 
          }


          System.out.println("(Server):" + xml);

            result = kkp.savePetrinet(username, petriName,xml); //save it to the file
            out.println(result);

        }

        out.close();
        in.close();
        objectInputStream.close();
        inputStream.close();
        objectOutputStream.close();
        outputStream.close();
        clientSocket.close();
        serverSocket.close();


    }
    }
}

Кто-нибудь знает в чем может быть проблема?веселит.

Answer 1

Socket InputStream на сервере подключен к двум различным входам, ObjectInputStream и BufferedReader. InputStreams не предназначены для использования таким образом, и это может вызвать много проблем. BufferedReaders, по своей природе, будет собирать больше данных с InputStream, чем вы на самом деле читаете. Если случится так, что они буферизуют данные, составляющие объект, то ваша последующая попытка прочитать объект с ObjectInputStream заблокирует, потому что данные уже удалены.

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

Редактировать на основе комментария @Dunes ниже

Кажется, вам лучше всего придерживаться ObjectInputStream и использовать другие его методы, которые позволяют вам читать произвольные типы примитивов из потока. И, если вы не возражаете против устаревшего вызова, у него даже есть метод readLine.