天琊出风云起 發表於 2019-5-6 22:06:00

iOS端IM开发从入门到填坑

<div>
<div>
<div class="image-package">
<div class="image-container">
<div class="image-container-fill">&nbsp;</div>
<div class="image-view" data-width="355" data-height="300"><img alt="" data-original-src="//upload-images.jianshu.io/upload_images/1496626-371e417b1f7f5ac2.png" data-original-width="355" data-original-height="300" data-original-format="image/png" data-original-filesize="99423"></div>
</div>
<div class="image-caption">让App聊起来</div>
</div>
<p>IM开发从入门到填坑Demo</p>
<h2>IM的实现方式</h2>
<h3>拿来主义,使用第三方IM服务</h3>
<p>IM的第三方服务商国内有很多,底层协议基本上都是基于TCP的,类似有网易云信、环信、融云、极光IM、LeanCloud、云通讯IM(腾讯)、云旺IM(阿里)、容联云、小能、美洽等等,技术也相对比较成熟,提供后台管理和定制化的UI,拿来主义,半小时集成。</p>
<p>缺点也很明显:定制化程度太高,需要二次开发,很多东西我们不可控,<strong>关键是太贵了</strong>。如果IM对于APP只是一个辅助功能,如客服系统、消息推送等,也基本够用。</p>
<h3>自己动手,切合业务自己实现</h3>
<p>几乎所有互联网IM产品都用服务器中转方式进行消息传输。自己去实现也会面临许多选择:</p>
<p>1、传输协议的选择:TCP还是UDP?<br>2、选择哪种聊天协议进行开发:MQTT、XMPP、基于 Socket 原生或 WebSocket 的私有协议?<br>3、传输数据的格式:用JSON、还是XML、还是谷歌推出的ProtocolBuffer?<br>4、我们还有一些细节问题需要考虑,例如TCP的长连接如何保持,心跳机制,Qos机制,重连机制等等。另外,还有一些安全问题需要考虑。</p>
<h2>一、传输协议的选择</h2>
<p>移动端IM的传输协议选型:TCP还是UDP?<br>TCP:基于连接的可靠协议的全双工的可靠信道,有流量控制、差错控制等,占用系统资源较多,传输效率相对低<br>UDP:基于无连接的不可靠协议,没有足够的控制手段,传输效率高,有丢包问题</p>
<p>TCP和UDP的最完整的区别</p>
<p>基于UDP协议开发成本较高,容易各种丢包或乱序,一般小公司或技术不成熟或即时性要求不高的公司,多用TCP开发。<br>QQ-IM的私有协议:登录等安全性操作使用TCP协议,好友之间发消息主要使用UDP协议,内网传输文件采用了P2P技术,另外腾讯还用了自己的私有协议,来保证传输的可靠性。</p>
<h2>二、聊天协议的选择</h2>
<p>首先我们以实现方式来切入,基本上有以下四种实现方式:</p>
<p>基于Socket原生:代表框架&nbsp;CocoaAsyncSocket。<br>基于WebSocket:代表框架&nbsp;SocketRocket。<br>基于MQTT:代表框架&nbsp;MQTTKit。<br>基于XMPP:代表框架&nbsp;XMPPFramework。</p>
<p>以上四种方式都可以不使用第三方框架,直接基于OS底层Socket去实现我们的自定义封装。其中MQTT和XMPP为聊天协议,是最上层的协议,而WebSocket是传输通讯协议,它是基于Socket封装的一个协议。而上面所说的QQ-IM的私有协议,就是基于WebSocket或者Socket原生进行封装的一个聊天协议。</p>

<br>
<div class="image-package">
<div class="image-container">
<div class="image-container-fill">&nbsp;</div>
<div class="image-view" data-width="1000" data-height="549"><img alt="" data-original-src="//upload-images.jianshu.io/upload_images/1496626-fbd8a63fca9aa7e6.png" data-original-width="1000" data-original-height="549" data-original-format="image/png" data-original-filesize="166071"></div>

</div>
<div class="image-caption">协议优劣对比</div>

</div>
<p>总之,iOS端要做一个真正的IM产品,一般都是基于Socket或WebSocket等,在之上加上一些私有协议来保证的。</p>
<h2>三、实现一个简单的IM</h2>
<h3>1.Socket概述</h3>
<p>Socket其实并不是一个协议,Socket通常也称作”套接字”,是对TCP/IP 或者UDP/IP协议封装的一组编程接口,用于描述IP地址和端口,使用socket实现进程之间的通信(跨网络的)。它工作在 OSI 模型会话层(第5层),Socket是对TCP/IP等更底层协议封装的一个抽象层,是一个调用接口(API)。网络上的两个程序通过一个双向的通讯连接实现数据的交换,这个双向链路的一端称为一个Socket,一个Socket由一个IP地址和一个端口号唯一确定。</p>

