feat(window): 使用流代替原有方法，强化取消按钮打断能力

Author: 502y

src/main/java/i18nupdatemod/I18nUpdateMod.java

@@ -34,6 +34,9 @@ public static void init(Path minecraftPath, String minecraftVersion, String load
         LoadDetailUI.setStage(LoadStage.INIT);
 
         try (InputStream is = I18nUpdateMod.class.getResourceAsStream("/i18nMetaData.json")) {
+            if (is == null) {
+                throw new IllegalStateException("/i18nMetaData.json not found");
+            }
             MOD_VERSION = GSON.fromJson(new InputStreamReader(is), JsonObject.class).get("version").getAsString();
         } catch (Exception e) {
             Log.warning("Error getting version: " + e);

src/main/java/i18nupdatemod/core/ResourcePack.java

@@ -1,12 +1,14 @@
 package i18nupdatemod.core;
 
+import i18nupdatemod.I18nUpdateMod;
 import i18nupdatemod.util.AssetUtil;
 import i18nupdatemod.util.DigestUtil;
 import i18nupdatemod.util.FileUtil;
 import i18nupdatemod.util.Log;
 
 import java.io.FileNotFoundException;
 import java.io.IOException;
+import java.io.InterruptedIOException;
 import java.net.URISyntaxException;
 import java.nio.file.Files;
 import java.nio.file.Path;
@@ -78,17 +80,29 @@ private boolean checkMd5(Path localFile, String md5Url) throws IOException, URIS
     }
 
     private void downloadFull(String fileUrl, String md5Url) throws IOException {
+        if (I18nUpdateMod.shouldShutdown) {
+            throw new InterruptedIOException("Download cancelled by user");
+        }
+
+        Path downloadTmp = FileUtil.getTemporaryPath(filename + ".tmp");
         try {
-            Path downloadTmp = FileUtil.getTemporaryPath(filename + ".tmp");
             AssetUtil.download(fileUrl, downloadTmp);
             if (!checkMd5(downloadTmp, md5Url)) {
                 throw new IOException("Download MD5 not match");
             }
             Files.move(downloadTmp, tmpFilePath, StandardCopyOption.REPLACE_EXISTING);
             Log.debug(String.format("Updates temp file: %s", tmpFilePath));
+        } catch (InterruptedIOException e) {
+            Files.deleteIfExists(downloadTmp);
+            throw e;
         } catch (Exception e) {
             Log.warning("Error while downloading: %s", e);
         }
+
+        if (I18nUpdateMod.shouldShutdown) {
+            throw new InterruptedIOException("Download cancelled by user");
+        }
+
         if (!Files.exists(tmpFilePath)) {
             throw new FileNotFoundException("Tmp file not found.");
         }

src/main/java/i18nupdatemod/util/AssetUtil.java

@@ -2,18 +2,23 @@
 
 import com.google.gson.Gson;
 import com.google.gson.reflect.TypeToken;
-import org.apache.commons.io.FileUtils;
+import i18nupdatemod.I18nUpdateMod;
 import org.apache.commons.io.IOUtils;
 import org.jetbrains.annotations.NotNull;
 
 import java.io.IOException;
+import java.io.InputStream;
 import java.io.InputStreamReader;
+import java.io.InterruptedIOException;
+import java.io.OutputStream;
 import java.lang.reflect.Type;
 import java.net.HttpURLConnection;
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.net.URL;
+import java.net.SocketTimeoutException;
 import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
 import java.nio.file.Path;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -35,8 +40,36 @@ public class AssetUtil {
 
     public static void download(String url, Path localFile) throws IOException, URISyntaxException {
         Log.info("Downloading: %s -> %s", url, localFile);
-        FileUtils.copyURLToFile(new URI(url).toURL(), localFile.toFile(),
-                (int) TimeUnit.SECONDS.toMillis(3), (int) TimeUnit.SECONDS.toMillis(33));
+
+        HttpURLConnection connection = (HttpURLConnection) new URI(url).toURL().openConnection();
+        connection.setRequestMethod("GET");
+        connection.setConnectTimeout((int) TimeUnit.SECONDS.toMillis(3));
+        connection.setReadTimeout((int) TimeUnit.SECONDS.toMillis(1));
+
+        try (InputStream input = connection.getInputStream();
+             OutputStream output = Files.newOutputStream(localFile)) {
+            byte[] buffer = new byte[8192];
+            while (true) {
+                if (I18nUpdateMod.shouldShutdown) {
+                    throw new InterruptedIOException("Download cancelled by user");
+                }
+
+                int read;
+                try {
+                    read = input.read(buffer);
+                } catch (SocketTimeoutException e) {
+                    continue;
+                }
+
+                if (read < 0) {
+                    break;
+                }
+                output.write(buffer, 0, read);
+            }
+        } finally {
+            connection.disconnect();
+        }
+
         Log.debug("Downloaded: %s -> %s", url, localFile);
     }