c++实战篇(三) ——对socket通讯服务端与客户端的封装

news/2024/12/23 1:22:34/

前言

在前面几篇文章中我们介绍过一些有关于网络编程的相关知识,我们介绍了在tcp传输数据的时候发送缓冲区与接收缓冲区，我们介绍了在tcp发送与接收的过程中可能出现的分包与粘包的问题：
c++理论篇(一) ——浅谈tcp缓存与tcp的分包与粘包
我们介绍了在网络编程如何利用IO多路复用来实现服务端对大量客户端进行通讯:
c++高级篇(二) ——Linux下IO多路复用之select模型
c++高级篇(三) ——Linux下IO多路复用之poll模型
但是说了那么多我们好像还是不知道客户端和服务端之间的连接究竟是一个怎样的过程，而这就是我们今天的主题，通过对Tcp通讯中客户端与服务端的连接来探究一些网络编程的细节。

客户端类的编写

客户端通讯的过程

客户端连接的过程其实很好理解，主要就是以下几步:

  • 创建客户端socket
  • 基于客户端socket和服务端ip以及服务端开放的通讯端口与服务端建立连接
  • 读取/发送数据
  • 关闭socket，断开连接
    而我们的对客户端类的编写，也是基于上面的几步过程来展开的。

客户端的私有成员

在上面我们提到了客户端连接服务端所需的一些信息，例如客户端socket，服务端ip以及服务端开放的通讯端口(云服务器开放通讯端口需要设置安全组)，所以我们可以这样定义客户端类:

private:int m_socket; // 客户端的socketunsigned int server_port;// 服务端的端口string server_ip; //服务端的ip

客户端的公共函数

我们上面说过客户端连接服务端以及相关工作的大致流程，所以在定义客户端类的函数时，大概是以下类型的函数:

public:ctcpclient(){m_socket=-1;}bool Connect(const unsigned int port,const string& ip);  //客户端连接服务端bool Read(string& buff,const int itimeout=0);  //接收文本数据bool Read(void* buff,const int bufflen,const int itimeout=0); //接收二进制数据bool Write(const string& buff); //发送文本数据bool Write(const void* buff,const int bufflen); //发送二进制数据void Close(); //关闭连接~ctcpclient(){Close();}

这里的构造函数与析构函数无需多言，接下来我们主要对相关的工作函数进行探究。

Connect(客户端连接)函数

