代码地址https://github.com/chenwei007/AFN-.git
中心化的设计思想,代码简洁
统一配置服务器地址,公共参数,实时变动的公共参数进行配置,可以针对单独的请求配置服务器
可以控制请求的频率,适用于减轻服务器压力,避免用户短时间内重复请求.并可以设置到时间后是否继续请求.
可以取消已经发送未返回的请求.
请求失败后是否再次请求
DQRequestConfig 模型类,网络请求通用的数据,比如服务器地址,回调线程,固定的公共参数,动态调整的公共参数
DQRequestItem 模型类,定义了网络请求模型,讲每次请求封装为对象,交给DQRequestCenter类来处理.
DQRequestCenter 工具类,负责对模型进行预处理(路径拼接,网络监测,请求频率监测),对请求结果处理(请求成功后特殊的处理,错误的统一处理).
DQRequestEngine 工具类,直接操作AFHTTPSessionManager,发送请求.
在DQRequestCenter类中,持有一个pool形式的NSMutableDictionary , 每次收到发送的请求以keyValue的形势将请求的url和一下次允许请求的时间存起来.下次调用前对pool进行检测是否允许请求,当未满足请求时间时,是否等待到时候再发送请求.并通过定时器轮询的方式对pool内的键值对进行筛选,移除超时的keyValue.
//第一,设置服务器配置地址和公共参数（也可以在DQRequestCenter中设置）
[DQRequestCenter setupConfig:^(DQRequestConfig * _Nonnull config) {
// 服务器地址
config.generalServer = @"http://www.baidu/"; //此处大家自己弄一下服务器地址
config.generalParameters = @{
// 不会发生变化的公共参数
@"channel":@"ios",
@"osVersion":[[UIDevice currentDevice] systemVersion],
@"version":[[NSBundle mainBundle] infoDictionary][@"CFBundleShortVersionString"],
@"imei":[[UIDevice currentDevice].identifierForVendor UUIDString],
};
}];
//第二发送一个请求，并设置接口路径（在这里设置频繁请求的间隔，请求失败重新请求的次数）
[DQRequestCenter sendRequest:^(DQRequestItem * _Nonnull item) {
item.api = @"system/getNoticeList.do";
item.requestInterval = 5; //间隔
item.retryCount = 3; //重复请求的次数
} onSuccess:^(id _Nullable responseObject) {
PTTLog(@"success = %@",responseObject);
} onFailure:^(NSError * _Nullable error) {
PTTLog(@"success = %@",error);
} onFinished:^(id _Nullable responseObject, NSError * _Nullable error) {
//不论成功或失败都会,如果成功error = nil 如果失败responseObject = nil
PTTLog(@"success = %@---%@",responseObject,error);
}];
// 第三种，取消已经发送的网络请求
NSString *identifier = [DQRequestCenter sendRequest:^(DQRequestItem * _Nonnull item) {
item.api = @"system/getNoticeList.do";
} onSuccess:^(id _Nullable responseObject) {
PTTLog(@"success = %@",responseObject);
} onFailure:^(NSError * _Nullable error) {
PTTLog(@"success = %@",error);
} onFinished:^(id _Nullable responseObject, NSError * _Nullable error) {
//不论成功或失败都会,如果成功error = nil 如果失败responseObject = nil
PTTLog(@"success = %@---%@",responseObject,error);
}];
[DQRequestCenter cancelRequest:identifier onCancel:^{
//取消完成后
}];
代码查看引导
一，同步进行任务，要等请求发出后，afn分配identifier后，在返回identifier
二， 给DQRequestItem设置参数
三，检查网络状态
四，做频繁请求的处理
五，进入DQRequestEngine，调用afn，进行网络请求
- (void)dataTaskWithRequest:(DQRequestItem *)item completionHandler:(DQCompletionHandler)completionHandler
{
NSString *httpMethod = (item.httpMethod == kDQHTTPMethodPOST) ? @"POST" : @"GET";
AFHTTPRequestSerializer *requestSerializer = [self getRequestSerializer:item];
NSError *serializationError = nil;
// 拼接参数后，得到NSMutableURLRequest，用以网络请求
NSMutableURLRequest *urlRequest = [requestSerializer requestWithMethod:httpMethod URLString:item.url parameters:item.parameters error:&serializationError];
if (serializationError) {
if (completionHandler) {
dispatch_async(request_Completion_Callback_Queue(), ^{
completionHandler(nil, serializationError);
});
}
return;
}
urlRequest.timeoutInterval = item.timeoutInterval;
NSURLSessionDataTask *dataTask = nil;
__weak __typeof(self)weakSelf = self;
// 进行网络请求
dataTask = [self.sessionManager dataTaskWithRequest:urlRequest completionHandler:^(NSURLResponse * _Nonnull response, id _Nullable responseObject, NSError * _Nullable error) {
__strong __typeof(weakSelf)strongSelf = weakSelf;
// 对返回的结果做处理
[strongSelf processResponse:response object:responseObject error:error requestItem:item completionHandler:completionHandler];
}];
//获取一个网络请求的管理者 dataTask，一次网络请求的信息都在这里
NSString *identifier = [NSString stringWithFormat:@"%lu",(unsigned long)dataTask.taskIdentifier];
[item setValue:identifier forKey:@"_identifier"];
[dataTask bindingRequestItem:item];
[dataTask resume];
}
网友评论