目前,iOS 原生网络请求数据共有 4 种方式,分别是传统 Completion 回调、Completion 回调 + Result、Combine 框架与Swift Concurrency (async/await)。本文以下载图片为例,详细讲解 4 种网络请求的差异。
一种最基础的异步处理方式,使用闭包作为回调函数。
/// 错误枚举
enum FetchError: Error {
case badURL
case badRequest
case badImage
}
/// 1. 传统completion回调
func fetchImage(from url: String, completion: @escaping (UIImage?, Error?) -> Void) {
guard let url = URL(string: url) else {
completion(nil, FetchError.badURL)
return
}
let request = URLRequest(url: url)
let task = URLSession.shared.dataTask(with: request) { data, response, error in
if let error = error {
completion(nil, error)
} else if (response as? HTTPURLResponse)?.statusCode != 200 {
completion(nil, FetchError.badRequest)
} else {
guard let data = data,
let image = UIImage(data: data) else {
completion(nil, FetchError.badImage)
return
}
completion(image, nil)
}
}
task.resume()
}
fetchImage(from: "https://search-operate.cdn.bcebos.com/7e85570b817e17e8f3ae93134cc78451.gif") { image, error in
if let image {
print(image)
} else if let error {
print(error)
}
}
对传统 Completion 回调的改进,使用 Swift 的 Result 类型统一处理成功和失败情况。
enum FetchError: Error {
case badURL
case badRequest
case badImage
}
/// 2. completion回调+Result
func fetchImage(from url: String, completion: @escaping (Result<UIImage, Error>) -> Void) {
guard let url = URL(string: url) else {
completion(.failure(FetchError.badURL))
return
}
let request = URLRequest(url: url)
let task = URLSession.shared.dataTask(with: request) { data, response, error in
if let error = error {
completion(.failure(error))
} else if (response as? HTTPURLResponse)?.statusCode != 200 {
completion(.failure(FetchError.badRequest))
} else {
guard let data = data,
let image = UIImage(data: data) else {
completion(.failure(FetchError.badImage))
return
}
completion(.success(image))
}
}
task.resume()
}
fetchImage(from: "https://search-operate.cdn.bcebos.com/7e85570b817e17e8f3ae93134cc78451.gif") { result in
switch result {
case let .success(image):
print(image)
case let .failure(error):
print(error)
}
}
Combine 是 Apple 在 iOS 13 引入的响应式编程框架,专为处理异步事件流设计。
enum FetchError: Error {
case badURL
case badRequest
case badImage
}
/// 3. Combine
func fetchImage(from url: String) -> AnyPublisher<UIImage, Error> {
guard let url = URL(string: url) else { return Fail<UIImage, Error>(error: FetchError.badURL).eraseToAnyPublisher() }
let request = URLRequest(url: url)
let session = URLSession.shared
let dataPublisher = session.dataTaskPublisher(for: request)
.retry(3)
.timeout(5, scheduler: DispatchQueue.global())
.tryMap { data, response -> Data in
guard (response as? HTTPURLResponse)?.statusCode == 200 else { throw FetchError.badRequest }
return data
}
.tryMap { data -> UIImage in
guard let image = UIImage(data: data) else {throw FetchError.badImage}
return image
}
.receive(on: DispatchQueue.main)
.subscribe(on: DispatchQueue.global())
.eraseToAnyPublisher()
return dataPublisher
}
var cancellables = Set<AnyCancellable>()
fetchImage(from: "https://search-operate.cdn.bcebos.com/7e85570b817e17e8f3ae93134cc78451.gif")
.sink(
receiveCompletion: { completion in
switch completion {
case .finished:
print("Image download completed successfully")
case let .failure(error):
print(error)
}
}, receiveValue: { image in
print(image)
}
)
.store(in: &cancellables)
Swift 5.5 引入的现代异步编程模型,使用结构化并发的概念。
enum FetchError: Error {
case badURL
case badRequest
case badImage
}
/// 4. Concurrency
func fetchImage(from url: String) async throws -> UIImage {
guard let url = URL(string: url) else { throw FetchError.badURL }
let request = URLRequest(url: url)
let (data, response) = try await URLSession.shared.data(for: request)
guard (response as? HTTPURLResponse)?.statusCode == 200 else { throw FetchError.badRequest }
let image = UIImage(data: data)
guard let image = image else { throw FetchError.badImage }
return image
}
Task {
do {
let image = try await fetchImage(from: "https://search-operate.cdn.bcebos.com/7e85570b817e17e8f3ae93134cc78451.gif")
print(image)
} catch {
print(error)
}
}