java - 套接字 - 无连续响应

Question

我第一次深入研究套接字。 该项目的重点是客户端能够通过编写“getall”来访问服务器中的联系人列表(CSV)，并仅通过该命令(“退出”)退出程序。

问题在于客户端只能编写一次命令并接收一次列表，然后服务器不再响应客户端的输入。

这里分别是服务器和客户端的套接字代码:

服务器:

public class CatalogueServer extends CatalogueLoader {

ServerSocket serverSocket;
ArrayList<CatalogueEntry> catalogue;

public void startServer(int port, String catalogueFile) {

    catalogue = loadLocalCatalogue(catalogueFile);

    try {
        serverSocket = new ServerSocket(port);

        while (true) {
            Socket clientSocket = serverSocket.accept();

            new Thread(
                    new Runnable() {
                        public void run() {
                            try {

                                InputStream inputStream = clientSocket.getInputStream();
                                InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "UTF-8");

                                BufferedReader BR = new BufferedReader(inputStreamReader);

                                OutputStream outputStream = clientSocket.getOutputStream();
                                PrintWriter PW = new PrintWriter(outputStream);
                                String clientInput;

                                while ((clientInput = BR.readLine()) != null) {
                                    System.out.println(clientInput);
                                    if (clientInput.equals("getall")) {
                                        System.out.println(printCatalogue(catalogue));
                                        PW.println(printCatalogue(catalogue));
                                        PW.flush();
                                        break;
                                    } else if (clientInput.equals("exit")) {
                                        clientSocket.close();
                                        BR.close();
                                        PW.close();
                                        break;
                                    } else {
                                        PW.flush();
                                        break;
                                    }
                                }
                                PW.close();
                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                    }
            ).start();
        }
    } catch (Exception i) {
        i.printStackTrace();
    }
  }
}

客户:

public class TestClient {

public static void main(String[] args) {

    try {
        Socket socket = new Socket("localhost", 5253);
        OutputStream outputStream = socket.getOutputStream();
        InputStream inputStream = socket.getInputStream();
        InputStreamReader inputStreamReader = new InputStreamReader(inputStream);

        BufferedReader BR = new BufferedReader(inputStreamReader);

        while (true) {

            String clientInput;
            String serverFeedback;

            PrintWriter PW = new PrintWriter(outputStream);

            Scanner inputScan = new Scanner(System.in, "UTF-8");
            clientInput = inputScan.nextLine();

            PW.println(clientInput);
            PW.flush();

            while ((serverFeedback = BR.readLine()) != null)  {
                System.out.println(serverFeedback);
            }

            if (clientInput.equals("exit")) {
                PW.close();
                socket.close();
                break;
            }
            PW.close();
        }
    }
    catch (IOException e){
        e.printStackTrace();
    }
  }
}

我尝试过互换读者和作者的立场和更新。但我不确定问题到底从哪里开始。

Answer 1

当你这样做时

        while ((serverFeedback = BR.readLine()) != null)  {
            System.out.println(serverFeedback);
        }

您正在阅读，直到到达流的末尾，即直到没有任何内容为止。因此，此后就没有任何内容了。

如果你想重用连接，你必须编写不使用此模式的代码，并且只读取直到它应该停止读取为止。