在讲解Connect函数之前我们先来看一下它的具体执行的逻辑:

  bool ctcpclient::Connect(const unsigned int port, const string &ip){if (m_socket != -1){Close();}// 忽略SIGPIPE信号，防止程序异常退出。// 如果send到一个disconnected socket上，内核就会发出SIGPIPE信号。这个信号// 的缺省处理方法是终止进程，大多数时候这都不是我们期望的。我们重新定义这// 个信号的处理方法，大多数情况是直接屏蔽它。signal(SIGPIPE, SIG_IGN);server_port = port;server_ip = ip;m_socket = socket(AF_INET, SOCK_STREAM, 0);if (m_socket < 0){return false;}struct sockaddr_in server_addr;struct hostent *h;memset(&server_addr, 0, sizeof(server_addr));if ((h = gethostbyname(ip.c_str())) == NULL){Close();return false;}server_addr.sin_family = AF_INET;//指定通讯协议server_addr.sin_port = htons(server_port); //指定通讯端口memset(h, 0, sizeof(h));memcpy(h->h_addr, &server_ip[0], server_ip.length());  //指定通讯IP地址if (connect(m_socket, (struct sockaddr *)&server_addr, sizeof(server_addr)) != 0){return false;}return true;}

上述主要经过了一下几个步骤：

  • 检查socket，查看当前客户端是否处于未连接状态
  • 设置相关信号的处理方式，防止异常情况的出现
  • 初始化客户端socket
  • 定义server_addr与 struct hostent *h结构体配置相关信息
  • 与客户端建立连接

Read(接收)函数

Read函数在这里所起到的作用主要是接收数据的作用,接下来我们将从接收数据的不同作为开始来探究其中的细节。

接收文本数据

在对相关函数的执行逻辑与细节进行讲解之前，我们先来看一下相关的函数签名与函数实现：

 bool Read(string& buff,const int itimeout=0);  //接收文本数据bool tcpread(const int sockfd,string &buffer,const int itimeout=0); // 读取文本数据bool readn(const int sockfd, char *buffer, const size_t n);

  bool ctcpclient::Read(string &buff, const int itimeout){if (m_socket < 0){return false;}return (tcpread(m_socket, buff, itimeout));}bool tcpread(const int sock, string &buff, const int itimeout){if (sock < 0){return false;}if (itimeout > 0){struct pollfd fds;fds.fd = sock;fds.events = POLLIN;int ret = poll(&fds, 1, itimeout * 1000);if (ret < 0){return false;}if (ret == 0){return false;}}if (itimeout < -1){struct pollfd fds;fds.fd = sock;fds.events = POLLIN;int ret = poll(&fds, 1, 0);if (ret < 0){return false;}if (ret == 0){return false;}}int bufflen = 0;if (readn(sock, (char *)&bufflen, 4) == false) // 读取报文长度{return false;}buff.resize(bufflen);if (readn(sock, &buff[0], bufflen) == false) // 读取报文内容{return false;}return true;}bool readn(const int sockfd, char *buffer, const size_t n){int nleft = n; // 剩余需要读取的字节数。int idx = 0;   // 已成功读取的字节数。int nread;     // 每次调用recv()函数读到的字节数。while (nleft > 0){if ((nread = recv(sockfd, buffer + idx, nleft, 0)) <= 0)return false;idx = idx + nread;nleft = nleft - nread;}return true;}

我们可以看到上面有关于数据接收的函数一共有三个,这里主要是客户端与服务端接收/发送数据的方式基本一致，所以我们选择对相关函数进行封装避免多次书写重复函数使代码编的臃肿，下面来给大家解释主要函数的作用:

  • tcpread
    我们知道端到端的通讯其实不是每次都是立即进行的,所以接收数据的一方有时候要等待发送数据的一方将数据发送过来，而这里我们基于poll实现了一个超时机制，让我们可以手动设置接收数据方是否等待以及等待的最大时长
  • readn
    这个主要是实现对数据的读写，相对于直接调用recv函数，每次从socket读取指定数量的字节，即使recv函数不能一次读取所有字节。通过在循环中跟踪剩余需要读取的字节数，可以确保读取完整的数据，进而避免因为recv函数每次读取的字节数不固定而导致的数据读取不完整或错误。

二进制数据

二进制数数接收与文本数据的接收又有所不同，我们来看一下它的函数签名与具体逻辑:

  • 函数签名
bool Read(void* buff,const int bufflen,const int itimeout=0); //接收二进制数据
bool tcpread(const int sockfd, void *buffer, const int ibuflen, const int itimeout = 0);//接收二进制数据
bool readn(const int sockfd, char *buffer, const size_t n);
  • 函数逻辑
    bool ctcpclient::Read(void *buff, const int bufflen, const int itimeout){if (m_socket < 0){return false;}return (tcpread(m_socket, buff, bufflen, itimeout));}bool tcpread(int sock, void *buff, const int bufflen, const int itimeout){if (sock < 0){return false;}if (itimeout > 0){struct pollfd fds;fds.fd = sock;fds.events = POLLIN;int ret = poll(&fds, 1, itimeout * 1000);if (ret <= 0){return false;}}if (itimeout < -1){struct pollfd fds;fds.fd = sock;fds.events = POLLIN;int ret = poll(&fds, 1, 0);if (ret <= 0){return false;}}if (readn(sock, (char *)buff, bufflen) == false) // 读取报文内容{return false;}return true;}bool readn(const int sockfd, char *buffer, const size_t n){int nleft = n; // 剩余需要读取的字节数。int idx = 0;   // 已成功读取的字节数。int nread;     // 每次调用recv()函数读到的字节数。while (nleft > 0){if ((nread = recv(sockfd, buffer + idx, nleft, 0)) <= 0)return false;idx = idx + nread;nleft = nleft - nread;}return true;}

我们可以发现二进制数据的接收与文本数据相比有所不同，相对于文本数据，二进制数据减少了一个接收数据长度的过程，这是因为我们在接收/二进制数据时，二进制数据通常会包含自身的大小信息。在通信双方约定好数据格式之后，发送方会在发送数据时先将数据的大小信息编码到数据中，接收方在接收数据时可以直接根据数据的大小信息来确定整个报文的大小，从而正确地解析和处理数据。

Write函数

write函数的细节与read函数类似，这里不做赘述，直接看函数签名与逻辑了:

  • 函数签名
 bool Write(const string& buff); //发送文本数据bool Write(const void* buff,const int bufflen); //发送二进制数据bool tcpwrite(const int sockfd, const void *buffer, const int ibuflen);//发送二进制数据bool tcpwrite(const int sockfd, const string &buffer);  //发送文本数据bool readn(const int sockfd, char *buffer, const size_t n);
  • 函数逻辑
 bool ctcpclient::Write(const string &buff){if (m_socket < 0){return false;}return (tcpwrite(m_socket, buff));}bool ctcpclient::Write(const void *buff, const int bufflen){if (m_socket < 0){return false;}return (tcpwrite(m_socket, (char *)buff, bufflen));}bool tcpwrite(const int sock, const string &buff){if (sock < 0){return false;}int bufflen = buff.length();if (writen(sock, (char *)&bufflen, 4) == false) // 发送报文长度{return false;}if (writen(sock, &buff[0], bufflen) == false) // 发送报文内容{return false;}return true;}bool tcpwrite(int sock, const void *buff, const int bufflen){if (sock < 0){return false;}if (writen(sock, (char *)buff, bufflen) == false) // 发送报文内容{return false;}return true;}bool writen(const int sockfd, const char *buffer, const size_t n){int nleft = n; // 剩余需要写入的字节数。int idx = 0;   // 已成功写入的字节数。int nwritten;  // 每次调用send()函数写入的字节数。while (nleft > 0){if ((nwritten = send(sockfd, buffer + idx, nleft, 0)) <= 0)return false;nleft = nleft - nwritten;idx = idx + nwritten;}return true;}

Close函数

Close函数主要用来关闭已经打开的socket

void ctcpclient::Close()
{if (m_socket > 0){close(m_socket);m_socket = -1;}
}

服务端类的编写

服务端类的工作流程

  • 初始化监听socket，指定端口与ip,将socket设置为监听状态
  • 从等待连接的队列中选取一个客户端进行连接
  • 发送/接收数据
  • 关闭socket,断开连接

服务端类的成员

class ctcpserver{private:int m_listensock;//服务端的监听socketint m_connsock; //已连接的客户端socketint sockaddr_len;//客户端地址的长度struct sockaddr_in server_addr;//服务端地址struct sockaddr_in client_addr;//客户端地址public:ctcpserver(){m_listensock=-1;m_connsock=-1;}bool Initserver(const unsigned int port,const int backlog=5);//初始化服务端bool Accept(); //从已连接队列中获取一个客户端连接bool Read(string& buff,const int itimeout=0); //接收文本数据bool Read(void* buff,const int bufflen,const int itimeout=0); //接收二进制数据bool Write(const string& buff); //发送文本数据bool Write(const void* buff,const int bufflen); //发送二进制数据char* getclientip(); //获取客户端的ipvoid Closelisten(); //关闭监听socketvoid Closeconn(); //关闭已连接的客户端socket~ctcpserver(){Closeconn();Closelisten();}};

Initserver函数

在讲解前我们来看一下函数的具体逻辑:

bool ctcpserver::Initserver(const unsigned int port, const int backlog) // backlog:等待连接队列的最大长度{if (m_listensock != -1){Closelisten();}signal(SIGPIPE, SIG_IGN);// 打开SO_REUSEADDR选项，当服务端连接处于TIME_WAIT状态时可以再次启动服务器，// 否则bind()可能会不成功，报：Address already in use。int opt = 1;setsockopt(m_listensock, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));m_listensock = socket(AF_INET, SOCK_STREAM, 0);if (m_listensock < 0){return false;}memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;m_listensock = socket(AF_INET, SOCK_STREAM, 0);if (m_listensock < 0){return false;}struct sockaddr_in server_addr;memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htonl(INADDR_ANY);server_addr.sin_port = htons(port);if (bind(m_listensock, (struct sockaddr *)&server_addr, sizeof(server_addr)) != 0){Closelisten();return false;}if (listen(m_listensock, backlog) != 0){Closelisten();return false;}return true;}

我们梳理一下它这个的工作流程；

  • 检查服务端是否已经被初始化
  • 设置相关信号的处理方式，防止异常情况的出现
  • 初始化服务端的监听socket
  • 设置相关参数,并指定其为用于通信的ip与端口(bind)
  • 将socket设置为监听状态

Accept函数

一个时间段可能会有多个客户端连接服务端，这时候就形成了一个等待队列，服务单会在这个等待队列里面利用accept函数选取一个客户端进行连接：

  bool ctcpserver::Accept(){if (m_listensock < 0){return false;}sockaddr_len = sizeof(struct sockaddr_in);if ((m_connsock = accept(m_listensock, (sockaddr *)&client_addr, (socklen_t *)&sockaddr_len)) < 0){return false;}return true;}

Read与Write函数

服务端接收与发送数据与客户端基本功一致，这里就不做赘述，基本的这一点什么都已经提出来了，我们直接看代码:

bool ctcpserver::Read(string &buff, const int itimeout){if (m_listensock < 0){return false;}return (tcpread(m_connsock, buff, itimeout));}bool ctcpserver::Read(void *buff, const int bufflen, const int itimeout){if (m_listensock < 0){return false;}return (tcpread(m_connsock, buff, bufflen, itimeout));}bool ctcpserver::Write(const string &buff){if (m_listensock < 0){return false;}return (tcpwrite(m_connsock, buff));}bool ctcpserver::Write(const void *buff, const int bufflen){if (m_listensock < 0){return false;}return (tcpwrite(m_connsock, (char *)buff, bufflen));}

getclientip()函数

该函数主要的作用是获取连接的客户端的ip:

  char *ctcpserver::getclientip(){return inet_ntoa(client_addr.sin_addr);}

Close函数

 void ctcpserver::Closelisten(){if (m_listensock > 0){close(m_listensock);m_listensock = -1;}}void ctcpserver::Closeconn(){if (m_connsock > 0){close(m_connsock);m_connsock = -1;}}

结语

Cpp不同于其他语言，像Go,Python等语言对上述的细节其实已经封装好了，但是cpp则是需要我们去一点点的实现,为了避免重复的书写代码，我们可以将它们封装成类来供我们去使用，以上就是这篇文章的全部内容了,大家下篇见！


http://www.ppmy.cn/news/1452739.html

相关文章

使用Qt for android 获取android PDA设备扫码数据

使用Qt for android 获取android PDA设备扫码数据

安装Qt Android 模块、Qt Creator、JDK8 Qt Creator版本太高不行&#xff0c;亲测最新版的会导致无法使用jdk 8&#xff08;2024-05-04 我的Qt版本是5.15.2&#xff0c;所以我选择了Qt Creator5.0.3进行开发 5.0.3 下载JDK8 JDK8 安装Qt Creator、JDK8 安装Qt Creator没什么…
阅读更多...
SharedPreferences源码解析

SharedPreferences源码解析

前言 文章中部分地方SharedPreferences会简写成SP&#xff0c;先抛出几个问题&#xff1a; SP存储的是什么文件&#xff0c;存储在哪个位置&#xff1f;SP是线程安全的吗&#xff1f;SP是如何保证数据安全的&#xff1f;使用SP有哪些问题&#xff1f;SP会把数据加载到内存中吗…
阅读更多...
Windows 下用 git clone ... 下载资料，资料下载到什么地方去了？

Windows 下用 git clone ... 下载资料，资料下载到什么地方去了？

当你使用 git clone 命令在 Windows 系统上克隆一个仓库时&#xff0c;资料会被下载到你指定的目录中。如果你没有指定目录&#xff0c;那么资料会被下载到你当前所在的目录&#xff08;命令提示符或终端的当前工作目录&#xff09;中的一个新文件夹里&#xff0c;这个文件夹的…
阅读更多...
webpack与vite

webpack与vite

webpack 使用步骤&#xff1a; 初始化项目 pnpm init -y安装依赖webpack、webpack-cli在项目中创建src目录&#xff0c;然后编写代码&#xff08;index.js&#xff09;执行pnpm weboack来对代码进行打包&#xff08;打包后观察dist文件夹&#xff09; 配置古文件&#xff08;w…
阅读更多...
Android4.4真机移植过程笔记（三）

Android4.4真机移植过程笔记（三）

如果文章字体看得不是很清楚&#xff0c;大家可以下载pdf文档查看&#xff0c;文档已上传&#xff5e;oo&#xff5e; 7、安装加密APK 需要修改文件如下&#xff1a; 相对Android4.2改动还是蛮大的&#xff0c;有些文件连路径都变了: //Android4.2 1、frameworks/native/libs…
阅读更多...
【简单介绍下Lisp的学习历程】

【简单介绍下Lisp的学习历程】

&#x1f3a5;博主&#xff1a;程序员不想YY啊 &#x1f4ab;CSDN优质创作者&#xff0c;CSDN实力新星&#xff0c;CSDN博客专家 &#x1f917;点赞&#x1f388;收藏⭐再看&#x1f4ab;养成习惯 ✨希望本文对您有所裨益&#xff0c;如有不足之处&#xff0c;欢迎在评论区提出…
阅读更多...
Atcoder Begginer Contest 352 A~E题解

Atcoder Begginer Contest 352 A~E题解

文章目录 [A - AtCoder Line ](https://atcoder.jp/contests/abc352/tasks/abc352_a)[B - Typing](https://atcoder.jp/contests/abc352/tasks/abc352_b)[C - Standing On The Shoulders](https://atcoder.jp/contests/abc352/tasks/abc352_c)[D - Permutation Subsequence](ht…
阅读更多...
JSON转CSV：使用Java处理复杂数据结构

JSON转CSV：使用Java处理复杂数据结构

引言 在数据处理和分析的世界中&#xff0c;经常需要将数据从一种格式转换为另一种更便于处理或分析的格式。本文将详细介绍如何使用Java语言&#xff0c;配合Jackson和Apache Commons CSV库&#xff0c;将嵌套的JSON数据转换成CSV格式。这种技能在数据科学、软件开发和系统集…
阅读更多...
最新文章

Copyright @ 2022~2023