Echo服务器学习__01(基础)

ASIO是一个跨平台，主要用于实现异步网络和其他一些底层I/O操作的C++库

可以基于ASIO实现Echo服务端，在这之前，学习一些基础的知识和概念

​

1：IO多路复用

简单的来说，一个线程同时监听多个I/O事件就是I/O多路复用。任何一个I/O流操作不需要阻塞等待每个I/O流的完成，即非阻塞

2：并发、并行、串行

并发(Concurrency)，并发偏重于多个任务交替执行，并发的"同时"是经过上下文快速切换，使得看上去多个进程同时都在运行的现象，是一种OS欺骗用户的现象

并行（Parallelism），并行指的是多个任务同时在多个处理单元上同时执行的能力，并行的"同时"是同一时刻可以多个进程在运行(处于running)

串行（Sequential），当任务按照固定的顺序依次执行，每个任务的开始都要等待上一个任务的完成，这就是串行执行

3：文件描述符（file descriptor，简称FD）

Linux 系统中，把一切都看做是文件（一切皆文件），当进程打开现有文件或创建新文件时，内核向进程返回一个文件描述符，文件描述符就是内核为了高效管理已被打开的文件所创建的索引，用来指向被打开的文件，所有执行I/O操作的系统调用都会通过文件描述符。

FD也可以被称为文件句柄(file handle)、文件指针(file pointer)或文件引用(file reference)。简单来说，它是操作系统为了管理 I/O 操作而维护的一个表中的索引，代表着系统中打开的文件的一个“门牌号”。

image.png

4：服务器套接字（Socket）

是在网络编程中用于实现网络通信的一种抽象接口，它提供了一种统一的编程接口，使得应用程序可以在网络上进行数据传输和通信。套接字的实现通常涉及到操作系统内核、网络协议栈和网络硬件设备等多个层面

Socket的过程形容为打电话，流程就如下：

  1. 创建Socket：就像拿起一部电话，准备开始通话。

  2. 绑定地址和端口：类似于确定你要打电话的号码。

  3. 监听连接请求（对于服务器端）：准备接听来自其他人的电话。

  4. 接受连接（对于服务器端）：接听来自其他人的电话。

  5. 连接到远程主机（对于客户端）：拨打某个号码开始通话。

  6. 发送和接收数据：你可以通过电话传递信息了。

  7. 关闭连接：挂断电话，结束通话。

4：select(80年代)，epoll(多用)，poll

①Select的实现：

