一 .什么時候需要考慮粘包問題?
- 如果利用tcp每次發(fā)送數(shù)據(jù)斜友，就與對方建立連接盘榨，然后雙方發(fā)送完一段數(shù)據(jù)后，就關(guān)閉連接贮匕，這樣就不會出現(xiàn)粘包問題（因為只有一種包結(jié)構(gòu),類似于http協(xié)議）勺良。關(guān)閉連接主要要雙方都發(fā)送close連接（參考tcp關(guān)閉協(xié)議）绰播。如：A需要發(fā)送一段字符串給B，那么A與B建立連接尚困，然后發(fā)送雙方都默認(rèn)好的協(xié)議字符如"hello give me sth abour yourself"蠢箩，然后B收到報文后，就將緩沖區(qū)數(shù)據(jù)接收,然后關(guān)閉連接事甜，這樣粘包問題不用考慮到谬泌，因為大家都知道是發(fā)送一段字符。
- 如果發(fā)送數(shù)據(jù)無結(jié)構(gòu)逻谦，如文件傳輸掌实，這樣發(fā)送方只管發(fā)送，接收方只管接收存儲就ok邦马，也不用考慮粘包
- 如果雙方建立連接潮峦，需要在連接后一段時間內(nèi)發(fā)送不同結(jié)構(gòu)數(shù)據(jù)，如連接后勇婴，有好幾種結(jié)構(gòu)：
1)"hello give me sth abour yourself"
2)"Don't give me sth abour yourself"
那這樣的話忱嘹，如果發(fā)送方連續(xù)發(fā)送這個兩個包出去，接收方一次接收可能會是"hello give me sth abour yourselfDon't give me sth abour yourself" 這樣接收方就傻了耕渴，到底是要干嘛拘悦？不知道，因為協(xié)議沒有規(guī)定這么詭異的字符串橱脸，所以要處理把它分包础米，怎么分也需要雙方組織一個比較好的包結(jié)構(gòu)，所以一般可能會在頭加一個數(shù)據(jù)長度之類的包添诉，以確保接收屁桑。
二 .粘包出現(xiàn)原因
在流傳輸中出現(xiàn)，UDP不會出現(xiàn)粘包栏赴，因為它有消息邊界(參考Windows 網(wǎng)絡(luò)編程)
1 發(fā)送端需要等緩沖區(qū)滿才發(fā)送出去蘑斧，造成粘包
2 接收方不及時接收緩沖區(qū)的包，造成多個包接收
三 .解決辦法
為了避免粘包現(xiàn)象须眷，可采取以下幾種措施竖瘾。一是對于發(fā)送方引起的粘包現(xiàn)象，用戶可通過編程設(shè)置來避免花颗，TCP提供了強制數(shù)據(jù)立即傳送的操作指令push捕传，TCP軟件收到該操作指令后，就立即將本段數(shù)據(jù)發(fā)送出去扩劝，而不必等待發(fā)送緩沖區(qū)滿庸论；二是對于接收方引起的粘包职辅，則可通過優(yōu)化程序設(shè)計、精簡接收進(jìn)程工作量聂示、提高接收進(jìn)程優(yōu)先級等措施域携，使其及時接收數(shù)據(jù)，從而盡量避免出現(xiàn)粘包現(xiàn)象催什；三是由接收方控制涵亏，將一包數(shù)據(jù)按結(jié)構(gòu)字段，人為控制分多次接收蒲凶，然后合并气筋，通過這種手段來避免粘包。
下面我們用一種簡單而使用的方法來解決這個問題,而這種方法尤其適用于初學(xué)者,思路如下:
我們?yōu)榱朔乐拐嘲c斷包,將每一條TCP數(shù)據(jù)都已\n結(jié)尾,這樣當(dāng)我們拿到\n的時候,就說明這是一條完整的數(shù)據(jù).
如果一次接受的數(shù)據(jù)中包含兩個或兩個以上的\n的時候,則以\n拆分成兩條或兩條以上的完整數(shù)據(jù)進(jìn)行解析,即粘包處理.
如果一次接受的數(shù)據(jù)中沒有\(zhòng)n,則將這條數(shù)據(jù)與下次接受的數(shù)據(jù)合并起來,知道接受到\n為止,即斷包處理.
實現(xiàn)過程如下:
ReceiveDataControl.h:
#import <Foundation/Foundation.h>
typedef void(^SocketDataBlock)(NSMutableArray * receiveData);
@interface ReceiveDataControl : NSObject
+(ReceiveDataControl *) sharedInstance;
-(void)appendingData:(id)data newData:(SocketDataBlock)block;
@end
ReceiveDataControl.m:
#import "ReceiveDataControl.h"
@interface ReceiveDataControl ()
{
//保存二級制文件數(shù)據(jù)
NSMutableData *_currentData;
//保存有用的字符串?dāng)?shù)據(jù)
NSMutableArray *_lastMessages;
}
@end
@implementation ReceiveDataControl
+(ReceiveDataControl *) sharedInstance
{
static ReceiveDataControl *sharedInstace = nil;
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
sharedInstace = [[self alloc] init];
});
return sharedInstace;
}
-(instancetype)init{
if (self = [super init]) {
_currentData = [[NSMutableData alloc] init];
}
return self;
}
-(void)appendingData:(id)data newData:(SocketDataBlock)block
{
//1旋圆、拼接二進(jìn)制數(shù)據(jù)
[_currentData appendData:data];
//2宠默、轉(zhuǎn)化成字符串
NSString *string = [[NSString alloc] initWithData:_currentData encoding:NSUTF8StringEncoding];
NSLog(@"socket 收到的數(shù)據(jù)data = %@",string);
//3、分割字符串
NSArray *stringArr = [string componentsSeparatedByString:@"\n"];
NSMutableArray *usefulStringArr = [NSMutableArray new];
int count = 0;
//4灵巧、獲取有用的字符串
for (NSString *str in stringArr) {
if ([str hasPrefix:@"{"] && [str hasSuffix:@"}"]) {
[usefulStringArr addObject:str];
}else if (!IsStringEmpty(str)){
NSData *strData = [str dataUsingEncoding:NSUTF8StringEncoding];
_currentData = [strData mutableCopy];
count ++;
}
}
if (count == 0) {
_currentData = [[NSMutableData alloc] init];
}
block(usefulStringArr);
//5搀矫、判斷有沒有新的字符串
// NSMutableArray *newStringArr = [NSMutableArray new];
// for (NSString *str in usefulStringArr) {
// if (![_lastMessages containsObject:str]) {
// [newStringArr addObject:str];
// }
// }
//6、返回新的字符串 保存老的數(shù)組
// _lastMessages = usefulStringArr;
// _currentData = data;
}
@end
注:喜歡的請關(guān)注一下我的簡書:白紙上涂鴉
