黑马程序员技术交流社区

标题: 为什么会丢失数据 [打印本页]
作者: 陌路行者    时间: 2013-7-14 23:05
标题: 为什么会丢失数据
本帖最后由 陌路行者 于 2013-7-15 14:14 编辑
  1. import java.io.*;
  2. import java.net.*;
  3. class  PicClient
  4. {
  5.         public static void main(String[] args) throws Exception
  6.         {
  7.                 Socket s = new Socket("192.168.1.12",8866);

  9.                 BufferedInputStream bis =
  10.                         new BufferedInputStream(new FileInputStream("1.jpg"));

  12.                 BufferedOutputStream bos =
  13.                         new BufferedOutputStream(s.getOutputStream());

  15.                 //byte[] buf = new byte[1024];

  17.                 int len = 0;

  19.                 while((len=bis.read())!=-1)
  20.                 {
  21.                         bos.write(len);
  22.                 }
  23.                 s.shutdownOutput();
  24.                 BufferedInputStream bufIn =
  25.                         new BufferedInputStream(s.getInputStream());

  27.                 //byte[] bufInput = new byte[1024];
  28.                
  29.                 int num = 0;

  31.                 while((num=bufIn.read())!=-1)
  32.                 {
  33.                         System.out.println(num);
  34.                 }

  36.                 bis.close();
  37.                 s.close();
  38.         }
  39. }
  40. class  PicServer
  41. {
  42.         public static void main(String[] args) throws Exception
  43.         {
  44.                 ServerSocket ss = new ServerSocket(8866);
  45.                
  46.                 Socket s = ss.accept();

  48.                 String ip = s.getInetAddress().getHostAddress();

  50.                 System.out.println(ip+".......connected");

  52.                 BufferedInputStream bis =
  53.                         new BufferedInputStream(s.getInputStream());

  55.                 BufferedOutputStream bos =
  56.                         new BufferedOutputStream(new FileOutputStream("2.jpg"));

  58.                 //byte[] buf = new byte[1024];

  60.                 int len = 0;

  62.                 while((len=bis.read())!=-1)
  63.                 {
  64.                         bos.write(len);
  65.                 }
  66.                 BufferedOutputStream bosOut =
  67.                         new BufferedOutputStream(s.getOutputStream());

  69.                 bosOut.write("上传成功".getBytes());

  71.                 bos.close();
  72.                 s.close();
  73.                 ss.close();
  74.         }
  75. }
复制代码
而且还读不到服务端反馈的信息
作者: 草貌路飞    时间: 2013-7-15 00:51
还没看到通信方面，不过知道一点点，不知道对不对。  你要传的东西不因该是图片的数据吗，怎么会是写长度len？  bos.write(len);。至于为什么接收不到应该是客户端没有等到服务器传过东西过来就执行完了，两边应该是分开的线程，而且不能停的吧
作者: wll_sx1990    时间: 2013-7-15 10:45
本帖最后由 wll_sx1990 于 2013-7-15 10:54 编辑

数据的丢失主要是由于你在传输的时候用的是包装流，所以内部都有个缓冲区，所以，在每次输出完以后一定要记得flush。这样就数据完整，而且有反馈了。代码如下：
  1. package com.getprop;

  3. import java.io.BufferedInputStream;
  4. import java.io.BufferedOutputStream;
  5. import java.io.FileInputStream;
  6. import java.net.Socket;

  8. class PicClient
  9. {
  10. public static void main(String[] args) throws Exception
  11. {
  12. Socket s = new Socket("127.0.0.1",9999);

  14. BufferedInputStream bis =
  15. new BufferedInputStream(new FileInputStream("1.jpg"));

  17. BufferedOutputStream bos =
  18. new BufferedOutputStream(s.getOutputStream());

  20. //byte[] buf = new byte[1024];

  22. int len = 0;

  24. while((len=bis.read())!=-1)
  25. {
  26. bos.write(len);
  27. bos.flush(); //记得在这里刷
  28. }
  29. s.shutdownOutput();
  30. BufferedInputStream bufIn =
  31. new BufferedInputStream(s.getInputStream());

  33. //byte[] bufInput = new byte[1024];

  35. int num = 0;

  37. System.out.println("echo");
  38. while((num=bufIn.read())!=-1)
  39. {
  40. System.out.println(num); //想不通你这里为什么要把反馈信息当做字节输出来？你能看懂那一个个的数字？
  41. }

  43. bis.close();
  44. s.close();
  45. }
  46. }

  48. package com.getprop;

  50. import java.io.BufferedInputStream;
  51. import java.io.BufferedOutputStream;
  52. import java.io.FileOutputStream;
  53. import java.net.ServerSocket;
  54. import java.net.Socket;

  56. class PicServer
  57. {
  58. public static void main(String[] args) throws Exception
  59. {
  60. ServerSocket ss = new ServerSocket(9999);

  62. Socket s = ss.accept();

  64. String ip = s.getInetAddress().getHostAddress();

  66. System.out.println(ip+".......connected");

  68. BufferedInputStream bis =
  69. new BufferedInputStream(s.getInputStream());

  71. BufferedOutputStream bos =
  72. new BufferedOutputStream(new FileOutputStream("2.jpg"));

  74. //byte[] buf = new byte[1024];

  76. int len = 0;

  78. while((len=bis.read())!=-1)
  79. {
  80. bos.write(len);
  81. bos.flush(); //记得在这里刷
  82. }


  85. BufferedOutputStream bosOut =
  86. new BufferedOutputStream(s.getOutputStream());

  88. bosOut.write("上传成功".getBytes());
  89. bosOut.flush();

  91. bos.close();
  92. s.close();
  93. ss.close();
  94. }
  95. }

复制代码


作者: 陌路行者    时间: 2013-7-15 14:14
wll_sx1990 发表于 2013-7-15 10:45
数据的丢失主要是由于你在传输的时候用的是包装流，所以内部都有个缓冲区，所以，在每次输出完以后一定要记 ...

明白喽，谢啦！



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