URLSession dataTaskPublisher 在特定错误延迟后重试

Question

我正在尝试重新发送针对特定类型错误的请求。假设对于超时错误，我想在延迟 3 秒后重试请求。显然，如果请求成功执行，我不希望有任何延迟。

我正在使用here建议的方法

var cancellables = Set<AnyCancellable>()

let url = URL(string: "https://www.apple.com")!
let sessionConfiguration = URLSessionConfiguration.default
sessionConfiguration.timeoutIntervalForRequest = 1
sessionConfiguration.requestCachePolicy = .reloadIgnoringLocalAndRemoteCacheData

let publisher = URLSession(configuration: sessionConfiguration).dataTaskPublisher(for: url).share()

let head = publisher.print().tryCatch { error -> AnyPublisher<(data: Data, response: URLResponse), URLError> in
    switch error {
    case URLError.timedOut:
        print("I'm in URLError.timedOut case")
        return publisher.delay(for: 3, scheduler: DispatchQueue.main).eraseToAnyPublisher()

    default:
        print("I'm in default case")
        throw error
    }
}.retry(3)

head.map { data, response in
    return data
}.sink(receiveCompletion: {
    print("completion \($0)")
}, receiveValue: {
    print("value \($0)")
}).store(in: &cancellables)

出于测试目的，我为 URLSession 设置了 1 秒的超时间隔，并限制了我的网络连接，预计当整个管道在大约 10 秒内完成时会看到 4 个失败的请求。但我实际上看到的只是一个失败的请求，并在一段时间后打印了一个失败的完成。对我来说，我似乎每三秒从tryCatch 运营商返回publisher，但由于某种原因，它不会碰巧发送新请求。

我错过了什么？这个问题有其他解决方案吗？

2020 年 14 月 5 日更新

我在tryCatch 之前添加了print() 运算符，并在闭包内添加了一些打印。我在控制台看到的是这个

receive subscription: (Multicast)
request unlimited
receive error: (URLError(_nsError: Error Domain=NSURLErrorDomain Code=-1001 "The request timed out."...))
I'm in URLError.timedOut case
receive subscription: (Multicast)
request unlimited
receive error: (URLError(_nsError: Error Domain=NSURLErrorDomain Code=-1001 "The request timed out." ...))
I'm in URLError.timedOut case
receive subscription: (Multicast)
request unlimited
receive error: (URLError(_nsError: Error Domain=NSURLErrorDomain Code=-1001 "The request timed out." ...))
I'm in URLError.timedOut case
receive subscription: (Multicast)
request unlimited
receive error: (URLError(_nsError: Error Domain=NSURLErrorDomain Code=-1001 "The request timed out." ...))
I'm in URLError.timedOut case
completion failure(Foundation.URLError(_nsError: Error Domain=NSURLErrorDomain Code=-1001 "The request timed out."...))

但我在 Charles http 代理中看到的正是一个请求，即在重试之前发送的一个请求

Answer 1

我做了一些测试，你的问题似乎在这一行：

let publisher = URLSession(configuration: sessionConfiguration).dataTaskPublisher(for: url).share()

通过使用share()，您可以重播或共享数据任务发布者的结果。因此，虽然您的重试逻辑工作正常，但每次都会重播第一个请求的结果。如果您删除 share()，则会在 URLError.timedOut 的情况下发出新请求。

如果您需要重播/共享，那么您可以在 retry 之后添加，这样您创建的数据任务发布者就不会重播初始尝试的结果。