socket 断线重连和心跳机制如何实现?

server/2024/9/20 13:36:11/ 标签: 面试, 计算机网络, socket, 心跳, tcp, http, 保活

一、socket 概念

1.套接字(socket)是网络通信的基石,是支持 TCP/IP 协议的网络通信的基本操作单元。它是网络通信过程中端点的抽象表示,包含进行网络通信必须的五种信息:连接使用的协议,本地主机的 IP 地址,本地进程的通信端口,远程主机的 IP 地址,远程进程的通信端口。

2.为了区别不同的应用程序进程和连接,许多计算机操作系统为应用程序与 TCP/IP 协议交互提供了套接字(socket)接口进行编程。

3.应用层和传输层可以通过 socket 接口,区分来自不同应用程序进程或网络连接的通信,实现数据通信的并发服务。

二、建立 socket 连接

1.建立 socket 连接至少需要一对套接字,其中一个运行于客户端,称为 ClientSocket ,另一个运行于服务端,称为 ServerSocket 。

2.套接字之间的连接过程分为三个步骤:服务端监听,客户端请求,连接确认。

1)服务端监听
服务端套接字并不仅限于具体的客户端套接字,而是处于等待连接的状态,实时监控网络状态,等待客户端的连接请求。

2)客户端请求
客户端的套接字向要连接的目标服务端的套接字提出连接请求。
为此,客户端的套接字必须首先描述它要连接的服务端的套接字,指出服务端套接字的地址和端口号,然后就可以向服务端套接字提出连接请求。 

3)连接确认
当服务端套接字监听到或者接收到客户端套接字的连接请求时,就会去响应客户端套接字的请求,建立一个新的线程,把服务端套接字的描述发 给客户端,一旦客户端确认了此描述,双方就正式建立连接。

此外,服务端套接字继续处于监听状态,继续接收其他客户端套接字的连接请求。


3.socket 连接与 HTTP 连接

1)创建 socket 连接时,可以指定使用某个传输层协议,socket 支持不同的传输层协议(TCP(Transmission Control Protocol)或 UDP(User Datagram Protocol))。
当使用 TCP 协议进行连接时,该 socket 连接就是一个 TCP 连接。

2)socket 连接
通常情况下 socket 连接就是 TCP 连接,因此 socket 连接一旦建立,通信双方即可开始互相发送数据内容,直到双方连接断开。
但在实际网 络应用中,客户端与服务端之间的通信往往需要穿越多个中间节点,例如路由器、网关、防火墙等。大部分防火墙默认会关闭长时间处于非活跃状态的连接而导致 socket 连接断连,因此需要通过轮询告诉网络,该连接处于活跃状态。

3)HTTP连接 HTTP连接使用的是"请求—响应"的方式,不仅在请求时需要先建立连接,而且需要客户端向服务端发出请求后,服务端才能返回数据。

很多情况下,需要服务端主动向客户端推送数据,保持客户端与服务端数据的实时与同步。
此时若双方建立的是 socket 连接,服务端就可以直接将数 据传送给客户端。
若双方建立的是 HTTP 连接,则服务端需要等到客户端发送一次请求后才能将数据返回给客户端。
因此,客户端定时向服务端发送连接请求,不仅可以保持在线,同时也是在"询问"服务端是否有新的数据,如果有就将数据传给客户端。

备注:(在HTTP/2及以上版本里,已经可以实现服务端向客户端主动发送数据的逻辑。)


三、socket断线重连和心跳机制

1.socket 断线重连实现

1)正常连接断开时客户端会给服务端发送一个 fin 包,服务端收到 fin 包后才会知道连接准备断开。

2)而断网断电时客户端无法发送 fin 包给服务端,所以服务端就没办法检测到客户端是否已经断线。

3)为了解决这个问题,服务端需要有个心跳逻辑,就是服务端检测到某个客户端多久没发送任何数据过来就认为客户端已经断开, 这需要客户端定时向服务端发送心跳数据维持连接。

2.socket心跳机制实现

1)长连接的实现
心跳机制,应用层协议大多都有 HeartBeat(心跳) 机制,通常是客户端每隔一小
段时间向服务端发送一个数据包,通知服务端自己仍然在线,并传输一些可能必要的数据。
使用心跳包的典型协议是 IM(Instant Messaging,即时通信),比如 微信/QQ/MSN/飞信等应用。

