【Linux】Socket中的心跳机制(心跳包)

Socket中的心跳机制(心跳包)

1. 什么是心跳机制？(心跳包)

在客户端和服务端长时间没有相互发送数据的情况下，我们需要一种机制来判断连接是否依然存在。直接发送任何数据包可以实现这一点，但为了效率和简洁，通常发送一个空包，这个就是心跳包。

心跳包类似心跳，每隔固定时间发送一次，通知服务器客户端依然活着。它是一种保持长连接的机制，包的内容没有特别规定，通常是很小的包或仅包含包头的空包。
在这里插入图片描述

心跳包可以由客户端发到服务器，也可以由服务器发到客户端，但一般是客户端发到服务器。发送心跳包需要额外的线程，不能和正常数据发送的线程混在一起。发送间隔根据具体业务情况决定，通常在while循环中加sleep()函数即可。

2. 心跳包的实现技术

心跳包可以通过两种方式实现：

2.1 应用层自实现：

由应用程序自己发送心跳包来检测连接是否正常，服务器每隔一定时间向客户端发送一个短小的数据包，然后启动一个线程，在线程中不断检测客户端的回应， 如果在一定时间内没有收到客户端的回应，即认为客户端已经掉线；同样，如果客户端在一定时间内没有收到服务器的心跳包，则认为连接不可用

2.2 使用SO_KEEPALIVE套接字选项：

在TCP机制中，默认存在一个心跳频率为2小时的机制，但无法检测断电、网线拔出、防火墙等断线情况。因此，在逻辑层常用空包发送来实现心跳包。服务器定时发送空包给客户端，客户端收到后回复一个同样的空包，服务器如果在一定时间内未收到回复则认为客户端掉线。在长连接下，如果一段时间没有数据往来，有可能会被中间节点断开连接，因此需要心跳包维持连接。一旦断线，服务器逻辑可能需要清理数据、重新连接等处理。通常情况下，心跳包的判定时间为30-40秒，要求高时可缩短至6-9秒。

1. setsockopt函数介绍

setsockopt函数用于设置与某个套接字关联的选项。选项可能存在于多层协议中，但它们总会出现在最上面的套接字层。要操作套接字层的选项，应该将层的值指定为SOL_SOCKET。要操作其他层的选项，需要提供合适的协议号。函数原型如下：

int setsockopt(int sock, int level, int optname, const void *optval, socklen_t optlen)
  • sock: 将要被设置选项的套接字
  • level: 选项所在的协议层
  • optname: 需要访问的选项名
  • optval: 指向包含新选项值的缓冲
  • optlen: 现选项的长度
2. 心跳机制的实现

在TCP客户端代码中加入心跳机制，使服务端在断网重连后能自动保持连接。

#include "socket_tcp_server.h"
#include "tcp_keepalive.h"
#include "socket_wrap.h"
#include "ctype.h"
#include "FreeRTOS.h"
#include "task.h"static char ReadBuff[BUFF_SIZE];void vTcpKeepaliveTask(void){int cfd, n, i, ret;struct sockaddr_in server_addr;int so_keepalive_val = 1;int tcp_keepalive_idle = 3;int tcp_keepalive_intvl = 3;int tcp_keepalive_cnt = 3;int tcp_nodelay = 1;again:	//创建socketcfd = Socket(AF_INET, SOCK_STREAM, 0);//使能socket层的心跳检测setsockopt(cfd, SOL_SOCKET, SO_KEEPALIVE, &so_keepalive_val, sizeof(int));server_addr.sin_family = AF_INET;server_addr.sin_port = htons(SERVER_PORT);server_addr.sin_addr.s_addr = inet_addr(SERVER_IP);//连接到服务器ret = Connect(cfd, (struct sockaddr*)&server_addr, sizeof(server_addr));if(ret < 0){//100ms去连接一次服务器vTaskDelay(100);goto again;}//配置心跳检测参数setsockopt(cfd, IPPROTO_TCP, TCP_KEEPIDLE, &tcp_keepalive_idle, sizeof(int));	setsockopt(cfd, IPPROTO_TCP, TCP_KEEPINTVL, &tcp_keepalive_intvl, sizeof(int));	setsockopt(cfd, IPPROTO_TCP, TCP_KEEPCNT, &tcp_keepalive_cnt, sizeof(int));	setsockopt(cfd, IPPROTO_TCP, TCP_NODELAY, &tcp_nodelay, sizeof(int));		printf("server is connect ok\r\n");while(1){//等待服务器发送数据n = Read(cfd, ReadBuff, BUFF_SIZE);if(n <= 0){	goto again;	}//进行大小写转换for(i = 0; i < n; i++){	ReadBuff[i] = toupper(ReadBuff[i]);		}//写回服务器n = Write(cfd, ReadBuff, n);if(n <= 0){	goto again;	}		}
}

