黑马程序员技术交流社区

标题: 关于ServerServer中读取Socket中的InpuStream [打印本页]
作者: 康乐    时间: 2012-12-22 18:49
标题: 关于ServerServer中读取Socket中的InpuStream
本帖最后由 康乐 于 2012-12-23 20:42 编辑
  1. import java.io.*;
  2. import java.net.*;

  4. class TcpClient2
  5. {
  6.         public static void main(String[] args) throws Exception
  7.         {
  8.                 Socket s =  new Socket(InetAddress.getLocalHost(),10002);

  10.                 OutputStream out = s.getOutputStream();

  12.                 out.write("请求数据".getBytes());
  13.                
  14.                 InputStream in = s.getInputStream();
  15.                 byte[] buf = new byte[1024];
  16.                 int len = 0;
  17.                 while((len = in.read(buf))!=-1)
  18.                 {
  19.                         System.out.println(new String(buf,0,len));
  20.                 }

  22.                 s.close();
  23.         }
  24. }
  25. class TcpServer2
  26. {
  27.         public static void main(String[] args) throws Exception
  28.         {
  29.                 ServerSocket ss = new ServerSocket(10002);

  31.                 Socket s = ss.accept();

  33.                 String ip = s.getInetAddress().getHostAddress();
  34.                 System.out.println(ip+"connect");

  36.                 InputStream in = s.getInputStream();
  37.                 byte[] buf = new byte[1024];
  38.                
  39.                 int len = in.read(buf);
  40.                 System.out.println(new String(buf,0,len));
  41.                
  42.                 /*为什么这样写会阻塞？
  43.                
  44.                 int len = 0;
  45.                 while((len = in.read(buf))!= -1)
  46.                 {
  47.                         System.out.println(len+new String(buf,0,len));
  48.                 }
  49.                 */
  50.         
  51.                 OutputStream out = s.getOutputStream();
  52.                 out.write("收到请求，已处理".getBytes());

  54.                 s.close();
  55.                 ss.close();

  57.         }
  58. }
复制代码
代码如上，为什么在服务端读取Socket中的InputStream时，用while时，程序会阻塞？
int len = in.read(buf);
System.out.println(new String(buf,0,len));语句后面再加一句System.out.println(in.read(buf))也会阻塞。
为什么呢？
  int len = 0;
   while((len = in.available())>0)
   {
    in.read(buf);
    int count = len<buf.length?len:buf.length;
    System.out.print(new String(buf,0,count));
   }
这样能解决问题，可是，为什么呢
作者: 康乐    时间: 2012-12-22 19:01
在读取文件时，如果用
  1. int len = 0;

  3.              while((len = in.read(buf))!= -1)

  5.               {

  7.                         System.out.println(len+new String(buf,0,len));

  9.               }
复制代码
也不会阻塞，为什么偏偏在这不行呢
作者: 王进亮    时间: 2012-12-22 20:16
read（)为阻塞式方法。你的客户端只有一条发送语句（ 12行：out.write("请求数据".getBytes());），
服务端有两条接收语句（39行： int len = in.read(buf);45行：while((len = in.read(buf))!= -1)）
当客户端发送信息时，服务端（39行）收到了数据，执行到45行时，客户端就没有再发数据，服务端（45行）就处于等待状态。下面的语句就不会执行、
客户端（17行）也在等待，这样就造成了两方都在等待.........




，



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2