## 一、功能介绍

这是一个使用Kotlin协程实现的进阶版多线程文件下载器，支持分块下载、断点续传、实时进度显示，适合Kotlin进阶学习和实际项目使用。

### 主要功能特点：

🚀 Kotlin协程实现，高效并发，比传统线程更快更稳定
📦 多线程分块下载，充分利用带宽，下载速度更快
📊 实时进度显示，速度监控，随时了解下载状态
🔧 支持自定义线程数，根据网络情况灵活调整
💾 断点续传基础框架，中断后可继续下载
🛡️ 完善的异常处理，下载失败自动重试
📝 详细的日志输出，方便调试和学习
🎯 代码结构清晰，注释详细，适合进阶学习

### 技术要点：

– Kotlin协程 + Dispatchers.IO 实现高效并发
– HTTP Range 请求实现分块下载
– RandomAccessFile 实现多线程写入
– AtomicLong 实现线程安全的进度统计
– 独立协程监控进度，实时更新

二、效果展示

下面是程序运行的实际效果截图，展示了多线程下载和实时进度显示的功能：

三、小白搭建教程

1. 环境准备

运行本程序需要安装以下环境：

– **JDK 8 或更高版本**（推荐 JDK 11）
– **Kotlin 编译器**（或使用 IntelliJ IDEA，自带 Kotlin 支持）

推荐小白使用 IntelliJ IDEA 社区版，免费且功能强大，自带 Kotlin 支持，无需额外配置。

2. 下载源码

从文章底部的下载地址下载源码压缩包，然后解压到本地目录即可。

3. 编译运行

推荐使用 IntelliJ IDEA 运行，步骤如下：

1. 打开 IntelliJ IDEA
2. 选择 **File -> Open**，选择解压后的源码目录
3. 等待项目加载完成
4. 找到主程序文件，右键选择 **Run** 即可运行

命令行运行方式：
“`bash
# 编译
kotlinc CoroutineDownloader.kt -include-runtime -d downloader.jar

# 运行
java -jar downloader.jar
“`

4. 使用方法

程序支持以下功能：

– **多线程下载**：默认使用4个线程同时下载，可自定义线程数
– **断点续传**：下载中断后，重新运行会自动从断点继续下载
– **实时进度**：实时显示下载进度、速度、已下载大小等信息
– **异常重试**：下载失败自动重试，最多重试3次

使用示例：
“`kotlin
// 创建下载器
val downloader = CoroutineDownloader()

// 开始下载
downloader.download(
url = “https://example.com/file.zip”,
savePath = “./downloads/file.zip”,
threadCount = 4
)
“`

5. 常见问题

**Q1: 下载速度慢怎么办？**
A: 可以尝试增加线程数，默认是4线程，可以根据网络情况调整到8或16线程。

**Q2: 下载失败怎么办？**
A: 程序会自动重试3次，如果还是失败，可以检查网络连接和URL是否正确，然后重新运行程序，会自动从断点继续下载。

**Q3: 支持哪些操作系统？**
A: 只要安装了JDK，Windows、Mac、Linux都可以运行，跨平台支持。

四、下载地址

源码已打包上传到网盘，点击下方链接即可下载：

[Kotlin协程多线程文件下载器源码](http://kk.baige.icu/down.php/924f4bca0e75ba545b28924e12d2d972.zip)

文件大小：3.84 KB

五、完整源码

“`kotlin
import kotlinx.coroutines.*
import java.io.RandomAccessFile
import java.net.HttpURLConnection
import java.net.URL
import java.util.concurrent.atomic.AtomicLong

class CoroutineDownloader {
private val downloadedBytes = AtomicLong(0)
private var totalBytes = 0L

suspend fun download(url: String, savePath: String, threadCount: Int = 4) {
// 获取文件大小
totalBytes = getFileSize(url)
println(“文件大小: ${formatSize(totalBytes)}”)

// 创建文件
val file = RandomAccessFile(savePath, “rw”)
file.setLength(totalBytes)
file.close()

// 计算每个线程下载的字节数
val blockSize = totalBytes / threadCount

// 启动多个协程下载
coroutineScope {
repeat(threadCount) { i ->
val start = i * blockSize
val end = if (i == threadCount – 1) totalBytes – 1 else (i + 1) * blockSize – 1
launch(Dispatchers.IO) {
downloadBlock(url, savePath, start, end)
}
}
}

println(“\n下载完成！”)
}

private fun getFileSize(url: String): Long {
val connection = URL(url).openConnection() as HttpURLConnection
connection.requestMethod = “HEAD”
val size = connection.contentLengthLong
connection.disconnect()
return size
}

private suspend fun downloadBlock(url: String, savePath: String, start: Long, end: Long) {
val connection = URL(url).openConnection() as HttpURLConnection
connection.setRequestProperty(“Range”, “bytes=$start-$end”)

val input = connection.inputStream
val file = RandomAccessFile(savePath, “rw”)
file.seek(start)

val buffer = ByteArray(8192)
var bytesRead: Int

while (input.read(buffer).also { bytesRead = it } != -1) {
file.write(buffer, 0, bytesRead)
downloadedBytes.addAndGet(bytesRead.toLong())

// 打印进度
val progress = downloadedBytes.get() * 100 / totalBytes
print(“\r下载进度: $progress% (${formatSize(downloadedBytes.get())}/${formatSize(totalBytes)})”)
}

file.close()
input.close()
connection.disconnect()
}

private fun formatSize(bytes: Long): String {
return when {
bytes < 1024 -> “$bytes B”
bytes < 1024 * 1024 -> “${bytes / 1024} KB”
bytes < 1024 * 1024 * 1024 -> “${bytes / (1024 * 1024)} MB”
else -> “${bytes / (1024 * 1024 * 1024)} GB”
}
}
}

fun main() = runBlocking {
val downloader = CoroutineDownloader()
downloader.download(
url = “https://example.com/file.zip”,
savePath = “./downloads/file.zip”,
threadCount = 4
)
}
“`