<br>
<div class="image-package">
<div class="image-container">
<div class="image-container-fill">&nbsp;</div>
<div class="image-view" data-width="640" data-height="560"><img alt="" data-original-src="//upload-images.jianshu.io/upload_images/1496626-4c09a29d3145c962.png" data-original-width="640" data-original-height="560" data-original-format="image/png" data-original-filesize="57935"></div>

</div>
<div class="image-caption">网络架构</div>

</div>
<p>先看下基于C的BSD Socket提供的接口:</p>
<pre class="hljs cpp"><code class="cpp"><span class="hljs-comment">//socket 创建并初始化 socket,返回该 socket 的文件描述符,如果描述符为 -1 表示创建失败。
<span class="hljs-function"><span class="hljs-keyword">int <span class="hljs-title">socket<span class="hljs-params">(<span class="hljs-keyword">int addressFamily, <span class="hljs-keyword">int type,<span class="hljs-keyword">int protocol)
<span class="hljs-comment">//关闭socket连接
<span class="hljs-keyword">int <span class="hljs-title">close<span class="hljs-params">(<span class="hljs-keyword">int socketFileDescriptor)
<span class="hljs-comment">//将 socket 与特定主机地址与端口号绑定,成功绑定返回0,失败返回 -1。
<span class="hljs-keyword">int <span class="hljs-title">bind<span class="hljs-params">(<span class="hljs-keyword">int socketFileDescriptor,sockaddr *addressToBind,<span class="hljs-keyword">int addressStructLength)
<span class="hljs-comment">//接受客户端连接请求并将客户端的网络地址信息保存到 clientAddress 中。
<span class="hljs-keyword">int <span class="hljs-title">accept<span class="hljs-params">(<span class="hljs-keyword">int socketFileDescriptor,sockaddr *clientAddress, <span class="hljs-keyword">int clientAddressStructLength)
<span class="hljs-comment">//客户端向特定网络地址的服务器发送连接请求,连接成功返回0,失败返回 -1。
<span class="hljs-keyword">int <span class="hljs-title">connect<span class="hljs-params">(<span class="hljs-keyword">int socketFileDescriptor,sockaddr *serverAddress, <span class="hljs-keyword">int serverAddressLength)
<span class="hljs-comment">//使用 DNS 查找特定主机名字对应的 IP 地址。如果找不到对应的 IP 地址则返回 NULL。
hostent* <span class="hljs-title">gethostbyname<span class="hljs-params">(<span class="hljs-keyword">char *hostname)
<span class="hljs-comment">//通过 socket 发送数据,发送成功返回成功发送的字节数,否则返回 -1。
<span class="hljs-keyword">int <span class="hljs-title">send<span class="hljs-params">(<span class="hljs-keyword">int socketFileDescriptor, <span class="hljs-keyword">char *buffer, <span class="hljs-keyword">int bufferLength, <span class="hljs-keyword">int flags)
<span class="hljs-comment">//从 socket 中读取数据,读取成功返回成功读取的字节数,否则返回 -1。
<span class="hljs-keyword">int <span class="hljs-title">receive<span class="hljs-params">(<span class="hljs-keyword">int socketFileDescriptor,<span class="hljs-keyword">char *buffer, <span class="hljs-keyword">int bufferLength, <span class="hljs-keyword">int flags)
<span class="hljs-comment">//通过UDP socket 发送数据到特定的网络地址,发送成功返回成功发送的字节数,否则返回 -1。
<span class="hljs-keyword">int <span class="hljs-title">sendto<span class="hljs-params">(<span class="hljs-keyword">int socketFileDescriptor,<span class="hljs-keyword">char *buffer, <span class="hljs-keyword">int bufferLength, <span class="hljs-keyword">int flags, sockaddr *destinationAddress, <span class="hljs-keyword">int destinationAddressLength)
<span class="hljs-comment">//从UDP socket 中读取数据,并保存发送者的网络地址信息,读取成功返回成功读取的字节数,否则返回 -1 。
<span class="hljs-keyword">int <span class="hljs-title">recvfrom<span class="hljs-params">(<span class="hljs-keyword">int socketFileDescriptor,<span class="hljs-keyword">char *buffer, <span class="hljs-keyword">int bufferLength, <span class="hljs-keyword">int flags, sockaddr *fromAddress, <span class="hljs-keyword">int *fromAddressLength)
</span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></code></pre>
<p>我们用基于OS底层的原生Socket来实现一个简单的IM。<br>socket扩展阅读</p>
<h3>2.搭建IM服务端</h3>
<p><strong>服务端需要做的工作简单的总结下:</strong></p>
<pre class="hljs bash"><code class="bash">1.服务器调用 socket(...) 创建socket;
2.绑定IP地址、端口等信息到socket上,用函数<span class="hljs-built_in">bind();
3.服务器调用 listen(...) 设置缓冲区;
4.服务器通过 accept(...)接受客户端请求建立连接;
5.服务器与客户端建立连接之后,通过 send(...)/receive(...)向客
户端发送或从客户端接收数据;
6.服务器调用 close 关闭 socket;
</span></code></pre>
<p>服务端可以电脑或手机等终端,也可以用多种语言c/c++/java/js等去实现后台,当然OC也可以实现。这里我们借用node.js实现了一个服务端,来验证socket效果。需要在Mac上安装node解释器,node下载,直接下载安装即可,也可以终端命令安装node。<br><strong>开启服务器</strong>:</p>
<pre class="hljs css"><code class="css">1.打开终端
2<span class="hljs-selector-class">.cd到目录 服务端(<span class="hljs-selector-tag">node<span class="hljs-selector-class">.js)
3<span class="hljs-selector-class">.node <span class="hljs-selector-tag">Server<span class="hljs-selector-class">.js   #开启<span class="hljs-selector-tag">IM服务器
</span></span></span></span></span></span></span></code></pre>
<h3>3.实现IM客户端</h3>
<p><strong>IM客户端需要做如下4件事</strong>:</p>
<pre class="hljs bash"><code class="bash">1.客户端调用 socket(...) 创建socket;
2.绑定IP地址、端口等信息到socket上,用函数<span class="hljs-built_in">bind();
3.客户端调用 connect(...) 向服务器发起连接请求以建立连接;
4.客户端与服务器建立连接之后,就可以通过send(...)/receive(...)向客户端发送或从客户端接收数据;
5.客户端调用 close 关闭 socket;
</span></code></pre>
<p><strong>代码实现</strong><br>我们采用CocoaAsyncSocket框架,封装一个名为WYKSocketManager的单例,来对socket相关方法进行调用:<br><strong>为了demo演示方便,代码中使用的时间都较短,实际开发中根据需要设置</strong></p>
<pre class="hljs objectivec"><code class="objectivec"><span class="hljs-meta">#import <span class="hljs-meta-string">"WYKSocketManager.h"
<span class="hljs-meta">#import <span class="hljs-meta-string">"GCDAsyncSocket.h" // for TCP

