接下來我來介紹一下我的PB封裝方法的使用,我感覺我頭一次接觸這個的時候非常蛋疼取胎，就是很抵觸挠进，因為以前的都是的AF的網(wǎng)絡(luò)封裝边锁，但是我又學(xué)到了新的技術(shù)矾麻，弄懂之后還是有成就感的纱耻。以下是我的代碼粘貼，大家有不懂得可以隨時給我险耀，在我閑暇時間會給解答的弄喘。
#pragma mark - 獲取數(shù)據(jù)
- (void)getData{
NSUserDefaults *defaults = [NSUserDefaults standardUserDefaults];
NSString *subServerUrl = [defaults objectForKey:@"subURL"];//http://192.168.0.36:8181//api/Department
//我以前做的時候傳的是一個實體類參數(shù)NSData *data =[token req]就可以了，可是后來后臺讓我傳兩個實體甩牺，我想那也挺好做蘑志，用數(shù)據(jù)輸出流轉(zhuǎn)化成一個data就好了，但是沒有成功（后臺無法將這一個data轉(zhuǎn)化成兩個data）贬派。這回可難住我了急但，怎么是好，百度無望搞乏，就是我這邊想辦法以分割的方式傳data波桩，我就大膽的在谷歌的第三方里加了一段代碼，結(jié)果好使了请敦。在最下面我給出了加的代碼镐躲。
//一個實體
UToken *token = [[[[[UToken builder] setToken:[defaults objectForKey:@"token"]] setUid:[[defaults objectForKey:@"uid"] intValue]] setMethodName:@"DepartmentALL"] build];
//兩個實體
DepartmentListReq *req = [[[[DepartmentListReq builder] setDepId:0] setIsShowMember:YES] build];
NSOutputStream* rawOutput = [NSOutputStream outputStreamToMemory];
[rawOutput open];
[token writeDelimitedToOutputStream:rawOutput];
[req writeDelimitedToOutputStream:rawOutput];
NSData* data = [rawOutput propertyForKey:NSStreamDataWrittenToMemoryStreamKey];
[PBHttpMethod postDataByString:[subServerUrl stringByAppendingString:@"Department"] BODYData:data WithDataBlock:^(id data) {
DepartmentListRes *res = [DepartmentListRes parseFromData:data];
_companyName = res.cmpInfo.name;
[_userdefaults setObject:res.cmpInfo.name forKey:@"companyName"];
//切記這里加上主線程要不UI界面無法更新（其實這也是個坑）
dispatch_async(dispatch_get_main_queue(), ^{
//這里我用了CoreData的本地化存儲储玫，用不到可以不刁它。
NSFetchRequest *fetchRequest = [NSFetchRequest fetchRequestWithEntityName:@"Dep"];
NSArray *allList = [_manager.managedObjectContext executeFetchRequest:fetchRequest error:nil];
_dataDepArray = [NSMutableArray arrayWithArray:allList];
for (_dep in _dataDepArray) {
[_manager.managedObjectContext deleteObject:_dep];
[_manager saveContext];
}
NSFetchRequest *fetchRequest1 = [NSFetchRequest fetchRequestWithEntityName:@"Member"];
NSArray *allList1 = [_manager.managedObjectContext executeFetchRequest:fetchRequest1 error:nil];
for (_member in allList1) {
[_manager.managedObjectContext deleteObject:_member];
[_manager saveContext];
}
for (DepRow *deprow in res.depList) {
_dep = [NSEntityDescription insertNewObjectForEntityForName:@"Dep" inManagedObjectContext:_manager.managedObjectContext];
_dep.iD = [NSNumber numberWithInt:deprow.id];
_dep.name = deprow.name;
_dep.pid = [NSNumber numberWithInt:deprow.pid];
_dep.isChild = [NSNumber numberWithBool:deprow.isChild];
_dep.memberCount = deprow.memberCount;
[_manager saveContext];
// NSLog(@"------%@", _dep.name);
}
for (MemberInfoRes *memres in res.memberList) {
_member = [NSEntityDescription insertNewObjectForEntityForName:@"Member" inManagedObjectContext:_manager.managedObjectContext];
_member.pid = memres.depId;
_member.name = memres.name;
_member.mobile = memres.mobile;
_member.sex = memres.sex;
_member.post = memres.post;
_member.email = memres.email;
_member.phone = memres.phone;
_member.headPoto = memres.headPoto;
_member.depName = memres.depName;
_member.iD = memres.id;
NSLog(@"->>>>><<<%@", memres.headPoto);
[_manager saveContext];
}
[_userdefaults setObject:@"1" forKey:@"iSContract"];
[self updateUI];
[_tableView.mj_header endRefreshing];
[_tableView.mj_footer endRefreshing];
});
} WithResponseBlock:^(NSURLResponse *response) {
NSHTTPURLResponse* httpResponse = (NSHTTPURLResponse*)response;
NSInteger responseStatusCode = [httpResponse statusCode];
if (responseStatusCode != 200) {
dispatch_async(dispatch_get_main_queue(), ^{
if (responseStatusCode == 0) {
DXAlertView *alert = [[DXAlertView alloc]initWithTitle:@"提示" contentText:[NSString stringWithFormat:@"網(wǎng)絡(luò)請求失敗匀油，請檢查網(wǎng)絡(luò)"] leftButtonTitle:nil rightButtonTitle:@"確定"];
[alert show];
[_tableView.mj_header endRefreshing];
alert.leftBlock = ^() {
NSLog(@"left button clicked");
};
}else{
DXAlertView *alert = [[DXAlertView alloc]initWithTitle:@"提示" contentText:[NSString stringWithFormat:@"服務(wù)器異常缘缚，請稍后再試"] leftButtonTitle:nil rightButtonTitle:@"確定"];
[alert show];
[_tableView.mj_header endRefreshing];
alert.leftBlock = ^() {
NSLog(@"left button clicked");
};
}
});
}
} WithErroBlock:^(NSError *error) {
if (error) {
dispatch_async(dispatch_get_main_queue(), ^{
DXAlertView *alert = [[DXAlertView alloc]initWithTitle:@"提示" contentText:[NSString stringWithFormat:@"解析失敗，請稍后再試"] leftButtonTitle:nil rightButtonTitle:@"確定"];
[alert show];
[_tableView.mj_header endRefreshing];
alert.leftBlock = ^() {
NSLog(@"left button clicked");
};
});
}
}];
}
** 我做的時候第三方里沒有數(shù)據(jù)輸出流分割傳數(shù)據(jù)的方法敌蚜，久思苦想在Protocol Buffer的 **
AbstractMessage.m文件里添加了如下方法后好使了：
- (void) writeToOutputStream:(NSOutputStream*) output {
PBCodedOutputStream* codedOutput = [PBCodedOutputStream streamWithOutputStream:output];
[self writeToCodedOutputStream:codedOutput];
[codedOutput flush];
}
- (void) writeDelimitedToOutputStream:(NSOutputStream *)output
{
int serialized = [self serializedSize];
PBCodedOutputStream* codedOutput = [PBCodedOutputStream streamWithOutputStream:output];
[codedOutput writeRawVarint32:serialized];
[self writeToCodedOutputStream:codedOutput];
[codedOutput flush];
}
