C++Linux网络编程:简单的select模型运用

文章目录

    • 前言
    • 源代码
    • 部分重点解读
      • read/write与recv/send
        • 在使用上的差异

前言

这段代码来自于游双的《Linux高性能服务器编程》,在Ubuntu中对代码进行了实现,并在注释部分加上了我的个人解读

源代码

//
#include <sys/types.h>
// 网络通讯的核心函数都在这
#include <sys/socket.h>
//
#include <netinet/in.h>
#include <arpa/inet.h>
//
#include <assert.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
//
#include <fcntl.h>
//
#include <stdlib.h>int main(int argc, char* argv[]){if(argc < 2){// basename这个函数在string.h中// 这个函数会去除文件名中的目录部分,只留下真正的文件名printf("usage:%s ip_address port_number\n", basename(argv[0]));return 1;}// 设置ip和portconst char* ip = argv[1];// 这个atoi其实就是C++string中的stoi,其中的a是ASCII的缩写int port = atoi(argv[1]);// 使用ret来接收函数的返回值,以此来判断程序是否出错int ret = 0;sockaddr_in address;bzero(&address, sizeof(sockaddr_in));address.sin_family = AF_INET;/*因为我们输入的内容通常是点分十进制但是在网络传输的实际过程中,ip和port通常都需要在二进制的形式下进行处理此函数将ip转换为二进制后,将其设置为sockaddr_in.sin_addr这个函数在头文件arpa/inet.h中*/inet_pton(AF_INET, ip, &address.sin_addr);address.sin_port = htons(port);// 创建监听套接字int listenfd = socket(PF_INET, SOCK_STREAM, 0);/*这是一个断言它判断条件是否满足若是满足,程序继续运行;若是不满足,程序终止运行,并输出错误信息*/assert(listenfd >= 0);ret = bind(listenfd, (struct sockaddr*)&address, sizeof(address));assert(ret != -1);// 第二个参数是指:能够同时处理的最大连接数ret = listen(listenfd, 5);assert(ret != -1);struct sockaddr_in client_address;/*用于表示表示套接字地址结构长度的数据类型。是一个无符号整数类型,在套接字编程中用于指定套接字地址结构的长度。socklen_t类型的变量则用于指示地址结构的大小,常用于与函数accept()、bind()、connect()等配合使用。*/socklen_t client_addrlength = sizeof(client_address);int connfd = accept(listenfd, (struct sockaddr*)&client_address, &client_addrlength);// 如果套接字创建失败if(connfd < 0){printf("errno is:%d", errno);close(listenfd);}/*有点不明觉厉*/char buf[1024];fd_set read_fds;fd_set exception_fds;FD_ZERO(&read_fds);FD_ZERO(&exception_fds);while(1){memset(buf, '\0', sizeof(buf));/*每次调用select前都要重新在read_fds和expection_fdfs中设置文件描述符connfd因为事件发生后,文件描述符集合将被内核修改将文件描述符:connfd的状态进行设置同时对其开启“读”和“异常”处理*/FD_SET(connfd, &read_fds);FD_SET(connfd, &exception_fds);/*这里就有个问题了,第一个参数它是什么?是:指定被监听文件描述符的总数而文件描述符是从0开始的,因此需要+1*/ret = select(connfd+1, &read_fds, NULL, &exception_fds, NULL);if(ret < 0){printf("selection failure");break;}/*对于可读事件,采用普通的recv函数读取数据*/if(FD_ISSET(connfd, &read_fds)){/*可以发现,大佬在使用recv的时候使用的是sizeof(buf)-1这是因为在C格式的字符串中,存在结尾标识符,即:\0而-1能够保证我们能够很完整得读取数据*/ret = recv(connfd, buf, sizeof(buf)-1, 0);if(ret < 0){break;}printf("get%d bytes of normal data:%s\n", ret, buf);}/*对于异常事件,采用才MSG_OOB标志的recv函数读取带外数据(这个地方看得不是太懂)*/else if(FD_ISSET(connfd, &exception_fds)){/*recv的最后一个参数就是指定传输的数据类型MSG_OOB就是带外数据的意思这个宏在send和recv中常常被使用*/ret = recv(connfd, buf, sizeof(buf)-1, MSG_OOB);if(ret < 0){break;}printf("get#d bytes of oob data:%s\n", ret, buf);}}close(connfd);close(listenfd);return 0;
}