<span class="hljs-keyword">static <span class="hljs-built_in">NSString *Khost = <span class="hljs-string">@"127.0.0.1";
<span class="hljs-keyword">static uint16_tKport = <span class="hljs-number">6969;
<span class="hljs-keyword">static <span class="hljs-built_in">NSInteger KPingPongOutTime= <span class="hljs-number">3;
<span class="hljs-keyword">static <span class="hljs-built_in">NSInteger KPingPongInterval = <span class="hljs-number">5;

<span class="hljs-class"><span class="hljs-keyword">@interface <span class="hljs-title">WYKSocketManager()&lt;<span class="hljs-title">GCDAsyncSocketDelegate&gt;

<span class="hljs-keyword">@property (<span class="hljs-keyword">nonatomic, <span class="hljs-keyword">strong) GCDAsyncSocket *gcdSocket;
<span class="hljs-keyword">@property (<span class="hljs-keyword">nonatomic, <span class="hljs-keyword">assign) <span class="hljs-built_in">NSTimeInterval reConnectTime;
<span class="hljs-keyword">@property (<span class="hljs-keyword">nonatomic, <span class="hljs-keyword">assign) <span class="hljs-built_in">NSTimeInterval heartBeatSecond;
<span class="hljs-keyword">@property (<span class="hljs-keyword">nonatomic, <span class="hljs-keyword">strong) <span class="hljs-built_in">NSTimer *heartBeatTimer;
<span class="hljs-keyword">@property (<span class="hljs-keyword">nonatomic, <span class="hljs-keyword">assign) <span class="hljs-built_in">BOOL socketOfflineByUser;<span class="hljs-comment">//!&lt; 主动关闭
<span class="hljs-keyword">@property (<span class="hljs-keyword">nonatomic, <span class="hljs-keyword">retain) <span class="hljs-built_in">NSTimer *connectTimer; <span class="hljs-comment">// 计时器

<span class="hljs-keyword">@end

<span class="hljs-class"><span class="hljs-keyword">@implementation <span class="hljs-title">WYKSocketManager

