Синхронизация нескольких вызовов веб-сервисов в последовательном порядке в Swift - PullRequest
Новая
       39

Синхронизация нескольких вызовов веб-сервисов в последовательном порядке в Swift

0 голосов
/ 23 июня 2018

Я вхожу в URL веб-службы 10 раз и получаю ответ.Я использую Alamofire и SwiftyJSON.Это мой код контроллера 

class ViewController: UIViewController {

    let dispatchGroup = DispatchGroup()

    var weatherServiceURL = "http://samples.openweathermap.org/data/2.5/weather?q=London,uk&appid=b6907d289e10d714a6e88b30761fae22"

    override func viewDidLoad() {
        super.viewDidLoad()
        start()
    }

    func start() {
        weatherService()
        dispatchGroup.notify(queue: .main) {
            print("All services complete")
        }
    }

    func weatherService() {
        for i in 1...10 {
            dispatchGroup.enter()
            APIManager.apiGet(serviceName: self.weatherServiceURL, parameters: ["counter":i]) { (response:JSON?, error:NSError?, count:Int) in
                if let error = error {
                    print(error.localizedDescription)
                    return
                }
                guard let response = response else { return }
                print("\n\(response) \n\(count) response\n")
                self.dispatchGroup.leave()
            }
        }
    }
}

Это мой код класса Service Handler 

class APIManager: NSObject {

    class func apiGet(serviceName:String,parameters: [String:Any]?, completionHandler: @escaping (JSON?, NSError?, Int) -> ()) {
        Alamofire.request(serviceName, method: .get, parameters: nil, encoding: URLEncoding.default, headers: nil).responseJSON { (response:DataResponse<Any>) in

            switch(response.result) {
            case .success(_):
                if let data = response.result.value{
                    let json = JSON(data)
                    completionHandler(json,nil, parameters!["counter"] as! Int)
                }
                break

            case .failure(_):
                completionHandler(nil,response.result.error as NSError?, parameters!["counter"] as! Int)
                break
            }
        }
    }
}

Я отправляю счетчик ключа с индексом цикла for просто для отслеживания ответакакой индекс возвращается.Но ответ идет не в серийном порядке.Мы можем ожидать 3-й ответ до 2-го и 1-го ответа.Это связано с тем, что вызов API с вызовом функции APIManager.apiGet является асинхронным и экранируется, и поэтому продолжается цикл for.

Также я использовал dispatchQueue 

let dispatchQueue = DispatchQueue(label: "com.test.Queue", qos: .userInteractive)

и преобразовал функцию следующим образом:

func weatherService() {
    for i in 1...10 {
        dispatchGroup.enter()
        dispatchQueue.async {
            APIManager.apiGet(serviceName: self.weatherServiceURL, parameters: ["counter":i]) { (response:JSON?, error:NSError?, count:Int) in
                if let error = error {
                    print(error.localizedDescription)
                    return
                }
                guard let response = response else { return }
                print("\n\(response) \n\(count) response\n")
                self.dispatchGroup.leave()
            }
        }
    }
}

Тот же результат, что и код вызова службы асинхронный.Если мы сделаем 

dispatchQueue.sync {
   //service call 
}

, то мы также не получим ответ в последовательном порядке, так как сетевой вызов в async и dispatchQueue предполагает, что задача выполнена.

Условием является включение службы втолько в асинхронном режиме без зависания интерфейса.Если я нажму на сервис синхронно, то получу желаемый результат.Но блокировка основного потока совсем не приемлема.

Я могу управлять этим, используя массив или некоторые глобальные переменные bool, но я не хочу их использовать.Есть ли другой способ получить ответ в последовательном порядке, в котором он вызывается?Любая помощь или подсказка приветствуется.

Ответы [ 3 ]

0 голосов
/ 24 июня 2018

Идея

  • index1 - индекс в цикле при создании замыкания
  • index2 - индекс выполненной операции в контейнере

Вам необходимо создать контейнер с замыканиями.Этот контейнер сохранит все замыкания.Контейнер проверит, выполняет ли index1 == index2 все операции до index1 и после if index1 + 1 > exist.

. Таким образом, этот контейнер будет проверять порядок полученных замыканий и запускать замыкания одну за другой в порядке возрастания..

Подробности

Xcode 9.4.1, Swift 4.1

Контейнер 

class ActionsRunController {

    typealias Func = ()->()
    private var actions: [Int: Func] = [:]
    private var dispatchSemaphore = DispatchSemaphore(value: 1)
    private var firstIndex = 0
    private var lastIndex = 0