#include <iostream>
#include <vector>
#include <algorithm>
#include <cstring>
#include <cstdio>
#include <cstdlib>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>int main() {// 创建 TCP 服务器套接字int server_socket = socket(AF_INET, SOCK_STREAM, 0); //AF_INET: 是一个宏，表示使用 IPv4 地址族（Address Family）,套接字将使用 IPv4 地址来标识主机和端口，也可以使用AF_INET6表示IPv6//SOCK_STREAM: 是一个宏，表示创建一个基于流的套接字，用于 TCP 协议，如果是SOCK_DGRAM，就是使用UDP协议//0: 是套接字的类型标志，通常为 0if (server_socket == -1) {      //-1表示没有成功创建socketperror("socket failed");    exit(EXIT_FAILURE);        //exit() 函数用于终止程序的执行，并返回一个整数参数作为程序的退出状态码。//EXIT_FAILURE 是一个宏，表示程序执行失败的状态码，通常定义为非零值。}// 设置服务器地址和端口struct sockaddr_in server_address;    //用于存储服务器地址信息的数据结构memset(&server_address, 0, sizeof(server_address));    //将 server_address 结构体中的所有字节都设置为零的操作，初始化结构体server_address.sin_family = AF_INET;                   //这行代码设置了地址族为 AF_INET，表示使用 IPv4 地址族。AF_INET 是一个常量，代表 IPv4 地址族。server_address.sin_addr.s_addr = htonl(INADDR_ANY);    //这行代码设置了 IP 地址为 INADDR_ANY，表示服务器将接受来自任意网络接口的连接请求server_address.sin_port = htons(8080);                 //这行代码设置了端口号为 8080，并将其从主机字节序转换为网络字节序// 绑定地址和端口if (bind(server_socket, (struct sockaddr*)&server_address, sizeof(server_address)) == -1) {    //bind() 函数的第二个参数是一个指向 struct sockaddr 类型的指针//&server_address 返回的是指向server_address 结构体变量的指针，也就是指向该变量在内存中的地址//server_address 的地址转换为一个指向通用地址结构体的指针，以便能够传递给网络编程函数perror("bind failed");close(server_socket);exit(EXIT_FAILURE);}// 监听连接请求if (listen(server_socket, 5) == -1) {perror("listen failed");close(server_socket);exit(EXIT_FAILURE);}std::cout << "Server started, waiting for connections..." << std::endl;// 创建要监视的文件描述符集合，并将服务器套接字加入集合中std::vector<int> client_sockets;fd_set read_fds;FD_ZERO(&read_fds);FD_SET(server_socket, &read_fds);int max_fd = server_socket;while (true) {// 使用 select 函数等待文件描述符就绪fd_set tmp_fds = read_fds;    //fd_set 是一个位图（bitmap），它将每个文件描述符映射到一个位（bit）。在 fd_set 中，每个位代表一个文件描述符//当位被设置为 1 时，表示相应的文件描述符是待监听的；当位被设置为 0 时，表示相应的文件描述符不需要监听if (select(max_fd + 1, &tmp_fds, NULL, NULL, NULL) == -1) {    //max_fd 表示监视的文件描述符集合中的最大文件描述符//fd_set 结构的指针,select() 函数将检查 tmp_fds 集合中的文件描述符，判断是否有文件描述符处于就绪状态    //第三个参数用于指定要监视的写和异常事件的文件描述符集合//第四个参数用于指定 select() 函数的超时时间。在这里传入 NULL 表示 select() 函数将一直阻塞，直到有文件描述符就绪或者出错为止//第五个参数用于指定 select() 函数的超时时间精度perror("select failed");close(server_socket);exit(EXIT_FAILURE);}// 遍历就绪的文件描述符for (int fd = 0; fd <= max_fd; ++fd) {if (FD_ISSET(fd, &tmp_fds)) {    //FD_ISSET() 是一个宏，用于检查指定的文件描述符是否在给定的 fd_set 集合中被设置if (fd == server_socket) {     如果是服务器套接字，表示有新的连接请求int client_socket = accept(server_socket, NULL, NULL);     //调用 accept() 函数来接受客户端的连接请求，并创建一个新的套接字用于与客户端进行通信。//第二个参数表示指向 struct sockaddr 类型的指针，用于获取客户端的地址信息。在这里传入 NULL 表示不获取客户端的地址信息。//第三个参数指向 socklen_t 类型的指针，用于获取客户端地址结构体的大小。在这里传入 NULL 表示不获取客户端地址结构体的大小if (client_socket == -1) {perror("accept failed");close(server_socket);exit(EXIT_FAILURE);}std::cout << "New connection" << std::endl;client_sockets.push_back(client_socket);FD_SET(client_socket, &read_fds);    //将 client_socket 添加到 read_fds 集合中，以便在调用 select() 函数时监视它的就绪状态。max_fd = std::max(max_fd, client_socket);} else {// 如果是客户端套接字，表示有数据可读char buffer[1024];ssize_t bytes_received = recv(fd, buffer, sizeof(buffer), 0);if (bytes_received <= 0) {// 客户端关闭连接std::cout << "Connection closed" << std::endl;close(fd);FD_CLR(fd, &read_fds);client_sockets.erase(std::remove(client_sockets.begin(), client_sockets.end(), fd), client_sockets.end());} else {buffer[bytes_received] = '\0';std::cout << "Received from client: " << buffer << std::endl;}}}}}return 0;
}

所以我们能看出select的缺点：

    bitmap缺点，只能是1024

    FDset不可重用，每次都需要新声明

    用户态到内核太切换要开销

    select()函数每次都要重新遍历文件描述符

②poll

