UIKit 中的 Swift 组合。某些用户的 URLSession dataTaskPublisher NSURLErrorDomain -1

Question

将我们的 API 客户端切换到组合后，我们开始收到用户关于错误“无法完成操作 (NSURLErrorDomain -1.)”的报告，这是从我们的 API 客户端转发到 UI 的 error.localizedDescription。

顶级 api 调用如下所示：

class SomeViewModel {
  private let serviceCategories: ICategoriesService
  private var cancellables = [AnyCancellable]()

  init(service: ICategoriesService) {
    self.serviceCategories = service
  }

  // ...

  // Yes, the block is ugly. We are only on the half way of the migration to Combine
  func syncData(force: Bool = false, _ block: @escaping VoidBlock) {
    serviceCategories
      .fetch(force: force)
      .combineLatest(syncOrders(ignoreCache: force))
      .receive(on: DispatchQueue.main)
      .sink { [unowned self] completion in
        // bla-bla-bla
        // show alert on error
      }
      .store(in: &cancellables)
  }
}

低级 API 客户端调用如下所示：

func fetch<R>(_ type: R.Type, at endpoint: Endpoint, page: Int, force: Bool) -> AnyPublisher<R, TheError> where R : Decodable {
  guard let request = request(for: endpoint, page: page, force: force) else {
    return Deferred { Future { $0(.failure(TheError.Network.cantEncodeParameters)) } }.eraseToAnyPublisher()
  }

  let decoder = JSONDecoder()
  decoder.keyDecodingStrategy = .convertFromSnakeCase

  return URLSession.shared
      .dataTaskPublisher(for: request)
      .subscribe(on: DispatchQueue.background)
      .tryMap { element in
        guard
          let httpResponse = element.response as? HTTPURLResponse,
          httpResponse.statusCode == 200 else
        { throw URLError(.badServerResponse) }
        
        return element.data
      }
      .decode(type: type, decoder: decoder)
      .mapError { error in
        // We map error to present in UI
        switch error {
        case is Swift.DecodingError:
          return TheError.Network.cantDecodeResponse
          
        default:
          return TheError(title: nil, description: error.localizedDescription, status: -2)
        }
      }
      .eraseToAnyPublisher()
}

在我们的分析中，我们可以清楚地看到事件链：

• 应用程序已更新
• 应用程序已打开
• 显示主屏幕
• 显示警报 (NSURLErrorDomain -1)
• 应用程序后台 然后用户陷入循环“打开，警报，后台”尝试重新启动或重新安装应用程序但没有成功。

首先寻找的是它可能是从后端发送到客户端的一些垃圾，但我们的服务器日志有与分析日志相关的 API 调用记录，按日期和时间与 http 状态代码 499。
所以我们可以清楚地确定这不是服务器问题。 在此更新之前，我们也没有来自用户的报告或分析记录。

所有指向新 API 客户端的点都切换到了 Combine。

看起来会话由于某种原因被客户端丢弃，但同时它与内存释放周期无关，因为如果可取消，则释放sink 将永远不会执行闭包并且不会显示警报消息。

问题：

• 此 URLSession 设置有什么问题？
• 您是否遇到过类似的行为并设法解决？
• 您知道如何使用 URLSession 重现或至少模拟此类错误吗？

注意事项：

• 我们不使用 SwiftUI
• iOS 版本从 14.8 到 15.0 不等
• 5% 到 10% 的用户受到影响
• 我们在开发或测试期间从未遇到过此类错误

Answer 1

我不确定，但我在您提供的代码中看到了几个问题...我在下面发表了评论。

499 表示您的 Cancellable 在网络请求完成之前被删除。也许这会帮助你找到它。

另外，您不需要subscribe(on:)，它可能不会按照您的想法做。这可能是导致问题的原因，但无法确定。

使用subscribe(on:) 就像这样做：

DispatchQueue.background.async {
    URLSession.shared.dataTask(with: request) { data, response, error in
        <#code#>
    }
}

如果您了解 URLSession 的工作原理，您会发现调度是完全没有必要的，并且不会影响数据任务将在哪个线程上发出。

func fetch<R>(_ type: R.Type, at endpoint: Endpoint, page: Int, force: Bool) -> AnyPublisher<R, TheError> where R : Decodable {
    guard let request = request(for: endpoint, page: page, force: force) else {
        return Fail(error: TheError.Network.cantEncodeParameters).eraseToAnyPublisher() // your failure here is way more complex than it needs to be. A simple Fail will do what you need here.
    }

    let decoder = JSONDecoder()
    decoder.keyDecodingStrategy = .convertFromSnakeCase

    return URLSession.shared
        .dataTaskPublisher(for: request)
        // you don't need the `subscribe(on:)` here.
        .tryMap { element in
            guard
                let httpResponse = element.response as? HTTPURLResponse,
                httpResponse.statusCode == 200 else
                { throw URLError(.badServerResponse) }

            return element.data
        }
        .decode(type: type, decoder: decoder)
        .mapError { error in
            // We map error to present in UI
            switch error {
            case is Swift.DecodingError:
                return TheError.Network.cantDecodeResponse

            default:
                return TheError(title: nil, description: error.localizedDescription, status: -2)
            }
        }
        .eraseToAnyPublisher()
}