3 
static void sendFile(Socket socket, File file) throws IOException {

    File testFile = new File( Environment.getExternalStorageDirectory().toString()+"/DCIM/Camera/Test.jpg");
    byte [] buffer = new byte[(int)testFile.length()];
    FileInputStream fis = new FileInputStream(testFile);
    BufferedInputStream bis = new BufferedInputStream(fis);
    Log.d(DebugTag, "Trying to read testFile from storage into buffer");
    bis.read(buffer,0,buffer.length); 
    Log.d(DebugTag, "Read testFile into buffer");
    OutputStream os = socket.getOutputStream();
    Log.d(DebugTag, "Trying to write testFile from buffer into output stream");
    os.write(buffer, 0, buffer.length);
    Log.d(DebugTag, "Wrote testFile from buffer into output stream");
    os.flush();
    Log.d(DebugTag, "Outputstream flushed");
}

static void receiveFile(Socket socket) throws IOException {

    InputStream is = socket.getInputStream();
    String receivedFileDirectory = Environment.getExternalStorageDirectory().toString()+"/Pictures/receivedFile.jpg";
    File receivedFile = new File(receivedFileDirectory);
    //check if directory exists, otherwise create it
    if (receivedFile.exists()) {
        Log.d(DebugTag, "Filename at destination already exists");
    } else if (!receivedFile.exists()) {
        Log.d(DebugTag, "Filename at destination does not exist, trying to create it!");
        receivedFile.createNewFile();
        Log.d(DebugTag, "Created file!");
    }

    Log.d(DebugTag, "Preparing file reception. Destination:"+receivedFileDirectory);
    OutputStream os = new FileOutputStream(receivedFileDirectory);
    Log.d(DebugTag, "established outputstream to file directory");
    byte[] buffer = new byte[2048];
    int length;
    Log.d(DebugTag, "Trying to read inputstream into buffer and write file to destination");
    while ((length = is.read(buffer)) >0 ) {
        os.write(buffer,0,length);
    }
    Log.d(DebugTag, "File received.");
    os.flush();
    os.close();
    is.close();
    Log.d(DebugTag, "Closed in and out streams");

}

发件人文件似乎工作正常，我收到每条日志消息，直到“输出流被刷新”。在接收方，一切似乎都很顺利，直到代码到达 while 循环：我得到的最后一个日志消息总是“尝试将输入流读入缓冲区并将文件写入目标”，而不是“收到文件”和以下消息. 奇怪的是：我收到了测试文件并可以打开它（虽然需要几秒钟 - 不知道这是否适用于 android）。 为什么代码卡在while循环中的任何线索？

第二个问题：这是我的第一个 Android/Java 应用程序。这段代码可以通过套接字发送和接收文件吗？即使文件变大（高达 >100MB）？

提前致谢！

4

1 回答 1

2

如果连接的另一端正常关闭（或在错误时抛出异常），那只is.read(buffer)会返回零，所以你缺少的是socket.close()发送端。

os.flush()在这里还不够，因为 TCP 不知道您何时完成发送数据。

于 2012-07-16T00:08:35.450 回答