黑马程序员技术交流社区

标题: 网络编程部分TCP上传图片程序中使用缓冲流发现的一个问题 [打印本页]

---

作者: 我要的幸福呢    时间: 2014-2-16 22:38
标题: 网络编程部分TCP上传图片程序中使用缓冲流发现的一个问题


问题已明白，看了一下源码，BufferedOutputStream里面缓冲区（也就是一个字节数组）的默认大小是8192字节，当缓冲区中数据达到最大值后就是自动执行flush()操作，将数据刷新出去。我代码的问题就是数据到最后并没有填满BufferedOutputStream的缓冲区，所以没有自动刷新出去，也没有手动刷新（包括bufOut的关闭操作），所以造成了数据丢失。

看过了tcp上传图片的视频之后，自己写的代码，使用了缓冲流（视频中毕老师没用缓冲流），发现了数据丢失的情况，即原图片大小为18999字节，上传后图片大小只有16384字节。经过多次尝试之后，发现加入下面注释的代码之后正常，但是我记得缓冲字节输出流是不用flush刷新的，翻看io流时候的代码也没有。大家帮忙看看问题出在哪里。代码如下

1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
4. class UploadPicClient
   
5. {
   
6.         public static void main(String[] args) throws Exception
   
7.         {
   
8.                 Socket s = new Socket("192.168.31.1",10010);
   
9. 
   
10.                 BufferedInputStream bis = new BufferedInputStream(
    
11.                         new FileInputStream("client.png"));
    
12.                 BufferedOutputStream bufOut = new BufferedOutputStream(
    
13.                         s.getOutputStream());
    
14. 
    
15.                 byte[] buf = new byte[1024];
    
16.                 int len = 0;
    
17.                 while((len=bis.read(buf))!=-1)
    
18.                 {
    
19.                         bufOut.write(buf,0,len);
    
20.                         //bufOut.flush();//为什么不刷新，就不正常？
    
21.                 }
    
22.                 s.shutdownOutput();
    
23. 
    
24.                 BufferedReader bufIn = new BufferedReader(
    
25.                         new InputStreamReader(s.getInputStream()));
    
26.                 System.out.println(bufIn.readLine());
    
27. 
    
28.                 bis.close();
    
29.                 s.close();
    
30. 
    
31.         }
    
32. }
    
33. 
    
34. class UploadPicServer
    
35. {
    
36.         public static void main(String[] args) throws Exception
    
37.         {
    
38.                 ServerSocket ss = new ServerSocket(10010);
    
39.                 Socket s = ss.accept();
    
40. 
    
41.                 String ip = s.getInetAddress().getHostAddress();
    
42.                 System.out.println(ip+" connected...");
    
43. 
    
44.                 BufferedInputStream bufIn = new BufferedInputStream(
    
45.                         s.getInputStream());
    
46.                 BufferedOutputStream bos = new BufferedOutputStream(
    
47.                         new FileOutputStream("server.png"));
    
48. 
    
49.                 byte[] buf = new byte[1024];
    
50.                 int len = 0;
    
51.                 while((len=bufIn.read(buf))!=-1)
    
52.                 {
    
53.                         bos.write(buf,0,len);
    
54.                 }
    
55. 
    
56.                 PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
    
57.                 pw.println("图片上传成功");
    
58. 
    
59.                 bos.close();
    
60.                 s.close();
    
61.                 ss.close();
    
62.         }
    
63. }
    

复制代码

---

作者: 程澄    时间: 2014-2-17 01:26
你记错了，只要用到缓冲区就必须刷新流

---

作者: 我要的幸福呢    时间: 2014-2-17 07:48

程澄 发表于 2014-2-17 01:26
你记错了，只要用到缓冲区就必须刷新流

不是吧，下面是讲利用字节流缓冲区复制MP3文件的视频截图

(黑马程序员_毕向东_Java基础视频教程第19天-13-IO流(字节流的缓冲区).avi)[00.05.37..jpg (155.4 KB, 下载次数: 16)

下载附件

2014-2-17 07:48 上传

---

作者: e.c    时间: 2014-2-17 15:51

我要的幸福呢 发表于 2014-2-17 07:48
不是吧，下面是讲利用字节流缓冲区复制MP3文件的视频截图

bufos.close()关闭流的时候会将缓冲数据写入。

---

作者: joure    时间: 2014-2-18 14:50

e.c 发表于 2014-2-17 15:51
bufos.close()关闭流的时候会将缓冲数据写入。

正解！，如果LZ将代码中有 bufOut.close()关闭流的动作，不刷新也是可以的
但是你只写了一个 bufOut.flush()，没有close();
毕老师的视频中没有刷新，但是有一个close的动作
io流使用完后一定要记得关闭资源，要养成习惯！
不释放资源可能会导致内存泄露

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2