struct pollfd{int fd;short events;short revents;
};    //fd 表示文件描述符，events 表示要监视的事件，revents 表示实际发生的事件
for(i = 0; i<5,i++){memset(client,0,sizeof(client));    //memset 是 C/C++ 标准库中的一个函数，用于将一块内存区域的内容设置为指定的值。addrlen = sizeof(client);pllfds[i] = accept(sockfd,(struct sockaddr*)&client,&addelen);pooldfs[i].events = POLLIN;    //设置 poolfds[i].events 为 POLLIN，表示要监视该文件描述符的可读事件。}sleep(1);while(1){puts("round again");poll(poolfds,5,50000); //阻塞函数，等待文件描述符有数据for(i = 0;i<5;i++)    //遍历 poolfds 数组，检查每个文件描述符的事件。如果 revents 中包含 POLLIN 事件，表示该文件描述符有数据可读。{if(poolfds[i].revents & POOLIN){poolfds[i].revents = 0;    //清空 revents，就是置位memset(buffer,0,MAXBUF);read(poolfds[i].fd,buffer,MAXBUF); //读取数据puts(buffer);}}}

③epoll

struct epoll_event events[5];    
int epfd = epoll_create(10);    //参数 10 表示 epoll 实例的大小，但是在实际中这个参数并不会限制 epoll 实例的大小，内核会根据需要调整大小。
..
..
for(i = 0;i<5;i++)
{static struct epoll_event ev;memset(&client,0,sizeof(client));addlen = sizeof(client);ev.data.fd = accept(sockfd,(struct sockaddr*(&client, &addrlen);    //向 epoll 实例中添加了 5 个文件描述符，这些文件描述符是通过 accept() 函数接受客户端连接而得到的ev.events = EPOLLIN;    //每个事件的类型都设置为 EPOLLIN，表示监听可读事件epoll_ctl(epfd,EPOLL_CTL_ADD,ev.data.fd,&ev);    //epoll_ctl() 函数将其添加到 epoll 实例中
}
while(true){puts("round again");nfds = epoll_wait(epfd,events,5,10000);for(i == 0;i<nfds;i++){memset(buffer,0,MAXBUF);read(events[i].data.fd,buffer,MAXBUF);puts(buffer);}
}

epoll中最重要的函数就是epoll_wait()函数

他的原型是

int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout);

epfd：是 epoll 实例的文件描述符，即通过 epoll_create() 创建的 epoll 实例。

events：是一个结构体数组，用于存储发生的事件信息

maxevents：是 events 数组的大小，即最多能够存储多少个事件。timeout：是超时时间，以毫秒为单位。如果设置为 -1，表示永远等待，直到有事件发生；如果设置为 0，表示立即返回，不阻塞；如果大于 0，表示等待指定时间后返回

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

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

相关文章

Python Learn day05

Python Learn day05

Python Learn day05 本文主要讲解 继承、多态、定制类 继承和多态 什么是继承 当新类想要拥有现有类的功能结构&#xff0c;可以使用继承。继承的前提是新类 is a 现有类&#xff0c;即&#xff1a; 子类 is 父类 总是从某个类继承&#xff1a; class Myclass(object):pass…
阅读更多...
GaussDB数据库的索引管理

GaussDB数据库的索引管理

目录 一、引言 二、GaussDB数据库中的索引基本概念 1. 什么是GaussDB索引&#xff1f; 2. GaussDB索引的作用 三、GaussDB支持的索引类型 1. B-Tree索引 2. GIN索引 3. GiST索引 4. SP-GiST索引 四、创建和管理GaussDB索引 1. 创建索引 2. 删除索引 3. 索引的优化…
阅读更多...
中兴通讯联手新疆移动，开通全疆首个乡农场景700M+900M双频双模基站

中兴通讯联手新疆移动，开通全疆首个乡农场景700M+900M双频双模基站

日前&#xff0c;在新疆博尔塔拉蒙古自治州&#xff0c;中兴通讯携手新疆移动共同完成了全疆首个乡农场景的700M900M双频双模基站建设&#xff0c;其通过采用“700M与900M共天馈共RRU设备”&#xff0c;成功实现乡农4/5G网络的同站址快速部署&#xff0c;为新疆的农牧业发展注入…
阅读更多...
密码CTF

密码CTF

一、[SWPUCTF 2021 新生赛]crypto8——unencode编码 1.题目 73E-30U1&>V-H965S95]I<U]P;WE<GT 特征&#xff1a;有-&#xff0c;是uuencode编码&#xff0c;使用python脚本或者在线网站 二、[AFCTF 2018]Vigenre——维吉尼亚密码 1.题目&#xff1a; 给了一个…
阅读更多...
中国联通全球无缝连接，畅享高速通信

