网络编程懒人入门(八):手把手教你写基于TCP的Socket长链接

本文原做者:“水晶虾饺”,原文由“玉刚说”写做平台提供写做赞助,原文版权归“玉刚说”微信公众号全部,即时通信网收录时有改动。php

一、引言

好多小白初次接触即时通信(好比:IM或者消息推送应用)时,老是不能理解Web短链接(就是最多见的HTTP通讯了)跟长链接(主要指TCP、UDP协议实现的socket通讯,固然HTML5里的Websocket协议也是长链接)的区别,致使写即时通信这类系统代码时每每找不到最佳实践,搞的一脸蒙逼。html

本篇咱们先简单了解一下 TCP/IP,而后经过实现一个 echo 服务器来学习 Java 的 Socket API。最后咱们聊聊偏高级一点点的 socket 长链接和协议设计。java

另外,本系列文章的前2篇《网络编程懒人入门(一):快速理解网络通讯协议(上篇)》、《网络编程懒人入门(二):快速理解网络通讯协议(下篇)》快速介绍了网络基本通讯协议及理论基础,若是您对网络基础毫无概念,则请务必首先阅读完这2篇文章。本系列的第3篇文章《网络编程懒人入门(三):快速理解TCP协议一篇就够》有助于您快速理解TCP协议理论的方方面面,建议也能够读一读。面试

TCP 是互联网的核心协议之一,鉴于它的重要性,但愿经过阅读上面介绍的几篇理论文章,再针对本文的动手实践,能真正加深您对TCP协议的理解。数据库

若是您正打算系统地学习即时通信开发,在读完本文后,建议您能够详细阅读《新手入门一篇就够:从零开发移动端IM》。编程

学习交流:api

- 即时通信开发交流3群:185926912[推荐]安全

- 移动端IM开发入门文章:《新手入门一篇就够:从零开发移动端IM服务器

