插座不工作

Question

我正在尝试制作一个简单的客户端和服务器来发送和接收文本。客户端等待命令行输入，然后将其发送到服务器，服务器在System.out 上显示它。但是，尽管客户端允许我输入下一行来发送，但服务器仍然无法从套接字读取。

客户：

public class Main implements Runnable{
    String [] args;
    Socket socket;
     PrintWriter printer;

    public Main(String [] args){
        this.args = args;
    }
    @Override
    public void run() {
        try {
            socket = new Socket(args[0], Integer.parseInt(args[1]));
            printer = new PrintWriter(socket.getOutputStream());
        } catch (UnknownHostException e){
            System.out.println("Unknown host.");
            System.exit(2);
        } catch (IOException e) {
            e.printStackTrace();
        }
        while(true){
            String textToSend = System.console().readLine();
            printer.print(textToSend);
        }
    }
}

printer.print(textToSend); 行不通。

服务器：

public class Main implements Runnable{
    String [] args;

    public Main(String [] args){
        this.args = args;
    }
    @Override
    public void run() {
        if (args == null){
            System.out.println("Argument for port missing");
            System.exit(2);
        }
        try {
            ServerSocket listener = new ServerSocket(Integer.parseInt(args[0]));

            while (true){
                Socket client = listener.accept();
                System.out.println("Client connected");
                BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));

                try{
                    while(true){
                        String text = in.readLine();
                        System.out.println(text);
                        if (in.read() == -1){
                            return;
                        }
                    }
                }catch (IOException e){
                    System.out.println("Client lost");
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

欢迎任何帮助。

Answer 1

当你在做的时候

 if (in.read() == -1){
    return;
 }

你正在扔掉一个字符

还有，当你写作时

printer.print(textToSend); 

textToSend 没有CR，因此接收readLine 将阻塞。 尝试在textToSend 末尾添加CR 或使用println 方法

Answer 2

我发现错误：你必须添加换行符并调用flush：

      printer.print(textToSend + "\n");
      printer.flush();

这对我有用。

Flush 强制发送所有数据并清空所有缓冲区，以便发送数据。需要换行，以便接收端知道该行是完整的。

您检查是否没有发送数据应该是line == null，而不是read() == -1。

这是我的整个演示代码：

BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
while(true){
    String textToSend = null;
    try {
       textToSend = reader.readLine();
       System.out.println("read text: " + textToSend);
    } catch (IOException e) {
        e.printStackTrace();
    }
    printer.print(textToSend + "\n");
    printer.flush();
    System.out.println("text send");
 }

服务器端的错误检查：

    String text = in.readLine();
    if (text == null){
          return;
    }
    System.out.println(text);