利用 RAC 封装网络请求

与后台协定的网络规则:
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 的时间不长，还请各路大神指导。