Socket详解

定义

套接字(通信双方C/S协商好的约定),网络上两个程序经过一个双向的通讯链接实现数据的交换,这个连接的一端称为一个Socket.
应用程序经过套接字向网络发出请求或者应答网络请求
Socket简单介绍java

网络通讯的要素

网络请求就是经过Socket创建链接而后互相通讯git

  • IP地址(主机的惟一标识)
  • 端口号(定位程序,标示不一样的进程)
  • 传输协议(通信的规则)
    常见的协议:TCP、UDP

TCP&UDP

TCP-传输控制协议

  • 创建链接,造成传输数据的通道
  • 在链接中可进行大数据传输,数据大小不作限制
  • 经过三次握手完成链接,是可靠协议,安全送达
  • 必须创建链接,效率会下降

UDP-用户数据报协议

  • 将数据源和目的封装到数据包中,不须要创建链接
  • 每一个数据包的大小限制在64K以内
  • 由于不须要链接,所以是不可靠协议
  • 不须要创建链接,速度快

实现Socket服务端监听

使用CocoaAsyncSocket第三方库程序员

Telnet命令 $telnet host port/telnet 192.168.10.10 5288

监听服务端某个端口对应的服务有没有开启shell

Socket层上的协议(数据传输的格式)

1.HTTP协议

超文本传输协议,访问的是远程的网络资源,格式是http://数据库

  • 传输格式-假设
http1.1,content-type:multipart/form-data,content-length:188,body:username=zhangsan&password=123456

2.XMPP协议(即时通信协议)

可扩展的数据传输协议,基于XML的即时通信协议,它用于及时通信(IM),目的是为了保持长链接,以实现即时通信功能
传输格式:(标签对)缓存

<from>zhangsan<from>
<to>lisi<to>
<body>一块儿吃晚上</body>

基本形式:单客户端经过TCP/IP链接到单服务器,而后在之上传输XML流.
(XMPP相似于HTTP的数据传输协议,其过程就如同”解包装->包装”的过程),只须要理解其接收的类型和返回的类型,即可以很好的利用XMPP进行数据通信。XMPP官网-http://xmpp.org
即时通信准备工做:
下载Openfire服务器
下载XMPPFramework框架
解析XML框架KissXML
Openfire服务器默认端口5288安全

XMPP自动重连机制

自动链接 : 若是网络不经过,用户应该自动链接到服务器,以及时接收消息
自动链接机制:2的n次方链接
Pasted Graphic 1.png服务器

在使用XMPP的时候有没有须要什么困难
  • 发送附件(图片,语音,文档…)时比较麻烦
  • XMPP框架没有提供附件传送的功能,须要本身实现
  • 实现方法,把文件上传到文件服务器,上传成功后获取文件保存路径,再把附件的路径发送给好友
环信简介

1.环信是一个即时通讯的服务提供商
2.环信使用的是XMPP协议,它是再XMPP的基础上进行二次开发,对服务器Openfire和客户端进行功能模型的添加和客户端SDK的封装,环信的本质仍是使用XMPP,基本于Socket的网络通讯
3.环信内部实现了数据缓存,会把聊天记录添加到数据库,把附件下载到本地,程序员更多时间是花到界面用户体验上
4.环信内部已经实现了视频,音频,图片,其它附件发送功能
5.环信使用公司能够节约时间成本
不须要公司内部搭建服务器
客户端的开发,使用环信SDK比使用XMPPFramework更简洁方便网络

3.MQTT协议

遥信消息队列传输,轻量级的XMPP,基于TCP的发布订阅协议 通常用于物联网(硬件交互)框架

心跳机制

客户端发送一个心跳给服务端,服务端给客户端一个心跳应答(以保持长链接),若是超过一个时间的阈值,客户端没有收到服务端的应答或者服务器没有收到客户端的心跳,那么客户端会断开链接而后从新创建一个链接,服务器只须要断开这个链接便可。

心跳机制实现流程

实现方式:
MQTT实现方式

实现MQTT协议须要客户端和服务器端通信完成,在通信过程当中,MQTT协议中有三种身份:发布者(Publish)、代理(Broker)(服务器)、订阅者(Subscribe)。其中,消息的发布者和订阅者都是客户端,消息代理是服务器,消息发布者能够同时是订阅者。

各类聊天协议

基于Scoket原生:表明框架 CocoaAsyncSocket
基于WebScoket:表明框架 SocketRocket
基于MQTT:表明框架 MQTTKit
基于XMPP:表明框架 XMPPFramework

心跳检测步骤:

1客户端每隔一个时间间隔发生一个探测包给服务器
2客户端发包时启动一个超时定时器
3服务器端接收到检测包,应该回应一个包
4若是客户机收到服务器的应答包,则说明服务器正常,删除超时定时器
5若是客户端的超时定时器超时,依然没有收到应答包,则说明服务器挂了

发送数据

  • 只有 SR_OPEN 开启状态才能调 send 方法,否则要崩
  • SR_CONNECTING 每隔2秒检测一次 socket.readyState 状态,检测 10 次左右若是 10 次都仍是没连上的,那这个发送请求就丢失了 [self reConnect];
  • SR_CLOSING、SR_CLOSED重连

    重连机制

- (void)reConnect
{
    [self SRWebSocketClose];
    //超过一分钟就再也不重连 因此只会重连5次 2^5 = 64
    if (self.reConnectTime >= 1024) {
        //就是这么调皮
        return;
    }
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(self.reConnectTime * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        self.socket = nil;
        [self SRWebSocketOpenWithURLString:self.urlString];
        //NSLog(@"重连");
    });
    
    //重连时间2的指数级增加
    if (self.reConnectTime == 0) {
        self.reConnectTime = 2;
    }else{
        self.reConnectTime *= 2;
    }
}

Demo仓库地址:

相关文章
相关标签/搜索