Tcp Socket：如果在客户端的while循环中使用readine挂起：java

Question

我一直在敲我的头试图找出问题所在。

我正在 java 中尝试一个简单的服务器客户端 TCP 套接字。服务器可以发送多行作为响应。
我在客户端使用while((str = in.readLine())!= null)，它在阅读响应后挂起。请在下面找到代码。我发帖前已经搜索过了。我确保我以新行结束响应。

我尝试了 \n、\r\n 的组合，但 readLine 没有检测到行尾。
但它在服务器端运行良好。

请帮忙。

谢谢。

服务器：

import java.net.*;
import java.io.*;
public class SimpleServer {
public static void main(String args[]) throws IOException {

    ServerSocket s = new ServerSocket(55555);
    Socket socket = s.accept();

    BufferedReader in = new BufferedReader(
            new InputStreamReader(socket.getInputStream()));

    PrintWriter out = new PrintWriter(socket.getOutputStream(), true);

    String inputLine= null;
    System.out.println("call processInput"); 

       while ((inputLine = in.readLine()) != null) {
           System.out.println("before call processInput");           
           out.print("200 Success \r\n");
           out.flush();
           System.out.println("after call processInput: ");            
    }
    System.out.println("after while");
    out.close();
    in.close();
    socket.close();
    }
}

客户：

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.nio.CharBuffer;

public class Test {
     public static void main(String[] args) throws IOException {

          try {

              System.out.println(":Connect");
                  Socket s = new Socket("192.168.1.114",55555);
                  System.out.println("Socket:" + s); 


                  System.out.println("after :Connect");



                  OutputStream s1out = s.getOutputStream();


                  PrintWriter output = new PrintWriter(s1out, true);   
                  output.println("login user root");
                  output.flush();


                  BufferedReader in = new BufferedReader(
                        new InputStreamReader(
                            s.getInputStream()));

                  System.out.println( in.readLine());



                  output.println("servershare");
                  output.flush();
                  System.out.println( "servershare");
                  String str = null;


             while((str = in.readLine())!= null) // hangs here
             {
                  System.out.println(str);

              }


               System.out.println( "share");
               output.println("share file1.txt file1.html, roopa ramesh");
                   str = null;
                   while((str = in.readLine())!= null && !str.equals(""))
                  System.out.println(str);

                  in.close();
                  output.close();
                  s.close();







          } catch (UnknownHostException e) {

                  // TODO Auto-generated catch block

                  e.printStackTrace();

          } catch (IOException e) {

                  // TODO Auto-generated catch block

                  e.printStackTrace();

          } 
     }
}

Answer 1

你有一个死锁：

1. 客户端发送登录信息
2. 服务器读取登录行并发送 200 OK，并等待下一行
3. 客户端读取 200 OK
4. 客户端发送服务器共享
5. 服务器读取 servershare 行，发送 200 OK，等待下一行
6. 客户端读取 200 OK，等待下一行

客户端和服务器都在等待另一端的下一行。您的协议不正确。

此外，您在服务器端和客户端使用平台默认编码来读取和写入消息。如果客户端和服务器没有相同的默认编码，你就会遇到问题。您应该使用输入/输出流编写器包装您的流，并在构造它们时指定特定的编码。