捕获 ZipException 并匹配“invalid cen”等关键词确认压缩包损坏，安全删除旧文件及解压目录，再提交至线程池重下载并递归解压。
java 中 zipexception 本身是只读异常，不能“处理变量”或直接触发下载逻辑，但它可作为关键信号——当解压失败时捕获该异常，确认压缩包损坏，进而执行清理 + 重下载流程。核心在于：捕获异常 → 验证损坏原因 → 安全删除旧文件 → 触发新下载。
捕获 ZipException 并区分真实损坏场景
不是所有 ZipException 都代表文件损坏（比如路径不存在会抛 FileNotFoundException，权限问题抛 SecurityException），需聚焦典型损坏特征：
- “invalid CEN header” / “invalid LOC header”：中央目录或本地文件头损坏，基本可判定 ZIP 结构异常
- “zip file is empty” / “error in opening zip file”：空文件或魔数（PK\x03\x04）缺失
-
“invalid stored block lengths”（配合
ZipInputStream）：数据块校验失败
建议用 exception.getMessage().toLowerCase() 做关键词匹配，避免依赖异常类型继承关系（ZipException 是 IOException 子类，但具体子类如 ZipError 不公开）。
安全清理旧压缩包文件
删除前务必确认目标是已知的下载文件（而非用户其他 ZIP），并防止并发冲突：
- 使用
Files.deleteIfExists(path)而非File.delete()，避免静默失败 - 若文件正被其他线程读取，
deleteIfExists可能返回false，此时应加简单重试（如最多 3 次，间隔 100ms）或记录警告 - 清理后建议同步删除关联的解压目录（如
archive.zip.extracted/），避免残留脏数据
触发重下载逻辑的推荐方式
不要在 catch 块里直接调用阻塞式下载（如 HttpURLConnection 同步请求），尤其在 UI 线程或服务主线程中：
立即学习“Java免费学习笔记（深入）”；
- 推荐提交到独立线程池：
downloadExecutor.submit(() -> downloadAndExtract(zipPath)) - 若需通知上层（如 Android 的 Activity、Spring 的 Controller），通过回调、事件总线或状态监听器传递“重试开始/成功/失败”事件
- 加入基础重试控制：首次失败后等待 1–2 秒再重下，避免瞬时网络抖动导致反复拉取
完整轻量示例（含关键注释）
注意：此处仅展示核心流程，生产环境请补全日志、监控和超时控制
public void safeExtract(Path zipPath) {
try (ZipInputStream zis = new ZipInputStream(Files.newInputStream(zipPath))) {
zis.getNextEntry(); // 触发解析，损坏时在此抛 ZipException
// ... 正常解压逻辑
} catch (ZipException e) {
String msg = e.getMessage().toLowerCase();
if (msg.contains("invalid cen") || msg.contains("empty") || msg.contains("error in opening")) {
cleanupCorruptedZip(zipPath);
triggerRedownload(zipPath);
} else {
throw e; // 其他 ZipException（如密码错误）不走重下流程
}
} catch (IOException e) {
// 处理流关闭等 IO 异常，非 ZIP 结构问题
throw new RuntimeException("IO error during extraction", e);
}
}
private void cleanupCorruptedZip(Path zipPath) {
try {
Files.deleteIfExists(zipPath);
Path extractedDir = zipPath.resolveSibling(zipPath.getFileName() + ".extracted");
if (Files.exists(extractedDir)) {
Files.walk(extractedDir)
.sorted(Comparator.reverseOrder())
.forEach(path -> {
try { Files.delete(path); } catch (IOException ignored) {}
});
}
} catch (IOException e) {
log.warn("Failed to clean up corrupted zip: {}", zipPath, e);
}
}
private void triggerRedownload(Path zipPath) {
downloadExecutor.submit(() -> {
try {
downloadNewZipTo(zipPath);
safeExtract(zipPath); // 递归尝试解压新文件
} catch (Exception ex) {
log.error("Redownload and extract failed for {}", zipPath, ex);
}
});
} 
