iOS系統(tǒng)SRWebSocket的源碼解析上

　　一。 前言：

　　WebSocket協(xié)議是基于TCP的一種新的網(wǎng)絡(luò)協(xié)議。它實現(xiàn)了瀏覽器與服務(wù)器全雙工（full-duplex）通信——可以通俗的解釋為服務(wù)器主動發(fā)送信息給客戶端。

　　區(qū)別于MQTT、XMPP等聊天的應(yīng)用層協(xié)議，它是一個傳輸通訊協(xié)議。它有著自己一套連接握手，以及數(shù)據(jù)傳輸?shù)囊?guī)范。

　　而本文要講到的SRWebSocket就是iOS中使用websocket必用的一個框架，它是用Facebook提供的。

　　關(guān)于WebSocket起源與發(fā)展，是怎么由：輪詢、長輪詢、再到websocket的，可以看看冰霜這篇文章：

　　微信，QQ這類IM app怎么做——談?wù)刉ebsocket

　　關(guān)于SRWebSocket的API用法，可以看看樓主之前這篇文章：

　　iOS即時通訊，從入門到“放棄”？

　　二。 SRWebSocket的對外的業(yè)務(wù)流程：

　　首先貼一段SRWebSocket的API調(diào)用代碼：

　　//初始化socket并且連接

　　- （void）connectServer：（NSString *）server port：（NSString *）port

　　{

　　NSURLRequest *request = ［NSURLRequest requestWithURL：［NSURL URLWithString：［NSString stringWithFormat：@“ws://%@：%@”，server，port］］］;

　　_socket = ［［SRWebSocket alloc］ initWithURLRequest:request］;

　　_socket.delegate = self;

　?。踎socket open］;

　　}

　　- （void）webSocket：（SRWebSocket *）webSocket didReceiveMessage：（id）message

　　{

　　}

　　- （void）webSocketDidOpen：（SRWebSocket *）webSocket

　　{

　　}

　　- （void）webSocket：（SRWebSocket *）webSocket didFailWithError：（NSError *）error

　　{

　　}

　　- （void）webSocket：（SRWebSocket *）webSocket didCloseWithCode：（NSInteger）code reason：（NSString *）reason wasClean：（BOOL）wasClean

　　{

　　}

　　要簡單使用起來，總共就4行代碼，并且實現(xiàn)你需要的代理即可，整個業(yè)務(wù)邏輯非常簡潔。

　　但是就這么幾個對外的方法，SRWebSocket.m里面用了2000行代碼來進(jìn)行封裝，那么它到底做了什么？我們接著往下看：

　　三。 SRWebSocket的初始化以及連接流程：

　　1首先我們初始化：

　　//初始化

　　- （void）_SR_commonInit;

　　{

　　//得到url schem小寫

　　NSString *scheme = _url.scheme.lowercaseString;

　　//如果不是這幾種，則斷言錯誤

　　assert（［scheme isEqualToString：@“ws”］ || ［scheme isEqualToString：@“http”］ || ［scheme isEqualToString：@“wss”］ || ［scheme isEqualToString：@“https”］）;

　　_readyState = SR_CONNECTING;

　　_webSocketVersion = 13;

　　//初始化工作的隊列，串行

　　_workQueue = dispatch_queue_create（NULL， DISPATCH_QUEUE_SERIAL）;

　　//給隊列設(shè)置一個標(biāo)識，標(biāo)識為指向自己的，上下文對象為這個隊列

　　dispatch_queue_set_specific（_workQueue， （__bridge void *）self， maybe_bridge（_workQueue）， NULL）;

　　//設(shè)置代理queue為主隊列

　　_delegateDispatchQueue = dispatch_get_main_queue（）;

　　//retain主隊列？

　　sr_dispatch_retain（_delegateDispatchQueue）;

　　//讀Buffer

　　_readBuffer = ［［NSMutableData alloc］ init］;

　　//輸出Buffer

　　_outputBuffer = ［［NSMutableData alloc］ init］;

　　//當(dāng)前數(shù)據(jù)幀

　　_currentFrameData = ［［NSMutableData alloc］ init］;

　　//消費(fèi)者數(shù)據(jù)幀的對象

　　_consumers = ［［NSMutableArray alloc］ init］;

　　_consumerPool = ［［SRIOConsumerPool alloc］ init］;

　　//注冊的runloop

　　_scheduledRunloops = ［［NSMutableSet alloc］ init］;

　　。。.。省略了一部分代碼

　　}

　　會初始化一些屬性：

　　包括對schem進(jìn)行斷言，只支持ws/wss/http/https四種。

　　當(dāng)前socket狀態(tài)，是正在連接，還是已連接、斷開等等。

　　初始化工作隊列，以及流回調(diào)線程等等。