java - 通过Java套接字传输大文件

This question already has answers here:

Java multiple file transfer over socket

(3个答案)


3年前关闭。




我已经编写了一个小的客户端-服务器代码，用于传输小文件。它使用数据输出流和数据输入流的readFully()方法。由于明显的原因，此代码不适用于较大的文件。我正在考虑将大文件分成小块，每个小块1Kb，然后再将它们发送到客户端。但是我想不出任何解决方案(例如如何在数据输出流上以正确的偏移量写入多个块，以及如何在接收端重新组装它们。任何人都可以提供解决方法吗？如果可以修改我的代码，这将非常有帮助:

发件人(服务器):

public void sendFileDOS() throws FileNotFoundException {
    runOnUiThread( new Runnable() {
          @Override
          public void run() {
              registerLog("Sending. . . Please wait. . .");
          }
        });
    final long startTime = System.currentTimeMillis();
    final File myFile= new File(filePath); //sdcard/DCIM.JPG
    byte[] mybytearray = new byte[(int) myFile.length()];
    FileInputStream fis = new FileInputStream(myFile);
    BufferedInputStream bis = new BufferedInputStream(fis);
    DataInputStream dis = new DataInputStream(bis);
    try {
        dis.readFully(mybytearray, 0, mybytearray.length);
        OutputStream os = socket.getOutputStream();
        //Sending file name and file size to the client
        DataOutputStream dos = new DataOutputStream(os);
        dos.writeUTF(myFile.getName());
        dos.writeLong(mybytearray.length);
        int i = 0;
        final ProgressBar myProgBar=(ProgressBar)findViewById(R.id.progress_bar);
        while (i<100) {
            dos.write(mybytearray, i*(mybytearray.length/100), mybytearray.length/100);
            final int c=i;
            runOnUiThread( new Runnable() {
                  @Override
                  public void run() {
                      myProgBar.setVisibility(View.VISIBLE);
                      registerLog("Completed: "+c+"%");
                      myProgBar.setProgress(c);
                      if (c==99)
                          myProgBar.setVisibility(View.INVISIBLE);
                  }
                });
            i++;
        }
        dos.flush();

    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    runOnUiThread( new Runnable() {
          @Override
          public void run() {
              long estimatedTime = (System.currentTimeMillis() - startTime)/1000;
              registerLog("File successfully sent");
              registerLog("File size: "+myFile.length()/1000+" KBytes");
              registerLog("Elapsed time: "+estimatedTime+" sec. (approx)");
              registerLog("Server stopped. Please restart for another session.");
              final Button startServerButton=(Button)findViewById(R.id.button1);
              startServerButton.setText("Restart file server");
          }
        });
}

接收方(客户):

public class myFileClient {
final static String servAdd="10.141.21.145";
static String filename=null;
static Socket socket = null;
static Boolean flag=true;

/**
 * @param args
 */
public static void main(String[] args) throws IOException {
    // TODO Auto-generated method stub
    initializeClient();
    receiveDOS();
}
public static void initializeClient () throws IOException {
    InetAddress serverIP=InetAddress.getByName(servAdd);
    socket=new Socket(serverIP, 4444);
}
public static void receiveDOS() {
    int bytesRead;
    InputStream in;
    int bufferSize=0;

    try {
        bufferSize=socket.getReceiveBufferSize();
        in=socket.getInputStream();
        DataInputStream clientData = new DataInputStream(in);
        String fileName = clientData.readUTF();
        System.out.println(fileName);
        OutputStream output = new FileOutputStream("//home//evinish//Documents//Android//Received files//"+ fileName);
        long size = clientData.readLong();
        byte[] buffer = new byte[bufferSize];
        while (size > 0
                && (bytesRead = clientData.read(buffer, 0,
                        (int) Math.min(buffer.length, size))) != -1) {
            output.write(buffer, 0, bytesRead);
            size -= bytesRead;
        }

    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

请帮忙!提前致谢! :)

最佳答案

没错，这是一种糟糕的方法。它浪费了内存和时间。假设文件大小为32位；假定整个文件都可以放入内存；假定一次读取了整个文件；并且直到读取完整个文件后，它才发送任何内容。

在Java中复制流的规范方法是:

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

它可以与您喜欢的任何大小的缓冲区一起使用，因此可以与您想出的任何大小的文件一起使用。尽管不必在两端使用相同的大小缓冲区，但在两端使用相同的代码。当您通过网络进行复制时，您可能会认为1k或1.5k是最佳大小，但是这忽略了内核中套接字发送和接收缓冲区的存在。考虑到它们，最好使用8k或更高。

关于java - 通过Java套接字传输大文件，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/17285846/