我一直在敲我的头,试图找出问题所在。
我正在用 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();
}
}
}
最佳答案
你有一个死锁:
- 客户端发送登录信息
- 服务器读取登录行并发送 200 OK,并等待下一行
- 客户端读取 200 OK
- 客户端发送servershare
- 服务器读取servershare行,发送200 OK,等待下一行
- 客户端读取 200 OK,并等待下一行
客户端和服务器都在等待另一端的下一行。您的协议(protocol)不正确。
此外,您在服务器端和客户端使用平台默认编码来读取和写入消息。如果客户端和服务器没有相同的默认编码,就会有问题。您应该使用输入/输出流编写器包装您的流,并在构造它们时指定特定的编码。
关于java - TCP 套接字 : readine hangs if used in while loop at Client : java,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/7877596/