iOS Socket封包、粘包、拆包处理

NSMutableDictionary*dictTemp=[NSMutableDictionarydictionary];
dictTemp[@"username"]=@"LD";

//先创建模型-->转Json-->转字符串
TestModel*model=[TestModelnew];
model.type=1;
model.userName=@"LD";
model.age=@"18";
model.message=@"Hellow";
model.Content=dictTemp;

//先将模型转换成Json格式的数据这里根据自己项目情况来看是否需要转成Json格式使用到了MJExtension，
NSString*strJson=[[NSStringalloc]initWithData:model.mj_JSONDataencoding:NSUTF8StringEncoding];
Cs_Connect*connect=[Cs_Connectnew];
connect.serverID=1;
connect.message=strJson;
connect.length=(int)connect.message.length;

//将数据传换成二进制数据,转换之后的数据和协议顺序是一致的（为什么不需要调整顺序我也不知道，有兴趣的的同学自己去研究下这个方法）
NSMutableData*dataModel=[socketRequestSpliceAttribute:connect];

//通过Socket发出去
[socketsendMessage:dataModel];

//将模型数据转换成二进制数据
-(NSMutableData*)RequestSpliceAttribute:(id)obj{

_data=nil;//记得清空不然数据包会越来越大
if(obj==nil){
self.object=self.data;

NSLog(@"传入需转二进制的数据为空");
returnnil;
}
unsignedintnumIvars;//成员变量个数
objc_property_t*propertys=class_copyPropertyList(NSClassFromString([NSStringstringWithUTF8String:object_getClassName(obj)]),&numIvars);
NSString*type=nil;
NSString*name=nil;

for(inti=0;i<numIvars;i++){
objc_property_tthisProperty=propertys[i];

name=[NSStringstringWithUTF8String:property_getName(thisProperty)];
//NSLog(@"%d.name:%@",i,name);
type=[[[NSStringstringWithUTF8String:property_getAttributes(thisProperty)]componentsSeparatedByString:@","]objectAtIndex:0];//获取成员变量的数据类型
//NSLog(@"%d.type:%@",i,type);
idpropertyValue=[objvalueForKey:[(NSString*)namesubstringFromIndex:0]];
//NSLog(@"%d.propertyValue:%@",i,propertyValue);

if([typeisEqualToString:TYPE_UINT8]){
uint8_ti=[propertyValuecharValue];//8位
[self.dataappendData:[DLSocketDataUtilsbyteFromUInt8:i]];
}elseif([typeisEqualToString:TYPE_UINT16]){
uint16_ti=[propertyValueshortValue];//16位
[self.dataappendData:[DLSocketDataUtilsbytesFromUInt16:i]];
}elseif([typeisEqualToString:TYPE_UINT32]){
uint32_ti=[propertyValueintValue];//32位
[self.dataappendData:[DLSocketDataUtilsbytesFromUInt32:i]];
}elseif([typeisEqualToString:TYPE_UINT64]){
uint64_ti=[propertyValuelongLongValue];//64位
[self.dataappendData:[DLSocketDataUtilsbytesFromUInt64:i]];
}elseif([typeisEqualToString:TYPE_STRING]){
NSData*data=[(NSString*)propertyValue\
dataUsingEncoding:NSUTF8StringEncoding];//通过utf-8转为data
[self.dataappendData:data];

}else{
NSLog(@"RequestSpliceAttribute:未知类型");
NSAssert(YES,@"RequestSpliceAttribute:未知类型");
}
}

//hy:记得释放C语言的结构体指针
free(propertys);
self.object=_data;
return_data;
}

-(void)didReadData:(NSData*)data{

//将接收到的数据保存到缓存数据中
[self.cacheDataappendData:data];;

//取出4-8位保存的数据长度，计算数据包长度
NSData*dataLength=[_cacheDatasubdataWithRange:NSMakeRange(4,4)];
intdataLenInt=CFSwapInt32BigToHost(*(int*)([dataLengthbytes]));
NSIntegerlengthInteger=0;
lengthInteger=(NSInteger)dataLenInt;
NSIntegercomplateDataLength=lengthInteger+8;//算出一个包完整的长度(内容长度＋头长度)
NSLog(@"data=%ld----length=%d",data.length,dataLenInt);

//因为服务号和长度字节占8位，所以大于8才是一个正确的数据包
while(_cacheData.length>8){

if(_cacheData.length<complateDataLength){//如果缓存中的数据长度小于包头长度则继续拼接

[[SingletonSocketsharedInstance].socketreadDataWithTimeout:-1tag:0];//socket读取数据
break;

}else{

//截取完整数据包
NSData*dataOne=[_cacheDatasubdataWithRange:NSMakeRange(0,complateDataLength)];
[selfhandleTcpResponseData:dataOne];//处理包数据
[_cacheDatareplaceBytesInRange:NSMakeRange(0,complateDataLength)withBytes:nillength:0];

if(_cacheData.length>8){

[selfdidReadData:nil];

}
}
}
}