套接字上的数据损坏[重复]

Question

我通过我的 Socket 获取损坏的数据我真的不明白问题出在哪里。我发送一个语音剪辑，用户在放手时录制它，它在下面激活了它发送的这个方法。当我查看发送的文件时，它总是比我记录的原始文件小很多。

22:00/23/03 更新 **发送结束

 public void sendVoice() throws IOException{


    System.out.println("send voice");
    Socket connection2 = new Socket(InetAddress.getByName("127.0.0.1"),1200);
    System.out.println(connection2);

    ObjectOutputStream output2 = new ObjectOutputStream(connection2.getOutputStream());
    output2.flush();
    ObjectInputStream  input2 = new ObjectInputStream(connection2.getInputStream());
     System.out.println(input2);


                DataOutputStream dos = null;
                try {
                    dos = new DataOutputStream(connection2.getOutputStream());
                } catch (IOException ex1) {
                    Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex1);
                }
        FileInputStream fis = null;
                try {
                    fis = new FileInputStream(voiceOutput);

                } catch (FileNotFoundException ex1) {
                    Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex1);

                }
         // new       
        int count = 0;
        byte[] buffer = new byte[4096];

                try {
while ((count = fis.read(buffer)) > 0) {
                        dos.write(buffer,0,count); 
                        dos.flush();
                        System.out.println(fis);
                    }
                } catch (IOException ex1) {
                    Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex1);
                }

                try {

                    fis.close();
                } catch (IOException ex1) {
                    Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex1);
                }
                try {
                    dos.flush();
                    dos.close();

                  ////        
                } catch (IOException ex1) {
                    Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex1);
                }


}

接收结束是

 public void downloadFile() throws IOException {
           server2 = new ServerSocket(1200,100);    
        System.out.println("downloading file.........");
       Socket connection2 = new Socket();
     connection2 = server2.accept();

     ObjectOutputStream output2 = new ObjectOutputStream(connection2.getOutputStream());
     output2.flush();
     ObjectInputStream   input2 = new ObjectInputStream(connection2.getInputStream());

DataInputStream dis = new DataInputStream(connection2.getInputStream());

    FileOutputStream fos = new FileOutputStream("voiceClip.wav");

    byte[] buffer = new byte[4096];
   System.out.println(buffer.length);
    //int filesize = 15123; 
    int read = 0;

   //int remaining = filesize;

   while ((read = dis.read(buffer)) > 0)
{
    fos.write(buffer, 0, read);
}


    /*
    while((read = dis.read(buffer, 0, Math.min(buffer.length, remaining))) > 0) {
        totalRead += read;
        remaining -= read;
        System.out.println("read " + totalRead + " bytes.");
        fos.write(buffer, 0, read);
    }
*/
    fos.close();
    dis.close();

    }

Answer 1

常见问题，忽略read() 返回的计数。您的复制循环应如下所示：

while ((count = in.read(buffer)) > 0)
{
    out.write(buffer, 0, count);
}

并且不要在循环内部刷新。

EDIT 并摆脱对象流。您似乎没有使用它们，并且它们会发送标头，这会浪费带宽。并且不要在接受同一个变量之前创建一个新的 Socket。那是资源泄漏。