求大神帮忙分析下，为什么我在TCP传输的时候先把文件名传给服务端，然后再把文件上传到服务端时会出现数据丢失的情况啊，是因为我开了两次输出流的缘故么？我把第一次写文件名的几行去掉后文件就完整了，为什么？？？
客户端是：

1. package edu.heima.tcptest3;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedReader;
   
5. import java.io.FileInputStream;
   
6. import java.io.InputStreamReader;
   
7. import java.io.OutputStream;
   
8. import java.io.PrintWriter;
   
9. import java.net.Socket;
   
10. 
    
11. /*
    
12. * 上传MP3文件，客户端
    
13. * 1.建立客户端
    
14. * 2.建立字节读取流获取本地的MP3文件
    
15. * 3.获取Socket中的输出流，把本地文件写入到输出流中
    
16. * 4.获取Socket输入流，得到服务端反馈数据
    
17. * 5.关闭资源
    
18. * */
    
19. public class Client {
    
20. 
    
21.         public static void main(String[] args)throws Exception {
    
22.                
    
23. 
    
24.                         //建立Socket客户端
    
25.                         Socket s = new Socket("127.0.0.1",8889);
    
26.                        
    
27.                         //告诉服务器文件的名称
    
28.                         PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
    
29.                         pw.println("那个女孩.mp3");
    
30.                        
    
31.                         //获取本地文件，通过字节流
    
32.                         BufferedInputStream bis = new BufferedInputStream(
    
33.                                                                                         new FileInputStream("d://音乐//那个女孩.mp3"));
    
34.                        
    
35.                         //获取输出流
    
36.                         OutputStream ps = s.getOutputStream();
    
37.                         //将获取到文件数据写入到输出流中
    
38.                         byte[] buf = new byte[1024];
    
39.                         int len = 0;
    
40.                         while((len = bis.read(buf))!=-1)
    
41.                         {
    
42.                                 ps.write(buf, 0, len);
    
43.                         }
    
44.                         //写入结束标记
    
45.                         s.shutdownOutput();
    
46.                         //获取输入流
    
47.                         BufferedReader br = new BufferedReader(
    
48.                                                                         new InputStreamReader(s.getInputStream()));
    
49.                         System.out.println(br.readLine());
    
50.                         //关资源
    
51.                         bis.close();
    
52.                         s.close();
    
53.        
    
54.         }
    
55. 
    
56. }
    

复制代码

服务端是：

1. package edu.heima.tcptest3;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedReader;
   
5. import java.io.BufferedWriter;
   
6. import java.io.FileOutputStream;
   
7. import java.io.InputStreamReader;
   
8. import java.io.OutputStreamWriter;
   
9. import java.io.PrintStream;
   
10. import java.io.PrintWriter;
    
11. import java.net.ServerSocket;
    
12. import java.net.Socket;
    
13. 
    
14. /*
    
15. * 并发上传文件，服务端
    
16. * 1.建立服务端，获取客户端对象
    
17. * 2.每获取到一个客户端对象就开启一条线程
    
18. * 3.在线程类中封装一下内容
    
19. *                 首先获取到文件名字
    
20. *                  获取客户端对象的输入流，读取数据
    
21. *                 建立新的输出流，将Socket中的数据写入到本地磁盘
    
22. *                 完成后关闭客户端对象
    
23. * */
    
24. //定义一个线程类
    
25. class PicThread implements Runnable{
    
26.         //接收一个客户端对象
    
27.         private Socket s;
    
28.         PicThread(Socket s)
    
29.         {
    
30.                 this.s = s;
    
31.         }
    
32.         public void run()
    
33.         {
    
34.                 //获取客户端ip
    
35.                 String ip = s.getInetAddress().getHostAddress();
    
36.                 System.out.println(ip+"run time...");
    
37.                 try {
    
38.                         //获取文件名字
    
39.                         BufferedReader br = new BufferedReader(
    
40.                                                                         new InputStreamReader(s.getInputStream()));
    
41.                         String fileName = br.readLine();
    
42.                        
    
43.                        
    
44.                         //获取客户端对象的输入流
    
45.                         BufferedInputStream bis = new BufferedInputStream(s.getInputStream());
    
46.                         //建立输出流，写入到本地磁盘中
    
47.                         PrintStream ps = new PrintStream(new FileOutputStream("e://"+fileName));
    
48.                         //读取客户端中的数据，写入到指定的文件中
    
49.                         byte[] buf = new byte[1024];
    
50.                         int len = 0;
    
51.                         while((len = bis.read(buf))!=-1)
    
52.                         {
    
53.                                 ps.write(buf, 0, len);
    
54.                         }
    
55.                         //反馈信息给服务端
    
56.                         PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
    
57.                         pw.println("数据上传成功！");
    
58.                         //关闭资源
    
59.                         s.close();
    
60.                         ps.close();
    
61.                 } catch (Exception e) {
    
62.                         throw new RuntimeException(ip+"上传失败！");
    
63.                 }
    
64.                
    
65.         }
    
66. }
    
67. public class Server {
    
68. 
    
69.         public static void main(String[] args)throws Exception {
    
70.                 //服务端一般不关闭，通过accept阻塞式方法来获取连接建立的客户端
    
71.                 //建立服务端
    
72.                 ServerSocket ss = new ServerSocket(8889);
    
73.                 while(true)
    
74.                 {
    
75.                         //获取客户端
    
76.                         Socket s = ss.accept();
    
77.                         //每获取到一个客户端就开启一条线程
    
78.                         new Thread(new PicThread(s)).start();
    
79.                 }
    
80.         }
    
81. }
    

复制代码

