黑马程序员技术交流社区

标题: TCP文件复制错误，请帮忙！ [打印本页]
作者: 张晨    时间: 2011-11-8 13:25
标题: TCP文件复制错误，请帮忙！
Help with Tcp problem
  1. import java.net.*;
  2. import java.io.*;

  4. public class SendFile {

  6.     public void send()throws Exception{
  7.         Socket socket =
  8.                 new Socket (InetAddress.getByName("192.168.1.5"),10000);
  9.         BufferedInputStream bis =
  10.                 new BufferedInputStream(new FileInputStream("D:\\hello.txt"));
  11.         BufferedOutputStream socketOut = new BufferedOutputStream(socket.getOutputStream());
  12.          
  13.         byte[] buff = new byte[1024];
  14.         int len ;
  15.         while ( (len = bis.read(buff))!=-1)
  16.         {
  17.             socketOut.write(buff);
  18.         }
  19.         System.out.println("finished");
  20.         socket.shutdownOutput();
  21.         BufferedReader socketInput =
  22.                 new BufferedReader( new InputStreamReader(socket.getInputStream()));
  23.         String s = socketInput.readLine();
  24.         System.out.println(s);
  25.         bis.close();
  26.         socket.close();
  27.     }
  28.      
  29.      
  30.     public static void main(String[] args) throws Exception {
  31.         SendFile s = new SendFile();
  32.         s.send();
  33.     }

  35. }
复制代码
Server:
  1. import java.io.*;
  2. import java.net.*;

  4. public class ReceiveFile {
  5.   
  6.     public void Receive() throws Exception{
  7.         ServerSocket serSocket = new ServerSocket(10000);
  8.         Socket socket = serSocket.accept();
  9.          
  10.         BufferedOutputStream fileOut =
  11.                 new BufferedOutputStream(new FileOutputStream("E:\\hello.txt"));
  12.          
  13.         BufferedInputStream inSocket =
  14.                 new BufferedInputStream(socket.getInputStream());
  15.          
  16.         byte[] buf = new byte[1024];
  17.         int len =0;
  18.         System.out.println("Going to While");
  19.         while ( (len = inSocket.read(buf))!=-1)   // i cant go into this loop
  20.         {
  21.             System.out.println("s"+new String(buf, 0,  len));  //because this line  never printed
  22.             fileOut.write(buf, 0, len);
  23.             fileOut.flush();
  24.             
  25.         }
  26.         String s = "finished！";
  27.         System.out.println(s);
  28.         DataOutputStream socketOut = new DataOutputStream(socket.getOutputStream());
  29.         socketOut.writeBytes(s);
  30.          
  31.         fileOut.close();
  32.         socket.close();
  33.         serSocket.close();      
  34.     }
  35.      
  36.     public static void main(String[] args) throws Exception {
  37.         ReceiveFile rec = new ReceiveFile();
  38.         rec.Receive();
  39.     }

  41. }
复制代码
the problem was described inside the code(line 18 in the last code), can anyone help me with that?
作者: 李建雄    时间: 2011-11-8 13:41
不好意思,我不会用english 回答,

socketOut.write(buff);  后面加一句 socketOut.flush();
问题解决就ok 了

good luck!!



作者: 张晨    时间: 2011-11-8 13:49
写入循环还是没有进去，所以创建的文件是空的
这个应该和缓冲区没关系，应为最后我把流关掉，会刷新缓冲区

我用english其实因为发在一个英文论坛拉，直接复制过来的，别见怪。
作者: 张晨    时间: 2011-11-8 13:56
后来我把与Socket相关的流 都写成OutputStram out= socket.getOutputStream (input也是）然后就对了， 很奇怪就不能用缓冲区技术吗？
作者: olkldksl    时间: 2011-11-8 14:24
bufferedoutputstream里的write方法
void write(byte[] b, int off, int len)
void write(int b)
你第一个文件里循环语句里的方法参数不合适吧，是不是应该加上“0，len”
作者: 李建雄    时间: 2011-11-8 14:44
张晨 发表于 2011-11-8 13:49
写入循环还是没有进去，所以创建的文件是空的
这个应该和缓冲区没关系，应为最后我把流关掉，会刷新缓冲区
...

用缓存就要flush啊,我都运行了你的,可以的,

不用缓存,就可以不flush();吧,这个我没试过
作者: 李建雄    时间: 2011-11-8 14:52
张晨 发表于 2011-11-8 13:56
后来我把与Socket相关的流 都写成OutputStram out= socket.getOutputStream (input也是）然后就对了， 很奇 ...

因为你没有fulsh() 就 socket.shutdownOutput();
就结束了写入,server已经停止读取了,

最后才fsocket.close(),这里面的自动刷新来得太迟了


作者: 李建雄    时间: 2011-11-8 14:55
olkldksl 发表于 2011-11-8 14:24
bufferedoutputstream里的write方法
void write(byte[] b, int off, int len)
void write(int b)

不加o,len 也行,不过这样的话,得到的文件,就会比原来的文件,大一点,
作者: 张晨    时间: 2011-11-8 15:08
李建雄 发表于 2011-11-8 14:52
因为你没有fulsh() 就 socket.shutdownOutput();
就结束了写入,server已经停止读取了,

恩，是我错了，加了fulsh（)可以，我又实验过，谢谢！:victory:



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