Besser asynchrone Ablaufsteuerung mit Objective-C blocks

Ich bin mit AFNetworking für asynchrone Aufrufe an eine web service. Einige dieser Aufrufe müssen in Reihe geschaltet werden, wobei die Ergebnisse von call-A-by-call B die verwendet werden, durch aufrufen von C, etc.

AFNetworking Griffe Ergebnisse der asynchronen Aufrufe mit Erfolg/Misserfolg Blöcke auf die Zeit der operation erstellt:

NSURL *url = [NSURL URLWithString:@"http://api.twitter.com/1/statuses/public_timeline.json"];
NSURLRequest *request = [NSURLRequest requestWithURL:url];
AFJSONRequestOperation *operation = [AFJSONRequestOperation JSONRequestOperationWithRequest:request success:^(NSURLRequest *request, NSHTTPURLResponse *response, id JSON) {
    NSLog(@"Public Timeline: %@", JSON);
} failure:nil];
[operation start];

Diese Ergebnisse in geschachtelte async-Aufruf blockiert schnell unlesbar wird. Es ist sogar noch komplizierter, wenn die Aufgaben nicht voneinander abhängig, sondern müssen parallel ausgeführt werden und die Ausführung hängt von den Ergebnissen aller Vorgänge.

Es scheint, dass der bessere Ansatz wäre die Nutzung einer verspricht framework zu bereinigen, die Ablaufsteuerung.

Denen ich begegnet bin MAFuture aber kann nicht herausfinden, wie man am besten zu integrieren, Sie mit AFNetworking. Da der asynchrone Aufrufe könnten mehrere Ergebnisse (Erfolg/Misserfolg) und nicht über eine return-Wert es scheint nicht, wie eine ideale Passform.

Irgendwelche Hinweise oder Ideen würde geschätzt.

Vielen Dank für diese Frage – Sie haben einige gute Antworten. Ich hatte ein wenig Mühe, es zu finden, zunächst aber, und habe hier über die Suche zu Versprechen. Dieses anti-pattern passieren kann, für alle asynchronen callback-API: es ist nicht AFNetworking bestimmten. Ich wurde durch eine Suche so etwas wie: "serialising verschachtelten block Rückrufe". Vielleicht ein paar mehr tags helfen könnte? Es könnte nur sein, mich aber! 🙂

InformationsquelleAutor bromanko | 2012-06-06

10

Ich noch nicht benutzt, aber es klingt wie Reaktive Kakao wurde entworfen, um zu tun genau das, was Sie beschreiben.
- Ich habe es verwendet, und Jon hat Recht. es ist ideal für genau diese Art der Sache.
- Interessant. Ich würde kommen über Reaktive Kakao aber nicht, halten es für dieses Szenario. Da die AF-Operationen sind alle KVO konform, ich könnte Handler hinzuzufügen, um entweder den Betrieb der Warteschlange oder den einzelnen Operationen. Ich werde Zohan an, dass.
- Ich mag die ReactiveCocoa Ansatz. Meine blog Artikel erklärt, wie Sie mit ReactiveCocoa für diesen Zweck.
InformationsquelleAutor Jon Reid
19

Erstellte ich eine leichte Lösung für dieses. Es nennt sich Sequenzer und es ist bis auf github.

Macht es chaining-API-Aufrufe (oder jedem anderen async-code) einfach und unkompliziert.

