套接字多线程 - 读取输入流暂停线程

Question

我正在测试本地机器上的套接字.我正在尝试使用线程在一个程序中运行套接字和服务器.我的服务器是一个echo服务器,因此它会发回它收到的任何消息.我的问题是,当我在客户端和服务器上启动两个线程时,当它们到达我从输入流中读取的部分时,它们会"冻结".它适用于客户端发送消息的部分.之后,它只是停止,因为看起来客户端正在等待消息,即使我已经通过写入输出流向服务器发送消息,服务器也是如此.代码有什么问题？

Client.java

@Override
    public void run() {

        try {
            Socket socket = new Socket("localhost", 22600);

            BufferedReader br = new BufferedReader(new InputStreamReader(
                    socket.getInputStream()));
            BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(
                    socket.getOutputStream()));
            BufferedReader input = new BufferedReader(new InputStreamReader(
                    System.in));
            System.out.println("Client 1");

            while (true) {

                System.out.print("\nEnter text : ");
                String inputText = input.readLine();
                writer.write(inputText);
                System.out.println("Client 2");

                System.out.println("Client 3");
                String s = br.readLine();
                System.out.println("CLIENT RECEIVED : " + s);

            }

        } catch (Exception e) {
            e.printStackTrace();
        }

    }

Server.java

@Override
public void run() {

    try {
        ServerSocket server = new ServerSocket(22600);
        Socket socket = server.accept();
        BufferedReader br = new BufferedReader(new InputStreamReader(
                socket.getInputStream()));
        BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(
                socket.getOutputStream()));


        System.out.println("Server 1");
        while (true) {

            System.out.println("Server 2");
            String s = br.readLine();
            System.out.println("Server 3");
            if (s == null) {
                System.out.println("NULL SERVER SIDE ERROR");
                break;
            }

            writer.write("ECHO : " + s);
            System.out.println("SYSOUT ECHO " + s);

        }
        server.close();
    } catch (Exception e) {
        e.printStackTrace();
    }

}

Answer 1

您正在编写一个字符串,其末尾没有行尾.

            String inputText = input.readLine();
            writer.write(inputText);
            System.out.println("Client 2");

该inputText字符串不包括您键入的行尾.然后你按原样把它写到服务器上.但是,服务器尝试读取一行:

        String s = br.readLine();
        System.out.println("Server 3");

所以它会一直等到客户端发送换行符.但到目前为止,客户端正在等待服务器的回答,现在它们已陷入僵局.

因此,您应该writer.newLine()向客户端添加一个,以及服务器的echo,它会遇到同样的问题.在每次写入之后,还建议writer.flush()在服务器和客户端上使用它.否则,它可能会等到缓冲区已满,然后才会实际写入,并导致相同的死锁.