客户端代码

1. package com.xiaozhi.jingtian.tcp;  
   
2. 
   
3. import java.io.BufferedReader;  
   
4. import java.io.BufferedWriter;  
   
5. import java.io.FileInputStream;  
   
6. import java.io.IOException;  
   
7. import java.io.InputStreamReader;  
   
8. import java.io.OutputStreamWriter;  
   
9. import java.net.Socket;  
   
10. 
    
11. public class UploadClient {  
    
12. 
    
13.     public static void main(String[] args) throws Exception, IOException {  
    
14.         //创建客户端的Socket服务，指定目的主机和端口号  
    
15.         Socket socket=new Socket("121.251.158.251",10000);  
    
16.          
    
17.         BufferedReader bufferedReader=new BufferedReader(new InputStreamReader(new FileInputStream("c://1.txt")));   
    
18.         BufferedWriter bufferedWriter= new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));  
    
19.          
    
20.         String line=null;  
    
21.         while((line=bufferedReader.readLine())!=null){  
    
22.             bufferedWriter.write(line);  
    
23.             bufferedWriter.newLine();  
    
24.             bufferedWriter.flush();  
    
25.         }  
    
26.       
    
27.         socket.shutdownOutput();
    
28.         
    
29.         bufferedReader.close();  
    
30.         bufferedWriter.close();  
    
31.         socket.close();  
    
32.     }  
    
33. }  

复制代码

服务端代码

1. package com.xiaozhi.jingtian.tcp;  
   
2. 
   
3. import java.io.BufferedReader;  
   
4. import java.io.BufferedWriter;  
   
5. import java.io.FileNotFoundException;  
   
6. import java.io.FileOutputStream;  
   
7. import java.io.IOException;  
   
8. import java.io.InputStream;  
   
9. import java.io.InputStreamReader;  
   
10. import java.io.OutputStreamWriter;  
    
11. import java.net.ServerSocket;  
    
12. import java.net.Socket;  
    
13. 
    
14. import javax.xml.crypto.Data;  
    
15. 
    
16. public class UploadServer {  
    
17. 
    
18.     public static void main(String[] args) throws Exception {  
    
19.         //创建服务端的Socket服务，指定端口号  
    
20.         ServerSocket serverSocket=new ServerSocket(10000);  
    
21.          
    
22.         while(true){  
    
23.             //通过accept方法获取连接过来的Socket对象  
    
24.             Socket socket=serverSocket.accept();  
    
25.             new MyThread(socket).start();  
    
26.         }  
    
27.          
    
28.     }  
    
29. }  
    
30. 
    
31. class MyThread extends Thread{  
    
32.     private Socket socket;  
    
33.       
    
34.     public MyThread(Socket socket) {  
    
35.         this.socket = socket;  
    
36.     }  
    
37. 
    
38.     @Override  
    
39.     public void run() {  
    
40.         try {  
    
41.             System.out.println(socket.getInetAddress().getHostAddress()+"上传文件");  
    
42.             BufferedReader bufferedReader=new BufferedReader(new InputStreamReader(socket.getInputStream()));  
    
43.             BufferedWriter bufferedWriter=new BufferedWriter(new OutputStreamWriter(new FileOutputStream("c://"+System.currentTimeMillis()+".txt")));  
    
44.               
    
45.             String line=null;  
    
46.             while((line=bufferedReader.readLine())!=null){  
    
47.                 bufferedWriter.write(line);  
    
48.                 bufferedWriter.newLine();  
    
49.                 bufferedWriter.flush();  
    
50.             }  
    
51.               
    
52.             System.out.println("上传成功");
    
53. 
    
54.             bufferedReader.close();  
    
55.             bufferedWriter.close();  
    
56.             socket.close();  
    
57.         } catch (FileNotFoundException e) {  
    
58.             e.printStackTrace();  
    
59.         } catch (IOException e) {  
    
60.             e.printStackTrace();  
    
61.         }  
    
62.     }  
    
63. }  

复制代码

看毕老师的视频，说没有这行代码 socket.shutdownOutput();，客户端服务端会互相等待，因为没有结束标志-1.
可是我这里没有这行代码并没有出现互相等待的现象？？？

