XMNetworking 网络库的设计与使用

XMNetwoking 是我们团队开源的一个网络库,详见:GitHub

XMNetworking 是一个轻量的、简单易用但功能强大的网络库,基于 AFNetworking 3.0 封装。
其中,XM 前缀是我们团队 Xcode-Men 的缩写。英文文档

简介

XMNetworking.png

如上图所示,XMNetworking 采用中心化的设计思想,由 XMCenter 统一发起并管理所有的 XMRequest 请求,并可通过 XMCenter 给所有请求配置回调线程、公共 Server URL、Header、Parameter 等信息,同时也可以 Block 注入的方式实现自定义的响应结果处理逻辑,如数据模型转换、业务错误码判断、网络缓存等。另外增加了 XMEgine 这一层是为了隔离底层第三方库依赖,便于以后切换其他底层网络库或自己实现底层逻辑。

特性

  • 简单易用,发送请求只需调用一个方法,通过 Block 配置信息,代码紧凑;
  • 功能强大,适用于几乎所有的网络请求使用场景(普通请求、上传、下载);
  • 专为 RESTful Server API 设计,并提供多种不同的请求和响应的序列化类型;
  • 支持批量请求、链式请求等复杂业务逻辑的网络需求;
  • 可随时取消未完成的网络请求,支持自动重试失败的请求;
  • 全局配置所有请求的公共信息,自定义回调线程以及响应处理逻辑;
  • 支持检查网络连接类型,并集成 AFNetworking 强大的安全策略模块。

系统要求

  • iOS 7.0 以上系统
  • Xcode 7.3 或更高版本

安装说明

CocoaPods

在你工程的 Podfile 文件中添加如下一行,并执行 pod installpod update

pod 'XMNetworking'

注意: XMNetworking 已经包含了 AFNetworking 3.1.0 的源代码,所以你工程里的 Podfile 文件不能再添加 pod AFNetworking 去导入 AFNetworking,否则会有冲突!

Carthage (只支持 iOS 8+)

与 CocoaPods 不同的是,Carthage 是一个去中心化的第三方依赖库管理工具,它自动帮你编译所依赖的第三方库并以 framework 形式提供给你。

你可以通过 Homebrew 执行以下命令来安装 Carthage:

$ brew update
$ brew install carthage

成功安装完 Carthage 后,在你工程的 Cartfile 文件中添加如下一行:

github "kangzubin/XMNetworking"

然后执行 carthage update --platform ios 命令生成 framework 包,并把生成的 XMNetworking.framework 拖拽到你的工程中。

注意: XMNetworking 已经包含了 AFNetworking 3.1.0 的源代码,所以你无需通过 Carthage 生成 AFNetworking.framework 导到你工程中,否则会有冲突!

手动安装

下载 XMNetworking 子文件夹的所有内容,并把其中的源文件添加(拖放)到你的工程中。

使用教程

头文件的导入

  • 如果是通过 CocoaPods 或 Carthage 安装,则:
#import <XMNetworking/XMNetworking.h>
  • 如果是手动下载源码安装,则:
#import "XMNetworking.h"

全局网络配置

[XMCenter setupConfig:^(XMConfig *config) {
    config.generalServer = @"general server address";
    config.generalHeaders = @{@"general-header": @"general header value"};
    config.generalParameters = @{@"general-parameter": @"general parameter value"};
    config.generalUserInfo = nil;
    config.callbackQueue = dispatch_get_main_queue();
#ifdef DEBUG
    config.consoleLog = YES;
#endif
}];

你可以调用 XMCenter+setupConfig: 类方法,通过修改传入的 XMConfig 对象来配置全局网络请求的公共信息,包括如下:

  • generalServer: 公共服务端地址,如果一个 XMRequest 请求对象的 server 属性为 nil,且其 useGeneralServerYES(默认),那么该请求的服务端地址 server 将会取 XMCenter 中 generalServer 的值。
  • generalParameters: 公共请求参数,如果一个 XMRequest 请求对象的 useGeneralParameters 属性为 YES(默认),并且 XMCenter 的公共参数 generalParameters 不为空,那么这些公共参数会自动加到该请求的 parameters 中。
  • generalHeaders: 公共请求头,如果一个 XMRequest 请求对象的 useGeneralHeaders 属性为 YES(默认),并且 XMCenter 的公共请求头 generalHeaders 不为空,那么这些公共请求头会自动加到该请求的 headers 中。
  • generalUserInfo: 公共用户信息,默认为 nil,如果一个 XMRequest 请求对象的 userInfo 属性为 nil(默认)而该字段不为 nil,那么该字段会自动赋值给 XMRequest 对象的 userInfo。而 userInfo 属性可用于区分具有相同上下文信息的不同请求。
  • callbackQueue: 请求的回调 Block 执行的 dispatch 队列(线程),如果为 NULL(默认),那么会在一个私有的并发队列(子线程)中执行回调 Block。
  • consoleLog: 一个 BOOL 值,用于表示是否在控制台输出请求和响应的信息,默认为 NO