Hier ist ein Beispiel für die Verwendung von AFNetworking mit:
```
Sequencer *sequencer = [[Sequencer alloc] init];

[sequencer enqueueStep:^(id result, SequencerCompletion completion) {
    NSURL *url = [NSURL URLWithString:@"https://alpha-api.app.net/stream/0/posts/stream/global"];
    NSURLRequest *request = [NSURLRequest requestWithURL:url];
    AFJSONRequestOperation *operation = [AFJSONRequestOperation JSONRequestOperationWithRequest:request success:^(NSURLRequest *request, NSHTTPURLResponse *response, id JSON) {
        completion(JSON);
    } failure:nil];
    [operation start];
}];

[sequencer enqueueStep:^(NSDictionary *feed, SequencerCompletion completion) {
    NSArray *data = [feed objectForKey:@"data"];
    NSDictionary *lastFeedItem = [data lastObject];
    NSString *cononicalURL = [lastFeedItem objectForKey:@"canonical_url"];

    NSURLRequest *request = [NSURLRequest requestWithURL:[NSURL URLWithString:cononicalURL]];
    AFHTTPRequestOperation *operation = [[AFHTTPRequestOperation alloc] initWithRequest:request];
    [operation setCompletionBlockWithSuccess:^(AFHTTPRequestOperation *operation, id responseObject) {
        completion(responseObject);
    } failure:nil];
    [operation start];
}];

[sequencer enqueueStep:^(NSData *htmlData, SequencerCompletion completion) {
    NSString *html = [[NSString alloc] initWithData:htmlData encoding:NSUTF8StringEncoding];
    NSLog(@"HTML Page: %@", html);
    completion(nil);
}];

[sequencer run];
```
- Das ist eine schöne saubere, einfache Lösung. Vielen Dank für das teilen.
- Sieht aus wie im Fall eines Fehlers in Schritt 1 oder 2, die restlichen Schritte nicht ausgeführt werden.
- Ich glaube, dass das auch das gewünschte Ergebnis hier – es ist sicherlich der Effekt, den ich erzielen will.
- Wie werden Fehler behandelt, dann?
- Im Beispiel-code oben, nil übergeben wird, die das Versagen blockiert, so dass Fehler werden stillschweigend ignoriert (aber Fehler do führen Sie den sequencer zu stoppen und entsorgt werden, denn nichts fordert den nächsten Schritt). In meinem code habe ich eine Fehler-handler-block zur Verfügung, um die Funktion, die ausgeführt wird, die Sequencer. Ich pass dieser Fehler-handler anstelle der nil. Wenn es wird ein Fehler ist, ich will nicht die verbleibenden Schritte ausführen. Ich will die Fehler-block rief sofort dort an und der Sequenzer wird einfach weggeworfen am Ausgangspunkt erreicht.
- Ok, also Sequencer ist ein "halb" ist die Umsetzung eines Versprechens dann?
- Ich bin mir nicht sicher, was für eine Verheißung ist, um ehrlich zu sein. Die Sequenzer hier ist wirklich nur (buchstäblich) eine Warteschlange von Aufgaben, die Sie ausführen möchten. Seine wichtigsten Bequemlichkeiten sind, dass es "denkt" was ist die nächste Aufgabe für Euch (durch knallende es aus der Vorderseite der Warteschlange), und stellt eine einfache Schnittstelle zum übergeben eines Parameters zum nächsten Schritt.
- Ich mag diese Lösung sehr. In meinem code, wie bereits mit @fabb, ich habe einen einzigen Fehler-handler-block kann ich übergeben, um asynchrone Aufrufe, wo nötig (oder ich einpacken kann, wenn die Anrufe haben eine andere Fehlermeldung-block-Schnittstelle). Ein "Tipp" für die übergabe von Daten mehr weiterleiten, um die künftigen Schritte. Manchmal haben Sie Daten, die Sie brauchen, um nach vorne gehen mehrere Schritte. Eine saubere und einfache Möglichkeit, dies zu erreichen, ist zu erklären __block variable vor ein Schritt (in Funktionsumfang), weisen Sie im ein Schritt, und Verwendung die variable, die in einem zukünftigen Schritt.
- Ich empfehle Ihnen, lernen über verspricht. Es gibt 2 sehr gute iOS-Bibliotheken, die ich kenne, die haben auch exzellente Dokumentation und Einführung von Versprechen: github.com/couchdeveloper/RXPromise und promisekit.org
- Lassen Sie uns weiter, diese Diskussion im chat.
- Wie es scheint, Sequenzer, erlaubt nur die Wasserfall-wie steuert und nicht anpassbar für die Dinge parallel.
InformationsquelleAutor Tal Bereznitskey
10

Es war nicht ungewöhnlich, dass bei der Verwendung von AFNetworking in Gowalla Anrufe verkettet Erfolg blockiert.

Mein Rat wäre, um den Faktor der Netzwerk-Anfragen und serialisierungen, wie gut Sie können in die Klasse der Methoden, die in Ihrem Modell. Dann, für Anfragen, die brauchen, um sub-requets, Sie rufen kann, auch diejenigen Methoden, die den Erfolg blockieren.

