四。 接著來講講數(shù)據(jù)的讀和寫：

　　當建立連接成功后，就會循環(huán)調用這么一個方法：

　　//讀取http頭部

　　- （void）_readHTTPHeader;

　　{

　　if （_receivedHTTPHeaders == NULL） {

　　//序列化的http消息

　　_receivedHTTPHeaders = CFHTTPMessageCreateEmpty（NULL， NO）;

　　}

　　//不停的add consumer去讀數(shù)據(jù)

　　［self _readUntilHeaderCompleteWithCallback：^（SRWebSocket *self， NSData *data） {

　　//拼接數(shù)據(jù)，拼到頭部

　　CFHTTPMessageAppendBytes（_receivedHTTPHeaders， （const UInt8 *）data.bytes， data.length）;

　　//判斷是否接受完

　　if （CFHTTPMessageIsHeaderComplete（_receivedHTTPHeaders）） {

　　SRFastLog（@“Finished reading headers %@”， CFBridgingRelease（CFHTTPMessageCopyAllHeaderFields（_receivedHTTPHeaders）））;

　?。踫elf _HTTPHeadersDidFinish］;

　　} else {

　　//沒讀完遞歸調

　?。踫elf _readHTTPHeader］;

　　}

　　}］;

　　}

　　記得樓主之前寫過一篇即時通訊下數(shù)據(jù)粘包、斷包處理實例（基于CocoaAsyncSocket），因此拋出一個問題，WebSocket需要處理數(shù)據(jù)的斷包和粘包么？

　　答案是基本不需要。引用知乎上的一段回答：

　　RFC規(guī)范指出，WebSocket是一個message-based的協(xié)議，它可以自動將數(shù)據(jù)分片，并且自動將分片的數(shù)據(jù)組裝。

　　也就是說，WebSocket的RFC標準是不會產(chǎn)生粘包、斷包問題的。無需應用層開發(fā)人員關心緩存以及手工組裝message。

　　然而理想與現(xiàn)實的不一致：RFC規(guī)范與實現(xiàn)的不一致，現(xiàn)實當中有幾個問題：

　　每個message可以是一個或多個分片。message不記錄長度，分片才記錄長度。

　　message最大的長度可以達到 9，223，372，036，854，775，807 字節(jié)，是由于Payload的數(shù)據(jù)長度有63bit的限制。

　　很多WebSocket的實現(xiàn)其實并不按照標準的RFC實現(xiàn)完全，很多僅僅實現(xiàn)了50%就拿來用了。這就導致了，在WebSocket實現(xiàn)上的最大長度很難達到這個大小，于是，很多API的實現(xiàn)上是會有限制的，可能會限制你的發(fā)送的長度，也可能會把過長的數(shù)據(jù)直接以流式發(fā)送。

　　而SRWebSocket中實現(xiàn)的方式上徹底解決了數(shù)據(jù)粘包，斷包的可能。

　　數(shù)據(jù)是通過CFStream流的方式回調回來的，每次拿到流數(shù)據(jù)，都是先放在數(shù)據(jù)緩沖區(qū)中，然后去讀當前消息幀的頭部，得到當前數(shù)據(jù)包的大小，然后再去創(chuàng)建消費者對象consumer，去讀取緩沖區(qū)指定數(shù)據(jù)包大小的內容，讀完才會回調給我們上層用戶，所以，我們如果用SRWebSocket完全不需要考慮數(shù)據(jù)斷包、粘包的問題，每次到達的數(shù)據(jù)，都是一條完整的數(shù)據(jù)。

　　接著我們大概來看看這個流程：

　　//讀取CRLFCRLFBytes，直到回調回來

　　- （void）_readUntilHeaderCompleteWithCallback：（data_callback）dataHandler;

　　{

　?。踫elf _readUntilBytes:CRLFCRLFBytes length:sizeof（CRLFCRLFBytes） callback:dataHandler］;

　　}

　　//讀取數(shù)據(jù) CRLFCRLFBytes，邊界符

　　- （void）_readUntilBytes：（const void *）bytes length：（size_t）length callback：（data_callback）dataHandler;

　　{

　　// TODO optimize so this can continue from where we last searched

　　//消費者需要消費的數(shù)據(jù)大小

　　stream_scanner consumer = ^size_t（NSData *data） {

　　__block size_t found_size = 0;

　　__block size_t match_count = 0;

　　//得到數(shù)據(jù)長度

　　size_t size = data.length;

　　//得到數(shù)據(jù)指針

　　const unsigned char *buffer = data.bytes;

　　for （size_t i = 0; i 《 size; i++ ） {

　　//匹配字符

　　if （（（const unsigned char *）buffer）［i］ == （（const unsigned char *）bytes）［match_count］） {

　　//匹配數(shù)+1

　　match_count += 1;

　　//如果匹配了

　　if （match_count == length） {

　　//讀取數(shù)據(jù)長度等于 i+ 1

　　found_size = i + 1;

　　break;

　　}

　　} else {

　　match_count = 0;

　　}

　　}

　　//返回要讀取數(shù)據(jù)的長度，沒匹配成功就是0

　　return found_size;