Java 客户端服务器

Question

我正在尝试将消息从服​​务器传递到终端中的客户端。我希望程序做的是，在客户端，它应该能够输入命令，从服务器获取响应，并且能够在不重新启动客户端（通过 java 客户端）的情况下输入另一个命令。

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();
}

如果我在Client.java中不放while((response = br.readLine()!= null) { ... }，是可以在终端输入多个输入的，但是如果我放的话，它打印来自服务器的响应，如果不重新启动客户端，则无法完成另一个输入。

任何帮助将不胜感激。

谢谢

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