iOS自建IM相关

- (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];
        //执行相关逻辑
    }
}

+ (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;
}

<!--指明proto的语法规则是proto2还是proto3-->
syntax = "proto3";
 <!--这里是我们定义的Person包含的数据-->
message Person
{
int32 age = 1;
string username = 2;
string phone = 3;
}
<!--这个文件里面还可以把需要的数据格式都定义好-->
message Student 
{

}

protoc --proto_path=... --objc_out=... XXX.proto

- (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);
 
}