部分重点解读

在这篇文章之前,我已经写完我的Linux网络编程的day01与day02,可能会有细心的读者发现:在先前我对接收到的数据进行处理使用的是read和write,而在此处我使用的是recv和send,这是因为我两部分代码的出处不同,有的是来自的Github的开源教程,有的是来自《Linux高性能网络编程》一书。
实际上,这两个函数的差别不是很大。我们都知道:在Linux中,万事万物皆文件,网络编程的本质也是对文件进行操作
read和write是使用的Linux系统提供的接口,而recv和send则是套接字提供的函数,这里就来说说它两的区别。

read/write与recv/send

在先前的代码中,我们使用read/write都需要包含头文件unistd.h,我们先来看看read/write的函数声明(Linux下的GCC编译器):

ssize_t read (int __fd,        void *__buf, size_t __nbytes);
ssize_t write (int __fd, const void *__buf, size_t __n);

这个声明可以说是一看就懂,那我也就不过多赘述了。
接下来重点说说recv/send,先前说过,这两个函数由网络通信提供,因此就在头文件,sys/socket.h中:

ssize_t recv (int __fd,       void *__buf, size_t __n, int __flags);
ssize_t send (int __fd, const void *__buf, size_t __n, int __flags);

可以发现:recv/send多提供了一个标识作为参数,这也正是它的优点之一:可以使用额外的控制标志来控制数据传输的行为


在使用上的差异

虽然它们都将文件描述符作为第一个参数,但是实际上它们是有区别的:

  • read/write的第一个参数是要处理的文件的文件描述符
  • recv/send是将已连接的套接字描述符作为参数

这个我觉得是一个容易出错的点,但是想想好像也很好理解。

错误检测:这些函数的返回值都表示读取/发送的字节数,若是返回值为-1,则说明发生了错误,同时它们会设置error,因此我们可以以此来进行异常检测。

recv/send的最后一个参数用来控制数据传输的行为,在本文中,我们已经使用了MSG_OOB用于紧急数据传输,除此之外还有很多的常用的标识,例如:

  • MSG_DONTWAIT:在非阻塞模式下进行数据传输。如果没有可用的数据或缓冲区已满,函数会立即返回,而不会阻塞等待。该标志可用于确保接收或发送操作不会阻塞应用程序。
  • MSG_PEEK:从套接字缓冲区中查看数据,但不将其从缓冲区中移除。这样可以检查下一个数据报或消息的内容,而不会实际读取它。该标志可用于预览数据而不丢失它们,或者在处理选择器时检查可读或可写事件的条件。
  • MSG_WAITALL:在接收数据时,要求函数等待,直到请求的数据完全接收到缓冲区中后再返回。如果没有足够的数据可用,则函数将阻塞等待直到所有请求的数据接收完毕。

具体的解释我们以后再说。

总的来说:recv()和send()函数更适用于处理网络连接和套接字流量控制,具有更多的控制选项,而read()和write()函数更通用。在此处我们使用了select模型,该模型需要将数据类型分类,我想,这也许就是作者使用recv而不是read的原因吧。

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

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

相关文章

JavaScript 设计模式之代理模式

代理模式 其实这种模式在现在很多地方也都有使用到&#xff0c;如 Vue3 中的数据相应原理就是使用的 es6 中的 Proxy 代理及 Reflect 反射的方式来处理数据响应式 我们日常在使用数据请求时&#xff0c;也会用到一些代理的方式&#xff0c;比如在请求不同的域名&#xff0c;端…

