一、涉及到的第三方库
1、GCDAsyncSocket
GCDAsyncSocket是一个封装好的，帮助开发者完成socket的通信过程。数据上传以及接收。
创建scoket对象后，遵循它的代理，里面有一个最重要的方法: 接受解析服务器数据
- (void)socket:(GCDAsyncSocket *)socket didReadData:(NSData *)data withTag:(long)tag {
if (tag == xxx1) {
<!--DataInputStream是一个从二进制data取数据的类，以约定的格式-->
DataInputStream *input = [[DataInputStream alloc] initWithData:data];
TCPHeaderFrame *header = [[TCPHeaderFrame alloc] init];
<!--约定的格式：1-2字节为header内容长度-->
header.headLength = [input readShort];
<!--约定格式：3-4字节为版本号-->
header.version = [input readShort];
<!--约定格式：5-6字节为aid-->
header.cid = [input readShort];
<!--约定格式：7-10字节为bid-->
header.bid = [input readInt];
<!--约定格式：11-12字节为body长度-->
header.bodyLength = [input readShort];
<!--约定格式：以上定义了12字节的header内容 剩下的就是具体的消息内容了-->
if (header.bodyLength <= 0) {
[socket disconnect];
} else {
<!--这里从header中获取到消息内容长度 开始读取 调用该方法会再次进入此代理方法 tag:xxx2-->
[socket readDataToLength:header.bodyLength withTimeout:-1 tag:xxx2];
}
} else if (tab == xxx2) {
[[LocalDataReciever sharedInstance] handleProtocal:data cid:self.cid];
} else {
[socket disconnect];
}
}
<!--这里根据cid判断是我们定义的哪种消息 或者说是哪种命令-->
- (void) handleProtocal:(NSData *)body cid:(int16_t)cid {
if (cid == xxx) {
<!--假如这里是Person消息内容 那么就用Person类解析-->
Person *p = [Person parseFromData:data error:nil];
//执行相关逻辑
}
}接下来是如何使用scoket上传数据：下面是一个要上传给服务器的消息/命令
(NSData *)packMsgDataSeqId:(NSString *)seqId msgType:(int32_t)msgTyep to:(NSString *)to contentType:(int32_t)contentType content:(NSString *)content extra:(NSString *)extra
{
<!--上面定义了一个DataInputStream是解析服务器data的，这里的DataOutputStream是我们拼装data格式给服务器的类-->
DataOutputStream *output = [[DataOutputStream alloc] init];
<!--首先拼装header数据-->
[output writeTcpProtocolHeaderWithCId:CmdType_MsgSend];
<!--这里是消息数据结构-->
SendRequest *msg = [[SendRequest alloc] init];
msg.senderSeq = seqId;
MsgSendBody *body = [[MsgSendBody alloc] init];
body.mType = msgTyep;
body.to = to;
body.type = contentType;
body.extra = extra;
body.content = content;
msg.msg = body;
[output writeAESBytes:[msg data]];
<!--将拼装好的内容转data准备使用scoket上传-->
<!--[scoket writeData:data withTimeout:-1 tag:999];-->
<!--使用writeData:withTimeout:tag:该方法上传-->
return [output toByteArray];
}
<!--这里是如何拼装header数据 严格安装定义的格式: 先是header长度固定的 再是版本号 再是cid命令号 再试bid-->
-(void)writeTcpProtocolHeaderWithCId:(int16_t)cId
{
[self writeShort:TCP_HEADER_LENGTH];
[self writeShort:VERSION];
[self writeShort:cId];
[self writeInt:bid];
}
<!--举一个转换例子 其它依次类推-->
- (void)writeShort:(int16_t)v {
int8_t ch[2];
ch[0] = (v & 0x0ff00)>>8;
ch[1] = (v & 0x0ff);
[data appendBytes:ch length:2];
length = length 2;
}2、Protobuf
Protocol Buffer是google 的一种数据交换的格式。它独立于语言，独立于平台。平常客户端与服务器都是使用JSON或者XML格式，但是在IM方面Protocol Buffer数据交换会更快，并且数据量更小。因为它是一种二进制数据传输格式。
在与服务器通信过程中，我们肯定要定义一些数据结构，然后再把这些定义的数据以二进制方式上传到服务器。这里就是Protocol Buffer起作用的时候了。这里有一个后缀为.proto的文件，其中定义的就是通信数据格式，之后我们会把这个文件转成OC的.h .m文件。
例如：我们有一个Person数据格式，下面就是如何创建Person.proto文件
<!--指明proto的语法规则是proto2还是proto3-->
syntax = "proto3";
<!--这里是我们定义的Person包含的数据-->
message Person
{
int32 age = 1;
string username = 2;
string phone = 3;
}
<!--这个文件里面还可以把需要的数据格式都定义好-->
message Student
{
}定义好Person.proto文件后就要把它转成OC的.h .m文件，它会以Person对象创建。转换命令如下：
protoc --proto_path=... --objc_out=... XXX.proto其中proto_path是我们创建的proto文件所在目录，objc_out为Objective-C文件输出路径，XXX.proto是我们创建的proto文件，可以一次转换多个proto文件，加在XXX.proto后面即可。
以上将Person.proto文件转换后会在输出文件夹内生成Person.pbobjc.h Person.pbobjc.m文件，将这两个文件放入到项目中，如果项目使用了ARC,要将.m（例子的Person.pbobjc.m）的Complier Flags设为-fno-objc-arc。（protobuf基于性能原因没有使用ARC）。
效果验证：
代码语言：javascript复制- (void)viewDidLoad {
[super viewDidLoad];
Person *person = [[Person alloc] init];
person.age = 100;
person.username = @"huang";
person.phone = @"10086";
<!--直接调用实例方法 转成data格式 这里将在我们上传数据到服务器时使用-->
NSData *data = [person data];
<!--解析服务器返回的data数据-->
Person *p = [Person parseFromData:data error:nil];
NSLog(@"person:%@",p);
}