另外,你可以通过调用 XMCenter 的以下两个类方法来随时修改全局公共的 header 和 parameter:

+ (void)setGeneralHeaderValue:(nullable NSString *)value forField:(NSString *)field;
+ (void)setGeneralParameterValue:(nullable NSString *)value forKey:(NSString *)key;

普通请求

GET

[XMCenter sendRequest:^(XMRequest *request) {
    request.url = @"http://example.com/v1/foo/bar";
    //request.server = @"http://example.com/v1/";
    //request.api = @"foo/bar";
    request.parameters = @{@"param1": @"value1", @"param2": @"value2"};
    request.headers = @{@"User-Agent": @"Custom User Agent"};
    request.httpMethod = kXMHTTPMethodGET;
} onSuccess:^(id responseObject) {
   NSLog(@"onSuccess: %@", responseObject);
} onFailure:^(NSError *error) {
   NSLog(@"onFailure: %@", error);
} onFinished:^(id responseObject, NSError *error) {
   NSLog(@"onFinished");
}];

注意1:可以通过以下两种方法设置一个请求对象的 URL 地址,但当 serverapiurl 三个属性被同时赋值时,url 的优先级比较高,而此时 serverapi 的值会被忽略。

request.url = @"http://example.com/v1/foo/bar";
// 如果 request.server 为 `nil`,且 request.useGeneralServer 为 `YES`,那么此时 request.server 会取 XMCenter.generalServer 的值。
request.server = @"http://example.com/v1/";
request.api = @"foo/bar";

注意2:一个请求对象的回调 Block (success/failure/finished/progress) 是非必需的(默认为 nil),XMCenter 提供了多个设置不同回调 Block 参数的方法用于发送请求。另外,需要注意的是,success/faillure/finished 等回调 Block 会在 XMCenter 设置的 callbackQueue 队列中被执行,但 progress 回调 Block 将在 NSURLSession 自己的队列中执行,而不是 callbackQueue

POST

[XMCenter sendRequest:^(XMRequest *request) {
    //request.server = @"http://example.com/v1/"; // 可选,如果为空则读取 XMCenter.generalServer
    request.api = @"foo/bar";
    request.parameters = @{@"param1": @"value1", @"param2": @"value2"};
    request.httpMethod = kXMHTTPMethodPOST; // 可选,默认为 `POST`
    request.requestType = kXMRequestNormal; // 可选,默认为 `Normal`
} onSuccess:^(id responseObject) {
   NSLog(@"onSuccess: %@", responseObject);
} onFailure:^(NSError *error) {
   NSLog(@"onFailure: %@", error);
}];

其他 HTTP 方法

XMRequest 同样支持其他 HTTP 方法,比如:HEAD, DELETE, PUT, PATCH 等,使用方式与上述类似,不再赘述。

详见 XMConstXMRequestXMCenter 等几个文件中的代码和注释。

上传请求

// `NSData` form data.
UIImage *image = [UIImage imageNamed:@"testImage"];
NSData *fileData1 = UIImageJPEGRepresentation(image, 1.0);
// `NSURL` form data.
NSString *path = [NSHomeDirectory() stringByAppendingString:@"/Documents/testImage.png"];
NSURL *fileURL2 = [NSURL fileURLWithPath:path isDirectory:NO];

[XMCenter sendRequest:^(XMRequest *request) {
    request.server = @"http://example.com/v1/";
    request.api = @"foo/bar";
    request.requestType = kXMRequestUpload;
    [request addFormDataWithName:@"image[]" fileName:@"temp.jpg" mimeType:@"image/jpeg" fileData:fileData1];
    [request addFormDataWithName:@"image[]" fileURL:fileURL2];
    // see `XMUploadFormData` for more details.
} onProgress:^(NSProgress *progress) {
    // the progress block is running on the session queue.
    if (progress) {
        NSLog(@"onProgress: %f", progress.fractionCompleted);
    }
} onSuccess:^(id responseObject) {
    NSLog(@"onSuccess: %@", responseObject);
} onFailure:^(NSError *error) {
    NSLog(@"onFailure: %@", error);
} onFinished:^(id responseObject, NSError *error) {
    NSLog(@"onFinished");
}];