Auch im Fall, dass Sie nicht verwenden es bereits, AFHTTPClient vereinfacht diese Art von komplexen Netzwerk von Interaktionen.
- Danke @mattt. Das ist im Grunde das, was ich jetzt mache. Die verschachtelte Blöcke müssen nur einen Einblick code smell. Es ist der gleiche Geruch, den ich bekommen mit tief verschachtelten bedingten Logik. Vielleicht bin ich Sehnsucht für einige der Sauberkeit, die node.js und andere Javascript-frameworks bieten, für mehr lesbar funktionale Programmierung.
- Die Tiefe Verschachtelung ist nicht eine inhärente Ergebnis dieses Ansatzes-durch effektiv factoring-Rückrufe in Ihre eigenen Methoden, es sollte noch viel mehr freuen, wie die Verkettung in einer funktionalen Sprache. Mit tiefer zu gehen, als zwei geschachtelte Aufrufe ist definitiv ein Geruch, aber, und es bedeutet wahrscheinlich, dass Sie sollten in Betracht ziehen, erstellen Sie eine neue API-Aufruf zu bekommen, was Sie brauchen, alles auf einmal (wenn das in deiner macht)
InformationsquelleAutor mattt
6

PromiseKit nützlich sein könnte. Es scheint eines der beliebtesten Versprechen Implementierungen, und andere geschrieben haben Kategorien zu integrieren, Sie mit Bibliotheken wie z.B. AFNetworking, siehe PromiseKit-AFNetworking.

InformationsquelleAutor jeffmax
4

Gibt es ein Objective-C-Implementierung von CommonJS-Stil verspricht hier auf Github:

https://github.com/mproberts/objc-promise

Beispiel (aus der Readme-Datei.md)
```
Deferred *russell = [Deferred deferred];
Promise *promise = [russell promise];

[promise then:^(NSString *hairType){
    NSLog(@"The present King of France is %@!", hairType);
}];

[russell resolve:@"bald"];

//The present King of France is bald!
```
Ich noch nicht versucht, aus dieser Bibliothek, aber es sieht 'vielversprechend' trotz dieses etwas unglücklich Beispiel. (sorry, ich konnte nicht widerstehen).
- Wie es aussieht, könnte sehr nützlich sein, aber es ist nicht ARC-kompatibel ist und ich nicht das nötige kleingeld zu machen, so dass {seufz}.
- Diese verpflichten, scheint es geschafft zu haben ARC-kompatibel: github.com/mproberts/objc-promise/commit/...
InformationsquelleAutor Ben Clayton

Kombinieren Sie NSBlockOperation mit semaphore zu erreichen:

- (void)loadDataByOrderSuccess:(void (^)(void))success failure:(void (^)(void))failure {
    //first,load data1
    NSBlockOperation * operation1 = [NSBlockOperation blockOperationWithBlock:^{
        dispatch_semaphore_t sema = dispatch_semaphore_create(0);
        [self loadData1Success:^{
            dispatch_semaphore_signal(sema);
        } failure:^{
            !failure ?: failure();
        }];
        dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
    }];
    //then,load data2
    NSBlockOperation * operation2 = [NSBlockOperation blockOperationWithBlock:^{
        dispatch_semaphore_t sema = dispatch_semaphore_create(0);
        [self loadData2Success:^{
            dispatch_semaphore_signal(sema);
        } failure:^{
            !failure ?: failure();
        }];
        dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
    }];
    //finally,load data3
    NSBlockOperation * operation3 = [NSBlockOperation blockOperationWithBlock:^{
        dispatch_semaphore_t sema = dispatch_semaphore_create(0);
        [self loadData3Success:^{
            dispatch_semaphore_signal(sema);
        } failure:^{
            !failure ?: failure();
        }];
        dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
        !success ?: success();
    }];
    [operation2 addDependency:operation1];
    [operation3 addDependency:operation2];
    NSOperationQueue * queue = [[NSOperationQueue alloc] init];
    [queue addOperations:@[operation1, operation2, operation3] waitUntilFinished:NO];
}

InformationsquelleAutor 无夜之星辰

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.