一 .什么时候需要考虑粘包问题?
- 如果利用tcp每次发送数据，就与对方建立连接，然后双方发送完一段数据后，就关闭连接，这样就不会出现粘包问题（因为只有一种包结构,类似于http协议）。关闭连接主要要双方都发送close连接（参考tcp关闭协议）。如：A需要发送一段字符串给B，那么A与B建立连接，然后发送双方都默认好的协议字符如"hello give me sth abour yourself"，然后B收到报文后，就将缓冲区数据接收,然后关闭连接，这样粘包问题不用考虑到，因为大家都知道是发送一段字符。
- 如果发送数据无结构，如文件传输，这样发送方只管发送，接收方只管接收存储就ok，也不用考虑粘包
- 如果双方建立连接，需要在连接后一段时间内发送不同结构数据，如连接后，有好几种结构：
1)"hello give me sth abour yourself"
2)"Don't give me sth abour yourself"
那这样的话，如果发送方连续发送这个两个包出去，接收方一次接收可能会是"hello give me sth abour yourselfDon't give me sth abour yourself" 这样接收方就傻了，到底是要干嘛？不知道，因为协议没有规定这么诡异的字符串，所以要处理把它分包，怎么分也需要双方组织一个比较好的包结构，所以一般可能会在头加一个数据长度之类的包，以确保接收。
二 .粘包出现原因
在流传输中出现，UDP不会出现粘包，因为它有消息边界(参考Windows 网络编程)
1 发送端需要等缓冲区满才发送出去，造成粘包
2 接收方不及时接收缓冲区的包，造成多个包接收
三 .解决办法
为了避免粘包现象，可采取以下几种措施。一是对于发送方引起的粘包现象，用户可通过编程设置来避免，TCP提供了强制数据立即传送的操作指令push，TCP软件收到该操作指令后，就立即将本段数据发送出去，而不必等待发送缓冲区满；二是对于接收方引起的粘包，则可通过优化程序设计、精简接收进程工作量、提高接收进程优先级等措施，使其及时接收数据，从而尽量避免出现粘包现象；三是由接收方控制，将一包数据按结构字段，人为控制分多次接收，然后合并，通过这种手段来避免粘包。
下面我们用一种简单而使用的方法来解决这个问题,而这种方法尤其适用于初学者,思路如下:
我们为了防止粘包与断包,将每一条TCP数据都已\n结尾,这样当我们拿到\n的时候,就说明这是一条完整的数据.
如果一次接受的数据中包含两个或两个以上的\n的时候,则以\n拆分成两条或两条以上的完整数据进行解析,即粘包处理.
如果一次接受的数据中没有\n,则将这条数据与下次接受的数据合并起来,知道接受到\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 ()
{
//保存二级制文件数据
NSMutableData *_currentData;
//保存有用的字符串数据
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、拼接二进制数据
[_currentData appendData:data];
//2、转化成字符串
NSString *string = [[NSString alloc] initWithData:_currentData encoding:NSUTF8StringEncoding];
NSLog(@"socket 收到的数据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、返回新的字符串 保存老的数组
// _lastMessages = usefulStringArr;
// _currentData = data;
}
@end
注:喜欢的请关注一下我的简书:白纸上涂鸦
网友评论