1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
4. class TcpClient2
   
5. {
   
6.         public static void main(String[] args) throws Exception
   
7.         {
   
8.                 Socket s =  new Socket(InetAddress.getLocalHost(),10002);
   
9. 
   
10.                 OutputStream out = s.getOutputStream();
    
11. 
    
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.                 }
    
21. 
    
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);
    
30. 
    
31.                 Socket s = ss.accept();
    
32. 
    
33.                 String ip = s.getInetAddress().getHostAddress();
    
34.                 System.out.println(ip+"connect");
    
35. 
    
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());
    
53. 
    
54.                 s.close();
    
55.                 ss.close();
    
56. 
    
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));
   }
这样能解决问题，可是，为什么呢

在读取文件时，如果用

1. int len = 0;
   
2. 
   
3.              while((len = in.read(buf))!= -1)
   
4. 
   
5.               {
   
6. 
   
7.                         System.out.println(len+new String(buf,0,len));
   
8. 
   
9.               }
   

复制代码

也不会阻塞，为什么偏偏在这不行呢

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




，