在做TCP传输文件的题目时，发现服务端读取socket的输入流用BufferedInputStream包装后就会出错，直接调用s.getInputStream就没问题。这个问题耗费了我好久时间，哪位大神能给解答下？

in=new BufferedInputStream(s.getInputStream());读取文件就会错误，大小不一样
in=s.getInputStream    这样就没问题

客户端想服务端的outputStream同理，也不能用BufferedOutputStream类包装

我刚刚试了一下，感觉没问题
import java.net.*;
import java.io.*;
class TCPclient2{
        public static void main(String[] args){
                Socket s=null;
                try{
                        s=new Socket(InetAddress.getLocalHost(),18888);
                }catch(UnknownHostException e1){
                        throw new RuntimeException(e1);
                }catch(IOException e2){
                        throw new RuntimeException(e2);
                }
                BufferedWriter bw=null;
                BufferedReader br=null;
                try{
                        bw=new BufferedWriter(new OutputStreamWriter(new BufferedOutputStream(s.getOutputStream())));
                }catch(IOException e3){
                        throw new RuntimeException(e3);
                }
                try{
                        br=new BufferedReader(new InputStreamReader(new BufferedInputStream(s.getInputStream())));
                }catch(IOException e4){
                        throw new RuntimeException(e4);
                }
                try{
                        bw.write("TCP客户端来了！");
                        bw.newLine();
                        bw.flush();
                        s.shutdownOutput();
                }catch(IOException e5){
                        throw new RuntimeException(e5);
                }
                String buff=null;
                try{       
                        while((buff=br.readLine())!=null)
                                System.out.println(buff);
                }catch(IOException e6){
                        throw new RuntimeException(e6);
                }
                try{
                     s.close();
                }catch(IOException e7){
                     throw new RuntimeException(e7);
                }
        }
}




import java.net.*;
import java.io.*;
class TCPserver2{
        public static void main(String[] args){
                ServerSocket ss=null;
                Socket s=null;
                try{
                        ss=new ServerSocket(18888);
                }catch(SocketException e1){
                        throw new RuntimeException(e1);
                }catch(IOException e2){
                        throw new RuntimeException(e2);
                }
                try{
                        s=ss.accept();
                }catch(IOException e3){
                        throw new RuntimeException(e3);
                }
                System.out.println("ip"+s.getLocalAddress().getHostAddress()+"......"+"已连接");
                BufferedReader br=null;
                BufferedWriter bw=null;
                try{
                        br=new BufferedReader(new InputStreamReader(new BufferedInputStream(s.getInputStream())));
                }catch(IOException e4){
                     throw new RuntimeException(e4);
                }
                try{
                        bw=new BufferedWriter(new OutputStreamWriter(new BufferedOutputStream(s.getOutputStream())));
                }catch(IOException e5){
                     throw new RuntimeException(e5);
                }
                String buff=null;
                try{
                        while((buff=br.readLine())!=null)
                                       System.out.println("ip"+s.getLocalAddress().getHostAddress()+"......"+buff);
                }catch(IOException e5){
                        throw new RuntimeException(e5);
                }
                try{
                        bw.write("服务器已连接");
                        bw.newLine();
                        bw.flush();
                }catch(IOException e6){
                        System.out.println("服务器写异常");
                        throw new RuntimeException(e6);
                }
                try{
                     s.close();
                }catch(IOException e7){
                     throw new RuntimeException(e7);
                }
                try{
                     ss.close();
                }catch(IOException e8){
                     throw new RuntimeException(e8);
                }
        }
}

能不能看看代码先？

1. 
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedOutputStream;
   
5. import java.io.File;
   
6. import java.io.FileInputStream;
   
7. import java.io.FileOutputStream;
   
8. import java.io.IOException;
   
9. import java.io.InputStream;
   
10. import java.io.OutputStream;
    
11. import java.net.ServerSocket;
    
12. import java.net.Socket;
    
13. 
    
14. 
    
15. 
    
