在另一个线程中下载和解压缩文件，导致存档损坏

Question

我正在尝试从给定的 url 下载 .zip 存档并将其解压缩到选定的位置。由于下载量很大，我尝试在不同的线程中执行它，因此它不会冻结整个事情，但它并没有真正取得完全成功......通常，我会创建一个可运行和线程对象，但现在，由于我使用的是 javafx，它给出了一些错误。我在网上搜索，我不得不改用Platform.runLater()。这是我的代码：

private void startTask(Label st, ListView<String> view, HashMap<String, String> hash)
{

    Platform.runLater(new Runnable() {
        @Override
        public void run() {
            runTask(st,view,hash);
        }
    });
}

private void runTask(Label st, ListView<String> view, HashMap<String, String> hash){
    String link = hash.get(view.getSelectionModel().getSelectedItem());
    File file = new File("temp.zip");
    try {
        FileUtils.copyURLToFile(new URL(link), file);
        byte[] buffer = new byte[1024];
        ZipInputStream zis = new ZipInputStream(new FileInputStream(file));
        ZipEntry zipEntry = zis.getNextEntry();
        File newFile;
        FileOutputStream fos;
        String fileName;
        while(zipEntry != null){

            fileName = zipEntry.getName();
            if(fileName.contains("##TEMP##")) continue;
            if(fileName.contains("MACOSX")) continue;
            newFile = new File(fileName);
            fos = new FileOutputStream(newFile);
            int len;
            while ((len = zis.read(buffer)) > 0) {
                fos.write(buffer, 0, len);
            }
            fos.close();
            zipEntry = zis.getNextEntry();
        }
        zis.closeEntry();
        zis.close();
    } catch (IOException | NullPointerException e) {
        e.printStackTrace();
    }
    st.setText("Status: Ready");


}

结果如下：39ko temp.zip 文件似乎已损坏。它不会解压缩（显然）。我尝试了来自多个域的许多链接，仍然是同样的问题...

编辑：尝试了不同的方法...同样的错误..新代码：

        URL url = new URL(link);
        HttpURLConnection connection = (HttpURLConnection) url.openConnection();
        connection.setRequestMethod("GET");
        InputStream in = connection.getInputStream();
        FileOutputStream out = new FileOutputStream("download.zip");
        copy(in, out, 1024);
        out.close();
public static void copy(InputStream input, OutputStream output, int bufferSize) throws IOException {
    byte[] buf = new byte[bufferSize];
    int n = input.read(buf);
    while (n >= 0) {
        output.write(buf, 0, n);
        n = input.read(buf);
    }
    output.flush();
}

我评论了解压部分，还是一样...结论：下载是问题。

Answer 1

您在 while 循环的顶部执行 fileName.contains() 检查，可以 continue，返回到 while 循环的开头。但是zipEntry = zis.getNextEntry() 位于循环的底部，因此在这些情况下不会调用它。看起来它陷入了无限循环

     while(zipEntry != null) {
        fileName = zipEntry.getName();
        if(fileName.contains("##TEMP##")) continue;
        if(fileName.contains("MACOSX")) continue;

        // unzipping code

        zipEntry = zis.getNextEntry(); // never happens when filename  contains ##TEMP## or MACOSX 
    }

将getNextEntry() 代码移动到循环顶部并从变量声明中删除第一个调用..

     ZipEntry zipEntry;

     while((zipEntry = zis.getNextEntry()) != null) {
        fileName = zipEntry.getName();
        if(fileName.contains("##TEMP##")) continue;
        if(fileName.contains("MACOSX")) continue;

        // unzipping code
    }