与后台协定的网络规则:
1.协议 http(Content-Encoding gzip)
2.方式 post
3.格式 JSON
基础请求数据
@interface BaseRequestData : NSObject
@property (nonatomic, copy) NSString *uid;
@property (nonatomic, copy) NSString *devicetype;
@property (nonatomic, copy) NSString *version;
@property (nonatomic, copy) NSString *brand;
@property (nonatomic, copy) NSString *model;
@property (nonatomic, copy) NSString *sysversion;
@end
基础返回数据中规定了一些错误码 状态 等 这里忽略
BaseRequestAction 基础请求的主要内容
这里定义了两个方法urlWithProtocolStr只是用于拼接接口名。rac_commandWithRequestUrl就是网络请求的基础类。选择了RACCommand以防止信号的重复分发订阅，进行多次无意义的请求。
@interface BaseRequestAction : NSObject
//--------------------------------------------------------------------------------
//
// Description - 基础数据请求
// Para - 1.(NSString) urlStr，请求地址
// Return - RACCommand
// Author - Barney
//
+ (RACCommand *)rac_commandWithRequestUrl:(NSString *)urlStr;
//--------------------------------------------------------------------------------
//--------------------------------------------------------------------------------
//
// Description - url拼接
// Para - (NSString) proStr，接口名
// Return - NSString
// Author - Barney
//
+ (NSString *)urlWithProtocolStr:(NSString *)proStr;
//--------------------------------------------------------------------------------
@end
实现方法：
+ (RACCommand *)rac_commandWithRequestUrl:(NSString *)urlStr {
return [[RACCommand alloc] initWithSignalBlock:^RACSignal *(NSDictionary *parameters) {
return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
manager.requestSerializer = [AFJSONRequestSerializer serializer];
manager.responseSerializer.acceptableContentTypes = [NSSet setWithObject:@"application/json"];
[manager.requestSerializer setValue:@"gzip"
forHTTPHeaderField:@"Content-Encoding"];
[manager POST:urlStr
parameters:parameters
progress:^(NSProgress * _Nonnull uploadProgress) {
} success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) {
// 异常处理
BaseResponseData *data = [BaseResponseData mj_objectWithKeyValues:responseObject];
if (RESPONSE_STATUS_FAILED == data.status) {
if (RESPONSE_ERRORCODE_1044 == data.errorinfo.errcode) {// errcode1044 需要强制把用户踢下线
[self needClearLoginInfo];
[self needLogin];
}
// 主动 error
[subscriber sendError:nil];
}else {
[subscriber sendNext:responseObject];
[subscriber sendCompleted];
}
} failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
// 请求错误
[subscriber sendError:error];
}];
return [RACDisposable disposableWithBlock:^{
// block 调用时刻：当信号发送完成或者发送错误，就会自动执行这个block,取消订阅信号。
// 执行完block后，当前信号就不再被订阅了。
NSLog(@"signal disposed!");
}];
}];
}];
}
这里在 AFHTTPSessionManager 请求的成功中发送消息并完成
[subscriber sendNext:responseObject];
[subscriber sendCompleted];
在失败中发送 error
[subscriber sendError:error];
至此主要的基础请求就封装完毕了，主要思路就是使用RACCommand将请求数据进行包装，分发，成为可订阅的信号。
使用：
+ (RACSignal *)rac_signalRequestWithTel:(NSString *)telStr
withPsd:(NSString *)psdStr {
// 拼接url
NSString *urlStr = [self urlWithProtocolStr:LOGIN_REQUEST_PROTOCOL];
// 传输进来的参数转成 request 数据模型
LoginRequestData *reqData = [[LoginRequestData alloc] init];
reqData.tel = telStr;
reqData.psd = psdStr;
// 拼接请求 parameters
NSDictionary *parameters = [reqData mj_keyValues];
// 请求
return [[[self rac_commandWithRequestUrl:urlStr] execute:parameters] map:^id _Nullable(id responseObject) {
// 映射为理想数据模型
return [LoginResponseData mj_objectWithKeyValues:responseObject];
}];
}
上面都是一些请求入参的拼接，真正重要的这有下面这句。目的是将请求返回的数据转换为可用的数据模型（用了小码哥的第三方库）并返回一个RACSignal
return [[[self rac_commandWithRequestUrl:urlStr] execute:parameters] map:^id _Nullable(id responseObject) {
// 映射为理想数据模型
return [LoginResponseData mj_objectWithKeyValues:responseObject];
}];
这样我们在写一个请求的时候就很方便了，例如：
[[LoginRequestAction rac_signalRequestWithTel:@"123"
withPsd:@"123"] subscribeNext:^(LoginResponseData *data) {
// 请求返回的数据 LoginResponseData
}];
接触 RAC 的时间不长，还请各路大神指导。
