Чтение нескольких строк с сервера - PullRequest
Новая
       68

Чтение нескольких строк с сервера

1 голос
/ 30 марта 2020

Я открыт для других способов сделать это, но это мой код: 

public class Client {
    public static void main (String [] args) {
        try(Socket socket = new Socket("localhost", 7789)) {
            BufferedReader incoming = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            PrintWriter outgoing = new PrintWriter(socket.getOutputStream(),true);
            StringBuilder sb = new StringBuilder();

            Scanner scanner = new Scanner(System.in);
            String send = "";
            String response = "";

            while (!send.equals("logout")){
                System.out.println("Enter Command: ");
                send = scanner.nextLine();
                outgoing.println(send);
                while ((response = incoming.readLine()) != null) {
                    System.out.println(response);
                    sb.append(response);
                    sb.append('\n');

                    }
            }
        } catch (IOException e) {
            System.out.println("Client Error: "+ e.getMessage());
        }
    }
}

Я получаю ответ от сервера, но программа застревает во внутренней части, пока l oop while ((response = incoming.readLine()) != null), поэтому я не могу ввести вторую команду. как мне сломать l oop, если входящий ответ сделан?

1 Ответ

1 голос
/ 30 марта 2020

Проблема в том, что incoming.readLine() вернет null, только если сокет закрыт, в противном случае он заблокирует и будет ждать ввода от сервера.

Если вы можете изменить сервер, вы можете добавить отметку о том, что запрос был полностью обработан, а затем проверить его следующим образом while ((response = incoming.readLine()) != "--finished--").

Если вы не можете, попробуйте это: 

while(response.isEmpty()){
    if(incoming.ready()){ //check if there is stuff to read
        while ((response = incoming.readLine()) != null){
            System.out.println(response);
            sb.append(response);
            sb.append('\n');
        }
    }
}
...