2)在 TCP 传输层协议 的机制里面,本身也是存在心跳包机制的,那就是 TCP 的选项:SO_KEEPALIVE。
系统默认设置的是 2 小时的心跳频率。但是它检查不到机器断电、网线拔出、防火墙这些断线。 
逻辑层处理断线可能也不是那么好处理。一般,如果只是用于保活还是可以的。
通过使用 TCP 的 KeepAlive 机制(修改 SO_KEEPALIVE参数),可以让连接每隔一小段时间就产生一些 ack 包,以降低被服务端断开的风险。当然,这样的代价是额外的网络和 CPU 负担。

四、应用层心跳机制实现

1.定义心跳包的格式和大小。

2.在客户端和服务端分别设置定时器(一般几秒到几十秒之间),用于定时发送心跳包。

3.定时器触发,由客户端或服务端发送心跳包给到对端。

4.接收方收到心跳包后,应立即发送一个响应包给发送端,以确保连接仍然活跃。

5.若发送方在一定时间内未收到响应包,则认为连接已经断开或对方无响应。此时需要进行处理,如重建连接、记录日志、通知用户等。


微风不燥,阳光正好,你就像风一样经过这里,愿你停留的片刻温暖舒心。

我是程序员小迷(致力于C、C++、Java、Kotlin、Android、iOS、Shell、JavaScript、TypeScript、Python等编程技术的技巧经验分享),若作品对您有帮助,请关注、分享、点赞、收藏、在看、喜欢,您的支持是我们为您提供帮助的最大动力。

欢迎关注。助您在编程路上越走越好!


http://www.ppmy.cn/server/114016.html

相关文章

WordPress安装指南:主题、插件和最佳实践

WordPress是世界上最流行的内容管理系统(CMS),因其易用性和灵活性而备受欢迎。本文将指导您完成WordPress的安装过程,介绍一些常用的主题和插件,并分享一些重要的注意事项。 1. WordPress安装 步骤1:准备…

【Linux】System V通信

目录 System V共享内存 共享内存数据结构 共享内存函数 共享内存的关联 共享内存的去关联 用共享内存实现serve&client通信 共享内存与管道进行对比 System V共享内存 管道通信本质是基于文件的,也就是说操作系统并没有为此做过多的设计工作,…

设计模式六大原则

设计模式的六大原则,也称为SOLID原则,是面向对象编程中用于指导软件设计的一套基本原则。这些原则旨在帮助开发者创建可维护、可扩展、灵活且易于理解的代码。 1. 单一职责原则(Single Responsibility Principle, SRP) 含义&…

Anaconda Prompt 安装paddle2.6报错

bug描述 python 3.11.9 通过 pip install paddlepaddle2.6.1 安装后,运行 paddle.utils.run_check() 则出现下面的错误: 解决办法 方法一:使用paddle 3的版本 这里要注意我的python版本 方法二:使用低版本的python python3.9…

基于EPS32C3电脑远程开机模块设计

基于EPS32C3电脑远程开机模块设计 前言 缘起,手头资料太多了,所以想组一台NAS放在家里存储数据。在咸鱼淘了一套J3160主板加机箱,加上几块硬盘组建NAS。 对于NAS,我的需求是不用的时候关机(节省功耗),要用的时候开机…

Ubuntu16.04操作系统-内核优化

1. 概述 本文所用优化是生产环境中经过长期验证的内核优化策略,针对的服务器与POD主要用于高CPU、高内存、高IO的业务场景。 备注: OS: ubuntu16.04, 内核: 4.15.0-147-generic 主要涵盖以下内容优化: ulimit优化加强tcp参数其他内存参数 …

深度学习(一)-感知机+神经网络+激活函数

深度学习概述 深度学习的特点 优点 性能更好 不需要特征工程 在大数据样本下有更好的性能 能解决某些传统机器学习无法解决的问题 缺点 小数据样本下性能不如机器学习 模型复杂 可解释性弱 深度学习与传统机器学习相同点 深度学习、机器学习是同一问题不同的解决方法 …

.Net Core 笔试1