- (<span class="hljs-keyword">void)dealloc
{
    [<span class="hljs-keyword">self destoryHeartBeat];
}

+ (<span class="hljs-keyword">instancetype)share
{
    <span class="hljs-keyword">static <span class="hljs-built_in">dispatch_once_t onceToken;
    <span class="hljs-keyword">static WYKSocketManager *instance = <span class="hljs-literal">nil;
    <span class="hljs-built_in">dispatch_once(&amp;onceToken, ^{
      instance = [[<span class="hljs-keyword">self alloc] init];
      ;
    });
    <span class="hljs-keyword">return instance;
}

- (<span class="hljs-keyword">void)initSocket
{
    <span class="hljs-keyword">self.gcdSocket = [ initWithDelegate:<span class="hljs-keyword">self delegateQueue:dispatch_get_main_queue()];
}

<span class="hljs-meta">#pragma mark - 对外的一些接口
<span class="hljs-comment">//建立连接
- (<span class="hljs-built_in">BOOL)connect
{
    <span class="hljs-keyword">self.reConnectTime = <span class="hljs-number">0;
    <span class="hljs-keyword">return [<span class="hljs-keyword">self autoConnect];
}
<span class="hljs-comment">//断开连接
- (<span class="hljs-keyword">void)disConnect
{
    <span class="hljs-keyword">self.socketOfflineByUser = <span class="hljs-literal">YES;
    [<span class="hljs-keyword">self autoDisConnect];
}

<span class="hljs-comment">//发送消息
- (<span class="hljs-keyword">void)sendMsg:(<span class="hljs-built_in">NSString *)msg
{
    <span class="hljs-built_in">NSData *data = ;
    <span class="hljs-comment">//第二个参数,请求超时时间
    [<span class="hljs-keyword">self.gcdSocket writeData:data withTimeout:<span class="hljs-number">-1 tag:<span class="hljs-number">110];
}

<span class="hljs-meta">#pragma mark - GCDAsyncSocketDelegate
<span class="hljs-comment">//连接成功调用
- (<span class="hljs-keyword">void)socket:(GCDAsyncSocket *)sock didConnectToHost:(<span class="hljs-built_in">NSString *)host port:(uint16_t)port
{
    <span class="hljs-built_in">NSLog(<span class="hljs-string">@"连接成功,host:%@,port:%d",host,port);
    <span class="hljs-comment">//pingPong
    [<span class="hljs-keyword">self checkPingPong];
    <span class="hljs-comment">//心跳写在这...
    [<span class="hljs-keyword">self initHeartBeat];
}

