背景
最近做的项目中有要新增一个“竞价”模块的需求，讨论后的出用socket来做比较合适。这样的话就能够实时向用户反馈最新的信息。像这种和股票，金融这样的信息，必须要做到即时性，数据才有价值。
实现
实现也很简单：
1.初始化，连接
-(void)startConnectServerWithSocketWithParamets:(NSDictionary *)paramets{
if (self.socketIsConnected) {
return;
}
self.socketParamets = paramets;
self.clientSocket = [[GCDAsyncSocket alloc]initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
NSError *error = nil;
[self.clientSocket connectToHost:SOCKET_TCP_IP onPort:SOCKET_TCP_PORT viaInterface:nil withTimeout:-1 error:&error];
}
2.连接成功，传递参数给服务器，定好心跳包
-(void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port{
self.socketIsConnected = YES;
NSData *data =[[NSString stringWithFormat:@"DEMANDID:%@:%@",self.socketParamets[@"DEMANDID"],self.socketParamets[@"ID"]] dataUsingEncoding:NSUTF8StringEncoding];
[self.clientSocket writeData:data withTimeout:- 1 tag:0];
//创建定时器，发送心跳包
self.longConnectTimer = [NSTimer timerWithTimeInterval:10
target:self
selector:@selector(longConnectToSocket)
userInfo:nil
repeats:YES];
[[NSRunLoop currentRunLoop] addTimer:self.longConnectTimer forMode:NSRunLoopCommonModes];
[self.clientSocket readDataWithTimeout:-1 tag:0];
}
3.接收数据，解析，传递数据
//读取到数据
-(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag{
NSDictionary *dic = [NSJSONSerialization JSONObjectWithData:data
options:NSJSONReadingMutableContainers
error:&err];
if (dic) {
[self.socketResposeDataSignel sendNext:@{@"title":@"success",@"data":dic}];
}
[self.clientSocket readDataWithTimeout:-1 tag:0];
}
出现问题
最开始测试的时候是没有问题的，可是数据越大的时候，越来越频繁的时候就会间断性的出现UI不刷新的问题。我一开始以为没有传递数据过来。但是经过调试，检测后发现接收数据的代理是有响应的。再将数据分析，出现了断包（一条完整的数据A被断成A1和A2两条Socket传递过来，所以解析会出错）和粘包（两条数据A和B两次Socket传递过来，但是第一次传递的是A的50%（断包），第二次传递的是A的50%和B的100%,所以两次都无法正常解析）。
解决办法
在网上看了很多博客后觉得在消息后面添加个消息头，用来标记该条消息的具体长度。换算出数值后和实际接受到的消息长度作比较，若实际长度小于换算的数值则发生断包现象，数据缓存下来继续接收。若是两者相同则消息是完整的长度，正常解析。若是实际长度大于换算的数值，则出现了粘包现象，循环解析。具体实现如下：（我和后台固定了消息头为6位代表消息长度的数值，不足6位高位补0）
-(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag{
while (self.socketBufferData.length >= 6)//因为头部固定6个字节，数据长度至少要大于6个字节， 我们才能得到完整的消息描述信息
{
NSData *head = [self.socketBufferData subdataWithRange:NSMakeRange(0, 6)];//取得头部数据
NSInteger length = [[[NSMutableString alloc]initWithData:head encoding:NSUTF8StringEncoding] integerValue];//得出内容长度
NSInteger complateDataLength = length + 6;//算出一个包完整的长度(内容长度＋头长度)
if (self.socketBufferData.length >= complateDataLength)//如果缓存中数据够一个整包的长度
{
NSData *data = [self.socketBufferData subdataWithRange:NSMakeRange(6, length)];//截取一个包的长度(处理粘包)
//回调数据更新界面
NSError *err;
NSDictionary *dic = [NSJSONSerialization JSONObjectWithData:data
options:NSJSONReadingMutableContainers
error:&err];
if (dic) {
[self.socketResposeDataSignel sendNext:@{@"title":@"success",@"data":dic}];
}
//从缓存中截掉处理完的数据,继续循环
self.socketBufferData = [NSMutableData dataWithData:[self.socketBufferData subdataWithRange:NSMakeRange(complateDataLength, self.socketBufferData.length - complateDataLength)]];
}else//如果缓存中的数据长度不够一个包的长度，则包不完整(处理半包，继续读取)
{
[self.clientSocket readDataWithTimeout:-1 buffer:self.socketBufferData bufferOffset:self.socketBufferData.length tag:0];//继续读取数据
return;
}
}
//缓存中数据都处理完了，继续读取新数据
[self.clientSocket readDataWithTimeout:-1 buffer:self.socketBufferData bufferOffset:self.socketBufferData.length tag:0];//继续读取数据
}
总结
看了网上的很多解决办法，都能实现。还是要根据项目的具体需求来。就像定这个消息头的部分，有的需求可能还要定义消息的类型（图片、MP3等），版本，ID什么的，那定义的就更加复杂。所以上面的只提供参考，一种解决思路，具体情况还得具体分析。记录一下，留待以后要用到的话提醒自己！
如有问题请联系我：13048914897@163.com
