简单实现能够断线重连的TCP客户端

2024-09-04 23:12

本文主要是介绍简单实现能够断线重连的TCP客户端,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

代码 

主要是借助了状态机来实现断线重连

client.hpp

#include <iostream>
#include <string>
#include <cstring>
#include <cstdlib>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>using namespace std;#define RETRY_INTERVAL 1
#define MAX_RETRIES 5void Usage(const std::string& process)
{cout << "Usage: " << process << "argv[1]: server_ip and argv[2]: server_port" << endl; 
}enum ERR // 这里的出错状态码不用强枚举类型,因为exit()中必须传入整形,强枚举类型会编译报错
{SOCKFDERR = 1,BINDERR
};enum class Status // 强枚举类型
{NEW,            // 新建立的链接,还未初始化完的状态CONNECTIGN,     // 正在连接CONNECTED,      // 连接成功状态,或者重连成功状态DISCONNECTED,   // 重连失败CLOSED          // 连接关闭状态
};class Connection
{private:int _sockfd;uint16_t _serverport;   // 服务端的端口号string _serverip;       // 服务端的ipint  _retry_interval;   // 每次重连的时间间隔,单位是秒int _max_retries;       // 最大尝试重连次数Status _statu;          // 当前连接的状态public:Connection(uint16_t port,const string& ip) :_sockfd(-1),_serverport(port),_serverip(ip),_retry_interval(RETRY_INTERVAL),_max_retries(MAX_RETRIES),_statu(Status::NEW) {}void Connect(){// 1.创建socket_sockfd = socket(AF_INET,SOCK_STREAM,0);if(_sockfd < 0){cerr << "Create Sockfd Failed!" << endl;exit(SOCKFDERR);}// 2.connet,客户端是不需要bind的,因为在connet的时候,系统会给客户端随机分配端口号struct sockaddr_in server;memset(&server,0,sizeof(server));server.sin_family = AF_INET;server.sin_port = htons(_serverport);// p:process(进程), n(网络)-- 不太准确,但是好记忆inet_pton(AF_INET,_serverip.c_str(),&server.sin_addr);int n = connect(_sockfd,(struct sockaddr*)&server,sizeof(server)); // 自动绑定端口if(n < 0){Disconnect(); // 先重置连接的状态,关闭原来的套接字_statu = Status::DISCONNECTED; // 准备进行重连return;}// 连接成功了_statu = Status::CONNECTED;}int Sockfd() {return _sockfd; }// 重新连接void ReConnect(){// 其实就是不断调用Connect()int count = _max_retries;while(count > 0){cout << "正在重新连接,剩余重连次数: " << count << " 次..." << endl;Connect(); // 重新连接count--;if(_statu == Status::CONNECTED) return; // 重连成功直接返回sleep(_retry_interval);}// 重连失败_statu = Status::CLOSED;}// 关闭连接void Disconnect(){if(_sockfd != -1){close(_sockfd);_sockfd = -1;_statu = Status::CLOSED;}}Status GetStatu() { return _statu; }void Process(){// 简单的IOwhile(true){string inbuffer;cout << "Please Enter# ";getline(cin,inbuffer);if(inbuffer.size() == 0) continue;ssize_t n = send(_sockfd,inbuffer.c_str(),sizeof(inbuffer),0);if(n < 0){cout << "Send n : " << n << "errno: " << errno << " errno string: " << strerror(errno) << endl;_statu = Status::CLOSED;break; }else  {char buffer[1024];int m = recv(_sockfd,buffer,1023,0);if(m < 0){cout << "Recv m : " << "errno: " << errno << " errno string: " << strerror(errno) << endl;_statu = Status::CLOSED;break;}else if(m == 0){_statu = Status::DISCONNECTED;break;}else  {buffer[m] = 0;cout << "Server said: " << endl;cout << buffer << endl;}}}}~Connection() { Disconnect(); }
};class TcpClient
{private:Connection _conn; public:TcpClient(uint16_t port,const string& ip) : _conn(port,ip) {}void Execute(){while(true){switch(_conn.GetStatu()){case Status::NEW: _conn.Connect();break;case Status::CONNECTED:_conn.Process();break;case Status::DISCONNECTED:_conn.ReConnect();break;case Status::CLOSED:cout << "重连失败,关闭连接..." << endl;_conn.Disconnect();return;default:break;}}}~TcpClient() {}
};

