IOS 詳解socket編程[oc]粘包、半包處理
創(chuàng)新互聯(lián)長期為上1000家客戶提供的網(wǎng)站建設服務,團隊從業(yè)經(jīng)驗10年,關注不同地域、不同群體,并針對不同對象提供差異化的產品和服務;打造開放共贏平臺,與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為山丹企業(yè)提供專業(yè)的成都網(wǎng)站設計、網(wǎng)站建設,山丹網(wǎng)站改版等技術服務。擁有10多年豐富建站經(jīng)驗和眾多成功案例,為您定制開發(fā)。
在做socket編程時,如果是做tcp連接,那就不可避免的會遇到粘包與半包的問題,粘包就是多組數(shù)據(jù)被一并接收了,粘在了一起,無法做劃分;半包就是有數(shù)據(jù)接收不完整,無法處理。要解決粘包、半包的問題,一般在設計數(shù)據(jù)(消息)格式時會約定好一個字段專門用于描述數(shù)據(jù)包的長度,這樣就使數(shù)據(jù)有了邊界,依靠這個邊界,就能把每組數(shù)據(jù)劃分出來,數(shù)據(jù)不完整時也能獲知數(shù)據(jù)的缺失。
(當然也可以把數(shù)據(jù)設計成定長數(shù)據(jù),但這樣不夠靈活;或者用\n,\r這類字符作為數(shù)據(jù)劃分依據(jù),但不直觀、不明確,同時也不靈活)
舉個栗子:
消息=消息頭+消息體。消息頭用于描述消息本身的基本信息,消息體則為消息的具體內容
如上圖所示,假如我們的一個消息是這么定義的
消息頭 = msgId(4B)+version(2B)+len(4B),共占用10字節(jié)
消息體 = len中描述的16字節(jié)長
所以這條消息的長度就是 26字節(jié)
可以看到,要想知道一條完整數(shù)據(jù)的邊界,關鍵就是消息頭中的len字段
假如我們現(xiàn)在接收到的數(shù)據(jù)是這樣的:
這個情況下即包含了粘包,也出現(xiàn)了半包的情況,三個數(shù)據(jù)包粘在了一起,最后一個數(shù)據(jù)包沒有接收完全,出現(xiàn)了半包的情況,看看代碼如何處理
- (void)onSocket:(AsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag { while (_readBuf.length >= 10)//因為頭部固定10個字節(jié),數(shù)據(jù)長度至少要大于10個字節(jié),我們才能得到完整的消息描述信息 { NSData *head = [_readBuf subdataWithRange:NSMakeRange(0, 10)];//取得頭部數(shù)據(jù) NSData *lengthData = [head subdataWithRange:NSMakeRange(6, 4)];//取得長度數(shù)據(jù) NSInteger length = [[[NSString alloc] initWithData:lengthData encoding:NSUTF8StringEncoding] integerValue];//得出內容長度 NSInteger complateDataLength = length + 10;//算出一個包完整的長度(內容長度+頭長度) if (_readBuf.length >= complateDataLength)//如果緩存中數(shù)據(jù)夠一個整包的長度 { NSData *data = [_readBuf subdataWithRange:NSMakeRange(0, complateDataLength)];//截取一個包的長度(處理粘包) [self handleTcpResponseData:data];//處理包數(shù)據(jù) //從緩存中截掉處理完的數(shù)據(jù),繼續(xù)循環(huán) _readBuf = [NSMutableData dataWithData:[_readBuf subdataWithRange:NSMakeRange(complateDataLength, _readBuf.length - complateDataLength)]]; } else//如果緩存中的數(shù)據(jù)長度不夠一個包的長度,則包不完整(處理半包,繼續(xù)讀取) { [_socket readDataWithTimeout:-1 buffer:_readBuf bufferOffset:_readBuf.length tag:0];//繼續(xù)讀取數(shù)據(jù) return; } } //緩存中數(shù)據(jù)都處理完了,繼續(xù)讀取新數(shù)據(jù) [_socket readDataWithTimeout:-1 buffer:_readBuf bufferOffset:_readBuf.length tag:0];//繼續(xù)讀取數(shù)據(jù) }
感謝閱讀,希望能幫助到大家,謝謝大家對本站的支持!