Download.gif
下载功能的实现：
使用的网络连接的类为URLSession，在初始化URLSession前，需要先创建URLSessionConfiguration，可以理解为是URLSession需要的一个配置。URLSessionConfiguration有三种模式：
- default：可以使用缓存的Cache、Cookie、鉴权。
- ephemeral，仅内存缓存，不使用缓存的Cache、Cookie、鉴权。
- background，支持后台传输，需要一个identifier标识，用来重新连接session对象。
创建URLSession，设置配信息、代理、代理线程：
private lazy var session: URLSession = {
let configuration = URLSessionConfiguration.background(withIdentifier: "DownloadBackgroundSessionIdentifier")
let queue = OperationQueue()
queue.maxConcurrentOperationCount = 1
let session = URLSession(configuration: configuration, delegate: self, delegateQueue: queue)
return session
}()
在实现下载前，还需要了解一个很重要的类，URLSessionTask，无论下载多少文件，我们只需要初始化一个URLSession即可，而每个task对应一个任务，需要通过task才能实现下载，URLSessionTask是一个基类，有四个子类：
1、URLSessionDataTask：下载时，内容以Data对象返回，需要我们不断写入文件
2、URLSessionUploadTask：继承自URLSessionDataTask，内容以Data对象返回，协议方法中可以查看请求时上传内容的过程
3、URLSessionStreamTask:：建立了一个TCP/IP连接，替代InputStream/OutputStream，新的API可异步读写，自动通过HTTP代理连接远程服务器
4、URLSessionDownloadTask：资源会下载到一个临时文件，下载完成需将文件移动至想要的路径，系统会删除临时路劲文件，暂停时，系统会返回NSData对象，恢复下载时用这个data创建task
Download 是通过URLSessionDataTask进行下载的，核心代码：
// 创建流
let stream = OutputStream(toFileAtPath: path(url: url), append: true)
// 创建请求
var request = URLRequest(url: URL(string: url)!)
// 忽略本地缓存，代理服务器以及其他中介，直接请求源服务端
request.cachePolicy = .reloadIgnoringLocalAndRemoteCacheData
// 设置请求头
request.setValue("bytes=\(getDownloadSize(url: url))-", forHTTPHeaderField: "Range")
// 创建一个Data任务
let task = session.dataTask(with: request)
let taskIdentifier = arc4random() % ((arc4random() % 10000 + arc4random() % 10000))
task.setValue(taskIdentifier, forKey: "taskIdentifier")
// 开启下载
task.resume()
/// URLSessionDataDelegate
/// 接收到响应
func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, didReceive response: URLResponse, completionHandler: @escaping (URLSession.ResponseDisposition) -> Void) {
guard let model = sessionModels["\(dataTask.taskIdentifier)"],
let stream = model.stream,
let url = model.model.url else { return }
// 打开流
stream.open()
// 接收这个请求，允许接收服务器的数据
completionHandler(.allow)
}
/// 接收到服务器返回的数据，会被调用多次
func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, didReceive data: Data) {
guard let model = sessionModels["\(dataTask.taskIdentifier)"],
let stream = model.stream,
let url = model.model.url else { return }
let bytes = [UInt8](data)
// 写入数据
stream.write(UnsafePointer<UInt8>(bytes), maxLength: data.count)
// 已下载大小
let receivedSize = getDownloadSize(url: url)
// 总大小
let expectedSize = model.model.totalLength
// 下载进度
let progress: Double = Double(receivedSize) / Double(expectedSize)
}
/// URLSessionTaskDelegate
// 当请求完成之后调用，如果错误，那么error有值
func urlSession(_ session: URLSession, task: URLSessionTask, didCompleteWithError error: Error?) {
guard let model = sessionModels["\(task.taskIdentifier)"],
let url = model.model.url,
url.dw_isURL else { return }
if let error = error {
debugPrint("下载失败")
} else {
debugPrint("下载完成")
}
// 关闭流
model.stream?.close()
model.stream = nil
}
/// URLSessionDelegate
/// 应用处于后台，所有下载任务完成及URLSession协议调用之后调用
func urlSessionDidFinishEvents(forBackgroundURLSession session: URLSession) {}
Download API：
/// 设置下载并发数， 默认3
DownloadManager.default.maxDownloadCount = 3
/// 开启下载
func download(model: DownloadModel)
/// 判断该文件是否下载完成
func isCompletion(url: String) -> Bool
/// 判断该文件是否存在
func isExistence(url: String) -> Bool
/// 根据url取消/暂停任务
func cancelTask(url: String)
/// 取消/暂停所有任务
func cancelAllTask()
/// 根据url删除资源
func deleteFile(url: String)
/// 清空所有下载资源
func deleteAllFile()
/// 获取下载的数据
func getDownloadModels() -> [DownloadModel]
/// 获取下载完成的数据
func getDownloadFinishModels() -> [DownloadModel]
/// 获取未下载完成的数据
func getDownloadingModel() -> [DownloadModel]
/// 将未完成的下载状态改为.suspended
func updateDownloadingStateWithSuspended()
/// 开启未完成的下载
func updateDownloading()
/// 获取下载完成的文件路径
func getFile(url: String) -> String
/// 获取总缓存大小 单位：字节
func getCacheSize() -> Double
使用：见demo
Demo地址： Download
网友评论