黑马程序员技术交流社区

标题: TCP问题..求指点! [打印本页]
作者: 张然龙    时间: 2014-6-7 21:33
标题: TCP问题..求指点!
本帖最后由 张然龙 于 2014-6-8 08:38 编辑

这样上传图片会丢数据,请问问题是出在哪里呢???

  1. class  Fasong implements Runnable
  2. {
  3.         public void run()
  4.         {
  5.                 try
  6.                 {
  7.                         Socket s=new Socket ("192.168.1.106",19892);
  8.                         BufferedOutputStream bo=new BufferedOutputStream(s.getOutputStream());
  9.                         BufferedInputStream bi=new BufferedInputStream(new FileInputStream("D:\\截图.bmp"));
  10.                         byte b[]=new byte[1024];
  11.                         int len;
  12.                         while((len=bi.read(b))!=-1)
  13.                         {
  14.                                 bo.write(b,0,len);
  15.                         }
  16.                         s.shutdownOutput();
  17.                         s.close();
  18.                         bi.close();
  19.                         System.out.println("图片发送完成!");
  20.                 } catch (Exception e) {
  21.                         e.printStackTrace();
  22.                 }
  23.         }
  24. }

  26. class Jieshou implements Runnable
  27. {
  28.         public void run()
  29.         {
  30.                 try
  31.                 {
  32.                         ServerSocket ss=new ServerSocket(19892);
  33.                         Socket s=ss.accept();
  34.                         BufferedInputStream bi=new BufferedInputStream(s.getInputStream());
  35.                         BufferedOutputStream bo=new BufferedOutputStream(new FileOutputStream("D:\\截图保存.bmp"));
  36.                         byte b[]=new byte[1024];
  37.                         int len;
  38.                         while((len=bi.read(b))!=-1)
  39.                         {
  40.                                 bo.write(b,0,len);
  41.                         }
  42.                         bo.close();
  43.                         ss.close();
  44.                         System.out.println("上传成功!");
  45.                 } catch (Exception e) {
  46.                         e.printStackTrace();
  47.                 }
  48.         }
  49. }

  51. public class Demo
  52. {
  53.         public static void main(String[] args)throws Exception
  54.         {
  55.                 new Thread(new Jieshou()).start();
  56.                 Thread.sleep(1000);
  57.                 new Thread(new Fasong()).start();
  58.         }
  59. }
复制代码
作者: 月光海    时间: 2014-6-7 21:42
肿么又是你，，，，缓冲流写完数据要flush一下
  1. class  Fasong implements Runnable
  2. {
  3.         public void run()
  4.         {
  5.                 try
  6.                 {
  7.                         Socket s=new Socket ("192.168.1.101",19892);
  8.                         BufferedOutputStream bo=new BufferedOutputStream(s.getOutputStream());
  9.                         BufferedInputStream bi=new BufferedInputStream(new FileInputStream("D:\\截图.bmp"));
  10.                         byte b[]=new byte[1024];
  11.                         int len;
  12.                         while((len=bi.read(b))!=-1)
  13.                         {
  14.                                 bo.write(b,0,len);
  15.                                 bo.flush();//这里加flush
  16.                         }
  17.                         s.shutdownOutput();
  18.                         s.close();
  19.                         bi.close();
  20.                         System.out.println("图片发送完成!");
  21.                 } catch (Exception e) {
  22.                         e.printStackTrace();
  23.                 }
  24.         }
  25. }
复制代码
作者: 张然龙    时间: 2014-6-7 22:10
月光海 发表于 2014-6-7 21:42
肿么又是你，，，，缓冲流写完数据要flush一下

老大,刷新之后果然好了!!在指点下呗, 为啥不刷新就丢包呢?
真的是救星啊....为什么以前没刷的都传过来了,却只丢了一部分呢?
3133494 :原来的图片大小
3129344 :上传回本地后的大小
4150相减之后...4150个字节消失了
作者: cain    时间: 2014-6-7 22:16
那些地方必须刷新啊
作者: 月光海    时间: 2014-6-7 22:55
张然龙 发表于 2014-6-7 22:10
老大,刷新之后果然好了!!在指点下呗, 为啥不刷新就丢包呢?
真的是救星啊....为什么以前没刷的都传过来了, ...

数据在缓冲区中只有刷新一下里面的数据才会完全到目的地中。之前的一部分没有丢掉是因为之前的数据在缓冲区中，然后输出流从缓冲区中取了部分数据写了出去，不是全都存到缓冲区中之后才一起写的
如果你不刷新也可以这样写：
  1. class  Fasong implements Runnable
  2. {
  3.         public void run()
  4.         {
  5.                 try
  6.                 {
  7.                         Socket s=new Socket ("192.168.1.101",19892);
  8.                         BufferedOutputStream bo=new BufferedOutputStream(s.getOutputStream());
  9.                         BufferedInputStream bi=new BufferedInputStream(new FileInputStream("D:\\截图.bmp"));
  10.                         byte b[]=new byte[1024];
  11.                         int len;
  12.                         while((len=bi.read(b))!=-1)
  13.                         {
  14.                                 bo.write(b,0,len);
  15.                                // bo.flush();//这里加flush
  16.                         }
  17.                         bo.close();//加这一句，这句中包含flush，也将网络输出流关闭了
  18.                         bi.close();
  19.                        // s.shutdownOutput();
  20.                         s.close();
  21.                        
  22.                         System.out.println("图片发送完成!");
  23.                 } catch (Exception e) {
  24.                         e.printStackTrace();
  25.                 }
  26.                
  27.         }
  28. }
复制代码
作者: 张然龙    时间: 2014-6-8 08:38
月光海 发表于 2014-6-7 22:55
数据在缓冲区中只有刷新一下里面的数据才会完全到目的地中。之前的一部分没有丢掉是因为之前的数据在缓冲 ...

不好意思 我忘了自己是写的缓冲区了,!!!多谢 其实我记得是字节流不用刷,忘了是缓冲去了!  不好意思...
作者: dede风    时间: 2014-11-28 13:33
这都行.我不懂.学习下.



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