TCP socket心跳包示例程序

TCP socket心跳包示例程序_xqhrs232的专栏-CSDN博客_setsockopt 心跳包

原文地址::TCP socket心跳包示例程序_神奕的专栏-CSDN博客_tcp心跳包

相关文章

1、Linux网络编程--服务端判断客户端断开的经验方法 ----Linux网络编程--服务端判断客户端断开的经验方法_志存高远-CSDN博客_info.tcpi_state

2、Socket心跳包机制及SO_KEEPALIVE套接口选项----Socket心跳包机制及SO_KEEPALIVE套接口选项_u012252959的博客-CSDN博客

3、TCP Keepalive HOWTO----TCP Keepalive HOWTO

在做游戏开发时,经常需要在应用层实现自己的心跳机制,即定时发送一个自定义的结构体(心跳包),让对方知道自己还活着,以确保连接的有效性。

在TCP socket心跳机制中,心跳包可以由服务器发送给客户端,也可以由客户端发送给服务器,不过比较起来,前者开销可能更大。—— 这里实现的是由客户端给服务器发送心跳包,基本思路是:

1) 服务器为每个客户端保存了IP和计数器count,即map<fd, pair<ip, count>>。服务端主线程采用 select 实现多路IO复用,监听新连接以及接受数据包(心跳包),子线程用于检测心跳:

  • 如果主线程接收到的是心跳包,将该客户端对应的计数器 count 清零;
  • 在子线程中,每隔3秒遍历一次所有客户端的计数器 count: 
    • 若 count 小于 5,将 count 计数器加 1;
    • 若 count 等于 5,说明已经15秒未收到该用户心跳包,判定该用户已经掉线;

2) 客户端则只是开辟子线程,定时给服务器发送心跳包(本示例中定时时间为3秒)。


下面是Linux下一个socket心跳包的简单实现:

