套接字文件传输

Question

在此code如果文件在第一次发送（不管我发送的数字文件），代码工作正常。但是当我把FileSender放在一个循环中逐一发送文件时，在第一次传输之后，在接收器端收到的数据是任意的（如果在调试过程中检查过），它甚至不会接收文件。这是我所做的改变，它不起作用。

FileSender.java

import java.io.OutputStream; 
import java.io.File; 
import java.net.Socket; 
public class FileSender { 
public void main(Socket socket,String[] args) { 
try { 

    OutputStream os  = socket.getOutputStream(); 
    int cnt_files = args.length; 

    // How many files? 
    ByteStream.toStream(os, cnt_files); 

    for (int cur_file=0; cur_file<cnt_files; cur_file++) { 
    ByteStream.toStream(os, new File(args[cur_file]).getName()); 
    ByteStream.toStream(os, new File(args[cur_file])); 
    } 
} 
catch (Exception ex) { 
    ex.printStackTrace(); 
} 
} 
} 

字串[] args包含要被发送的文件的路径。

FileReceiver.java

import java.io.File; 
import java.io.InputStream; 
import java.net.Socket; 

public class FileReceiver { 

public void main(Socket socket,String arg) { 
try { 
    InputStream in = socket.getInputStream(); 

    int nof_files = ByteStream.toInt(in); 
System.out.println("reach 1  "+ nof_files); 
    for (int cur_file=0;cur_file < nof_files; cur_file++) { 
    String file_name = ByteStream.toString(in); 

    File file=new File(arg+file_name); 
    System.out.println("Received path is : "+file); 
    ByteStream.toFile(in, file); 
    } 

} 
catch (java.lang.Exception ex) { 
    ex.printStackTrace(System.out); 
} 
} 

} 

ARG包含这些文件将被存储的路径。

我希望我打电话主要函数提到每当我想传输文件。基本上我想传输多个可以包含目录的文件。为此我写了下面的代码。

ServerFile.java

import java.io.*; 
import java.net.*; 
public class ClientFile implements Runnable{ 
Socket clientsocket; 
public void run() { 
    try 
    { 
     clientsocket = new Socket("219.64.189.14",6789); 
    // Some code 
    copy(outtoserver,infromserver, files);  // files contains the path of files to be transferred. 
    // Some code 
     clientsocket.close(); 
    } 
    catch(Exception e2) 
    { 
      System.out.println("ClientFile "+String.valueOf(e2) + "\n"); 
    } 
} 
public void copy(DataOutputStream outtoserver,BufferedReader infromserver,String[] files) 
{ 
    try 
    { 
     FileSender fs = new FileSender(); 
     int totalfiles=0; 
     int r=0; 
     File oldfile; 
     outtoserver.write(files.length); 
     String chk; 
     while(totalfiles<files.length) 
     { 

      oldfile = new File(files[totalfiles]); 
      if(oldfile.isDirectory()) 
      { 
       outtoserver.writeBytes("folder\n"); 
       File folder1[] = oldfile.listFiles(); 
       String[] folder = new String[folder1.length]; 
       int count=0; 
       for(File name : folder1) 
       { 
        folder[count] = name + ""; 
        System.out.println(folder[count]); 
        count++; 
       } 
       outtoserver.writeBytes(oldfile.getName()+"\n"); 
       fs.main(clientsocket, folder); 

      } 
      else if(oldfile.isFile()) 
      { 
       outtoserver.writeBytes("file\n"); 
     chk = infromserver.readLine(); 
       if(chk.equals("send")) 
       { 
        outtoserver.writeBytes(oldfile.getName()+"\n"); 
        String[] folder = new String[]{oldfile.getAbsolutePath()}; 
        fs.main(clientsocket, folder); 
       } 
       totalfiles++; 
       outtoserver.flush(); 

      } 
     } 
    } 
    catch(Exception e) 
    { 
     System.out.println("ClientFile -->> "+e.toString()); 
    } 
} 
} 

ClientFile.java

import java.io.*; 
import java.net.*; 
import javax.swing.*; 
class ServerFile implements Runnable { 
Socket conn; 
public ServerFile(Socket a) 
{ 
    conn = a; 
} 
public void run() { 
    File file1; 
    String clientsen=""; 
    try 
    { // Some code 
     copy(outtoclient,infromclient,file1.getAbsolutePath());  //file1 is the directory to which the file has to stored.  
    // some code 
    }  
    catch(Exception e0) 
    { 
     System.out.println("ServerFile "+String.valueOf(e0)+"\n"+e0.getCause()); 
    } 
}//end main 
public void copy(DataOutputStream outtoclient,BufferedReader infromclient,String basepath) 
{ 
    try 
    { 
     FileReceiver fr = new FileReceiver(); 
     int totfiles = infromclient.read(); 
     int tot=0; 
     File file; 
     String path = null,chk; 
     while(tot<totfiles) 
     { 
      chk = infromclient.readLine(); 
      if(chk.equals("file")) 
      { 
       outtoclient.writeBytes("send\n"); 
       path = infromclient.readLine(); 
       path = basepath+File.separator+path; 
       file=new File(path); 
       fr.main(conn, basepath+File.separator); 
      } 
      else if(chk.equals("folder")) 
      { 
       String name = infromclient.readLine(); 
       name = basepath+File.separator+name; 
       new File(name).mkdir(); 
       fr.main(conn, name+File.separator); 
      } 
      tot++; 
     } 
    } 
    catch(Exception e) 
    { 
     System.out.println("Server file: "+e.toString()); 
    } 
} 

}//end class 

纠正我，通过各种手段，如果我错了。

任何帮助表示赞赏。

Answer 1

所以，我真的不知道它是如何将文件内容与文件名分开的？可能更好地创建包含文件名和内容的可序列化类。在这种情况下，您可以使用ObjectInput/OutputStream。否则，您需要定义一些文件内容/文件名称分隔符，并使用Scanner类将输入流中的文件分开。

Answer 2

您向客户发送"file\n"或"folder\n"。要阅读这些字符串，您正在使用BufferedReader。密切关注该类别的名称：BufferedReader。当您在BufferedReader上调用readLine()时，它将缓冲（读取）至少所需的字节数以读取该行。它可能读取更多比读取该行所需的确切字节数。例如，假设BufferedReader的缓冲区大小为256，但是您的行（包括"\n"）仅需要8个字节。这意味着被缓冲的其余248个字节将不被FileReceiver读取。然后它会被彻底弄糊涂，因为它需要一个4字节的整数，但实际上它正在读取其他内容。

我建议您充分利用本示例中已使用的技术。例如，使用发送"file"：

ByteStream.toStream(os, "file") 

而且使用阅读：

ByteStream.toString(in)