中国联通全球无缝连接，畅享高速通信

中国联通&#xff0c;作为通信行业的领军企业&#xff0c;致力于为企业提供高效、稳定、安全的无线连接解决方案。我们依托覆盖全球的4G/5G网络和卫星连接服务&#xff0c;实现全球无缝连接&#xff0c;确保企业无论身处何地&#xff0c;都能畅享高速通信和数据传输体验。 一、…
阅读更多...
【Git】Github 上commit后，绿格子contribution却不显示？不知道怎么弥补？解决方法在这里

【Git】Github 上commit后，绿格子contribution却不显示？不知道怎么弥补？解决方法在这里

github 上commit后&#xff0c;绿格子&#xff08;contribution&#xff09;却不显示 问题描述 今天一直在github上面commit代码&#xff0c;但是github中并没有显示自己的contribution&#xff08;没有绿色的格子&#xff09;&#xff0c;全是空白&#xff0c;网上一查是因为…
阅读更多...
YOLOv9(3):YOLOv9损失（Loss）计算

YOLOv9(3):YOLOv9损失（Loss）计算

1. 写在前面 YOLOv9的Loss计算与YOLOv8如出一辙&#xff0c;仅存在略微的差异。多说一句&#xff0c;数据的预处理和导入方式都是一样的。因此如果你已经对YOLOv8了解的比较透彻&#xff0c;那么对于YOLOv9你也只是需要多关注网络结构就可以。 YOLOv9本身也是Anchor-Free的&a…
阅读更多...
JavaScript中的事件模型(详细案例代码)

JavaScript中的事件模型(详细案例代码)

文章目录 一、事件与事件流二、事件模型原始事件模型特性 标准事件模型特性 IE事件模型 一、事件与事件流 javascript中的事件&#xff0c;可以理解就是在HTML文档或者浏览器中发生的一种交互操作&#xff0c;使得网页具备互动性&#xff0c; 常见的有加载事件、鼠标事件、自定…
阅读更多...
react中JSX的详解

react中JSX的详解

目录 JSX的本质及其与JavaScript的关系探究 一、JSX的本质 二、JSX与JavaScript的关系 三、为什么要使用JSX 四、不使用JSX的后果 五、JSX背后的功能模块 JSX的本质及其与JavaScript的关系探究 在React开发中&#xff0c;JSX是一个不可或缺的部分。那么&#xff0c;JSX的…
阅读更多...
SQLiteC/C++接口详细介绍之sqlite3类（四）

SQLiteC/C++接口详细介绍之sqlite3类（四）

快速跳转文章列表&#xff1a;SQLite—系列文章目录 上一篇&#xff1a;SQLiteC/C接口详细介绍之sqlite3类&#xff08;三&#xff09; 下一篇&#xff1a;SQLiteC/C接口详细介绍之sqlite3类&#xff08;五&#xff09; 编写不易&#xff0c;有用的朋友点个赞或加粉一下万分感…
阅读更多...
图片和PDF 加水印去水印

图片和PDF 加水印去水印

图片和PDF 加水印去水印 前要1. 图片加水印1.1 方法11.2 方法2 2. 图片去水印3. pdf 加水印4. pdf 去水印 前要 网上查了很多资料, 汇总了几个不错的代码, 顺便做个笔记 1. 图片加水印 1.1 方法1 简单方便, 后也好处理 # -*- coding:utf-8 -*- import os from PIL import…
阅读更多...
力扣由浅至深 每日一题.06 删除有序数组中的重复项

力扣由浅至深 每日一题.06 删除有序数组中的重复项

希望我们都能对抗生活的苦难&#xff0c;在乌云周围突破阴霾积极的生活 —— 24.3.16 删除有序数组中的重复项 提示 给你一个 非严格递增排列 的数组 nums &#xff0c;请你 原地 删除重复出现的元素&#xff0c;使每个元素 只出现一次 &#xff0c;返回删除后数组的新长度。元…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023