main.cc

#include "client.hpp"int main(int argc,char* argv[])
{if(argc != 3){Usage(argv[0]);return 1;}string serverip = argv[1];uint16_t serverport = stoi(argv[2]);TcpClient client(serverport,serverip);client.Execute();return 0;
}

makefile

TcpClient:main.ccg++ -std=c++11 $^ -o $@.PHONY::clean
clean:rm -f TcpClient;

这篇关于简单实现能够断线重连的TCP客户端的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1137307

相关文章

使用Sentinel自定义返回和实现区分来源方式

《使用Sentinel自定义返回和实现区分来源方式》:本文主要介绍使用Sentinel自定义返回和实现区分来源方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Sentinel自定义返回和实现区分来源1. 自定义错误返回2. 实现区分来源总结Sentinel自定

Mysql表的简单操作(基本技能)

《Mysql表的简单操作(基本技能)》在数据库中,表的操作主要包括表的创建、查看、修改、删除等,了解如何操作这些表是数据库管理和开发的基本技能,本文给大家介绍Mysql表的简单操作,感兴趣的朋友一起看... 目录3.1 创建表 3.2 查看表结构3.3 修改表3.4 实践案例:修改表在数据库中,表的操作主要

Java实现时间与字符串互相转换详解

《Java实现时间与字符串互相转换详解》这篇文章主要为大家详细介绍了Java中实现时间与字符串互相转换的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、日期格式化为字符串(一)使用预定义格式(二)自定义格式二、字符串解析为日期(一)解析ISO格式字符串(二)解析自定义

opencv图像处理之指纹验证的实现

《opencv图像处理之指纹验证的实现》本文主要介绍了opencv图像处理之指纹验证的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录一、简介二、具体案例实现1. 图像显示函数2. 指纹验证函数3. 主函数4、运行结果三、总结一、

Springboot处理跨域的实现方式(附Demo)

《Springboot处理跨域的实现方式(附Demo)》:本文主要介绍Springboot处理跨域的实现方式(附Demo),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不... 目录Springboot处理跨域的方式1. 基本知识2. @CrossOrigin3. 全局跨域设置4.

Spring Boot 3.4.3 基于 Spring WebFlux 实现 SSE 功能(代码示例)

《SpringBoot3.4.3基于SpringWebFlux实现SSE功能(代码示例)》SpringBoot3.4.3结合SpringWebFlux实现SSE功能,为实时数据推送提供... 目录1. SSE 简介1.1 什么是 SSE?1.2 SSE 的优点1.3 适用场景2. Spring WebFlu

基于SpringBoot实现文件秒传功能

《基于SpringBoot实现文件秒传功能》在开发Web应用时,文件上传是一个常见需求,然而,当用户需要上传大文件或相同文件多次时,会造成带宽浪费和服务器存储冗余,此时可以使用文件秒传技术通过识别重复... 目录前言文件秒传原理代码实现1. 创建项目基础结构2. 创建上传存储代码3. 创建Result类4.

SpringBoot日志配置SLF4J和Logback的方法实现

《SpringBoot日志配置SLF4J和Logback的方法实现》日志记录是不可或缺的一部分,本文主要介绍了SpringBoot日志配置SLF4J和Logback的方法实现,文中通过示例代码介绍的非... 目录一、前言二、案例一:初识日志三、案例二:使用Lombok输出日志四、案例三:配置Logback一

Python如何使用__slots__实现节省内存和性能优化

《Python如何使用__slots__实现节省内存和性能优化》你有想过,一个小小的__slots__能让你的Python类内存消耗直接减半吗,没错,今天咱们要聊的就是这个让人眼前一亮的技巧,感兴趣的... 目录背景:内存吃得满满的类__slots__:你的内存管理小助手举个大概的例子:看看效果如何?1.

Python+PyQt5实现多屏幕协同播放功能

《Python+PyQt5实现多屏幕协同播放功能》在现代会议展示、数字广告、展览展示等场景中,多屏幕协同播放已成为刚需,下面我们就来看看如何利用Python和PyQt5开发一套功能强大的跨屏播控系统吧... 目录一、项目概述:突破传统播放限制二、核心技术解析2.1 多屏管理机制2.2 播放引擎设计2.3 专