(本文同步发布于:http://www.52im.net/thread-1722-1-1.html)微信

二、系列文章

本文是系列文章中的第8篇,本系列文章的大纲以下:

网络编程懒人入门(一):快速理解网络通讯协议(上篇)

网络编程懒人入门(二):快速理解网络通讯协议(下篇)

网络编程懒人入门(三):快速理解TCP协议一篇就够

网络编程懒人入门(四):快速理解TCP和UDP的差别

网络编程懒人入门(五):快速理解为何说UDP有时比TCP更有优点

网络编程懒人入门(六):史上最通俗的集线器、交换机、路由器功能原理入门

网络编程懒人入门(七):深刻浅出,全面理解HTTP协议

网络编程懒人入门(八):手把手教你写基于TCP的Socket长链接》(本文)

若是您以为本系列文章过于基础,您可直接阅读《鲜为人知的网络编程》系列文章,该系列目录以下:

鲜为人知的网络编程(一):浅析TCP协议中的疑难杂症(上篇)

鲜为人知的网络编程(二):浅析TCP协议中的疑难杂症(下篇)

鲜为人知的网络编程(三):关闭TCP链接时为何会TIME_WAIT、CLOSE_WAIT

鲜为人知的网络编程(四):深刻研究分析TCP的异常关闭

鲜为人知的网络编程(五):UDP的链接性和负载均衡

鲜为人知的网络编程(六):深刻地理解UDP协议并用好它

若是您对服务端高性能网络编程感兴趣,能够阅读如下系列文章:

高性能网络编程(一):单台服务器并发TCP链接数到底能够有多少

高性能网络编程(二):上一个10年,著名的C10K并发链接问题

高性能网络编程(三):下一个10年,是时候考虑C10M并发问题了

高性能网络编程(四):从C10K到C10M高性能网络应用的理论探索

关于移动端网络特性及优化手段的总结性文章请见:

现代移动端网络短链接的优化手段总结:请求速度、弱网适应、安全保障

移动端IM开发者必读(一):通俗易懂,理解移动网络的“弱”和“慢”

移动端IM开发者必读(二):史上最全移动弱网络优化方法总结

三、参考资料

TCP/IP详解 - 第11章·UDP:用户数据报协议

TCP/IP详解 - 第17章·TCP:传输控制协议

TCP/IP详解 - 第18章·TCP链接的创建与终止

TCP/IP详解 - 第21章·TCP的超时与重传

通俗易懂-深刻理解TCP协议(上):理论基础

通俗易懂-深刻理解TCP协议(下):RTT、滑动窗口、拥塞处理

理论经典:TCP协议的3次握手与4次挥手过程详解

理论联系实际:Wireshark抓包分析TCP 3次握手、4次挥手过程

计算机网络通信协议关系图(中文珍藏版)

高性能网络编程(一):单台服务器并发TCP链接数到底能够有多少

高性能网络编程(二):上一个10年,著名的C10K并发链接问题

高性能网络编程(三):下一个10年,是时候考虑C10M并发问题了

高性能网络编程(四):从C10K到C10M高性能网络应用的理论探索

简述传输层协议TCP和UDP的区别

为何QQ用的是UDP协议而不是TCP协议?

移动端即时通信协议选择:UDP仍是TCP?

四、TCP/IP 协议简介

TCP/IP协议族是互联网最重要的基础设施之一,若有兴趣了解TCP/IP的贡献,能够读一读此文:《技术往事:改变世界的TCP/IP协议(珍贵多图、手机慎点)》,本文因篇幅缘由仅做简要介绍。

4.1IP协议

首先咱们看 IP(Internet Protocol)协议。IP 协议提供了主机和主机间的通讯。

为了完成不一样主机的通讯,咱们须要某种方式来惟一标识一台主机,这个标识,就是著名的IP地址。经过IP地址,IP 协议就可以帮咱们把一个数据包发送给对方。

4.2TCP协议

前面咱们说过,IP 协议提供了主机和主机间的通讯。TCP 协议在 IP 协议提供的主机间通讯功能的基础上,完成这两个主机上进程对进程的通讯。

有了 IP,不一样主机就可以交换数据。可是,计算机收到数据后,并不知道这个数据属于哪一个进程(简单讲,进程就是一个正在运行的应用程序)。TCP 的做用就在于,让咱们可以知道这个数据属于哪一个进程,从而完成进程间的通讯。

为了标识数据属于哪一个进程,咱们给须要进行 TCP 通讯的进程分配一个惟一的数字来标识它。这个数字,就是咱们常说的端口号。

TCP 的全称是 Transmission Control Protocol,你们对它说得最多的,大概就是面向链接的特性了。之因此说它是有链接的,是说在进行通讯前,通讯双方须要先通过一个三次握手的过程。三次握手完成后,链接便创建了。这时候咱们才能够开始发送/接收数据。(与之相对的是 UDP,不须要通过握手,就能够直接发送数据)。

下面咱们简单了解一下三次握手的过程:

 

首先,客户向服务端发送一个 SYN,假设此时 sequence number 为 x。这个 x 是由操做系统根据必定的规则生成的,不妨认为它是一个随机数;

服务端收到 SYN 后,会向客户端再发送一个 SYN,此时服务器的 seq number = y。与此同时,会 ACK x+1,告诉客户端“已经收到了 SYN,能够发送数据了”;

客户端收到服务器的 SYN 后,回复一个 ACK y+1,这个 ACK 则是告诉服务器,SYN 已经收到,服务器能够发送数据了。

通过这 3 步,TCP 链接就创建了,这里须要注意的有三点:

链接是由客户端主动发起的;

在第 3 步客户端向服务器回复 ACK 的时候,TCP 协议是容许咱们携带数据的。之因此作不到,是 API 的限制致使的;

TCP 协议还容许 “四次握手” 的发生,一样的,因为 API 的限制,这个极端的状况并不会发生。

TCP/IP 相关的理论知识咱们就先了解到这里,若是对TCP的3次握手和4次挥手还不太理解,那就详细读读如下文章:

通俗易懂-深刻理解TCP协议(上):理论基础

通俗易懂-深刻理解TCP协议(下):RTT、滑动窗口、拥塞处理

理论经典:TCP协议的3次握手与4次挥手过程详解

理论联系实际:Wireshark抓包分析TCP 3次握手、4次挥手过程

关于 TCP,还有诸如可靠性、流量控制、拥塞控制等很是有趣的特性。强烈推荐读者看一看 Richard 的名著《TCP/IP 详解 - 卷1》(注意,是第1版,不是第2版)。

 

▲ 网络编程理论经典《TCP/IP 详解 - 卷1》(在线阅读版点此进入

另外,TCP/IP协议实际上是一个庞大的协议族,《计算机网络通信协议关系图(中文珍藏版)》一文中为您清晰展示了这个协议族之间的关系,颇有收藏价值,建议务必读一读。

 

▲ TCP/IP协议族图(高清原图点此进入

下面咱们看一些偏实战的东西。

五、Socket 基本用法

Socket 是 TCP 层的封装,经过 socket,咱们就能进行 TCP 通讯。

在 Java 的 SDK 中,socket 的共有两个接口:用于监听客户链接的 ServerSocket 和用于通讯的 Socket

使用 socket 的步骤以下:

1)建立 ServerSocket 并监听客户链接;

2)使用 Socket 链接服务端;

3)经过 Socket.getInputStream()/getOutputStream() 获取输入输出流进行通讯。