/*************************************************************************> File Name: Server.cpp> Author: SongLee> E-mail: lisong.shine@qq.com> Created Time: 2016年05月05日 星期四 22时50分23秒> Personal Blog: http://songlee24.github.io/************************************************************************/
#include<netinet/in.h>   // sockaddr_in
#include<sys/types.h>    // socket
#include<sys/socket.h>   // socket
#include<arpa/inet.h>
#include<unistd.h>
#include<sys/select.h>   // select
#include<sys/ioctl.h>
#include<sys/time.h>
#include<iostream>
#include<vector>
#include<map>
#include<string>
#include<cstdlib>
#include<cstdio>
#include<cstring>
using namespace std;
#define BUFFER_SIZE 1024enum Type {HEART, OTHER};struct PACKET_HEAD
{Type type;int length;
};void* heart_handler(void* arg);class Server
{
private:struct sockaddr_in server_addr;socklen_t server_addr_len;int listen_fd;    // 监听的fdint max_fd;       // 最大的fdfd_set master_set;   // 所有fd集合,包括监听fd和客户端fd   fd_set working_set;  // 工作集合struct timeval timeout;map<int, pair<string, int> > mmap;   // 记录连接的客户端fd--><ip, count>
public:Server(int port);~Server();void Bind();void Listen(int queue_len = 20);void Accept();void Run();void Recv(int nums);friend void* heart_handler(void* arg);
};Server::Server(int port)
{bzero(&server_addr, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htons(INADDR_ANY);server_addr.sin_port = htons(port);// create socket to listenlisten_fd = socket(PF_INET, SOCK_STREAM, 0);if(listen_fd < 0){cout << "Create Socket Failed!";exit(1);}int opt = 1;setsockopt(listen_fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
}Server::~Server()
{for(int fd=0; fd<=max_fd; ++fd){if(FD_ISSET(fd, &master_set)){close(fd);}}
}void Server::Bind()
{if(-1 == (bind(listen_fd, (struct sockaddr*)&server_addr, sizeof(server_addr)))){cout << "Server Bind Failed!";exit(1);}cout << "Bind Successfully.\n"; 
}void Server::Listen(int queue_len)
{if(-1 == listen(listen_fd, queue_len)){cout << "Server Listen Failed!";exit(1);}cout << "Listen Successfully.\n";
}void Server::Accept()
{struct sockaddr_in client_addr;socklen_t client_addr_len = sizeof(client_addr);int new_fd = accept(listen_fd, (struct sockaddr*)&client_addr, &client_addr_len);if(new_fd < 0){cout << "Server Accept Failed!";exit(1);}string ip(inet_ntoa(client_addr.sin_addr));    // 获取客户端IPcout << ip << " new connection was accepted.\n";mmap.insert(make_pair(new_fd, make_pair(ip, 0)));// 将新建立的连接的fd加入master_setFD_SET(new_fd, &master_set);if(new_fd > max_fd){max_fd = new_fd;}
}   void Server::Recv(int nums)
{for(int fd=0; fd<=max_fd; ++fd){if(FD_ISSET(fd, &working_set)){bool close_conn = false;  // 标记当前连接是否断开了PACKET_HEAD head;recv(fd, &head, sizeof(head), 0);   // 先接受包头if(head.type == HEART){mmap[fd].second = 0;        // 每次收到心跳包,count置0cout << "Received heart-beat from client.\n";}else{// 数据包,通过head.length确认数据包长度 }   if(close_conn)  // 当前这个连接有问题,关闭它{close(fd);FD_CLR(fd, &master_set);if(fd == max_fd)  // 需要更新max_fd;{while(FD_ISSET(max_fd, &master_set) == false)--max_fd;}}}}   
}void Server::Run()
{pthread_t id;     // 创建心跳检测线程int ret = pthread_create(&id, NULL, heart_handler, (void*)this);if(ret != 0){cout << "Can not create heart-beat checking thread.\n";}max_fd = listen_fd;   // 初始化max_fdFD_ZERO(&master_set);FD_SET(listen_fd, &master_set);  // 添加监听fdwhile(1){FD_ZERO(&working_set);memcpy(&working_set, &master_set, sizeof(master_set));timeout.tv_sec = 30;timeout.tv_usec = 0;int nums = select(max_fd+1, &working_set, NULL, NULL, &timeout);if(nums < 0){cout << "select() error!";exit(1);}if(nums == 0){//cout << "select() is timeout!";continue;}if(FD_ISSET(listen_fd, &working_set))Accept();   // 有新的客户端请求elseRecv(nums); // 接收客户端的消息}
}// thread function
void* heart_handler(void* arg)
{cout << "The heartbeat checking thread started.\n";Server* s = (Server*)arg;while(1){map<int, pair<string, int> >::iterator it = s->mmap.begin();for( ; it!=s->mmap.end(); ){   if(it->second.second == 5)   // 3s*5没有收到心跳包,判定客户端掉线{cout << "The client " << it->second.first << " has be offline.\n";int fd = it->first;close(fd);            // 关闭该连接FD_CLR(fd, &s->master_set);if(fd == s->max_fd)      // 需要更新max_fd;{while(FD_ISSET(s->max_fd, &s->master_set) == false)s->max_fd--;}s->mmap.erase(it++);  // 从map中移除该记录}else if(it->second.second < 5 && it->second.second >= 0){it->second.second += 1;++it;}else{++it;}}sleep(3);   // 定时三秒}
}int main()
{Server server(15000);server.Bind();server.Listen();server.Run();return 0;
}
/*************************************************************************> File Name: Client.cpp> Author: SongLee> E-mail: lisong.shine@qq.com> Created Time: 2016年05月05日 星期四 23时41分56秒> Personal Blog: http://songlee24.github.io/************************************************************************/
#include<netinet/in.h>   // sockaddr_in
#include<sys/types.h>    // socket
#include<sys/socket.h>   // socket
#include<arpa/inet.h>
#include<sys/ioctl.h>
#include<unistd.h>
#include<iostream>
#include<string>
#include<cstdlib>
#include<cstdio>
#include<cstring>
using namespace std;
#define BUFFER_SIZE 1024enum Type {HEART, OTHER};struct PACKET_HEAD
{Type type;int length;
};void* send_heart(void* arg); class Client 
{
private:struct sockaddr_in server_addr;socklen_t server_addr_len;int fd;
public:Client(string ip, int port);~Client();void Connect();void Run();friend void* send_heart(void* arg); 
};Client::Client(string ip, int port)
{bzero(&server_addr, sizeof(server_addr));server_addr.sin_family = AF_INET;if(inet_pton(AF_INET, ip.c_str(), &server_addr.sin_addr) == 0){cout << "Server IP Address Error!";exit(1);}server_addr.sin_port = htons(port);server_addr_len = sizeof(server_addr);// create socketfd = socket(AF_INET, SOCK_STREAM, 0);if(fd < 0){cout << "Create Socket Failed!";exit(1);}
}Client::~Client()
{close(fd);
}void Client::Connect()
{cout << "Connecting......" << endl;if(connect(fd, (struct sockaddr*)&server_addr, server_addr_len) < 0){cout << "Can not Connect to Server IP!";exit(1);}cout << "Connect to Server successfully." << endl;
}void Client::Run()
{pthread_t id;int ret = pthread_create(&id, NULL, send_heart, (void*)this);if(ret != 0){cout << "Can not create thread!";exit(1);}
}// thread function
void* send_heart(void* arg)
{cout << "The heartbeat sending thread started.\n";Client* c = (Client*)arg;int count = 0;  // 测试while(1) {PACKET_HEAD head;head.type = HEART;head.length = 0;    send(c->fd, &head, sizeof(head), 0);sleep(3);     // 定时3秒++count;      // 测试:发送15次心跳包就停止发送if(count > 15)break;}
}int main()
{Client client("127.0.0.1", 15000);client.Connect();client.Run();while(1){string msg;getline(cin, msg);if(msg == "exit")break;cout << "msg\n";}return 0;
}

可以看出,客户端启动以后发送了15次心跳包,然后停止发送心跳包。在经过一段时间后(3s*5),服务器就判断该客户端掉线,并断开了连接。 

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

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

相关文章

sizeof()计算结构体的大小

原文链接&#xff1a;sizeof()计算结构体的大小_海月汐辰-CSDN博客_结构体的sizeof怎么计算 简要说明&#xff1a;结构体成员按照定义时的顺序依次存储在连续的内存空间&#xff0c;但是结构体的大小并不是简单的把所有成员大小相加&#xff0c;而是遵循一定的规则&#xff0c…

select、poll、epoll使用小结

转载&#xff1a;http://blog.csdn.net/kkxgx/article/details/7717125 Linux上可以使用不同的I/O模型&#xff0c;我们可以通过下图了解常用的I/O模型&#xff1a;同步和异步模型&#xff0c;以及阻塞和非阻塞模型&#xff0c;本文主要分析其中的异步阻塞模型。 一、select使用…

Qt报错:undefined reference to xxxxx

报错信息&#xff1a; 首先&#xff0c;要区分与undefined reference to xxxxx和 "xxxx was not declared in this scope"两种报错信息的差别&#xff0c;前者是因为编译器能找到函数的声明&#xff0c;但是找不到函数的定义&#xff0c;从而报错&#xff1b;而后者是…

对象的浅拷贝和深拷贝

对象的浅拷贝和深拷贝简要介绍代码实现简要介绍 浅拷贝&#xff1a;python拷贝一般都是浅拷贝。拷贝时&#xff0c;对象包含的子对象内容不拷贝。因此&#xff0c;源对象和拷贝对象引用同一个对象 深拷贝&#xff1a;使用copy模块的deepcopy函数&#xff0c;递归拷贝对象中包含…

用模板写单链表

转载自&#xff1a;http://blog.csdn.net/itcastcpp/article/details/39081953 为了加深对模板的理解&#xff0c;我们今天一起用模板写一个单链表&#xff0c;希望通过这个例子&#xff0c;能够帮助大家加深对模板的体会&#xff0c;具体如下&#xff1a; SList.hpp内容&#…

QT事件事件之一:Qt中的事件处理与传递

QT事件事件之一&#xff1a;Qt中的事件处理与传递前言一、简介二、QT中的事件三、事件的实现的方法前言 在QT中&#xff0c;事件是我们很常用的东西&#xff0c;以下是我用事件时总结和做法 一、简介 在QT中&#xff0c;事件作为一个对象&#xff0c;继承QEvent类&#xff0c…

linux下成功安装ffmpeg( 亲测有效 )

linux下成功安装ffmpeg&#xff08; 亲测有效 &#xff09;一、下载二、安装步骤1.安装yasm2.安装ffmpeg总结一、下载 ffmpeg 官网下载&#xff1a; http://ffmpeg.org/download.html 安装yasm 官网下载&#xff1a;http://yasm.tortall.net/Download.html 二、安装步骤 1.…

C++实现 简单 单链表

转自&#xff1a; http://blog.csdn.net/wonggonghong/article/details/21527577 我们首先建立一个<List.h>头文件&#xff0c;声明一个单链表结构&#xff1a; #include "List.h" [cpp] view plaincopy //创建一个单链表结构&#xff0c;包含一些常见的操作 …

ffmpeg音视频基础知识

ffmpeg音视频基础知识前言一、图像的基础知识二、视频编码基础知识1.视频和图片之间的关系2.为什么要编码&#xff1f;3.什么是编码&#xff1f;视频相关专业术语提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录前言…

Linux系统编程(一)

Linux系统编程&#xff08;一&#xff09;一、进程和程序二、内存布局内核空间用户空间三、进程状态四、环境变量五、进程共享一、进程和程序 程序&#xff1a;是指编译好的二进制文件&#xff0c;存储在磁盘中&#xff0c;不占用系统资源。 进程&#xff1a;是系统进行资源分…

Linux的SOCKET编程 简单演示

转载&#xff1a;http://blog.csdn.net/hguisu/article/details/7445768/ Linux的SOCKET编程详解 1. 网络中进程之间如何通信 进 程通信的概念最初来源于单机系统。由于每个进程都在自己的地址范围内运行&#xff0c;为保证两个相互通信的进 程之间既互不干扰又协调一致工作&a…

Unity(一)必然事件

【MonoBehaviour 类】&#xff08;一&#xff09;必然事件一、必然事件是什么&#xff1f;二、常用函数执行顺序1.Awake2.Start3.update4.FixedUpdate三、Awake和start区别一、必然事件是什么&#xff1f; 在Unity中必然事件也称脚本生命周期&#xff0c;是指在Unity脚本在唤醒…

Linux系统编程(二)孤儿进程和僵尸进程

Linux系统编程&#xff08;二&#xff09;一、exec函数族1.exec函数二、孤儿进程和僵尸进程三、wait和waitpid1.wait函数2.waitpid函数一、exec函数族 exec函数使用时&#xff0c;改程序的用户空间的代码和数据会被新程序给替代&#xff0c;会从新程序的启动例程开始。调用exe…

linux下c/c++实例之十socket简单应用

转自&#xff1a;http://blog.csdn.net/taiyang1987912/article/details/49738351 一、简介 通过socket扫描本机打开的tcp端口号&#xff0c;模拟用户名、密码登录服务器的过程、socket文件传输及模仿http服务器。 二、详解 1、Linux下tcp端口扫描 &#xff08;1&#xff09;…

Linux系统编程(三)进程间的通信

Linux系统编程&#xff08;三&#xff09;进程间的通信一、为什么需要进程之间的通信&#xff08;IPC&#xff09;&#xff1f;二、管道1.概念2.特质3.原理4.局限性5.代码2.读入数据三、共享存储映射注意事项父子进程通信一、为什么需要进程之间的通信&#xff08;IPC&#xff…

exec 函数族

转自&#xff1a;http://www.cnblogs.com/mickole/p/3187409.html linux系统编程之进程&#xff08;五&#xff09;&#xff1a;exec系列函数&#xff08;execl,execlp,execle,execv,execvp)使用 本节目标&#xff1a; exec替换进程映像exec关联函数组&#xff08;execl、execl…

Linux系统编程(四)信号

Linux系统编程&#xff08;四&#xff09;信号一、什么是信号&#xff1f;1、信号的本质2、信号来源硬件来源软件来源二、常见信号1.可靠信号和不可靠信号2、不可靠信号主要有以下问题:3、可靠信号与不可靠信号注册机制三、信号处理方式四、信号处理过程五、未决信号和阻塞信号…

SIGCHLD信号回收子进程

SIGCHLD信号回收子进程代码问题注意点代码 #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <sys/wait.h> #include <signal.h>void handler(int signo) {int status; pid_t pid;while ((pid waitpid(0, &status…

Wait waitpid

转自&#xff1a;http://www.cnblogs.com/mickole/p/3187770.html linux系统编程之进程&#xff08;六&#xff09;&#xff1a;父进程查询子进程的退出,wait,waitpid 本节目标&#xff1a; 僵进程SIGCHLDwaitwaitpid 一&#xff0c;僵尸进程 当一个子进程先于父进程结束运行时…

Linux C++ 简单爬虫

转载&#xff1a;http://blog.csdn.net/orthocenterchocolate/article/details/38665937 方便易用&#xff0c;传入URL&#xff0c;返回对应页面的内容 [cpp] view plaincopy #include <iostream> #include <string> #include <netdb.h> #include <…