下载请求

[XMCenter sendRequest:^(XMRequest *request) {
    request.url = @"http://example.com/v1/testDownFile.zip";
    request.downloadSavePath = [NSHomeDirectory() stringByAppendingString:@"/Documents/"];
    request.requestType = kXMRequestDownload;
} onProgress:^(NSProgress *progress) {
    // the progress block is running on the session queue.
    if (progress) {
        NSLog(@"onProgress: %f", progress.fractionCompleted);
    }
} onSuccess:^(id responseObject) {
    NSLog(@"onSuccess: %@", responseObject);
} onFailure:^(NSError *error) {
    NSLog(@"onFailure: %@", error);
}];

序列化

XMRequest 中有两个属性 requestSerializerTyperesponseSerializerType 分别用于设置请求参数和响应结果的序列化类型。

其中,XMRequestSerializerTypeXMResponseSerializerType 枚举的定义如下:

typedef NS_ENUM(NSInteger, XMRequestSerializerType) {
    kXMRequestSerializerRAW     = 0, // default
    kXMRequestSerializerJSON    = 1,
    kXMRequestSerializerPlist   = 2,
};
typedef NS_ENUM(NSInteger, XMResponseSerializerType) {
    kXMResponseSerializerRAW    = 0,
    kXMResponseSerializerJSON   = 1, // default
    kXMResponseSerializerPlist  = 2,
    kXMResponseSerializerXML    = 3,
};

详见 AFURLRequestSerialization.hAFURLResponseSerialization.h 获取更多细节。

自定义响应结果的处理逻辑

通常地,一个请求成功结束时,会执行 success block,当有错误发生时,执行 failure block。然而,开发中更常见的情况是,即使是一个请求成功结束,我们也需要进一步处理,比如验证响应结果数据、判断与服务端商量好的业务错误码类型等,再决定执行 success block 还是 failure block。

现在,你可以调用 [XMCenter setResponseProcessBlock:...] 方法以 Block 注入的方式设置自定义的处理逻辑,当请求成功结束时,这个 Block 会在 success block 被执行前调用,如果传入 *error 参数被赋值,则接下来会执行 failure block。

[XMCenter setResponseProcessBlock:^(XMRequest *request, id responseObject, NSError *__autoreleasing *error) {
    // 自定义响应结果处理逻辑,如果 `*error` 被赋值,则接下来会执行 failure block。
}];

批量请求

XMNetworking 支持同时发一组批量请求,这组请求在业务逻辑上相关,但请求本身是互相独立的,success block 会在所有请求都成功结束时才执行,而一旦有一个请求失败,则会执行 failure block。注:回调 Block 中的 responseObjectserrors 中元素的顺序与每个 XMRequest 对象在 batchRequest.requestArray 中的顺序一致。

[XMCenter sendBatchRequest:^(XMBatchRequest *batchRequest) {
    XMRequest *request1 = [XMRequest request];
    request1.url = @"server url 1";
    // set other properties for request1
        
    XMRequest *request2 = [XMRequest request];
    request2.url = @"server url 2";
    // set other properties for request2
        
    [batchRequest.requestArray addObject:request1];
    [batchRequest.requestArray addObject:request2];
} onSuccess:^(NSArray<id> *responseObjects) {
    NSLog(@"onSuccess: %@", responseObjects);
} onFailure:^(NSArray<id> *errors) {
    NSLog(@"onFailure: %@", errors);
} onFinished:^(NSArray<id> *responseObjects, NSArray<id> *errors) {
    NSLog(@"onFinished");
}];

[XMCenter sendBatchRequest:...] 方法会返回刚发起的新的 XMBatchRequest 对象,你可以保存这个对象,并在必要的时候调用它的 -cancelWithBlock: 方法取消这组批量请求。

链式请求

XMNetworking 同样支持发一组链式请求,这组请求之间互相依赖,下一请求是否发送以及请求的参数取决于上一个请求的结果,success block 会在所有的链式请求都成功结束时才执行,而中间一旦有一个请求失败,则会执行 failure block。注:回调 Block 中的 responseObjectserrors 中元素的顺序与每个链式请求 XMRequest 对象的先后顺序一致。

