玩转iOS开发：iOS中的Socket编程(三)

时间 2019-11-08

标签 ios 开发 socket 编程栏目 iOS 繁體版

原文原文链接

文章分享至个人我的技术博客: https://cainluo.github.io/14987481154595.htmlhtml

前言

前面第一讲, 讲的是Socket的基础知识, 若是没有去看的能够去了解一下玩转iOS开发：iOS中的Socket编程(一).git

第二讲算是给第一讲补全了, 还有就是深刻了一丢丢, 顺便也把HTTP和HTTPS也讲了一丢丢, 没有去看的朋友也能够去了解一下玩转iOS开发：iOS中的Socket编程(二).github

那么最后这一讲呢, 会把代码给你们奉献上, 我想这也是不少人所期待的.编程

注意: 本文的项目是在Xcode 8.3.3, iOS 10, Mac OS 10.12.5环境下运行的.小程序

Socket的库函数

在咱们的Socket里到底有啥函数能够用呢? 咱们一块儿来看看:服务器

建立Socket的函数微信

// socket()函数用于根据指定的地址族、数据类型和协议来分配一个套接口的描述字及其所用的资源。若是协议protocol未指定(等于0), 则使用缺省的链接方式。
socket(af,type,protocol)

// 将一本地地址与一套接口捆绑。本函数适用于未链接的数据报或流类套接口，在connect()或listen()调用前使用。当用socket()建立套接口后，它便存在于一个名字空间（地址族）中，但并未赋名。bind()函数经过给一个未命名套接口分配一个本地名字来为套接口创建本地捆绑(主机地址/端口号).
bind(sockid, local addr, addrlen)

// 建立一个套接口并监听申请的链接.
listen( Sockid ,quenlen)

// 用于创建与指定socket的链接.
connect(sockid, destaddr, addrlen)

// 在一个套接口接受一个链接.
accept(Sockid，Clientaddr, paddrlen)

// 用于向一个已经链接的socket发送数据，若是无错误，返回值为所发送数据的总数，不然返回SOCKET_ERROR。
send(sockid, buff, bufflen) 

// 用于已链接的数据报或流式套接口进行数据的接收。
recv()

// 指向一指定目的地发送数据，sendto()适用于发送未创建链接的UDP数据包 （参数为SOCK_DGRAM）
sendto(sockid,buff,…,addrlen) 

// 用于从（已链接）套接口上接收数据，并捕获数据发送源的地址。
recvfrom()

// 关闭Socket链接
close(socked)
复制代码

更详细的解释在经常使用socket函数详解里, 你们有须要能够去看看socket

C方式的Socket链接

刚刚说了一堆的只是函数, 那么咱们来看看具体实现的代码, 顺便说说这里只是客户端的代码, 并无服务端的:async

// 须要导入<arpa/inet.h>，<netdb.h>两个头文件

- (void)createSocketConnect {

    NSString *host = @"192.168.1.58";
    NSNumber *port = @8888;

    // 建立 socket
    int socketFileDescriptor = socket(AF_INET, SOCK_STREAM, 0);

    if (socketFileDescriptor == -1) {
    
        NSLog(@"建立失败");
    
        return;
    }

    // 获取 IP 地址 
    struct hostent * remoteHostEnt = gethostbyname([host UTF8String]);

    if (remoteHostEnt == NULL) {

        close(socketFileDescriptor);
    
        NSLog(@"没法解析服务器的主机名");
     
        return;
    }

    struct in_addr * remoteInAddr = (struct in_addr *)remoteHostEnt->h_addr_list[0];

    // 设置 socket 参数
    struct sockaddr_in socketParameters;

    socketParameters.sin_family = AF_INET;
    socketParameters.sin_addr   = *remoteInAddr;
    socketParameters.sin_port   = htons([port intValue]);

    // 链接 socket
    int ret = connect(socketFileDescriptor, (struct sockaddr *) &socketParameters, sizeof(socketParameters));

    if (ret == -1) {

        close(socketFileDescriptor);
    
        NSLog(@"链接失败");
    
        return;
    }

    NSLog(@"链接成功");
}

复制代码

以上就是比较难看懂的C版本的Socket链接的实现方式.函数

iOS中的Socket链接

在iOS中, 咱们有好几种实现方式, 第一个就是使用苹果爸爸提供的数据刘方式, 也就是NSStream来发送和接收数据, 还能够设置数据流的代理, 对数据流的变化作出相对应的操做, 好比创建链接, 接收到数据, 关闭链接等等.

这里解释一下:

NSStream：NSStream继承自CFStream, 是数据流的父类，用于定义抽象特性，例如：打开、关闭代理，
NSInputStream：NSStream的子类，用于读取输入
NSOutputStream：NSStream的子类，用于写输出。

