1. import java.io.*;
   
2. import java.net.*;
   
3. class  ClientDemo
   
4. {
   
5.         public static void main(String[] args) throws Exception
   
6.         {
   
7.                 Socket s = new Socket("127.0.0.1",10002);
   
8. 
   
9.                 DataOutputStream out =new DataOutputStream(s.getOutputStream());
   
10. 
    
11.                 out.write("TCP 来了".getBytes());
    
12. 
    
13.                 DataInputStream in = new DataInputStream(s.getInputStream());
    
14. 
    
15.                 byte[] buf = new byte[1024];
    
16. 
    
17.                 int len = in.read(buf);
    
18. 
    
19.                 String text = new String(buf,0,len);
    
20. 
    
21.                 System.out.println("server:"+text);
    
22. 
    
23.                 s.close();
    
24.         }
    
25. }
    
26. 
    
27. class  ServerDemo
    
28. {
    
29.         public static void main(String[] args) throws Exception
    
30.         {
    
31.                 ServerSocket ss = new ServerSocket(10002);
    
32. 
    
33.                 Socket s = ss.accept();//该方法是阻塞式的。
    
34.                
    
35.                 String ip = s.getInetAddress().getHostAddress();
    
36.                 System.out.println(ip+".....connected");
    
37. 
    
38.                 DataInputStream in = new DataInputStream(s.getInputStream());
    
39. 
    
40.                 byte[] buf  = new byte[1024];
    
41.                 int len = 0;
    
42.                 while(( len = in.read(buf))!=-1);
    
43.                 {
    
44.               String text = new String(buf,0,len);
    
45. 
    
46.                       System.out.println(text);
    
47.                 }
    
48. 
    
49.                 DataOutputStream out =new DataOutputStream(s.getOutputStream());
    
50. 
    
51.                 out.write("已收到".getBytes());
    
52. 
    
53.                 s.close();
    
54.                 ss.close();
    
55.         }
    
56. }

复制代码

开启服务端，运行客户端以后，程序阻塞了，收不到服务器端发来的信息
程序运行结果：

这个方法为什么会阻塞？可否解答一下？谢谢了。

因为read方法或者readLine方法是阻塞式。
本质原因还是Socket套接字里面没有（像文件那样的）文件开始标记和文件结束标记。
Socket套接字只是用来存储客户端或服务器端写进来的数据的，Socket自身并没有流的结束标记。
所以你的服务端一直阻塞在哪里....

msileandroid 发表于 2013-6-17 22:10
因为read方法或者readLine方法是阻塞式。
本质原因还是Socket套接字里面没有（像文件那样的）文件开始标记 ...

哦，原来如此。谢谢，非常厉害的回答。:handshake

我2了，这个问题毕老师视频后来讲了，我还一直在琢磨呢。。。

是的，毕姥爷讲了，
加一句
s.shutdownOutput();
此方法关闭客户端的输出流，相当于给流中加入一个结束标记

楼主您好~帖子长时间未作出回答，我已经将您的帖子改成已解决。如果有问题的话可以私密我哦~