Java Client Server

Question

Я пытаюсь передать сообщение от сервера к клиенту в терминале. То, что я хотел бы, чтобы программа выполняла, заключается в том, что на клиенте она должна иметь возможность вводить команду, получать ответ от сервера и иметь возможность вводить другую команду без перезапуска Client (через java Client).

Client.java

Socket socket = new Socket(host, port); 
InputStream is = socket.getInputStream(); 
InputStreamReader isr = new InputStreamReader(is); 
BufferedReader br = new BufferedReader(isr); 

String response = ""; 

boolean continuation = true; 
while(continuation) { 
    Scanner input = new Scanner(System.in); 
    String command = (input.nextLine()).toString(); 
    bw.write(command+"\r\n"); 
    bw.flush(); 

    if(command.equals("cmd1") { 
     while ((response = br.readLine()) != null) { 
      System.out.println(response); 
     } 
    } 
    System.out.println("This line will not execute as well."); 
} 

Server.java

InputStream is = socket.getInputStream(); 
InputStreamReader isr = new InputStreamReader(is); 
BufferedReader br = new BufferedReader(isr); 

OutputStream os = socket.getOutputStream(); 
OutputStreamWriter osw = new OutputStreamWriter(os); 
BufferedWriter bw = new BufferedWriter(osw); 

String[] in = br.readLine().split("\\s+"); 
String command = in[0]; 

if(command.equals("cmd1")) { 
    String response = ""; 
    response = response + "RESPONSE:\r\n"; 
    response = response + "This is a response.\r\n"; 
    bw.write(response); 

    bw.flush(); 
} 

Если я не ставлю в то время как ((ответ = br.readLine()! = NULL) {. ..} в Client.java, можно ввести несколько входов в терминале, но если я его положу, он печатает ответ с сервера, а другой вход не может быть выполнен без перезапуска клиента.

Любая помощь будет оценена по достоинству.

Благодаря

Answer 1

Это должно работать:

сервер:

DataInputStream dis = new DataInputStream(socket.getInputStream()); 
DataOutputStream dos = new DataOutputStream(socket.getOutputStream()); 

boolean continuation = true; 
while (continuation) { 
    String command = dis.readUTF(); 
    //proceeed command 
    dos.writeUTF("response"); 
    dos.flush(); 
} 

Клиент:

DataInputStream dis = new DataInputStream(socket.getInputStream()); 
DataOutputStream dos = new DataOutputStream(socket.getOutputStream()); 

    dos.writeUTF("your command"); 
    while (dis.available() == 0) { 
     try { 
      //wait for response 
      Thread.sleep(1); 
     } catch (InterruptedException ex) { 
      Logger.getLogger(RandomTest.class.getName()).log(Level.SEVERE, null, ex); 
     } 
    } 
    String response = dis.readUTF(); 
    //and so on