CocoaAsyncSocket实现局域网内通讯

内容概要

利用CocoaAsyncSocket实现局域网内 iOS设备间的简单通信.

结构

1,服务端,用于接受客户端链接.
2,客户端,向服务端发起链接
3,通信协议,两端都遵照协议格式进行数据收发无误 
复制代码

代码

通信协议

很是简略的协议只为实现简单的文字通信功能

1,长度包: |内容包长度(8bit)|
2,内容爆: |消息类型(1bit)|传输内容(不定)|
复制代码

客户端

1,建立GCDSocket

self.socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
//设置代理 和 代理队列,代理方法将在代理队列中执行
//其实也能够为其中的socket通信执行的队列,可是,队列需要为串行队列,保持数据成流
复制代码

2, 开始链接

///连接至指定ip
-(BOOL)connectToIP:(NSString*)ip{
    NSError* err;
    //此处端口号为服务端监听端口
   [self.socket connectToHost:ip onPort:8866 error:&err];
    NSLog(@"===%@===",err);
    return YES;
}

-(void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port{
    //开始读取操做,由于为阻塞式,会等待直至有数据返回,进行读取
    [self.socket readDataToLength:8 withTimeout:-1 tag:IMDataTag_Length];
    NSLog(@"===服务端接受连接===");
}
复制代码

3,写入数据

//发送模型
-(void)writeStr:(id<IMModelProtocol>)model{
//将要发送的模型转换为原始数据
    NSData* data = [model getSendData];

//发送数据长度包,表示后续内容包的长度
    [self.socket writeData:[data subdataWithRange:NSMakeRange(0, 8)] withTimeout:-1 tag:0];

//发送内容包    
    [self.socket writeData:[data subdataWithRange:NSMakeRange(8, data.length-8)] withTimeout:-1 tag:0];
    
}
复制代码

4,读取数据

-(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag{
    switch (tag) {
        case IMDataTag_Length:  //得到长度
            self.currentDataLength = [self.analy getDataTotalLength:data];
            //获取长度后,进行内容读取
            [self.socket readDataToLength:self.currentDataLength withTimeout:-1 tag:IMDataTag_Content];
            break;
        case IMDataTag_Content: //得到内容
        {
        
        //将原始数据转换为须要的模型(我讲模型与Data转化的方法为了简介提到了外面)
            id<IMModelProtocol> model = [self.analy getIMDataModelWithTotalLength:self.currentDataLength andData:data];
            [[NSNotificationCenter defaultCenter] postNotificationName:IMGetModelNoti object:model];
            [self.socket readDataToLength:8 withTimeout:-1 tag:IMDataTag_Length];
        }
            break;
    }
}
复制代码

服务端

1,建立接口监听的socket

//此socket用来监听接口,是否有服务端连接
self.socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];

//监听 8886接口
[self.socket acceptOnPort:8866 error:nil];
复制代码

2,接受到客户端连接请求

//当接受到连接请求时 回调该代理方法
-(void)socket:(GCDAsyncSocket *)sock didAcceptNewSocket:(GCDAsyncSocket *)newSocket{

// newSocket是对客户端连接的封装,若想保持链接,则将newSocket持有
// 对客户端的 断开,读取,写入都是对newSocket进行的
    self.clientSsocket = newSocket;
    newSocket.delegate = self.clientDelegate;
    [newSocket setDelegateQueue:dispatch_get_global_queue(0, 0)];
    //直接开始读取(由于为阻塞式的)
    [newSocket readDataToLength:8 withTimeout:-1 tag:IMDataTag_Length];
    
}
复制代码

而后对newSocket的读写操做就和客户端同样了. 效果以下,一个是虚拟机,一个是真机

其余

应为NAT的存在,因此这里只实现了在局域网下的通信,若想实现真正的想微信那样的通信, 还须要本身再路由器下映射的端口号,实现内网穿透, 此外 还有不少细节须要实现~~ 路漫漫其修远兮~~