[XMCenter sendChainRequest:^(XMChainRequest *chainRequest) {
    [[[[chainRequest onFirst:^(XMRequest *request) {
        request.url = @"server url 1";
        // set other properties for request
    }] onNext:^(XMRequest *request, id responseObject, BOOL *sendNext) {
        NSDictionary *params = responseObject;
        if (params.count > 0) {
            request.url = @"server url 2";
            request.parameters = params;
        } else {
            *sendNext = NO;
        }
    }] onNext:^(XMRequest *request, id responseObject, BOOL *sendNext) {
        request.url = @"server url 3";
        request.parameters = @{@"param1": @"value1", @"param2": @"value2"};
    }] onNext: ...];    
} onSuccess:^(NSArray<id> *responseObjects) {
    NSLog(@"onSuccess: %@", responseObjects);
} onFailure:^(NSArray<id> *errors) {
    NSLog(@"onFailure: %@", errors);
} onFinished:^(NSArray<id> *responseObjects, NSArray<id> *errors) {
    NSLog(@"onFinished");
}];

[XMCenter sendChainRequest:...] 方法会返回刚发起的新的 XMChainRequest 对象,你可以保存这个对象,并在必要的时候调用它的 -cancelWithBlock: 方法取消这组链式请求。

取消一个网络请求

当调用 [XMCenter sendRequest:...] 方法发送一个网络请求时,该方法会返回一个用于唯一标识该请求对象的 identifier(如果请求发送失败,该值为 0)。在必要的时候,你可以通过这个 identifier 来取消当前网络请求(如果一个请求已经结束,这时再用 identifier 来取消该请求时,会直接忽略)。

// send a request
NSUInteger identifier = [XMCenter sendRequest:^(XMRequest *request) {
    request.server = @"https://kangzubin.cn/";
    request.api = @"test/index.php";
    request.httpMethod = kXMHTTPMethodGET;
    request.timeoutInterval = 10;
    request.retryCount = 1;
} onFailure:^(NSError *error) {
    NSLog(@"onFailure: %@", error);
}];

// your business code
sleep(2);

// cancel the running request by identifier with cancel block
[XMCenter cancelRequest:identifier onCancel:^(XMRequest *request) {
    NSLog(@"onCancel");
}];

注意:调用 XMCenter cancelRequest:onCancel: 方法取消一个网络请求时,被取消的请求对象(如果存在)会以参数的形式传给 cancel block,另外 cancel block 是在当前调用 cancelRequest: 方法的线程中执行,并不是 XMCenter 的 callbackQueue

网络可连接性检查

我们提供了两种方法用于获取网络的可连接性,分别如下:

[XMCenter isNetworkReachable];
// 该方法会返回一个 Bool 值用于表示当前网络是否可连接。
[[XMEngine sharedEngine] networkReachability]; 
// 该方法会返回一个当前网络的状态值,-1 表示 `Unknown`,0 表示 `NotReachable,1 表示 `WWAN`,2 表示 `WiFi`  

详见 AFNetworkReachabilityManager 获取更多细节.

HTTPS 请求的本地证书校验(SSL Pinning)

在你的应用程序包里添加 (pinned) 相应的 SSL 证书做校验有助于防止中间人攻击和其他安全漏洞。非常方便的是,AFNetworking 的 AFSecurityPolicy 安全模块可以通过校验本地保存的证书或公钥帮助我们评估服务器是否可信任以及建立安全连接。

我们在 XMEngine 中暴露了一个 AFHTTPSessionManager 对象叫 sessionManager,你可以通过修改该对象的 securityPolicy 类型,以开启 SSL Pinning 功能,并把你们服务器对应的 .cer 证书或者公钥放到你的工程中。

[XMEngine sharedEngine].sessionManager.securityPolicy = [AFSecurityPolicy policyWithPinningMode:AFSSLPinningModeCertificate];

详见 AFSecurityPolicy 获取更多细节.

文档

详见 XMNetworking Documents Link.

结构

XMNetworking 的代码结构非常简洁和紧凑,只包含了 4 个核心文件:XMConst.h 用于定义全局常量枚举和 Block,XMRequestXMCenterXMEngine 则是核心类的声明和实现,具体的代码结构如下图所示:

Architecture.png

待完善

  • 支持断点下载
  • 支持网络层缓存
  • 兼容测试支持 tvOS/watchOS/OS X
  • 更加强大的自定义模型转换
  • 实现一套可扩展的插件机制,便于 XMNetworking 增加新功能

作者

贡献者

许可证

XMNetworking 使用 MIT 许可证,详情见 LICENSE 文件。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,884评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,347评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,435评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,509评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,611评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,837评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,987评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,730评论 0 267
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,194评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,525评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,664评论 1 340
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,334评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,944评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,764评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,997评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,389评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,554评论 2 349

推荐阅读更多精彩内容