这里我来讲说一个第三方的开源库CocoaAsyncSocket, 就不打算用原生去写了, 有兴趣的能够到苹果爸爸的Simple Code里面去找找, 或者去谷歌, 百度里搜搜一些代码.

这里要说一下, CocoaAsyncSocket是支持TCP和UDP两种传输协议的, 因此不用再本身去写一套.

- (IBAction)connectToServer:(id)sender {

    // 1.与服务器经过三次握手创建链接
    NSString *host = @"192.168.1.58";
    int port = 1212;

    //建立一个socket对象
    _socket = [[GCDAsyncSocket alloc] initWithDelegate:self 
                                         delegateQueue:dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)];

    NSError *error = nil;

    // 开始链接
    [_socket connectToHost:host 
                    onPort:port 
                     error:&error];

    if (error) {
        NSLog(@"%@",error);
    }
}


#pragma mark - Socket代理方法
// 链接成功
- (void)socket:(GCDAsyncSocket *)sock 
didConnectToHost:(NSString *)host 
         port:(uint16_t)port {
         
    NSLog(@"%s",__func__);
}


// 断开链接
- (void)socketDidDisconnect:(GCDAsyncSocket *)sock 
                 withError:(NSError *)err {
    if (err) {
        NSLog(@"链接失败");
    } else {
        NSLog(@"正常断开");
    }
}


// 发送数据
- (void)socket:(GCDAsyncSocket *)sock 
didWriteDataWithTag:(long)tag {

    NSLog(@"%s",__func__);

    //发送完数据手动读取，-1不设置超时
    [sock readDataWithTimeout:-1 
                          tag:tag];
}

// 读取数据
-(void)socket:(GCDAsyncSocket *)sock 
  didReadData:(NSData *)data 
      withTag:(long)tag {
      
    NSString *receiverStr = [[NSString alloc] initWithData:data 
                                                  encoding:NSUTF8StringEncoding];
                                                  
    NSLog(@"%s %@",__func__,receiverStr);
}
复制代码

基本上就酱紫就没啦, 若是以为还不够, 那咱们这里再来补充一个工程.

代码跟上

在这里我会用CocoaAsyncSocket写一个服务端和一个客户端, 服务端使用Mac OS的小程序, 负责输出日志就行了, 客户端就是咱们的iOS端, 须要和服务端对接, 而后和服务端互发送消息.

iOS端:

iOS的代码在IMClient文件夹里, 而整个Socket的逻辑都在ChatContentViewModel里, 代码以下:

#import "ChatContentViewModel.h"

@interface ChatContentViewModel () <GCDAsyncSocketDelegate>

@property (nonatomic, strong, readwrite) GCDAsyncSocket *socket;

@end

@implementation ChatContentViewModel

#pragma mark - Bind IP Host And Post
- (void)createSocketConnect {
    
    NSString *host = @"127.0.0.1";
    NSInteger post = 8080;
    NSError *error;
    
    [self.socket connectToHost:host
                        onPort:post
                         error:&error];
    
    if (error) {
                
        [self socketLogMessageWithString:[NSString stringWithFormat:@"链接失败: %@", error.localizedDescription]];
        
        return;
    }
}

#pragma mark - Init Socket
- (GCDAsyncSocket *)socket {
    
    if (!_socket) {
        
        _socket = [[GCDAsyncSocket alloc] initWithDelegate:self
                                              delegateQueue:dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)];
    }
    
    return _socket;
}

#pragma mark - Socket代理代理方法
// 成功链接
- (void)socket:(GCDAsyncSocket *)sock
didConnectToHost:(NSString *)host
          port:(uint16_t)port {
    
    [self socketLogMessageWithString:[NSString stringWithFormat:@"链接成功: %@", host]];

    [self.socket readDataWithTimeout:-1
                                 tag:0];
}

// 断开链接
- (void)socketDidDisconnect:(GCDAsyncSocket *)sock
                  withError:(NSError *)err {
    if (err) {
        
        [self socketLogMessageWithString:[NSString stringWithFormat:@"链接失败: %@", err.localizedDescription]];
    } else {
        
        [self socketLogMessageWithString:[NSString stringWithFormat:@"正常断开: %@", err.localizedDescription]];
    }
}

// 发送消息
- (void)sendMessageWithString:(NSString *)message {
    
    [self.socket writeData:[message dataUsingEncoding:NSUTF8StringEncoding]
               withTimeout:-1
                       tag:0];
    
    NSString *sendMessage = [NSString stringWithFormat:@"发送给服务器的消息: %@", message];
    
    [self socketLogMessageWithString:sendMessage];
}

// 发送数据后的回调方法
- (void)socket:(GCDAsyncSocket *)sock
didWriteDataWithTag:(long)tag {
    
    // 发送完数据手动读取，-1不设置超时
    [self.socket readDataWithTimeout:-1
                                 tag:0];
    
    NSLog(@"消息发送成功, 用户ID号为: %ld", tag);
}

