今天看到毕老师的tcp复制文件的视频有点不明白:

1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
4. class TextClient
   
5. {
   
6. public static void main(String[] args) throws Exception
   
7. {
   
8. Socket s = new Socket("KLO-PC",10006);
   
9. BufferedReader bufr =
   
10. new BufferedReader(new FileReader("f://ArrayTest2.java"));
    
11. PrintWriter out = new PrintWriter(s.getOutputStream(),true);
    
12. String line = null;
    
13. while((line=bufr.readLine())!=null)
    
14. {
    
15. out.println(line);
    
16. }
    
17. 
    
18. //s.shutdownOutput();//关闭客户端的输出流。相当于给流中加入一个结束标记-1.
    
19. BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
    
20. String str = bufIn.readLine();
    
21. System.out.println(str);
    
22. bufr.close();
    
23. s.close();
    
24. }
    
25. }
    
26. class TextServer
    
27. {
    
28. public static void main(String[] args) throws Exception
    
29. {
    
30. ServerSocket ss = new ServerSocket(10006);
    
31. Socket s = ss.accept();
    
32. String ip = s.getInetAddress().getHostAddress();
    
33. System.out.println(ip+"....connected");
    
34. BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
    
35. PrintWriter out = new PrintWriter(new FileWriter("f://ArrayTest2_copy.java"),true);
    
36. String line = null;
    
37. while((line=bufIn.readLine())!=null)
    
38. {
    
39. //if("over".equals(line))
    
40. //break;
    
41. out.println(line);
    
42. }
    
43. PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
    
44. pw.println("上传成功");
    
45. out.close();
    
46. s.close();
    
47. ss.close();
    
48. 
    
49. }
    
50. }

复制代码

这是毕老师未修正的代码,他老人家说,这样写服务器端的readLine()方法会因为客户端没有传来停止标示会一直阻塞,这里我不太明白,while((line=bufIn.readLine())!=null)
不是有停止循环的条件了吗?readLine()运行到流结尾不就退出循环了吗?
我在看视频前自己写了一段代码:

1. import java.net.*;
   
2. import java.io.*;
   
3. class TextClient
   
4. {
   
5. public static void main(String[] args)throws Exception
   
6. {
   
7. long startTime=System.currentTimeMillis();
   
8. 
   
9. Socket s=new Socket("KLO-PC",10007);
   
10. 
    
11. FileInputStream fis=new FileInputStream("d://javaAPI.chm");
    
12. 
    
13. OutputStream nos=s.getOutputStream();
    
14. 
    
15. byte buff[]=new byte[1024*1024];
    
16. //byte buff;
    
17. int len;
    
18. 
    
19. while((len=fis.read(buff))!=-1)
    
20. {
    
21. nos.write(buff,0,len);
    
22. //nos.write(buff);
    
23. 
    
24. nos.flush();
    
25. }
    
26. //s.close();
    
27. 
    
28. //fis.close();
    
29. long overTime=System.currentTimeMillis();
    
30. p.sop("传输时间为"+(overTime-startTime)+"毫秒");
    
31. 
    
32. 
    
33. }
    
34. }
    
35. 
    
36. 
    
37. class TextServer
    
38. {
    
39. public static void main(String args[])throws Exception
    
40. {
    
41. ServerSocket ss=new ServerSocket(10007);
    
42. Socket s=ss.accept();
    
43. p.sopln("已接收到IP::"+s.getInetAddress().getHostAddress()+"::的连接....");
    
44. InputStream nis=s.getInputStream();
    
45. File f=new File("d://javaAPI.chm");
    
46. FileOutputStream fos=new FileOutputStream(f);
    
47. byte buff[]=new byte[1024*1024];
    
48. int len;
    
49. 
    
50. long fileLen=0;
    
51. 
    
52. while ((len=nis.read(buff))!=-1)
    
53. {
    
54. fos.write(buff,0,len);
    
55. fos.flush();
    
56. 
    
57. fileLen+=f.length();
    
58. 
    
59. p.sopln("已接收到"+fileLen+"字节");
    
60. }
    
61. p.sopln("接收完成");
    
62. 
    
63. ss.close();
    
64. 
    
65. fos.close();
    
66. }
    
67. }

复制代码

我使用的是字节流传输,但是我也是用了阻塞式方法read(),也没有从客户端传什么停止标识.为什么就可以正常传输呢?

1.
Server那边
while((line=bufIn.readLine())!=null)是可以退出循环
但是Client那边在从一个文件里面读取时用的条件是while((line=bufr.readLine())!=null)
当Client读到文件结尾了 这个while循环就跳出去了
Client就不传东西过去了
Client知道文件到结尾了
但是没有告诉Server
所以Server那边还在等数据
s.shutdownOutput()就是告诉Server那边文件到结尾了

2.
毕老师的代码中,Client传完后,要等待Server传回一个"上传成功的信息"
所以也调用了read()阻塞方法
这样2边都在等待
就出问题了.
至于为什么你用字节流就可以正常传
我感觉是这样
如果Client那边传完之后不等Server的返回信息
直接把Socket给close了
那流也给close了
Server那边想等着read也等不了了
于是就正常结束了
不过我看你的代码里把s.close()注释掉了?
这样应该会有Server那边应该会有connection reset异常
但是文件还是传过去了
应该相当于强行中断了