<span class="hljs-comment">//断开连接的时候调用
- (<span class="hljs-keyword">void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(<span class="hljs-keyword">nullable <span class="hljs-built_in">NSError *)err
{
    <span class="hljs-built_in">NSLog(<span class="hljs-string">@"断开连接,host:%@,port:%d",sock.localHost,sock.localPort);
    <span class="hljs-keyword">if (<span class="hljs-keyword">self.delegate &amp;&amp; [<span class="hljs-keyword">self.delegate respondsToSelector:<span class="hljs-keyword">@selector(showMessage:)]) {
      <span class="hljs-built_in">NSString *msg = [<span class="hljs-built_in">NSString stringWithFormat:<span class="hljs-string">@"断开连接,host:%@,port:%d",sock.localHost,sock.localPort];
      [<span class="hljs-keyword">self.delegate showMessage:msg];
    }

    <span class="hljs-keyword">if (!<span class="hljs-keyword">self.socketOfflineByUser) {
      <span class="hljs-comment">//断线/失败了就去重连
      [<span class="hljs-keyword">self reConnect];
    }
}

<span class="hljs-comment">//写的回调
- (<span class="hljs-keyword">void)socket:(GCDAsyncSocket*)sock didWriteDataWithTag:(<span class="hljs-keyword">long)tag
{
    <span class="hljs-built_in">NSLog(<span class="hljs-string">@"写的回调,tag:%ld",tag);
    <span class="hljs-comment">//判断是否成功发送,如果没收到响应,则说明连接断了,则想办法重连
    [<span class="hljs-keyword">self checkPingPong];
}

<span class="hljs-comment">//收到消息
- (<span class="hljs-keyword">void)socket:(GCDAsyncSocket *)sock didReadData:(<span class="hljs-built_in">NSData *)data withTag:(<span class="hljs-keyword">long)tag
{
    <span class="hljs-built_in">NSString *msg = [[<span class="hljs-built_in">NSString alloc]initWithData:data encoding:<span class="hljs-built_in">NSUTF8StringEncoding];
    <span class="hljs-built_in">NSLog(<span class="hljs-string">@"收到消息:%@",msg);
    <span class="hljs-keyword">if (<span class="hljs-keyword">self.delegate &amp;&amp; [<span class="hljs-keyword">self.delegate respondsToSelector:<span class="hljs-keyword">@selector(showMessage:)]) {
      [<span class="hljs-keyword">self.delegate showMessage:[<span class="hljs-built_in">NSString stringWithFormat:<span class="hljs-string">@"收到:%@",msg]];
    }
    <span class="hljs-comment">//去读取当前消息队列中的未读消息 这里不调用这个方法,消息回调的代理是永远不会被触发的
    [<span class="hljs-keyword">self pullTheMsg];
}

<span class="hljs-comment">//为上一次设置的读取数据代理续时 (如果设置超时为-1,则永远不会调用到)
- (<span class="hljs-built_in">NSTimeInterval)socket:(GCDAsyncSocket *)sock shouldTimeoutReadWithTag:(<span class="hljs-keyword">long)tag elapsed:(<span class="hljs-built_in">NSTimeInterval)elapsed bytesDone:(<span class="hljs-built_in">NSUInteger)length
{
    <span class="hljs-built_in">NSLog(<span class="hljs-string">@"来延时,tag:%ld,elapsed:%f,length:%ld",tag,elapsed,length);
    <span class="hljs-keyword">if (<span class="hljs-keyword">self.delegate &amp;&amp; [<span class="hljs-keyword">self.delegate respondsToSelector:<span class="hljs-keyword">@selector(showMessage:)]) {
      <span class="hljs-built_in">NSString *msg = [<span class="hljs-built_in">NSString stringWithFormat:<span class="hljs-string">@"来延时,tag:%ld,elapsed:%.1f,length:%ld",tag,elapsed,length];
      [<span class="hljs-keyword">self.delegate showMessage:msg];
    }
    <span class="hljs-keyword">return KPingPongInterval;
}

<span class="hljs-meta">#pragma mark- Private Methods
- (<span class="hljs-built_in">BOOL)autoConnect
{
    <span class="hljs-keyword">return [<span class="hljs-keyword">self.gcdSocket connectToHost:Khost onPort:Kport error:<span class="hljs-literal">nil];
}

- (<span class="hljs-keyword">void)autoDisConnect
{
    [<span class="hljs-keyword">self.gcdSocket disconnect];
}

<span class="hljs-comment">//监听最新的消息
- (<span class="hljs-keyword">void)pullTheMsg
{
    <span class="hljs-comment">//监听读数据的代理,只能监听10秒,10秒过后调用代理方法-1永远监听,不超时,但是只收一次消息,
    <span class="hljs-comment">//所以每次接受到消息还得调用一次
    [<span class="hljs-keyword">self.gcdSocket readDataWithTimeout:<span class="hljs-number">-1 tag:<span class="hljs-number">110];
}

<span class="hljs-comment">//用Pingpong机制来看是否有反馈
- (<span class="hljs-keyword">void)checkPingPong
{
    <span class="hljs-comment">//pingpong设置为3秒,如果3秒内没得到反馈就会自动断开连接
    [<span class="hljs-keyword">self.gcdSocket readDataWithTimeout:KPingPongOutTime tag:<span class="hljs-number">110];
}

<span class="hljs-comment">//重连机制
- (<span class="hljs-keyword">void)reConnect
{
    <span class="hljs-comment">//如果对一个已经连接的socket对象再次进行连接操作,会抛出异常(不可对已经连接的socket进行连接)程序崩溃
    [<span class="hljs-keyword">self autoDisConnect];
    <span class="hljs-comment">//重连次数 控制3次
    <span class="hljs-keyword">if (<span class="hljs-keyword">self.reConnectTime &gt;= <span class="hljs-number">5) {
      <span class="hljs-keyword">return;
    }
    __<span class="hljs-keyword">weak __<span class="hljs-keyword">typeof(<span class="hljs-keyword">self) weakSelf = <span class="hljs-keyword">self;
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(<span class="hljs-keyword">self.reConnectTime * <span class="hljs-built_in">NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
      __<span class="hljs-keyword">strong <span class="hljs-keyword">typeof(weakSelf) strongSelf = weakSelf;
      <span class="hljs-keyword">if (strongSelf.delegate &amp;&amp; ) {
            <span class="hljs-built_in">NSString *msg = [<span class="hljs-built_in">NSString stringWithFormat:<span class="hljs-string">@"断开重连中,%f",strongSelf.reConnectTime];
            ;
      }
      strongSelf.gcdSocket = <span class="hljs-literal">nil;
      ;
      ;
    });
   
    <span class="hljs-comment">//重连时间增长
    <span class="hljs-keyword">if (<span class="hljs-keyword">self.reConnectTime == <span class="hljs-number">0) {
      <span class="hljs-keyword">self.reConnectTime = <span class="hljs-number">1;
    } <span class="hljs-keyword">else {
      <span class="hljs-keyword">self.reConnectTime += <span class="hljs-number">2;
    }
}