下面,咱们经过实现一个简单的 echo 服务来学习 socket 的使用。所谓的 echo 服务,就是客户端向服务端写入任意数据,服务器都将数据原封不动地写回给客户端。

5.1第一步:建立 ServerSocket 并监听客户链接

(因代码太长,为保证文章体验已在本文中删除,如需查看代码请至连接:http://www.52im.net/thread-1722-1-1.html)

5.2第二步:使用 Socket 链接服务端

(因代码太长,为保证文章体验已在本文中删除,如需查看代码请至连接:http://www.52im.net/thread-1722-1-1.html)

5.3第三步:经过 socket.getInputStream()/getOutputStream() 获取输入/输出流进行通讯

首先,咱们来实现服务端:

(因代码太长,为保证文章体验已在本文中删除,如需查看代码请至连接:http://www.52im.net/thread-1722-1-1.html)

能够看到,服务端的实现其实很简单,咱们不停地读取输入数据,而后写回给客户端。

下面咱们看看客户端:

(因代码太长,为保证文章体验已在本文中删除,如需查看代码请至连接:http://www.52im.net/thread-1722-1-1.html)

客户端会稍微复杂一点点,在读取用户输入的同时,咱们又想读取服务器的响应。因此,这里建立了一个线程来读服务器的响应。

不熟悉 lambda 的读者,能够把Thread readerThread = new Thread(this::readResponse) 换成下面这个代码:

(因代码太长,为保证文章体验已在本文中删除,如需查看代码请至连接:http://www.52im.net/thread-1722-1-1.html)

在客户端,咱们会看到,输入的全部字符都打印了出来。

5.4最后须要注意的有几点

1)在上面的代码中,咱们全部的异常都没有处理。实际应用中,在发生异常时,须要关闭 socket,并根据实际业务作一些错误处理工做;

2)在客户端,咱们没有中止 readThread。实际应用中,咱们能够经过关闭 socket 来让线程从阻塞读中返回。推荐读者阅读《Java并发编程实战》;

3)咱们的服务端只处理了一个客户链接。若是须要同时处理多个客户端,能够建立线程来处理请求。这个做为练习留给读者来彻底。

六、Socket、ServerSocket 傻傻分不清楚

在进入这一节的主题前,读者不妨先考虑一个问题:在上一节的实例中,咱们运行 echo 服务后,在客户端链接成功时,一个有多少个 socket 存在?

答案是 3 个 socket:客户端一个,服务端有两个。跟这个问题的答案直接关联的是本节的主题——Socket 和 ServerSocket 的区别是什么。

眼尖的读者,可能会注意到在上一节我是这样描述他们的:

在 Java 的 SDK 中,socket 的共有两个接口:用于监听客户链接的 ServerSocket 和用于通讯的 Socket。

注意:我只说 ServerSocket 是用于监听客户链接,而没有说它也能够用来通讯。下面咱们来详细了解一下他们的区别。

注:如下描述使用的是 UNIX/Linux 系统的 API。

首先,咱们建立 ServerSocket 后,内核会建立一个 socket。这个 socket 既能够拿来监听客户链接,也能够链接远端的服务。因为 ServerSocket 是用来监听客户链接的,紧接着它就会对内核建立的这个 socket 调用 listen 函数。这样一来,这个 socket 就成了所谓的 listening socket,它开始监听客户的链接。

接下来,咱们的客户端建立一个 Socket,一样的,内核也建立一个 socket 实例。内核建立的这个 socket 跟 ServerSocket 一开始建立的那个没有什么区别。不一样的是,接下来 Socket 会对它执行 connect,发起对服务端的链接。前面咱们说过,socket API 实际上是 TCP 层的封装,因此 connect 后,内核会发送一个 SYN 给服务端。

如今,咱们切换角色到服务端。服务端的主机在收到这个 SYN 后,会建立一个新的 socket,这个新建立的 socket 跟客户端继续执行三次握手过程。

三次握手完成后,咱们执行的 serverSocket.accept() 会返回一个 Socket 实例,这个 socket 就是上一步内核自动帮咱们建立的。

因此说:在一个客户端链接的状况下,其实有 3 个 socket。

关于内核自动建立的这个 socket,还有一个颇有意思的地方。它的端口号跟 ServerSocket 是一毛同样的。咦!!不是说,一个端口只能绑定一个 socket 吗?其实这个说法并不够准确。

前面我说的TCP 经过端口号来区分数据属于哪一个进程的说法,在 socket 的实现里须要改一改。Socket 并不只仅使用端口号来区别不一样的 socket 实例,而是使用 这个四元组。

在上面的例子中,咱们的 ServerSocket 长这样:<*:*, *:9877>。意思是,能够接受任何的客户端,和本地任何 IP。

accept 返回的 Socket 则是这样:<127.0.0.1:xxxx, 127.0.0.1:9877>。其中,xxxx 是客户端的端口号。

若是数据是发送给一个已链接的 socket,内核会找到一个彻底匹配的实例,因此数据准确发送给了对端。

若是是客户端要发起链接,这时候只有 <*:*, *:9877> 会匹配成功,因此 SYN 也准确发送给了监听套接字。

Socket/ServerSocket 的区别咱们就讲到这里。若是读者以为不过瘾,能够参考《TCP/IP 详解》卷1、卷2。

七、Socket “长”链接的实现

7.1背景知识

Socket 长链接,指的是在客户和服务端之间保持一个 socket 链接长时间不断开。

比较熟悉 Socket 的读者,可能知道有这样一个 API:

1socket.setKeepAlive(true);

嗯……keep alive,“保持活着”,这个应该就是让 TCP 不断开的意思。那么,咱们要实现一个 socket 的长链接,只须要这一个调用便可。

遗憾的是,生活并不老是那么美好。对于 4.4BSD 的实现来讲,Socket 的这个 keep alive 选项若是打开而且两个小时内没有通讯,那么底层会发一个心跳,看看对方是否是还活着。

注意:两个小时才会发一次。也就是说,在没有实际数据通讯的时候,我把网线拔了,你的应用程序要通过两个小时才会知道。

这个话题,对于即时通信的老手来讲,也就是常常讨论的“网络链接心跳保活”这个话题了,感兴趣的话能够读一读《聊聊iOS中网络编程长链接的那些事》、《为什么基于TCP协议的移动端IM仍然须要心跳保活机制?》、《微信团队原创分享:Android版微信后台保活实战分享(网络保活篇)》、《Android端消息推送总结:实现原理、心跳保活、遇到的问题等》。

在说明若是实现长链接前,咱们先来理一理咱们面临的问题。

假定如今有一对已经链接的 socket,在如下状况发生时候,socket 将再也不可用:

1)某一端关闭是 socket(这不是废话吗):主动关闭的一方会发送 FIN,通知对方要关闭 TCP 链接。在这种状况下,另外一端若是去读 socket,将会读到 EoF(End of File)。因而咱们知道对方关闭了 socket;

2)应用程序奔溃:此时 socket 会由内核关闭,结果跟状况1同样;

