将大文件客户端发送到服务器

Question

我正在尝试将文件发送到我的服务器。我让它处理小于 100mb 的文件。否则我的堆用完了。所以我重做了它，但不能真正让它工作。除了读取我卡在 bis.read(buffer) 中的最后一个数据之外，我还开始工作，因为它不知道文件何时结束。所以我尝试发送每个段的长度，以便 bufferedInputStream 知道何时停止读取。

知道有什么问题吗？

发件人代码：

        FileInputStream fis = new FileInputStream(file);
        byte[] buffer = new byte[2048];
        Integer bytesRead = 0;
        BufferedOutputStream bos = new BufferedOutputStream(clientSocket.getOutputStream());
        BufferedInputStream bis = new BufferedInputStream(fis);

        while ((bytesRead = bis.read(buffer)) > 0) {
            objectOutStream.writeObject(bytesRead);
            bos.write(buffer, 0, bytesRead);

        }
        System.out.println("Sucess sending file");

接收方（服务器）：

       fileName = request.getFileName();
       int size = (int) request.getSize();

        BufferedInputStream bis = new BufferedInputStream(clientSocket.getInputStream());

        FileOutputStream fos = new FileOutputStream(fileName);
        int totalBytesReceived = 0;
        int blockSize = 0;
        while (totalBytesReceived < size) {
            Object o = ois.readObject();

            if (!(o instanceof Integer)) {
                System.out.println("Something is wrong");
            }
            blockSize = (Integer) o;

            buffer = new byte[blockSize];

            bis.read(buffer);
            totalBytesReceived += blockSize;
            fos.write(buffer, 0, blockSize);
        }
        System.out.println("File succes");

Answer 1

您在服务器端的阅读代码应该与客户端相同。

// copy from bis to bos, using a buffer.
for(int len; (len = bis.read(buffer)) > 0) {
    bos.write(buffer, 0, len);
}

在你想要的客户端

BufferedInputStream bis = new BufferedInputStream(new FileInputStream(filename));
BufferedOutputStream bos = new BufferedOutputStream(clientSocket.getOutputStream());

在您想要的服务器端。

BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(filename));

完成后你想

bos.close();
bis.close();

如果您要使用 ObjectOutputStream（我建议您不要），您只需要使用此流，而不是混合流。

Answer 2

您可以简化代码。当您到达流的末尾时，您将从bis.read() 获得-1。这样您就不需要知道文件的长度。以及flush() 和close() 服务器和客户端上的流。正如另一张海报所说，不要使用ObjectOutputStream 或ObjectIntputStream。您将获得似乎会损坏您的数据的序列化标头。

   fileName = request.getFileName();

    BufferedInputStream bis = new BufferedInputStream(clientSocket.getInputStream());

    FileOutputStream fos = new FileOutputStream(fileName);
    int data = bis.read(); //reads an int
    while (data != -1) {
        fos.write(data);
        data = bis.read();

    }
    fos.flush();
    fos.close();

    System.out.println("File succes");