<span class="hljs-comment">//初始化心跳
- (<span class="hljs-keyword">void)initHeartBeat
{
    [<span class="hljs-keyword">self destoryHeartBeat];
    <span class="hljs-comment">// 每隔5s像服务器发送心跳包
    <span class="hljs-keyword">self.connectTimer = [<span class="hljs-built_in">NSTimer scheduledTimerWithTimeInterval:<span class="hljs-number">5
                                                         target:<span class="hljs-keyword">self selector:<span class="hljs-keyword">@selector(longConnectToSocket)
                                                       userInfo:<span class="hljs-literal">nil
                                                      repeats:<span class="hljs-literal">YES];
    <span class="hljs-comment">// 在longConnectToSocket方法中进行长连接需要向服务器发送的讯息
    [<span class="hljs-keyword">self.connectTimer fire];
}

<span class="hljs-comment">// 心跳连接
-(<span class="hljs-keyword">void)longConnectToSocket
{
    <span class="hljs-comment">// 根据服务器要求发送固定格式的数据,但是一般不会是这么简单的指令
    [<span class="hljs-keyword">self sendMsg:<span class="hljs-string">@"心跳连接"];
}

<span class="hljs-comment">//取消心跳
- (<span class="hljs-keyword">void)destoryHeartBeat
{
    <span class="hljs-keyword">if (<span class="hljs-keyword">self.heartBeatTimer&amp;&amp; [<span class="hljs-keyword">self.heartBeatTimer isValid]) {
      [<span class="hljs-keyword">self.heartBeatTimer invalidate];
      <span class="hljs-keyword">self.heartBeatTimer = <span class="hljs-literal">nil;
    }
}

<span class="hljs-keyword">@end
</span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></span></code></pre>
<p>我们发了一条消息,服务端成功的接收到了消息后,把该消息再发送回客户端,绕了一圈客户端又收到了这条消息。至此我们用OS底层socket实现了简单的IM。这里仅仅是实现了Socket的连接并传输字符串,我们要做的远不止于此。</p>
<h3>3.四个重要的功能:心跳机制、PingPong机制、断线重连、消息可达</h3>
<h4>(1)心跳机制</h4>
<p>心跳机制是相对时间内主动向服务器发送心跳包消息,用来检测TCP连接的双方是否可用。TCP的KeepAlive机制只能保证连接的存在,但是并不能保证客户端以及服务端的可用性。<br>扩展阅读:为什么说基于TCP的移动端IM仍然需要心跳保活?<br>真正需要心跳机制的原因其实主要是在于国内运营商的网络地址转换设备超时,对于家用路由器来说, 使用的是网络地址端口转换(NAPT), 它不仅改IP, 还修改TCP和UDP协议的端口号, 这样就能让内网中的设备共用同一个外网IP,造成连接存在,但并不一定可用。</p>
<p><strong>而国内的运营商一般NAT超时的时间为5分钟,频繁心跳会带来耗电和耗流量的弊端,所以通常IM心跳设置的时间间隔为3-5分钟,甚至10分钟都行。</strong>微信有一种更高端的实现方式,有兴趣的小伙伴可以看看:微信的智能心跳实现方式</p>
<h4>(2)PingPong机制</h4>
<p>心跳机制是不能完全保证消息的即时性的,业内的解决方案是辅助采用双向的PingPong机制。</p>

<br>
<div class="image-package">
<div class="image-container">
<div class="image-container-fill">&nbsp;</div>
<div class="image-view" data-width="372" data-height="424"><img alt="" data-original-src="//upload-images.jianshu.io/upload_images/1496626-38fdaaa377f2e761.jpg" data-original-width="372" data-original-height="424" data-original-format="image/jpeg" data-original-filesize="30472"></div>

</div>
<div class="image-caption">PingPong机制</div>