C++ 广度优先搜索的标记策略(五十六)【第三篇】

今天我们来看看bfs是如何规划标记策略的。 1.标记策略 但先等一下&#xff0c;先看一道题《一维坐标的移动》 在一个长度为 n 的坐标轴上&#xff0c;蒜头君想从 A 点 移动到 B 点。他的移动规则如下&#xff1a; 向前一步&#xff0c;坐标增加 1。 向后一步&#xff0c;坐…

Vue插槽

Vue插槽 一、插槽-默认插槽1.作用2.需求3.问题4.插槽的基本语法5.代码示例6.总结 二、插槽-后备内容&#xff08;默认值&#xff09;1.问题2.插槽的后备内容3.语法4.效果5.代码示例 三、插槽-具名插槽1.需求2.具名插槽语法3.v-slot的简写4.代码示例5.总结 四、作用域插槽1.插槽…

安卓价值1-如何在电脑上运行ADB

ADB&#xff08;Android Debug Bridge&#xff09;是Android平台的调试工具&#xff0c;它是一个命令行工具&#xff0c;用于与连接到计算机的Android设备进行通信和控制。ADB提供了一系列命令&#xff0c;允许开发人员执行各种操作&#xff0c;包括但不限于&#xff1a; 1. 安…

不关电脑不仅仅是因为懒

程序员为什么不喜欢关电脑&#xff1f;不管用台式机&#xff0c;还是笔记本&#xff0c;总有一批程序员下班后从不关闭电脑&#xff0c;台式机按掉屏幕电源&#xff0c;笔记本直接合上休眠就是了。 这种现象说明这些程序员懒吗&#xff1f;还是有其它原因&#xff1f;从我自身的…

【网络层介绍】

文章目录 一、网络层概述1. 网络层的作用2. 网络层与其他层的关系 二、核心协议和技术1. IP协议2. 路由和转发3. 子网划分和超网 三、网络层设备1. 路由器2. 三层交换机 一、网络层概述 1. 网络层的作用 网络层主要负责在不同网络间传输数据包&#xff0c;确保数据能够跨越多…

在python中JSON数据格式的使用

什么是JSON&#xff1f; JSON是一种数据格式&#xff0c;由美国程序设计师DouglasCrockford创建的&#xff0c;JSON全名是JavaScript Object Notation,由JSON英文全文字义我们可以推敲JSON的缘由&#xff0c;最初是为JavaScript开发的。这种数据格式由于简单好用被大量应用在We…

Rust Option类型详解

在Rust中&#xff0c;Option是一种枚举类型&#xff0c;用于表示一个可能有值&#xff0c;也可能为空&#xff08;None&#xff09;的情况。它是Rust中对于空值安全处理的一种方式&#xff0c;与其他语言中的null或undefined相比&#xff0c;Option提供了更安全、更明确的方式来…

DS Wannabe之5-AM Project: DS 30day int prep day15

Q1. What is Autoencoder? 自编码器是什么&#xff1f; 自编码器是一种特殊类型的神经网络&#xff0c;它通过无监督学习尝试复现其输入数据。它通常包含两部分&#xff1a;编码器和解码器。编码器压缩输入数据成为一个低维度的中间表示&#xff0c;解码器则从这个中间表示重…

数据库被人破解,删除数据,勒索

事情是这样的&#xff0c;我买了一台服务器自己部署项目玩儿玩儿&#xff0c;我的数据库运行在3306端口&#xff0c;密码没改&#xff0c;就是默认的123456&#xff0c;诡异的事情发生了&#xff0c;用了一段时间之后&#xff0c;数据库突然连接不上了&#xff0c;我一通操作猛…

Python爬虫——解析库安装(1)

目录 1.lxml安装2.Beautiful Soup安装3.pyquery 的安装 我创建了一个社区&#xff0c;欢迎大家一起学习交流。社区名称&#xff1a;Spider学习交流 注&#xff1a;该系列教程已经默认用户安装了Pycharm和Anaconda&#xff0c;未安装的可以参考我之前的博客有将如何安装。同时默…