16. class ClientDemo {
    
17.         public static void  main(String[] args) {
    
18.                 //定义需用到的流，先赋值null
    
19.                 BufferedInputStream bis=null;
    
20.                 BufferedInputStream fin=null;
    
21.                 //OutputStream out=null;
    
22.                 BufferedOutputStream out=null;
    
23.                 File f=new File("E:\\Test01.java");
    
24.                
    
25.                 Socket s=null;
    
26.                 try{
    
27.                         s=new Socket("127.0.0.1",10002);
    
28.                         fin=new BufferedInputStream(new FileInputStream(f));
    
29.                         bis=new BufferedInputStream(s.getInputStream());
    
30.                         //out=s.getOutputStream();                        
    
31.                         out=new BufferedOutputStream(s.getOutputStream());    //就是这句，用BufferedOutputStream包装后复制的文件就出错了
    
32.                         byte[] buf=new byte[1024];
    
33.                         int len=0;
    
34.                         while((len=fin.read(buf,0,buf.length))!=-1){
    
35.                                 out.write(buf, 0, len);
    
36.                         }
    
37.                         s.shutdownOutput();
    
38.                                
    
39.                 }
    
40.                 catch (IOException e) {
    
41.                         e.printStackTrace();
    
42.                 }
    
43.                 finally{
    
44.                         try {
    
45.                                 if(s!=null)s.close();
    
46.                         }catch (IOException e) {
    
47.                                 e.printStackTrace();
    
48.                         }
    
49.                         try{
    
50.                                 if(fin!=null)fin.close();
    
51.                         }catch (IOException e) {
    
52.                                 e.printStackTrace();
    
53.                         }
    
54.                 }
    
55.         }
    
56. }
    
57. 
    
58. class ServerDemo{
    
59.         public static void main(String[] args) {
    
60.                 //定义需用到的流，先赋值null
    
61.                 InputStream in=null;
    
62.                 OutputStream bos=null;
    
63.                 BufferedOutputStream fout=null;
    
64.                 ServerSocket ss=null;
    
65.                 Socket s=null;
    
66.                 try{
    
67.                         ss=new ServerSocket(10002);
    
68.                         s=ss.accept();
    
69.                         System.out.println(s.getInetAddress().getHostAddress()+"-----已连接");
    
70.                         in=s.getInputStream();
    
71.                         bos=s.getOutputStream();
    
72.                         File f=new File("E:\\rec.java");
    
73.                         fout=new BufferedOutputStream(new FileOutputStream(f));
    
74.                         byte[] buf=new byte[1024];
    
75.                         int len=0;
    
76.                         while((len=in.read(buf,0,buf.length))!=-1){
    
77.                                 fout.write(buf,0,len);
    
78.                         }
    
79.                         bos.write("文件已上传至Server！".getBytes());
    
80.                         System.out.println("文件已上传至Server！");
    
81.                         }
    
82.                 catch (IOException e) {
    
83.                         e.printStackTrace();
    
84.                 }
    
85.                 finally{
    
86.                         try{
    
87.                                 if(s!=null)s.close();
    
88.                         }catch (IOException e) {
    
89.                                 e.printStackTrace();
    
90.                         }
    
91.                         try{
    
92.                                 if(ss!=null)ss.close();
    
93.                         }catch (IOException e) {
    
94.                                 e.printStackTrace();
    
95.                         }
    
96.                         try{
    
97.                                 if(fout!=null)fout.close();
    
98.                         }catch (IOException e) {
    
99.                                 e.printStackTrace();
    
100.                         }
     
101.                 }
     
102.                
     
103.         }
     
104.        
     
105. }
     

复制代码

把ClientDemo中的out用BufferedOutputString包装后复制的文件就出错了。

难道是和操作文件有关？我用的字节流，包装后复制文本和图片都有问题

兄弟，你没有flush()

真实姓名被注册 发表于 2015-8-9 12:05
兄弟，你没有flush()

字节流不需要flush啊

umbriel 发表于 2015-8-9 12:48
字节流不需要flush啊

你用的是缓冲字节流

out=new BufferedOutputStream(s.getOutputStream());  改为out=new BufferedOutputStream(new OutputStreamWriter（s.getOutputStream()）);    原因你的文件为字符流需要转换为字节流，才能被Socket的输出流接收，OutputStreamWriter为字符到字节的转换流。