</div>
<p>当服务端发出一个Ping,客户端没有在约定的时间内返回响应的ack,则认为客户端已经不在线,这时我们Server端会主动断开Socket连接,并且改由APNS推送的方式发送消息。<br>同样的是,当客户端去发送一个消息,因为我们迟迟无法收到服务端的响应ack包,则表明客户端或者服务端已不在线,我们也会显示消息发送失败,并且断开Socket连接。</p>
<h4>(3)重连机制</h4>
<p>理论上,自己主动断开的Socket连接(如退出账号,APP退出到后台等),不需要重连。其他的连接断开,我们都需要进行断线重连。 一般解决方案是尝试重连几次,如果仍旧无法重连成功,那么不再进行重连。</p>
<h4>(4)消息可达(即QoS机制)</h4>
<p>在移动网络下,丢包、网络重连等情况非常之多,为了保证消息的可达,一般需要做消息回执和重发机制。<br>一般有三种类型:<br>QOS(0),最多发送一次:如果消息没有发送过去,那么就直接丢失。<br>QOS(1),至少发送一次:保证消息一定发送过去,但是发几次不确定。<br>QOS(2),精确只发送一次:它内部会有一个很复杂的发送机制,确保消息送到,而且只发送一次。</p>
<p>参考易信,每条消息会最多会有3次重发,超时时间为15秒,同时在发送之前会检测当前连接状态,如果当前连接并没有正确建立,缓存消息且定时检查(每隔2秒检查一次,检查15次)。所以一条消息在最差的情况下会有2分钟左右的重试时间,以保证消息的可达。因为重发的存在,接受端偶尔会收到重复消息,这种情况下就需要接收端进行去重。通用的做法是每条消息都戴上自己唯一的message id(一般是uuid)。</p>
<p>扩展阅读:<br>IM消息送达保证机制实现</p>
<h3>4.IM的其他实现方式</h3>
<h4>(1)基于WebSocket最具代表性的一个第三方框架SocketRocket</h4>
<p>实现的思路和基于CocoaAsyncSocket框架类似,需要编写遵守webSocket协议的服务端,感兴趣的也可以参照实现一下。</p>
<h4>(2)基于MQTT协议的框架-MQTTKit</h4>
<p>MQTT是一个聊天协议,它比webSocket更上层,属于应用层,它的基本模式是简单的发布订阅,也就是说当一条消息发出去的时候,谁订阅了谁就会收到消息。其实它并不适合IM的场景,例如用来实现有些简单IM场景,却需要很大量的、复杂的处理。这个框架是c来写的,把一些方法公开在MQTTKit类中,对外用OC来调用,这个库有4年没有更新了。</p>
<h4>(3)基于XMPP协议的框架-MQTTKit</h4>
<p>XMPP是较早的聊天协议(2000年发布第一个公开版本),当时主要是用来打通 ICQ、MSN 等 PC 端的聊天软件而设计的,技术比较成熟,它本身有很多优点,如开放、标准、可扩展,并且客户端和服务器端都有很多开源的实现,但是相对于移动端它也有很明显的缺点,譬如数据负载过重、不支持二进制,在交互中有50% 以上的流量是协议本身消耗的,需要做深度的二次开发。</p>
<h2>三、关于IM通信协议的选择</h2>
<h3>1.序列化与反序列化</h3>
<p>移动互联网相对于有线网络最大特点是:带宽低,延迟高,丢包率高和稳定性差,流量费用高。所以在私有协议的序列化上一般使用二进制协议,而不是文本协议。<br>常见的二进制序列化库有Protocol Buffers和MessagePack,当然你也可以自己实现自己的二进制协议序列化和反序列的过程,比如蘑菇街的TeamTalk。但是前面二者无论是可拓展性还是可读性都完爆TeamTalk(TeamTalk连Variant都不支持,一个int传输时固定占用4个字节),所以大部分情况下还是不推荐自己去实现二进制协议的序列化和反序列化过程。</p>
<p>一条消息数据用Protobuf序列化后的大小是 JSON 的1/10、XML格式的1/20、是二进制序列化的1/10。同 XML 相比, Protobuf 性能优势明显。它以高效的二进制方式存储,比 XML 小 3 到 10 倍,快 20 到 100 倍。</p>
<p>同时心跳包协议对IM的电量和流量影响很大,对心跳包协议上进行了极简设计:仅 1 Byte 。<br>ProtocolBuffer可能会造成 APP 的包体积增大,通过 Google 提供的脚本生成的 Model,会非常“庞大”,Model 一多,包体积也就会跟着变大。<br>如何测试验证 Protobuf 的高性能?<br>对数据分别操作100次,1000次,10000次和100000次进行了测试,<br>纵坐标是完成时间,单位是毫秒</p>

<br>
<div class="image-package">
<div class="image-container">
<div class="image-container-fill">&nbsp;</div>
<div class="image-view" data-width="551" data-height="331"><img alt="" data-original-src="//upload-images.jianshu.io/upload_images/1496626-9b1803abb8c3c8a4.jpg" data-original-width="551" data-original-height="331" data-original-format="image/jpeg" data-original-filesize="36978"></div>

