場(chǎng)景描述:我們同時(shí)發(fā)出了a、b、c 3個(gè)網(wǎng)絡(luò)請(qǐng)求,我們希望在a、b、c 3個(gè)網(wǎng)絡(luò)請(qǐng)求都結(jié)束的時(shí)候獲得一個(gè)通知。
常見解決方法:通過度娘目前找到兩種做法;1、通過添加標(biāo)識(shí)來判斷請(qǐng)求是否全部結(jié)束 2、dispatch_group + 信號(hào)量
1、添加標(biāo)識(shí)的解決方法
在遇到這個(gè)問題時(shí)首先想到了唐巧大大的猿題庫團(tuán)隊(duì)開源的網(wǎng)絡(luò)框架ytknetwork,然后閱讀源碼發(fā)現(xiàn)ytknetwork是通過添加標(biāo)識(shí)來實(shí)現(xiàn)網(wǎng)絡(luò)請(qǐng)求的批量請(qǐng)求處理;
話不多說直接上代碼在ytknetwork里負(fù)責(zé)進(jìn)行網(wǎng)絡(luò)批處理請(qǐng)求的是ytkbatchrequest類,下面看下它的使用示例:
ytkbatchrequest *batchrequest = [[ytkbatchrequest alloc] initwithrequestarray:@[a, b, c, d]];
先調(diào)用初始化方法把4個(gè)網(wǎng)絡(luò)請(qǐng)求的實(shí)例塞進(jìn)去,看下這個(gè)初始化方法
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
- (id)initwithrequestarray:(nsarray )requestarray { self = [super init]; if (self) { _requestarray = [requestarray copy]; _finishedcount = 0; for (ytkrequest req in _requestarray) { if (![req iskindofclass:[ytkrequest class ]]) { ytklog(@ "error, request item must be ytkrequest instance." ); return nil; } } } return self; } |
我們看到有一個(gè)_finishedcount的變量根據(jù)字面很好理解是用來記錄請(qǐng)求完成的個(gè)數(shù),然后我們?nèi)炙严逻@個(gè)變量,發(fā)現(xiàn)只有在下面的這個(gè)方法中用到了這個(gè)變量
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
- ( void )requestfinished:(ytkrequest *)request { _finishedcount++; if (_finishedcount == _requestarray.count) { [self toggleaccessorieswillstopcallback]; if ([_delegate respondstoselector:@selector(batchrequestfinished:)]) { [_delegate batchrequestfinished:self]; } if (_successcompletionblock) { _successcompletionblock(self); } [self clearcompletionblock]; [self toggleaccessoriesdidstopcallback]; [[ytkbatchrequestagent sharedinstance] removebatchrequest:self]; } } |
上述方法是網(wǎng)絡(luò)請(qǐng)求結(jié)束的回調(diào)代理方法,完成后_finishedcount計(jì)數(shù)加1,然后和保存網(wǎng)絡(luò)請(qǐng)求實(shí)例的數(shù)組元素個(gè)數(shù)進(jìn)行比較如果相等說明所有的請(qǐng)求都已經(jīng)完成,調(diào)用回調(diào)的代理方法及block請(qǐng)求結(jié)束。
然后ytknetwork對(duì)于批量網(wǎng)絡(luò)請(qǐng)求失敗的處理是,只要一個(gè)失敗就立即停止請(qǐng)求,調(diào)用失敗回調(diào):
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
- ( void )requestfailed:(ytkrequest )request { [self toggleaccessorieswillstopcallback]; // stop for (ytkrequest req in _requestarray) { //遍歷請(qǐng)求實(shí)例數(shù)組 [req stop]; //停止請(qǐng)求 } // callback //回調(diào) if ([_delegate respondstoselector:@selector(batchrequestfailed:)]) { [_delegate batchrequestfailed:self]; } if (_failurecompletionblock) { _failurecompletionblock(self); } // clear [self clearcompletionblock]; [self toggleaccessoriesdidstopcallback]; [[ytkbatchrequestagent sharedinstance] removebatchrequest:self]; } |
總結(jié):ytknetwork的做法大致就是用一個(gè)變量記錄完成請(qǐng)求的個(gè)數(shù),然后在單個(gè)網(wǎng)絡(luò)請(qǐng)求結(jié)束回調(diào)的時(shí)候判斷當(dāng)前完成的網(wǎng)絡(luò)請(qǐng)求個(gè)數(shù)是否和總的網(wǎng)絡(luò)請(qǐng)求個(gè)數(shù)相等,如果相等則說明請(qǐng)求結(jié)束。
2、dispatch_group + 信號(hào)量
參考文章采用的是group + 信號(hào)量,下面示例采用dispatch_group_enter、dispatch_group_leave實(shí)現(xiàn)詳見 本篇文章demo。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
- ( void )loadrequest1 { dispatch_group_t dispatchgroup = dispatch_group_create(); dispatch_group_enter(dispatchgroup); [malafnmanger getdatawithurl:url1 parameters:nil finish:^(requestresult result) { nslog(@ "第一個(gè)請(qǐng)求完成" ); dispatch_group_leave(dispatchgroup); } des:@ "第一個(gè)url" ]; dispatch_group_enter(dispatchgroup); [malafnmanger getdatawithurl:url2 parameters:nil finish:^(requestresult result) { dispatch_async(dispatch_get_global_queue(0, 0), ^{ sleep(10); //網(wǎng)絡(luò)請(qǐng)求結(jié)束后回調(diào)是在主線程如果sleep放在外面會(huì)阻塞主線程 nslog(@ "第二個(gè)請(qǐng)求完成" ); dispatch_group_leave(dispatchgroup); }); } des:@ "第二個(gè)url" ]; dispatch_group_notify(dispatchgroup, dispatch_get_main_queue(), ^(){ nslog(@ "請(qǐng)求完成" ); }); } |
以上就是本文的全部內(nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持服務(wù)器之家。
原文鏈接:http://www.jianshu.com/p/07eb268c93f2