    func add(at index: Int, action: Func?) {
        dispatchSemaphore.wait()
        actions[index] = action
        if lastIndex == index {
            while (actions[firstIndex] != nil) {
                actions[firstIndex]?()
                actions[firstIndex] = nil
                firstIndex += 1
            }
            lastIndex = firstIndex
        }
        dispatchSemaphore.signal()
    }
}

Полный код

Не делатьзабудьте добавить код Контейнера здесь 

import UIKit
import Alamofire
import SwiftyJSON

class ViewController: UIViewController {

    let dispatchGroup = DispatchGroup()

    var weatherServiceURL = "http://samples.openweathermap.org/data/2.5/weather?q=London,uk&appid=b6907d289e10d714a6e88b30761fae22"

    override func viewDidLoad() {
        super.viewDidLoad()
        start()
    }

    func start() {
        weatherService()
        dispatchGroup.notify(queue: .main) {
            print("All services complete")
        }
    }

    func weatherService() {
        for i in 0...9 {
            dispatchGroup.enter()
            APIManager.apiGet(serviceName: self.weatherServiceURL, counter: i) { (response:JSON?, error:NSError?, count:Int) in
                if let error = error {
                    print(error.localizedDescription)
                    return
                }
                //guard let response = response else { return }
                print("[executed] action \(count)")
                self.dispatchGroup.leave()
            }
        }
    }
}

class APIManager: NSObject {

    private static let actionsRunController = ActionsRunController()

    class func apiGet(serviceName:String, counter:  Int, completionHandler: @escaping (JSON?, NSError?, Int) -> ()) {
        Alamofire.request(serviceName, method: .get, parameters: nil, encoding: URLEncoding.default, headers: nil).responseJSON { (response:DataResponse<Any>) in

            //print("[created] action \(counter)")
            switch(response.result) {
            case .success(_):
                if let data = response.result.value{
                    let json = JSON(data)
                    actionsRunController.add(at: counter) {
                        completionHandler(json, nil, counter)
                    }
                }
                break

            case .failure(_):
                actionsRunController.add(at: counter) {
                    completionHandler(nil,response.result.error as NSError?, counter)
                }
                break
            }
        }
    }
}

Результат

enter image description here

0 голосов
/ 06 мая 2019

Вместо того чтобы сохранять замыкания, я решил обернуть все в очередь отправки и использовать внутри нее семафоры 

//Create a dispatch queue 
let dispatchQueue = DispatchQueue(label: "myQueue", qos: .background)

//Create a semaphore
let semaphore = DispatchSemaphore(value: 0)

func weatherService() {

    dispatchQueue.async {
        for i in 1...10 {
            APIManager.apiGet(serviceName: self.weatherServiceURL, parameters: ["counter":i]) { (response:JSON?, error:NSError?, count:Int) in
                if let error = error {
                    print(error.localizedDescription)
                    return
                }
                guard let response = response else { return }
                //print("\n\(response) \n\(count) response\n")
                print("\(count) ")

                //Check by index, the last service in this case
                if i == 10 {
                    print("Services Completed")
                }

                //Signals free on service return to work for next service
                self.semaphore.signal()
            }

            //Wait till the service returns
            self.semaphore.wait()
        }
    }
    print("Start Fetching")
}

Вывод это всегда

enter image description here

0 голосов
/ 24 июня 2018

Самый простой способ получить вызовы API, сделанные по порядку, - это выполнить «следующий» вызов в обработчике завершения предыдущего, а не использовать цикл for вне вызовов API. 

func weatherService(counter: Int = 1, maxCount: Int = 10) {
    guard counter <= maxCount else {
        return
    }
    dispatchGroup.enter()
    APIManager.apiGet(serviceName: self.weatherServiceURL, parameters: ["counter":i]) { (response:JSON?, error:NSError?, count:Int) in
            self.weatherService(counter: counter+1, maxCount: maxCount)
            if let error = error {
                print(error.localizedDescription)
                self.dispatchGroup.leave()
                return
            }
            guard let response = response else {
                self.dispatchGroup.leave()
                return 
            }
            print("\n\(response) \n\(count) response\n")
            self.dispatchGroup.leave()
        }
    }
}

Я бы посоветовал против этого, хотя, если не существует какой-либо зависимости от порядка (т.е. для вызова номер 2 требуется информация из результата вызова 1), потому что это займет больше времени, чем параллельные запросы.

Было бы гораздо лучше учитывать тот факт, что результаты могут возвращаться не в порядке.

Кроме того, при использовании группы рассылки вам необходимо убедиться, что вы звоните dispatchGroup.leave во всех случаях, когда код завершается;в вашем случае вы этого не делаете в случае возникновения ошибки.Это приведет к тому, что dispatchGroup.notify никогда не сработает, если в одном или нескольких запросах произойдет ошибка.

...