Java IO网络编程为什么这里没有阻塞

Aojacy

1. package netStream;
   
2. 
   
3. import org.junit.Test;
   
4. 
   
5. import java.io.*;
   
6. import java.net.*;
   
7. 
   
8. public class SocketTest2 {
   
9.     @Test
   
10.     public void clientTest()  {
    
11.         Socket socket = null;
    
12.         OutputStream os = null;
    
13.         try {
    
14.             socket = new Socket(InetAddress.getByName("127.0.0.1"), 9090);
    
15.             os = socket.getOutputStream();
    
16.             FileInputStream fis = new FileInputStream(new File("hello1.jpg"));
    
17.             byte[] buff = new byte[1024];
    
18.             int len;
    
19.             while ((len = fis.read(buff))!=-1){
    
20.                 os.write(buff,0,len);
    
21.             }
    
22.         } catch (IOException e) {
    
23.             e.printStackTrace();
    
24.         } finally {
    
25.             if(os!=null){
    
26.                 try {
    
27.                     os.close();
    
28.                 } catch (IOException e) {
    
29.                     e.printStackTrace();
    
30.                 }
    
31.             }
    
32.             if(socket!=null){
    
33.                 try {
    
34.                     socket.close();
    
35.                 } catch (IOException e) {
    
36.                     e.printStackTrace();
    
37.                 }
    
38.             }
    
39.         }
    
40.     }
    
41.     @Test
    
42.     public void serveTest() throws IOException {
    
43.         ServerSocket serverSocket = null;
    
44.         Socket acceptSocket = null;
    
45.         InputStream is = null;
    
46.         FileOutputStream fos = null;
    
47.         try {
    
48.             serverSocket = new ServerSocket(9090);
    
49.             acceptSocket = serverSocket.accept();
    
50.             is = acceptSocket.getInputStream();
    
51.             fos = new FileOutputStream(new File("hello2.jpg"));
    
52.             byte[] buff = new byte[1024];
    
53.             int len;
    
54.             while ((len = is.read(buff))!=-1){
    
55.                 fos.write(buff,0,len);
    
56.             }
    
57.             System.out.println("复制成功");
    
58.         } catch (IOException e) {
    
59.             e.printStackTrace();
    
60.         } finally {
    
61.             if(fos!=null){
    
62.                 fos.close();
    
63.             }
    
64.             if(is!=null){
    
65.                 is.close();
    
66.             }
    
67.             if(acceptSocket!=null){
    
68.                 acceptSocket.close();
    
69.             }
    
70.             if(serverSocket!=null){
    
71.                 serverSocket.close();
    
72.             }
    
73.         }
    
74.     }
    
75. }

复制代码

按理说第57行不会执行到，上面循环会进入阻塞，为什么实际没有阻塞？

Aojacy

自己想通了，后面紧跟着有个close()，应该和socket.shutdownOutput()作用差不多，可以让服务器接收到文件结束标记