在使用SocketRocket之前先了解關(guān)于網(wǎng)絡(luò)層的幾個(gè)概念
關(guān)于Socket
我們都知道socket是套接字棒呛，描述ip地址和端口，它本身并不是協(xié)議肋乍，而是一個(gè)調(diào)用接口兵怯，為了大家直接使用更底層的協(xié)議（TCP或UDP），是對(duì)TCP/IP 或 UDP/IP的封裝漠烧。socket處于網(wǎng)絡(luò)層中的第五層杏愤，是一個(gè)抽象層。
關(guān)于WebSocket
websocket是一個(gè)協(xié)議已脓，是基于http協(xié)議的珊楼，是建立在TCP連接之上的，是應(yīng)用層上的一個(gè)應(yīng)用層協(xié)議度液，和socket不是一個(gè)概念厕宗。
WebSocket的特點(diǎn)
websocket可以傳輸文本和二進(jìn)制。
websocket的協(xié)議頭是ws開頭的堕担，并不是http已慢。
WebSocket和HTTP協(xié)議
WebSocket 是 HTML5 開始提供的一種在單個(gè) TCP 連接上進(jìn)行全雙工通訊的協(xié)議。
HTTP 協(xié)議是一種無狀態(tài)的霹购、無連接的佑惠、單向的應(yīng)使用層協(xié)議。它采使用了請(qǐng)求/響應(yīng)模型齐疙。通信請(qǐng)求只能由用戶端發(fā)起膜楷，服務(wù)端對(duì)請(qǐng)求做出應(yīng)答解決。這種通信模型有一個(gè)弊端：HTTP 協(xié)議無法實(shí)現(xiàn)服務(wù)器主動(dòng)向用戶端發(fā)起消息贞奋。這種單向請(qǐng)求的特點(diǎn)赌厅，注定了假如服務(wù)器有連續(xù)的狀態(tài)變化，用戶端要獲知就非常麻煩轿塔。大多數(shù) Web 應(yīng)使用程序?qū)⑼ㄟ^頻繁的異步JavaScript和XML（AJAX）請(qǐng)求實(shí)現(xiàn)長輪詢特愿。輪詢的效率低，非常白費(fèi)資源（由于必需不停連接催训，或者者 HTTP 連接始終打開）洽议。
WebSocket 連接允許用戶端和服務(wù)器之間進(jìn)行全雙工通信，以便任一方都可以通過建立的連接將數(shù)據(jù)推送到另一端漫拭。WebSocket 只要要建立一次連接，即可以一直保持連接狀態(tài)混稽。這相比于輪詢方式的不停建立連接顯然效率要大大提高采驻。
WebSocket與Socket的關(guān)系
Socket其實(shí)并不是一個(gè)協(xié)議审胚，而是為了方便用TCP或者UDP而籠統(tǒng)出來的一層，是位于應(yīng)使用層和傳輸控制層之間的一組接口礼旅。是應(yīng)使用層與TCP/IP協(xié)議族通信的中間軟件籠統(tǒng)層膳叨，它是一組接口。在設(shè)計(jì)模式中痘系，Socket其實(shí)就是一個(gè)門面模式菲嘴，它把復(fù)雜的TCP/IP協(xié)議族隱藏在Socket接口后面，對(duì)使用戶來說汰翠，一組簡單的接口就是一律龄坪，讓Socket去組織數(shù)據(jù)，以符合指定的協(xié)議复唤。當(dāng)兩臺(tái)主機(jī)通信時(shí)健田，必需通過Socket連接，Socket則利使用TCP/IP協(xié)議建立TCP連接佛纫。TCP連接則更依靠于底層的IP協(xié)議妓局，IP協(xié)議的連接則依賴于鏈路層等更低層次。
WebSocket則是一個(gè)典型的應(yīng)使用層協(xié)議呈宇。
區(qū)別是Socket是傳輸控制層協(xié)議好爬，WebSocket是應(yīng)使用層協(xié)議。
框架
在iOS 平臺(tái)上甥啄，我們知道socket的開源框架有 CocoaAsyncSocket抵拘， 而websocket的框架有Facebook的 SocketRocket， 以及socket.io-client-swift型豁。
??下面介紹我們今天的主角
SocketRocket
SocketRocket是一個(gè)WebSocket客戶端（WebSocket是適用于Web應(yīng)用的下一代全雙工通訊協(xié)議僵蛛，被成為“Web的TCP”，它實(shí)現(xiàn)了瀏覽器與服務(wù)器的雙向通信）迎变，采用Object-C編寫充尉。SocketRocket遵循最新的WebSocket規(guī)范RFC 6455。
特性:
支持TLS (wss)衣形。
使用NSStream/CFNetworking驼侠。
使用ARC。
采用并行架構(gòu)谆吴。大部分的工作由后端的工作隊(duì)列（worker queues）完成倒源。
基于委托編程。
1. 集成
- 使用cocoapods
只需要在podfile文件中加入pod 'SocketRocket'句狼，然后執(zhí)行pod install就可以了 - 不使用cocoapods
-
添加文件
把下面的三個(gè)文件拖入項(xiàng)目中#import "SRWebSocket.h" -
添加依賴庫
在Build Phases -> Link Binary With Libraries里加入如下frameworks：- libicucore.dylib
- CFNetwork.framework
- Security.framework
- Foundation.framework
-
2. 使用
2.1 添加引用
#import "SocketRocket.h"
2.2 寫代理方法
@interface ViewController ()<SRWebSocketDelegate>
2.3 寫成屬性
@property (strong, nonatomic) SRWebSocket *socket;
2.4 初始化
這里的server_ip為宏定義static NSString *const server_ip = @"ws://"; 存放后臺(tái)提供的ws地址, 調(diào)用open方法即開啟長連接
//初始化 WebSocket
- (void)initWebSocket{
if (_socket) {
return;
}
//Url
NSURL *url = [NSURL URLWithString:server_ip];
//請(qǐng)求
NSMutableURLRequest *request = [[NSMutableURLRequest alloc]initWithURL:url cachePolicy:NSURLRequestUseProtocolCachePolicy timeoutInterval:10];
//初始化請(qǐng)求`
_socket = [[SRWebSocket alloc] initWithURLRequest:request];
//代理協(xié)議`
_socket.delegate = self;
// 實(shí)現(xiàn)這個(gè) SRWebSocketDelegate 協(xié)議啊`
//直接連接`
[_socket open]; // open 就是直接連接了
}
2.5 代理方法的實(shí)現(xiàn)
這里需要注意
①如果沒有連接成功就先調(diào)用send方法會(huì)崩潰進(jìn)入斷言, 一定要等webSocketDidOpen回調(diào)完成在發(fā)送文本幀/數(shù)據(jù)包
②和后臺(tái)協(xié)商好發(fā)包的格式, 如果沒有統(tǒng)一會(huì)被關(guān)閉連接, 一般為JSON格式的二進(jìn)制流, 音頻是PCM數(shù)據(jù)流
#pragma mark -- SRWebSocketDelegate
//收到服務(wù)器消息是回調(diào)
- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message{
NSLog(@"收到服務(wù)器返回消息：%@",message);
}
//連接成功
- (void)webSocketDidOpen:(SRWebSocket *)webSocket{
NSLog(@"連接成功笋熬，可以立刻登錄你公司后臺(tái)的服務(wù)器了，還有開啟心跳");
[self initHeart]; //開啟心跳
if (self.socket != nil) {
// 只有 SR_OPEN 開啟狀態(tài)才能調(diào) send 方法啊腻菇，不然要崩
if (_socket.readyState == SR_OPEN) {
NSString *jsonString = @"{\"sid\": \"13b313a3-fea9-4e28-9e56-352458f7007f\"}";
[_socket send:jsonString]; //發(fā)送數(shù)據(jù)包
} else if (_socket.readyState == SR_CONNECTING) {
NSLog(@"正在連接中胳螟，重連后其他方法會(huì)去自動(dòng)同步數(shù)據(jù)");
// 每隔2秒檢測一次 socket.readyState 狀態(tài)昔馋，檢測 10 次左右
// 只要有一次狀態(tài)是 SR_OPEN 的就調(diào)用 [ws.socket send:data] 發(fā)送數(shù)據(jù)
// 如果 10 次都還是沒連上的，那這個(gè)發(fā)送請(qǐng)求就丟失了糖耸，這種情況是服務(wù)器的問題了秘遏，小概率的
// 代碼有點(diǎn)長，我就寫個(gè)邏輯在這里好了
} else if (_socket.readyState == SR_CLOSING || _socket.readyState == SR_CLOSED) {
// websocket 斷開了嘉竟，調(diào)用 reConnect 方法重連
}
} else {
NSLog(@"沒網(wǎng)絡(luò)邦危，發(fā)送失敗，一旦斷網(wǎng) socket 會(huì)被我設(shè)置 nil 的");
NSLog(@"其實(shí)最好是發(fā)送前判斷一下網(wǎng)絡(luò)狀態(tài)比較好舍扰，我寫的有點(diǎn)晦澀倦蚪，socket==nil來表示斷網(wǎng)");
}
}
//連接失敗的回調(diào)
- (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error{
NSLog(@"連接失敗，這里可以實(shí)現(xiàn)掉線自動(dòng)重連妥粟，要注意以下幾點(diǎn)");
NSLog(@"1.判斷當(dāng)前網(wǎng)絡(luò)環(huán)境审丘，如果斷網(wǎng)了就不要連了，等待網(wǎng)絡(luò)到來勾给，在發(fā)起重連");
NSLog(@"2.判斷調(diào)用層是否需要連接滩报，例如用戶都沒在聊天界面，連接上去浪費(fèi)流量");
//關(guān)閉心跳包
[webSocket close];
[self reConnect];
}
//連接斷開的回調(diào)
- (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean;
{
NSLog(@"Close");
}
- (void)webSocket:(SRWebSocket *)webSocket didReceivePong:(NSData *)pongPayload;
{
NSLog(@"Pong");
}
2.6 心跳包(定時(shí)器實(shí)現(xiàn))
//辈ゼ保活機(jī)制 探測包
- (void)initHeart{
__weak typeof(self) weakSelf = self;
_heatBeat = [NSTimer scheduledTimerWithTimeInterval:3*60 repeats:YES block:^(NSTimer * _Nonnull timer) {
[weakSelf.socket send:@"heart"];
NSLog(@"已發(fā)送");
}];
[[NSRunLoop currentRunLoop] addTimer:_heatBeat forMode:NSRunLoopCommonModes];
}
如果開啟了心跳記得在合適的地方銷毀定時(shí)器, 避免內(nèi)存泄漏
//斷開連接時(shí)銷毀心跳
- (void)destoryHeart{
}
2.7 重連機(jī)制
- (void)reConnect{
//每隔一段時(shí)間重連一次
//規(guī)定64不在重連,2的指數(shù)級(jí)
if (_reConnectTime > 60) {
return;
}
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(_reConnectTime * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
self.socket = nil;
[self initWebSocket];
});
if (_reConnectTime == 0) {
_reConnectTime = 2;
}else{
_reConnectTime *= 2;
}
}
參考文獻(xiàn):
SocketRocket的簡單使用
socketRocket 封裝脓钾，添加重連機(jī)制，block回調(diào)
SocketRocket源碼分析