中科星图GVE(AI案例)——AI影像进行超分案例

简介 超分辨率图像处理是一种通过增加图像的空间分辨率来提高图像质量的技术。传统的超分辨率算法主要基于插值和滤波方法,然而这些方法往往无法准确恢复丢失的高频细节,导致图像出现模糊或失真。近年来,基于人工智能的超分辨率算法得到了广泛的关注和研究。下面将介绍AI影…

【开源】SpringBoot框架开发企业项目合同信息系统

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 数据中心模块2.2 合同审批模块2.3 合同签订模块2.4 合同预警模块2.5 数据可视化模块 三、系统设计3.1 用例设计3.2 数据库设计3.2.1 合同审批表3.2.2 合同签订表3.2.3 合同预警表 四、系统展示五、核心代码5.1 查询合同…

Linux多线程[二]

引入知识 进程在线程内部执行是OS的系统调度单位。 内核中针对地址空间&#xff0c;有一种特殊的结构&#xff0c;VM_area_struct。这个用来控制虚拟内存中每个malloc等申请的空间&#xff0c;来区别每个malloc的是对应的堆区哪一段。OS可以做到资源的精细度划分。 对于磁盘…

ModuleNotFoundError: No module named ‘_bz2‘

今天装了py3.11&#xff0c;但是在导入pandas的时候出现了以下错误&#xff1a; from _bz2 import BZ2Compressor, BZ2Decompressor ModuleNotFoundError: No module named _bz2很显然缺少了依赖包&#xff0c;可以用 yum install bzip2进行安装&#xff0c;安装之后发现还是…

嵌入式软件设计入门:从零开始学习嵌入式软件设计

&#xff08;本文为简单介绍&#xff0c;个人观点仅供参考&#xff09; 首先,让我们了解一下嵌入式软件的定义。嵌入式软件是指运行在嵌入式系统中的特定用途软件,它通常被用来控制硬件设备、处理实时数据和实现特定功能。与桌面应用程序相比,嵌入式软件需要具备更高的实时性、…

C++ //练习 7.5 在你的Person类中提供一些操作使其能够返回姓名和住址。这些函数是否应该是const的呢?解释原因。

C Primer&#xff08;第5版&#xff09; 练习 7.5 练习 7.5 在你的Person类中提供一些操作使其能够返回姓名和住址。这些函数是否应该是const的呢&#xff1f;解释原因。 环境&#xff1a;Linux Ubuntu&#xff08;云服务器&#xff09; 工具&#xff1a;vim 解释 姓名大概…

反无人机系统技术分析,无人机反制技术理论基础,无人机技术详解

近年来&#xff0c;经过大疆、parrot、3d robotics等公司不断的努力&#xff0c;具有强大功能的消费级无人机价格不断降低&#xff0c;操作简便性不断提高&#xff0c;无人机正快速地从尖端的军用设备转入大众市场&#xff0c;成为普通民众手中的玩具。 然而&#xff0c;随着消…

Python算法题集_翻转二叉树

Python算法题集_翻转二叉树 题226&#xff1a;翻转二叉树1. 示例说明2. 题目解析- 题意分解- 优化思路- 测量工具 3. 代码展开1) 标准求解【DFS递归】2) 改进版一【BFS迭代&#xff0c;节点循环】3) 改进版二【BFS迭代&#xff0c;列表循环】 4. 最优算法 本文为Python算法题集…

Spring Boot 笔记 019 创建接口_文件上传

1.1 创建阿里OSS bucket OSS Java SDK 兼容性和示例代码_对象存储(OSS)-阿里云帮助中心 (aliyun.com) 1.2 编写工具类 package com.geji.utils;import com.aliyun.oss.ClientException; import com.aliyun.oss.OSS; import com.aliyun.oss.OSSClientBuilder; import com.aliyun…