JAVA TCP 服务端需要等到客户端关闭之后才能后台打印发送数据。
启动TCP服务端之后,我用TCP助手连接TCP客户端,想该服务端发送数据。发现后台打印不出来。然后关闭TCP助手的客户端之后,服务端打印出刚才客户端发送的信息。我单步调试...
启动TCP服务端之后,我用TCP助手连接TCP客户端,想该服务端发送数据。发现后台打印不出来。然后关闭TCP助手的客户端之后,服务端打印出刚才客户端发送的信息。我单步调试之后,发现函数在while ((msg = br .readLine()) != null)之后停滞不前。等关闭客户端之后,程序才前进到System.out.println(msg); 请问这个是什么原因?怎么修改呢?读数据和处理部分代码如下:
//读数据方法
private BufferedReader getReader(Socket socket)throws IOException{
InputStream socketIn = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(socketIn);
return new BufferedReader(isr);
}
//接受处理
public void run() {
System.out.println("一个新的连接 " +
socket.getInetAddress() + ":" +socket.getPort());
try {
BufferedReader br =getReader(socket);
// PrintWriter pw = getWriter(socket);
String msg = null;
// byte[] b = new byte[100];
while ((msg = br .readLine()) != null) { //接收和发送数据,直到通信结束
System.out.println(msg);
// pw .println(echo(msg));
if (msg.equals("bye"))
break;
}
} catch (IOException e) {
}finally{
if (socket!=null) {
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
} 展开
//读数据方法
private BufferedReader getReader(Socket socket)throws IOException{
InputStream socketIn = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(socketIn);
return new BufferedReader(isr);
}
//接受处理
public void run() {
System.out.println("一个新的连接 " +
socket.getInetAddress() + ":" +socket.getPort());
try {
BufferedReader br =getReader(socket);
// PrintWriter pw = getWriter(socket);
String msg = null;
// byte[] b = new byte[100];
while ((msg = br .readLine()) != null) { //接收和发送数据,直到通信结束
System.out.println(msg);
// pw .println(echo(msg));
if (msg.equals("bye"))
break;
}
} catch (IOException e) {
}finally{
if (socket!=null) {
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
} 展开
3个回答
展开全部
这是因为你的服务端是先读取客户端数据,因为这个Socket InputStream 是阻塞的。因为 socket 是全双工的,所以我们应该:
1、当我们使用同步的 I/O 我们就得用双线程,一个负责读取,读取后处理并把回复放入“出站队列”;另一个线程就是从”出站队列“中读取"回复”并写出。
2、当我们使用异步的 I/O 时我们不需要多线程,不过流程略有不同。可以百度/google 一下 Java NIO 中关于 ServerSocketChannel 和 SocketChannel 的样例。
http://docs.oracle.com/javase/1.4.2/docs/guide/nio/example/
http://docs.oracle.com/javase/7/docs/technotes/guides/io/example/
1、当我们使用同步的 I/O 我们就得用双线程,一个负责读取,读取后处理并把回复放入“出站队列”;另一个线程就是从”出站队列“中读取"回复”并写出。
2、当我们使用异步的 I/O 时我们不需要多线程,不过流程略有不同。可以百度/google 一下 Java NIO 中关于 ServerSocketChannel 和 SocketChannel 的样例。
http://docs.oracle.com/javase/1.4.2/docs/guide/nio/example/
http://docs.oracle.com/javase/7/docs/technotes/guides/io/example/
本回答被提问者采纳
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
原因猜测如下:
客户端写的数据太小,缓冲区没刷新,服务端未接受到数据;
客户端写完一定的数据量后没flush,所有的数据都在缓冲区中。
你可以试试~
客户端写一定的数据flush一下;
或者客户端写完一定的数据加入结束标志。
更多追问追答
追问
但是我用的是套接字助手啊。不是我自己写的客户端。应该不存在这个flush的问题吧?
追答
因为你关闭了助手之后,就会打印出来,所以才这么说的,你看下这个助手有没有发送功能~ 要不你别用Reader了 ,直接用Stream看能否打印出二进制~
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询