求大神帮忙分析下，为什么我在TCP传输的时候先把文件名传给服务端，然后再把文件上传到服务端时会出现数据丢失的情况啊，是因为我开了两次输出流的缘故么？我把第一次写文件名的几行去掉后文件就完整了，为什么？？？
客户端是：

1. package edu.heima.tcptest3;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedReader;
   
5. import java.io.FileInputStream;
   
6. import java.io.InputStreamReader;
   
7. import java.io.OutputStream;
   
8. import java.io.PrintWriter;
   
9. import java.net.Socket;
   
10. 
    
11. /*
    
12. * 上传MP3文件，客户端
    
13. * 1.建立客户端
    
14. * 2.建立字节读取流获取本地的MP3文件
    
15. * 3.获取Socket中的输出流，把本地文件写入到输出流中
    
16. * 4.获取Socket输入流，得到服务端反馈数据
    
17. * 5.关闭资源
    
18. * */
    
19. public class Client {
    
20. 
    
21.         public static void main(String[] args)throws Exception {
    
22.                
    
23. 
    
24.                         //建立Socket客户端
    
25.                         Socket s = new Socket("127.0.0.1",8889);
    
26.                        
    
27.                         //告诉服务器文件的名称
    
28.                         PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
    
29.                         pw.println("那个女孩.mp3");
    
30.                        
    
31.                         //获取本地文件，通过字节流
    
32.                         BufferedInputStream bis = new BufferedInputStream(
    
33.                                                                                         new FileInputStream("d://音乐//那个女孩.mp3"));
    
34.                        
    
35.                         //获取输出流
    
36.                         OutputStream ps = s.getOutputStream();
    
37.                         //将获取到文件数据写入到输出流中
    
38.                         byte[] buf = new byte[1024];
    
39.                         int len = 0;
    
40.                         while((len = bis.read(buf))!=-1)
    
41.                         {
    
42.                                 ps.write(buf, 0, len);
    
43.                         }
    
44.                         //写入结束标记
    
45.                         s.shutdownOutput();
    
46.                         //获取输入流
    
47.                         BufferedReader br = new BufferedReader(
    
48.                                                                         new InputStreamReader(s.getInputStream()));
    
49.                         System.out.println(br.readLine());
    
50.                         //关资源
    
51.                         bis.close();
    
52.                         s.close();
    
53.        
    
54.         }
    
55. 
    
56. }
    

复制代码

服务端是：

1. package edu.heima.tcptest3;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedReader;
   
5. import java.io.BufferedWriter;
   
6. import java.io.FileOutputStream;
   
7. import java.io.InputStreamReader;
   
8. import java.io.OutputStreamWriter;
   
9. import java.io.PrintStream;
   
10. import java.io.PrintWriter;
    
11. import java.net.ServerSocket;
    
12. import java.net.Socket;
    
13. 
    
14. /*
    
15. * 并发上传文件，服务端
    
16. * 1.建立服务端，获取客户端对象
    
17. * 2.每获取到一个客户端对象就开启一条线程
    
18. * 3.在线程类中封装一下内容
    
19. *                 首先获取到文件名字
    
20. *                  获取客户端对象的输入流，读取数据
    
21. *                 建立新的输出流，将Socket中的数据写入到本地磁盘
    
22. *                 完成后关闭客户端对象
    
23. * */
    
24. //定义一个线程类
    
25. class PicThread implements Runnable{
    
26.         //接收一个客户端对象
    
27.         private Socket s;
    
28.         PicThread(Socket s)
    
29.         {
    
30.                 this.s = s;
    
31.         }
    
32.         public void run()
    
33.         {
    
34.                 //获取客户端ip
    
35.                 String ip = s.getInetAddress().getHostAddress();
    
36.                 System.out.println(ip+"run time...");
    
37.                 try {
    
38.                         //获取文件名字
    
39.                         BufferedReader br = new BufferedReader(
    
40.                                                                         new InputStreamReader(s.getInputStream()));
    
41.                         String fileName = br.readLine();
    
42.                        
    
43.                        
    
44.                         //获取客户端对象的输入流
    
45.                         BufferedInputStream bis = new BufferedInputStream(s.getInputStream());
    
46.                         //建立输出流，写入到本地磁盘中
    
47.                         PrintStream ps = new PrintStream(new FileOutputStream("e://"+fileName));
    
48.                         //读取客户端中的数据，写入到指定的文件中
    
49.                         byte[] buf = new byte[1024];
    
50.                         int len = 0;
    
51.                         while((len = bis.read(buf))!=-1)
    
52.                         {
    
53.                                 ps.write(buf, 0, len);
    
54.                         }
    
55.                         //反馈信息给服务端
    
56.                         PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
    
57.                         pw.println("数据上传成功！");
    
58.                         //关闭资源
    
59.                         s.close();
    
60.                         ps.close();
    
61.                 } catch (Exception e) {
    
62.                         throw new RuntimeException(ip+"上传失败！");
    
63.                 }
    
64.                
    
65.         }
    
66. }
    
67. public class Server {
    
68. 
    
69.         public static void main(String[] args)throws Exception {
    
70.                 //服务端一般不关闭，通过accept阻塞式方法来获取连接建立的客户端
    
71.                 //建立服务端
    
72.                 ServerSocket ss = new ServerSocket(8889);
    
73.                 while(true)
    
74.                 {
    
75.                         //获取客户端
    
76.                         Socket s = ss.accept();
    
77.                         //每获取到一个客户端就开启一条线程
    
78.                         new Thread(new PicThread(s)).start();
    
79.                 }
    
80.         }
    
81. }
    

复制代码