Combine:从URLSession.shared.dataTaskPublisher输出解码数据

基础概念

URLSession.shared.dataTaskPublisher 是 Swift 中用于发起网络请求并获取数据的一种方式。它是 Combine 框架的一部分，Combine 是苹果推出的响应式编程框架，用于处理异步事件流。

类型

URLSession.shared.dataTaskPublisher 返回的是一个 Publisher，具体类型是 URLSession.DataTaskPublisher。这个 Publisher 会发布 Result<Data, Error> 类型的事件。

应用场景

适用于需要从网络获取数据并进行处理的场景，例如：

获取 API 数据并更新 UI
下载文件并保存到本地
实时获取和处理网络数据

示例代码

以下是一个使用 URLSession.shared.dataTaskPublisher 发起网络请求并解码数据的示例：

import Foundation
import Combine

struct User: Codable {
    let id: Int
    let name: String
}

func fetchUser() -> AnyPublisher<User, Error> {
    let url = URL(string: "https://api.example.com/user/1")!
    
    return URLSession.shared.dataTaskPublisher(for: url)
        .map { $0.data }
        .decode(type: User.self, decoder: JSONDecoder())
        .eraseToAnyPublisher()
}

let cancellable = fetchUser()
    .sink(receiveCompletion: { completion in
        switch completion {
        case .finished:
            print("Finished")
        case .failure(let error):
            print("Error: \(error)")
        }
    }, receiveValue: { user in
        print("User: \(user)")
    })

参考链接

常见问题及解决方法

问题：网络请求失败，无法获取数据

原因：

网络连接问题
URL 错误
服务器错误

解决方法：

检查网络连接是否正常。
确保 URL 正确无误。
检查服务器状态，确保服务器能够正常响应请求。

let cancellable = fetchUser()
    .sink(receiveCompletion: { completion in
        switch completion {
        case .finished:
            print("Finished")
        case .failure(let error):
            print("Error: \(error)")
            // 处理错误
        }
    }, receiveValue: { user in
        print("User: \(user)")
    })

问题：数据解码失败

原因：

数据格式不正确
解码器配置错误

解决方法：

确保返回的数据格式与解码的模型结构一致。
检查解码器的配置，确保使用正确的解码器。

let decoder = JSONDecoder()
decoder.dateDecodingStrategy = .iso8601 // 根据需要配置解码器

return URLSession.shared.dataTaskPublisher(for: url)
    .map { $0.data }
    .decode(type: User.self, decoder: decoder)
    .eraseToAnyPublisher()

通过以上方法，可以有效地解决在使用 URLSession.shared.dataTaskPublisher 过程中遇到的常见问题。