3)系统奔溃:这时候系统是来不及发送 FIN 的,由于它已经跪了。此时对方没法得知这一状况。对方在尝试读取数据时,最后会返回 read time out。若是写数据,则是 host unreachable 之类的错误。

4)电缆被挖断、网线被拔:跟状况3差很少,若是没有对 socket 进行读写,两边都不知道发生了事故。跟状况3不一样的是,若是咱们把网线接回去,socket 依旧能够正常使用。

在上面的几种情形中,有一个共同点就是,只要去读、写 socket,只要 socket 链接不正常,咱们就可以知道。基于这一点,要实现一个 socket 长链接,咱们须要作的就是不断地给对方写数据,而后读取对方的数据,也就是所谓的心跳。只要心还在跳,socket 就是活的。写数据的间隔,须要根据实际的应用需求来决定。

心跳包不是实际的业务数据,根据通讯协议的不一样,须要作不一样的处理。

比方说,咱们使用 JSON 进行通讯,那么,能够为协议包加一个 type 字段,表面这个 JSON 是心跳仍是业务数据:

{

    "type": 0,  // 0 表示心跳

    // ...

}

使用二进制协议的状况相似。要求就是,咱们可以区别一个数据包是心跳仍是真实数据。这样,咱们便实现了一个 socket 长链接。

