内容概要

利用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的读写操作就和客户端一样了.
效果如下,一个是虚拟机,一个是真机

Socket1.gif

其他

应为NAT的存在,所以这里只实现了在局域网下的通讯,若想实现真正的想微信那样的通讯, 还需要自己再路由器下映射的端口号,实现内网穿透, 此外 还有很多细节需要实现~~ 路漫漫其修远兮~~