1、用两个线程一个输出字母一个输出数字,交替输出Chat数组 char[] aI "1234567".ToCharArray();char[] aC "ABCDEFG".ToCharArray();Task task1 null;Task task2 null;task1 Task.Run(() >{foreach (var item in aI){Console.WriteLine…

2024数学建模国赛ABCDE题选题分析及初步思路

高教社杯全国大学生数学建模竞赛(以下简称“国赛”)是面向全国大学生的一项重要赛事,旨在培养学生的数学建模能力、团队合作能力和科学研究能力。近年来,国赛的参赛人数和比赛难度不断提升,对参赛者的数学建模能力提出…

上海亚商投顾:深成指、创业板指均涨超1%,华为产业链反复活跃

上海亚商投顾前言:无惧大盘涨跌,解密龙虎榜资金,跟踪一线游资和机构资金动向,识别短期热点和强势个股。 一.市场情绪 大小指数昨日走势分化,沪指全天震荡调整,2800点失而复得,深成指、创业板指…

C++之格式化日期时间为字符串(精确到毫秒)

C11中提供了获取时间的chrono库&#xff0c;但是格式化显示太方便&#xff1b;C11还提供了格式化时间iomanip库&#xff0c;通过其put_time方法可以格式化时间到秒&#xff0c;要显示毫秒&#xff0c;就需要自己处理了。 #include <chrono> #include <string> #in…

LiveQing视频点播流媒体RTMP推流服务功能-支持大疆等无人机RTMP推流支持OBS推流一步一步搭建RTMP视频流媒体服务示例

LiveQing支持大疆等无人机RTMP推流支持OBS推流一步一步搭建RTMP视频流媒体服务示例 1、流媒体服务搭建2、推流工具准备3、创建鉴权直播间4、获取推流地址5、配置OBS推流6、推流及播放7、获取播放地址7.1 页面查看视频源地址7.2 接口查询 8、相关问题8.1、大疆无人机推流花屏 9、…

nginx配置中的服务器名称

通常&#xff0c;在nginx的配置节中&#xff1a; server {listen 80;server_name example.org www.example.org;... } server_name(服务器名称) 指令定义确定哪个服务器块用于给定请求。可以使用确切名称、通配符名称、ip地址或正则表达式来定义它们&#xff1a; se…

Excel 将行和列转置的两种方法

方法一&#xff1a; 方法二&#xff1a;使用transpose公式

.NetCore+vue3上传图片 Multipart body length limit 16384 exceeded.

实现目标。点击图片上传头像 效果图 前端部分图片上传关键代码 <div class"avatar-wrap"><el-imagestyle"width: 154px; height: 154px":src"form.headPic":fit"fit"/></div><div class"upload-box"…

Android 串口数据分包处理

/* class PacketHandler { private static final byte PACKET_START 0x79; // 假设包的开始标记为0x79 private static final byte PACKET_END 0x0D; // 假设包的结束标记为0x0D private static ByteArrayOutputStream buffer new ByteArrayOutputStream();public static v…

区块链基础

密码学原理 密码学中的哈希原理有两个重要的性质 1 collision resistance 碰撞防御 亦或者称为collision free,主要是为了保密性。由于人为难以制造hash碰撞&#xff0c;因此hash可以用作与验证 2 hiding hash值可以从x -> f(x)&#xff0c;但是难以通过f(x)去反推出x。 验…

[数据集][目标检测]人脸口罩佩戴目标检测数据集VOC+YOLO格式8068张3类别

数据集格式&#xff1a;Pascal VOC格式YOLO格式(不包含分割路径的txt文件&#xff0c;仅仅包含jpg图片以及对应的VOC格式xml文件和yolo格式txt文件) 图片数量(jpg文件个数)&#xff1a;8068 标注数量(xml文件个数)&#xff1a;8068 标注数量(txt文件个数)&#xff1a;8068 标注…

数据库英雄:探索MySQL高可用性的秘密武器

目录 一、引言 1.1 数据库高可用性的重要性 1.2 MySQL在现代架构中的角色 二、MySQL集群技术概览 2.1 集群技术的定义和目标 2.2 MySQL集群的类型和用例 三、搭建MySQL组从复制环境 3.1 环境准备和依赖安装 3.2 配置组从复制 3.3 当有数据时添加slave2 四、深入理解M…

Matlab simulink建模与仿真 第八章(数学运算库)【上】

参考视频&#xff1a;simulink1.1simulink简介_哔哩哔哩_bilibili 一、数学运算库中的模块概览 二、与加减相关的模块 1、Add加法模块与Subtract减法模块 &#xff08;1&#xff09;Add模块与Subtract模块的功能基本完全相同&#xff0c;不同的是它们的默认配置不一样&#…