3. 心跳包的自主实现

服务端代码

主要思路：

在服务端代码中，首先创建一个监听套接字，等待客户端连接。一旦有客户端连接成功，就将其信息（包括客户端的文件描述符、IP地址和心跳计数器）存储在一个map中。同时，服务端启动一个心跳检测线程，定期遍历这个map，检查每个客户端的心跳计数器。若某客户端在一定时间内未发送心跳包，则认为该客户端掉线，关闭相应连接并从map中移除。

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <vector>
#include <map>
using namespace std;#define HEART_COUNT 5
#define BUF_SIZE 512
#define ERR_EXIT(m)         \do                      \{                       \perror(m);          \exit(EXIT_FAILURE); \} while (0)typedef map<int, pair<string, int>> FDMAPIP;enum Type
{HEART,OTHER
};struct PACKET_HEAD
{Type type;int length;
};//支线程传递的参数结构体
struct myparam
{FDMAPIP *mmap;
};//心跳线程
void *heart_handler(void *arg)
{printf("the heart-beat thread started\n");struct myparam *param = (struct myparam *)arg;//Server *s = (Server *)arg;while (1){FDMAPIP::iterator it = param->mmap->begin();for (; it != param->mmap->end();){// 3s*5没有收到心跳包，判定客户端掉线if (it->second.second == HEART_COUNT){printf("The client %s has be offline.\n", it->second.first.c_str());int fd = it->first;close(fd);               // 关闭该连接param->mmap->erase(it++); // 从map中移除该记录}else if (it->second.second < HEART_COUNT && it->second.second >= 0){it->second.second += 1;++it;}else{++it;}}sleep(3); // 定时三秒}
}int main()
{//创建套接字int m_sockfd = socket(AF_INET, SOCK_STREAM, 0);if (m_sockfd < 0){ERR_EXIT("create socket fail");}//初始化socket元素struct sockaddr_in server_addr;int server_len = sizeof(server_addr);memset(&server_addr, 0, server_len);server_addr.sin_family = AF_INET;//server_addr.sin_addr.s_addr = inet_addr("0.0.0.0"); //用这个写法也可以server_addr.sin_addr.s_addr = INADDR_ANY;server_addr.sin_port = htons(39002);//绑定文件描述符和服务器的ip和端口号int m_bindfd = bind(m_sockfd, (struct sockaddr *)&server_addr, server_len);if (m_bindfd < 0){ERR_EXIT("bind ip and port fail");}//进入监听状态，等待用户发起请求int m_listenfd = listen(m_sockfd, 20);if (m_listenfd < 0){ERR_EXIT("listen client fail");}//定义客户端的套接字，这里返回一个新的套接字，后面通信时，就用这个m_connfd进行通信struct sockaddr_in client_addr;socklen_t client_len = sizeof(client_addr);int m_connfd = accept(m_sockfd, (struct sockaddr *)&client_addr, &client_len);printf("client accept success\n");string ip(inet_ntoa(client_addr.sin_addr)); // 获取客户端IP// 记录连接的客户端fd--><ip, count>，暂时就一个FDMAPIP mmap;mmap.insert(make_pair(m_connfd, make_pair(ip, 0)));struct myparam param;param.mmap = &mmap;// 创建心跳检测线程pthread_t id;int ret = pthread_create(&id, NULL, heart_handler, ¶m);if (ret != 0){printf("can't create heart-beat thread.\n");}//接收客户端数据，并相应char buffer[BUF_SIZE];while (1){if (m_connfd < 0){m_connfd = accept(m_sockfd, (struct sockaddr *)&client_addr, &client_len);printf("client accept success again！！！\n");}PACKET_HEAD head;int recv_len = recv(m_connfd, &head, sizeof(head), 0); // 先接受包头if (recv_len <= 0){close(m_connfd);m_connfd = -1;printf("client head lose connection！！！\n");continue;}if (head.type == HEART){mmap[m_connfd].second = 0;printf("receive heart beat from client.\n");}else{//接收数据部分}}//关闭套接字close(m_connfd);close(m_sockfd);printf("server socket closed!!!\n");return 0;
}