7.2实现示例

这一小节咱们一块儿来实现一个带长链接的 Android echo 客户端。完整的代码能够在本文末尾的附件找到。

首先了接口部分:

(因代码太长,为保证文章体验已在本文中删除,如需查看代码请至连接:http://www.52im.net/thread-1722-1-1.html)

咱们这个支持长链接的类就叫 LongLiveSocket 好了。若是在 socket 断开后须要重连,只须要在对应的接口里面返回 true 便可(在真实场景里,咱们还须要让客户设置重连的等待时间,还有读写、链接的 timeout等。为了简单,这里就直接不支持了。

另外须要注意的一点是,若是要作一个完整的库,须要同时提供阻塞式和回调式API。一样因为篇幅缘由,这里直接省掉了。

下面咱们直接看实现:

(因代码太长,为保证文章体验已在本文中删除,如需查看代码请至连接:http://www.52im.net/thread-1722-1-1.html)

下面是咱们新实现的 EchoClient:

(因代码太长,为保证文章体验已在本文中删除,如需查看代码请至连接:http://www.52im.net/thread-1722-1-1.html)

就这样,一个带 socket 长链接的客户端就完成了。剩余代码跟咱们这里的主题没有太大关系,感兴趣的读者能够看看文末附件里的源码或者本身完成这个例子。

下面是一些输出示例:

03:54:55.583 12691-12713/com.example.echoI/LongLiveSocket: readResponse: heart beat received

03:55:00.588 12691-12713/com.example.echoI/LongLiveSocket: readResponse: heart beat received

03:55:05.594 12691-12713/com.example.echoI/LongLiveSocket: readResponse: heart beat received

03:55:09.638 12691-12710/com.example.echoD/EchoClient: onSuccess:

03:55:09.639 12691-12713/com.example.echoI/EchoClient: EchoClient: received: hello

03:55:10.595 12691-12713/com.example.echoI/LongLiveSocket: readResponse: heart beat received

03:55:14.652 12691-12710/com.example.echoD/EchoClient: onSuccess:

03:55:14.654 12691-12713/com.example.echoI/EchoClient: EchoClient: received: echo

03:55:15.596 12691-12713/com.example.echoI/LongLiveSocket: readResponse: heart beat received

03:55:20.597 12691-12713/com.example.echoI/LongLiveSocket: readResponse: heart beat received

03:55:25.602 12691-12713/com.example.echoI/LongLiveSocket: readResponse: heart beat received

最后须要说明的是,若是想节省资源,在有客户发送数据的时候能够省略 heart beat。

咱们对读出错时候的处理,可能也存在一些争议。读出错后,咱们只是关闭了 socket。socket 须要等到下一次写动做发生时,才会从新链接。实际应用中,若是这是一个问题,在读出错后能够直接开始重连。这种状况下,还须要一些额外的同步,避免重复建立 socket。heart beat timeout 的状况相似。

八、跟 TCP/IP 学协议设计

若是仅仅是为了使用是 socket,咱们大能够不去理会协议的细节。之因此推荐你们去看一看《TCP/IP 详解》,是由于它们有太多值得学习的地方。不少咱们工做中遇到的问题,均可以在这里找到答案。

如下每个小节的标题都是一个小问题,建议读者独立思考一下,再继续往下看。

8.1协议版本如何升级?

有这么一句流行的话:这个世界惟一不变的,就是变化。当咱们对协议版本进行升级的时候,正确识别不一样版本的协议对软件的兼容很是重要。那么,咱们如何设计协议,才可以为未来的版本升级作准备呢?

答案能够在 IP 协议找到。

IP 协议的第一个字段叫 version,目前使用的是 4 或 6,分别表示 IPv4 和 IPv6。因为这个字段在协议的开头,接收端收到数据后,只要根据第一个字段的值就可以判断这个数据包是 IPv4 仍是 IPv6。

再强调一下,这个字段在两个版本的IP协议都位于第一个字段,为了作兼容处理,对应的这个字段必须位于同一位置。文本协议(如,JSON、HTML)的状况相似。

8.2如何发送不定长数据的数据包?

举个例子,咱们用微信发送一条消息。这条消息的长度是不肯定的,而且每条消息都有它的边界。咱们如何来处理这个边界呢?

仍是同样,看看 IP。IP 的头部有个 header length 和 data length 两个字段。经过添加一个 len 域,咱们就可以把数据根据应用逻辑分开。

跟这个相对的,还有另外一个方案,那就是在数据的末尾放置终止符。比方说,想 C 语言的字符串那样,咱们在每一个数据的末尾放一个 \0 做为终止符,用以标识一条消息的尾部。这个方法带来的问题是,用户的数据也可能存在 \0。此时,咱们就须要对用户的数据进行转义。比方说,把用户数据的全部 \0 都变成 \0\0。读消息的过程总,若是遇到 \0\0,那它就表明 \0,若是只有一个 \0,那就是消息尾部。

使用 len 字段的好处是,咱们不须要对数据进行转义。读取数据的时候,只要根据 len 字段,一次性把数据都读进来就好,效率会更高一些。

终止符的方案虽然要求咱们对数据进行扫描,可是若是咱们可能从任意地方开始读取数据,就须要这个终止符来肯定哪里才是消息的开头了。

固然,这两个方法不是互斥的,能够一块儿使用。

8.3上传多个文件,只有全部文件都上传成功时才算成功

如今咱们有一个需求,须要一次上传多个文件到服务器,只有在全部文件都上传成功的状况下,才算成功。咱们该如何来实现呢?

IP 在数据报过大的时候,会把一个数据报拆分红多个,并设置一个 MF (more fragments)位,表示这个包只是被拆分后的数据的一部分。

好,咱们也学一学 IP。这里,咱们能够给每一个文件从 0 开始编号。上传文件的同时,也携带这个编号,并额外附带一个 MF 标志。除了编号最大的文件,全部文件的 MF 标志都置位。由于 MF 没有置位的是最后一个文件,服务器就能够根据这个得出总共有多少个文件。

另外一种不使用 MF 标志的方法是,咱们在上传文件前,就告诉服务器总共有多少个文件。

若是读者对数据库比较熟悉,学数据库用事务来处理,也是能够的。这里就不展开讨论了。

8.4如何保证数据的有序性?

这里讲一个我曾经遇到过的面试题。如今有一个任务队列,多个工做线程从中取出任务并执行,执行结果放到一个结果队列中。先要求,放入结果队列的时候,顺序顺序须要跟从工做队列取出时的同样(也就是说,先取出的任务,执行结果须要先放入结果队列)。

咱们看看 TCP/IP 是怎么处理的。IP 在发送数据的时候,不一样数据报到达对端的时间是不肯定的,后面发送的数据有可能较先到达。TCP 为了解决这个问题,给所发送数据的每一个字节都赋了一个序列号,经过这个序列号,TCP 就可以把数据按原顺序从新组装。

同样,咱们也给每一个任务赋一个值,根据进入工做队列的顺序依次递增。工做线程完成任务后,在将结果放入结果队列前,先检查要放入对象的写一个序列号是否是跟本身的任务相同,若是不一样,这个结果就不能放进去。此时,最简单的作法是等待,知道下一个能够放入队列的结果是本身所执行的那一个。可是,这个线程就没办法继续处理任务了。

更好的方法是,咱们维护多一个结果队列的缓冲,这个缓冲里面的数据按序列号从小到大排序。

工做线程要将结果放入,有两种可能:

1)刚刚完成的任务恰好是下一个,将这个结果放入队列。而后从缓冲的头部开始,将全部能够放入结果队列的数据都放进去;

2)所完成的任务不能放入结果队列,这个时候就插入结果队列。而后,跟上一种状况同样,须要检查缓冲。

若是测试代表,这个结果缓冲的数据很少,那么使用普通的链表就能够。若是数据比较多,可使用一个最小堆。

8.5如何保证对方收到了消息?

咱们说,TCP 提供了可靠的传输。这样不就可以保证对方收到消息了吗?

很遗憾,其实不能。在咱们往 socket 写入的数据,只要对端的内核收到后,就会返回 ACK,此时,socket 就认为数据已经写入成功。然而要注意的是,这里只是对方所运行的系统的内核成功收到了数据,并不表示应用程序已经成功处理了数据。

解决办法仍是同样,咱们学 TCP,添加一个应用层的 APP ACK。应用接收到消息并处理成功后,发送一个 APP ACK 给对方。

有了 APP ACK,咱们须要处理的另外一个问题是,若是对方真的没有收到,须要怎么作?

TCP 发送数据的时候,消息同样可能丢失。TCP 发送数据后,若是长时间没有收到对方的 ACK,就假设数据已经丢失,并从新发送。

咱们也同样,若是长时间没有收到 APP ACK,就假设数据丢失,从新发送一个。

关于数据送达保证和应应答机制,如下文章进行了详细讨论:

IM消息送达保证机制实现(一):保证在线实时消息的可靠投递

IM消息送达保证机制实现(二):保证离线消息的可靠投递

IM群聊消息如此复杂,如何保证不丢不重?

从客户端的角度来谈谈移动端IM的消息可靠性和送达机制

九、源码附件下载

请从连接:http://www.52im.net/thread-1722-1-1.html 中下载。

附录:更多网络编程资料

技术往事:改变世界的TCP/IP协议(珍贵多图、手机慎点)

UDP中一个包的大小最大能多大?

Java新一代网络编程模型AIO原理及Linux系统AIO介绍

NIO框架入门(一):服务端基于Netty4的UDP双向通讯Demo演示

NIO框架入门(二):服务端基于MINA2的UDP双向通讯Demo演示

NIO框架入门(三):iOS与MINA二、Netty4的跨平台UDP双向通讯实战

NIO框架入门(四):Android与MINA二、Netty4的跨平台UDP双向通讯实战

P2P技术详解(一):NAT详解——详细原理、P2P简介

P2P技术详解(二):P2P中的NAT穿越(打洞)方案详解

P2P技术详解(三):P2P技术之STUN、TURN、ICE详解

通俗易懂:快速理解P2P技术中的NAT穿透原理

>> 更多同类文章 ……

(本文同步发布于:http://www.52im.net/thread-1722-1-1.html)

相关文章
相关标签/搜索