</div>
<div class="image-caption">序列化</div>

</div>

<br>
<div class="image-package">
<div class="image-container">
<div class="image-container-fill">&nbsp;</div>
<div class="image-view" data-width="551" data-height="331"><img alt="" data-original-src="//upload-images.jianshu.io/upload_images/1496626-f9580e7c61bb476e.jpg" data-original-width="551" data-original-height="331" data-original-format="image/jpeg" data-original-filesize="33919"></div>

</div>
<div class="image-caption">反序列化</div>

</div>
<p>Xml,Json,Hessian,Protocol Buffers序列化对比<br>选择传输格式的时候:ProtocolBuffer &gt; JSON &gt; XML<br>ProtocolBuffer for Objective-C 运行环境配置及使用<br>iOS之ProtocolBuffer搭建和示例demo</p>
<h3>2.协议格式设计</h3>
<p>基于TCP的应用层协议一般都分为包头和包体(如HTTP),IM协议也不例外。包头一般用于表示每个请求/反馈的公共部分,如包长,请求类型,返回码等。 而包头则填充不同请求/反馈对应的信息。</p>
<p>一个最简单的包头可以定义为:</p>
<pre class="hljs cpp"><code class="cpp"><span class="hljs-class"><span class="hljs-keyword">struct <span class="hljs-title">PackHeader
{
    <span class="hljs-keyword">int32_t   length_;    <span class="hljs-comment">//包长度
    <span class="hljs-keyword">int32_t   serial_;    <span class="hljs-comment">//包序列号
    <span class="hljs-keyword">int32_t   command_;   <span class="hljs-comment">//包请求类型
    <span class="hljs-keyword">int32_t   code_;      <span class="hljs-comment">//返回码
};
</span></span></span></span></span></span></span></span></span></span></span></code></pre>
<p>以心跳包为例,假设当前的serial为1,心跳包的command为10,那么使用MessagePack做序列化时:length=4,serial=1,command=10,code=0,每个字段各占一个字节,包体为空,仅需要4个字节。</p>
<p>当然这是最简单的一个例子,面对真正的业务逻辑时,包体里面会需要塞入更多地信息,这个需要开发根据自己的业务逻辑总结公共部分,如为了兼容加入的协议版本号,为了负载均衡加入的模块id等。</p>
<h2>四、IM一些其它问题</h2>
<h3>1.IM的可靠性:</h3>
<p>除了心跳机制、PingPong机制、断线重连机制这些被用来保证连接的可用,要提高IM服务时的可靠性,能做的还有很多:比如在大文件传输的时候使用分片上传、断点续传、秒传技术、P2P技术等来保证文件的传输。</p>
<h3>2.安全性:</h3>
<p>我们通常还需要一些安全机制来保证我们IM通信安全。如:加密传输、防止 DNS 污染、帐号安全、第三方服务器鉴权、单点登录等。</p>
<h3>3.一些其他的优化:</h3>
<p>精简心跳包,心跳包只在空闲时发送,动态化心跳间隔。文件上传、下载优化等。类似微信,服务器不做聊天记录的存储,只在本机进行缓存,这样可以减少对服务端数据的请求,一方面减轻了服务器的压力,另一方面减少客户端流量的消耗。<br>我们进行http连接的时候尽量采用上层API,类似NSUrlSession。而网络框架尽量使用AFNetWorking3.0 以上版本。因为这些上层网络请求都用的是HTTP/2 ,我们请求的时候可以复用这些连接。<br>更多优化相关请参考这篇文章:<br>《iOS端移动网络调优的8条建议》<br>IM 即时通讯技术在多应用场景下的技术实现,以及性能调优( iOS 视角)</p>
<h2>五、实时音视频通话</h2>
<p>IM应用中的实时音视频技术,几乎是IM开发中的最后一道高墙。原因在于:实时音视频技术 = 音视频处理技术 + 网络传输技术 的横向技术应用集合体,而公共互联网不是为了实时通信设计的。<br>实时音视频技术上的实现内容主要包括:音视频的采集、编码、网络传输、解码、播放等环节。这么多项并不简单的技术应用,如果把握不当,将会在在实际开发过程中遇到一个又一个的坑。</p>
<p>&nbsp;</p>

</div>

<br><br>作者:择势勤<br>链接:https://www.jianshu.com/p/b1d54fd570ef<br>来源:简书<br>简书著作权归作者所有,任何形式的转载都请联系作者获得授权并注明出处。</div><br><br>
来源:https://www.cnblogs.com/jiaoxiangjie/p/10822486.html
頁: [1]
查看完整版本: iOS端IM开发从入门到填坑