客户端代码

主要思路：

客户端代码中，首先创建一个套接字并连接到服务端。连接建立后，客户端启动一个心跳发送线程，定期向服务端发送心跳包。发送心跳包的过程不需要携带任何实际数据，只需发送一个标识心跳的消息即可。服务端收到心跳包后，将对应客户端的心跳计数器重置为0，表示该客户端仍然活跃。如果服务端未收到心跳包，则认为客户端已经掉线。

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <vector>
#include <map>
using namespace std;#define BUF_SIZE 512
#define ERR_EXIT(m)         \do                      \{                       \perror(m);          \exit(EXIT_FAILURE); \} while (0)enum Type
{HEART,OTHER
};struct PACKET_HEAD
{Type type;int length;
};//线程传递的参数结构体
struct myparam   
{   int fd;  
};void *send_heart(void *arg)
{printf("the heartbeat sending thread started.\n");struct myparam *param = (struct myparam *)arg;int count = 0; // 测试while (1){PACKET_HEAD head;//发送心跳包head.type = HEART;head.length = 0;send(param->fd, &head, sizeof(head), 0);// 定时3秒，这个可以根据业务需求来设定sleep(3); }
}int main()
{//创建套接字int m_sockfd = socket(AF_INET, SOCK_STREAM, 0);if (m_sockfd < 0){ERR_EXIT("create socket fail");}//服务器的ip为本地，端口号struct sockaddr_in server_addr;memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = inet_addr("81.68.140.74");server_addr.sin_port = htons(39002);//向服务器发送连接请求int m_connectfd = connect(m_sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr));if (m_connectfd < 0){ERR_EXIT("connect server fail");}struct myparam param;param.fd = m_sockfd;pthread_t id;int ret = pthread_create(&id, NULL, send_heart, ¶m);if (ret != 0){printf("create thread fail.\n");}//发送并接收数据char buffer[BUF_SIZE] = "asdfg";int len = strlen(buffer);while (1){// 发送数据部分;}//断开连接close(m_sockfd);printf("client socket closed!!!\n");return 0;
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/336202.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

FPGA——eMMC验证

FPGA——eMMC验证

一.FPGA基础 1.FPGA烧录流程 (1) 加载流文件 —— bitfile (2) 烧录文件 —— cmm 二.MMC 1.基础知识 (1)jz4740、mmc、emmc、sd之间的关系&#xff1f; jz4740——处理器 mmc——存储卡标准 emmc——mmc基础上发展的高效存储解决方案 sd—— 三.eMMC和SD case验证 1.ca…
阅读更多...
slam14讲（第8讲、前端里程计）LK光流、直接法

slam14讲（第8讲、前端里程计）LK光流、直接法

直接法的引出 因为第7讲大部分都是讲特征点法&#xff0c;通过提取orb特征点和点的描述子&#xff0c;来构建两帧图像之间的特征点对应关系。这种方法会有缺点&#xff1a; 关键点和描述子提取计算耗时&#xff0c;如果相机的频率高&#xff0c;则slam算法大部分耗时被占。特…
阅读更多...
HaloDB 的 Oracle 兼容模式

HaloDB 的 Oracle 兼容模式

↑ 关注“少安事务所”公众号&#xff0c;欢迎⭐收藏&#xff0c;不错过精彩内容~ 前倾回顾 前面介绍了“光环”数据库的基本情况和安装办法。 哈喽&#xff0c;国产数据库&#xff01;Halo DB! 三步走&#xff0c;Halo DB 安装指引 ★ HaloDB是基于原生PG打造的新一代高性能安…
阅读更多...
基于 FastAI 文本迁移学习的情感分类（93%+Accuracy）

基于 FastAI 文本迁移学习的情感分类（93%+Accuracy）

前言 系列专栏:【深度学习&#xff1a;算法项目实战】✨︎ 涉及医疗健康、财经金融、商业零售、食品饮料、运动健身、交通运输、环境科学、社交媒体以及文本和图像处理等诸多领域&#xff0c;讨论了各种复杂的深度神经网络思想&#xff0c;如卷积神经网络、循环神经网络、生成对…
阅读更多...
JAVA：多线程常见的面试题和答案

JAVA：多线程常见的面试题和答案

请关注微信公众号&#xff1a;拾荒的小海螺 博客地址&#xff1a;http://lsk-ww.cn/ 1、并发编程三要素&#xff1f; 原 子 性 原子性指的是一个或者多个操作&#xff0c;要么全部执行并且在执行的过程中不被其他操作打断&#xff0c;要么就全部都不执行。可 见 性 可见性指多…
阅读更多...
NSSCTF | [SWPUCTF 2021 新生赛]no_wakeup

NSSCTF | [SWPUCTF 2021 新生赛]no_wakeup

打开题目后&#xff0c;点击三个&#xff1f;&#xff0c;发现是一个php序列化脚本 <?phpheader("Content-type:text/html;charsetutf-8"); error_reporting(0); show_source("class.php");class HaHaHa{public $admin;public $passwd;public function…
阅读更多...
CentOS下安装SVN客户端及使用方法

CentOS下安装SVN客户端及使用方法

一、前言 Subversion&#xff08;SVN&#xff09;是一款开源的版本控制系统&#xff0c;它可以帮助开发者追踪和管理代码、文档或其他文件的更改历史。在Linux系统中&#xff0c;特别是在CentOS环境下&#xff0c;安装和使用SVN客户端是日常工作中常见的任务。本文将介绍如何在…
阅读更多...
数学建模--LaTex插入表格详细介绍

数学建模--LaTex插入表格详细介绍

目录 1.插入普通的边线表格 3.三线表的插入和空格说明 3.基于复杂情况下表格的插入 1.插入普通的边线表格 &#xff08;1&#xff09;像这个右边的生成的这个比较普通的表格&#xff0c;我们是使用下面的代码实现的&#xff1a; &#xff08;2&#xff09;和插入一个一个图片…
阅读更多...
【漏洞复现】大华智能物联综合管理平台 log4j远程代码执行漏洞

【漏洞复现】大华智能物联综合管理平台 log4j远程代码执行漏洞

0x01 产品简介 大华ICC智能物联综合管理平台对技术组件进行模块化和松耦合&#xff0c;将解决方案分层分级&#xff0c;提高面向智慧物联的数据接入与生态合作能力。 0x02 漏洞概述 大华ICC智能物联综合管理平台/evo-apigw/evo-brm/1.2.0/user/is-exist 接口处存在 l0g4i远程…
阅读更多...
基于FMEA保证汽车电控系统的可靠性

基于FMEA保证汽车电控系统的可靠性

随着汽车技术的飞速发展&#xff0c;电控系统已成为现代汽车的“大脑”&#xff0c;掌控着车辆的方方面面。然而&#xff0c;这一复杂的系统也面临着诸多潜在失效风险&#xff0c;如何确保汽车电控系统的可靠性&#xff0c;成为汽车制造业亟待解决的问题。幸运的是&#xff0c;…
阅读更多...
SQL刷题笔记day6-1

SQL刷题笔记day6-1

1从不订购的客户 分析&#xff1a;从不订购&#xff0c;就是购买订单没有记录&#xff0c;not in 我的代码&#xff1a; select c.name as Customers from Customers c where c.id not in (select o.customerId from Orders o) 2 部门工资最高的员工 分析&#xff1a;每个部…
阅读更多...
LPDDR6带宽预计将翻倍增长：应对低功耗挑战与AI时代能源需求激增

LPDDR6带宽预计将翻倍增长：应对低功耗挑战与AI时代能源需求激增

在当前科技发展的背景下&#xff0c;低能耗问题成为了业界关注的焦点。国际能源署(IEA)近期报告显示&#xff0c;日常的数字活动对电力消耗产生显著影响——每次Google搜索平均消耗0.3瓦时&#xff08;Wh&#xff09;&#xff0c;而向OpenAI的ChatGPT提出的每一次请求则消耗2.9…
阅读更多...
008-Linux后台进程管理（作业控制：、jobs、fg、bg、ctrl + z、nohup）

008-Linux后台进程管理（作业控制：、jobs、fg、bg、ctrl + z、nohup）

文章目录 前言 1、& 2、ctrl z 3、jobs 4、fg&#xff1a;将后台进程调到前台执行 5、bg&#xff1a;将一个暂停的后台进程变为执行 6、&和nohup 总结 前言 有时候我们需要将一个进程放到后台去运行&#xff0c;或者将后台程序切换回前台&#xff0c;这时候就…
阅读更多...
【笔记】Pytorch安装配置

【笔记】Pytorch安装配置

参考视频 安装前建议预留至少10个G的空间&#xff0c;会省下很多麻烦 查看安装是否成功&#xff0c;可以在Anaconda Prompt里输入conda list查看conda环境是否配置了pytorch/torchvision 1.安装anaconda 2.安装 CUDA CUDA在官网直接安装即可&#xff0c;需要先查看自己电脑…
阅读更多...
文件IO（二）

文件IO（二）

文件IO&#xff08;二&#xff09; 标准IO缓冲类型全缓冲行缓冲不缓冲 打开文件fopen 操作文件按字符读写(fgetc fputc)按行读写&#xff08;fgets fputs&#xff09;按块&#xff08;对象&#xff09;读写&#xff08;fread fwrite&#xff09;按格式化读写&#xff08;fscanf…
阅读更多...
计算机网络学习笔记——应用层

计算机网络学习笔记——应用层

一、应用层概述 二、客户/服务器方式(C/S方式)和对等方式(P2P方式) 客户/服务器(Client/Server&#xff0c;C/S)方式 服务器总是处于运行状态&#xff0c;并等待客户的服务请求。服务器具有固定端口号(例如HTTP服务器的默认端口号为80)&#xff0c;而运行服务器的主机也具有固…
阅读更多...
使用git生成SSH公钥，并设置SSH公钥

使用git生成SSH公钥，并设置SSH公钥

1、在git命令行里输入以下命令 ssh-keygen -t rsa 2、按回车&#xff0c;然后会看到以下字眼 Generating public/private rsa key pair. Enter file in which to save the key (/c/Users/xxx/.ssh/id_rsa) 例&#xff1a; 3、继续回车&#xff0c;然后会看到以下字眼 Enter…
阅读更多...
Linux中断

Linux中断

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、中断的相关概念1.中断号2.中断的申请和释放申请API函数如下&#xff1a;释放API函数如下&#xff1a;中断处理函数如下&#xff1a;使能和禁止中断 二、上半…
阅读更多...
Mac安装tomcat

Mac安装tomcat

代码 brew install tomcat 运行结果如下&#xff1a; 如果要启动输入&#xff1a; brew services start tomcat
阅读更多...
Linux学习笔记（epoll，IO多路复用）

Linux学习笔记（epoll，IO多路复用）

Linux learning note 1、epoll的使用场景2、epoll的使用方法和内部原理2.1、创建epoll2.2、使用epoll监听和处理事件 3、示例 1、epoll的使用场景 epoll的英文全称是extend poll&#xff0c;顾名思义是poll的升级版。常见的IO复用技术有select&#xff0c;poll&#xff0c;epo…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023