客户端代码

1. package com.xiaozhi.jingtian.tcp;  
   
2. 
   
3. import java.io.BufferedReader;  
   
4. import java.io.BufferedWriter;  
   
5. import java.io.FileInputStream;  
   
6. import java.io.IOException;  
   
7. import java.io.InputStreamReader;  
   
8. import java.io.OutputStreamWriter;  
   
9. import java.net.Socket;  
   
10. 
    
11. public class UploadClient {  
    
12. 
    
13.     public static void main(String[] args) throws Exception, IOException {  
    
14.         //创建客户端的Socket服务，指定目的主机和端口号  
    
15.         Socket socket=new Socket("121.251.158.251",10000);  
    
16.          
    
17.         BufferedReader bufferedReader=new BufferedReader(new InputStreamReader(new FileInputStream("c://1.txt")));   
    
18.         BufferedWriter bufferedWriter= new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));  
    
19.          
    
20.         String line=null;  
    
21.         while((line=bufferedReader.readLine())!=null){  
    
22.             bufferedWriter.write(line);  
    
23.             bufferedWriter.newLine();  
    
24.             bufferedWriter.flush();  
    
25.         }  
    
26.       
    
27.         socket.shutdownOutput();
    
28.         
    
29.         bufferedReader.close();  
    
30.         bufferedWriter.close();  
    
31.         socket.close();  
    
32.     }  
    
33. }  

复制代码

服务端代码

1. package com.xiaozhi.jingtian.tcp;  
   
2. 
   
3. import java.io.BufferedReader;  
   
4. import java.io.BufferedWriter;  
   
5. import java.io.FileNotFoundException;  
   
6. import java.io.FileOutputStream;  
   
7. import java.io.IOException;  
   
8. import java.io.InputStream;  
   
9. import java.io.InputStreamReader;  
   
10. import java.io.OutputStreamWriter;  
    
11. import java.net.ServerSocket;  
    
12. import java.net.Socket;  
    
13. 
    
14. import javax.xml.crypto.Data;  
    
15. 
    
16. public class UploadServer {  
    
17. 
    
18.     public static void main(String[] args) throws Exception {  
    
19.         //创建服务端的Socket服务，指定端口号  
    
20.         ServerSocket serverSocket=new ServerSocket(10000);  
    
21.          
    
22.         while(true){  
    
23.             //通过accept方法获取连接过来的Socket对象  
    
24.             Socket socket=serverSocket.accept();  
    
25.             new MyThread(socket).start();  
    
26.         }  
    
27.          
    
28.     }  
    
29. }  
    
30. 
    
31. class MyThread extends Thread{  
    
32.     private Socket socket;  
    
33.       
    
34.     public MyThread(Socket socket) {  
    
35.         this.socket = socket;  
    
36.     }  
    
37. 
    
38.     @Override  
    
39.     public void run() {  
    
40.         try {  
    
41.             System.out.println(socket.getInetAddress().getHostAddress()+"上传文件");  
    
42.             BufferedReader bufferedReader=new BufferedReader(new InputStreamReader(socket.getInputStream()));  
    
43.             BufferedWriter bufferedWriter=new BufferedWriter(new OutputStreamWriter(new FileOutputStream("c://"+System.currentTimeMillis()+".txt")));  
    
44.               
    
45.             String line=null;  
    
46.             while((line=bufferedReader.readLine())!=null){  
    
47.                 bufferedWriter.write(line);  
    
48.                 bufferedWriter.newLine();  
    
49.                 bufferedWriter.flush();  
    
50.             }  
    
51.               
    
52.             System.out.println("上传成功");
    
53. 
    
54.             bufferedReader.close();  
    
55.             bufferedWriter.close();  
    
56.             socket.close();  
    
57.         } catch (FileNotFoundException e) {  
    
58.             e.printStackTrace();  
    
59.         } catch (IOException e) {  
    
60.             e.printStackTrace();  
    
61.         }  
    
62.     }  
    
63. }  

复制代码

看毕老师的视频，说没有这行代码 socket.shutdownOutput();，客户端服务端会互相等待，因为没有结束标志-1.
可是我这里没有这行代码并没有出现互相等待的现象？？？