// 读取数据
- (void)socket:(GCDAsyncSocket *)sock
   didReadData:(NSData *)data
       withTag:(long)tag {
        
    if (!data) {
        
        [self socketLogMessageWithString:@"并无接收到服务器的消息"];
        
        return;
    }
    
    NSString *receiverStr = [[NSString alloc] initWithData:data
                                                  encoding:NSUTF8StringEncoding];
    
    NSLog(@"读取数据成功: %@", receiverStr);
    
    
    NSString *sendMessage = [NSString stringWithFormat:@"接收到的服务器消息: %@", receiverStr];
    
    [self socketLogMessageWithString:sendMessage];
}

#pragma mark - Log Message
- (void)socketLogMessageWithString:(NSString *)string {
    
    dispatch_async(dispatch_get_main_queue(), ^{

        if (self.chatContentSendMessage) {
            
            self.chatContentSendMessage(string);
        }
    });
}

@end
复制代码

布局代码这里就不演示了, 没啥好演示的, 效果图:

Mac端

Mac的Socket逻辑在SocketViewModel文件夹里, 主要代码:

#import "SocketViewModel.h"

@interface SocketViewModel () <GCDAsyncSocketDelegate>

@property (nonatomic, strong) GCDAsyncSocket *serverSocket;
@property (nonatomic, strong) GCDAsyncSocket *clientSocket;

@end

@implementation SocketViewModel

#pragma mark - 绑定IP地址和端口号
- (void)createSocketWithClient {
    
    NSInteger post = 8080;
    NSError *error;
    
    [self.serverSocket acceptOnPort:post
                              error:&error];
    
    if (error) {
        
        NSString *errorString = [NSString stringWithFormat:@"链接客户端失败: %@", error.localizedDescription];
        
        [self changeLogTextViewWithString:errorString];

        return;
    }
}

- (void)sendMessageToClientWithString:(NSString *)string {
    
    [self.clientSocket writeData:[string dataUsingEncoding:NSUTF8StringEncoding]
                     withTimeout:-1
                             tag:0];

    NSString *sendMessage = [NSString stringWithFormat:@"发送的消息为: %@", string];
    
    [self changeLogTextViewWithString:sendMessage];
}

- (void)socket:(GCDAsyncSocket *)sock
didWriteDataWithTag:(long)tag {
    
    [self redClientSocket];
}

- (void)redClientSocket {
    
    [self.clientSocket readDataWithTimeout:-1
                                       tag:0];
}

#pragma mark - Init Socket
- (GCDAsyncSocket *)serverSocket {
    
    if (!_serverSocket) {
        
        _serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self
                                             delegateQueue:dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)];
    }
    
    return _serverSocket;
}

#pragma mark - Socket Delegate
- (void)socket:(GCDAsyncSocket *)sock
didAcceptNewSocket:(GCDAsyncSocket *)newSocket {

    if (!newSocket) {
        
        [self changeLogTextViewWithString:@"连接客户端失败"];

        return;
    }
    
    self.clientSocket = newSocket;
    
    [self changeLogTextViewWithString:@"客户端链接成功"];
    
    [self redClientSocket];
}

- (void)socket:(GCDAsyncSocket *)sock
   didReadData:(NSData *)data
       withTag:(long)tag {
    
    
    NSString *getMessage = @"";

    if (!data) {
        
        getMessage = @"读取数据失败";
        
        return;
    }
    
    NSString *string = [[NSString alloc] initWithData:data
                                             encoding:NSUTF8StringEncoding];
    
    getMessage = [NSString stringWithFormat:@"接收的消息为: %@", string];
    
    [self changeLogTextViewWithString:getMessage];
    
}

#pragma mark - Socket Log
- (void)changeLogTextViewWithString:(NSString *)string {
    
    if (self.messageWithClientSocket) {
        
        self.messageWithClientSocket(string);
    }
}

@end
复制代码

看完以后, 这里须要注意一下, 因为是服务端, 这边是须要两个Socket, 一个是负责连接客户端, 一个是发送和读取客户端发来的消息.

Mac OS的布局都是在Storyboard, 这里就不演示了, 效果图:

开始链接

这里须要注意一点, Socket链接须要先开启服务端, 因此这里我是优先运行Mac OS的代码, 最后才运行iOS的代码, 因为我这里的设备问题, 因此效果图有些诧异, 你们看完以后能够自行去试试:

最后贴上几篇我的以为不错的博文:

iOS 使用 socket 即时通讯（非第三方库）

iOS之GCDAsyncSocket(TCP)

iOS即时通信进阶 - CocoaAsyncSocket源码解析(Read篇终)

工程地址:

项目地址: https://github.com/CainRun/iOS-NetWork/tree/master/Socket编程(三)

最后

码字很费脑, 看官赏点饭钱可好