1. 使用poll或epoll创建echo服务器

1. 说明：

此篇博客主要记录一种客户端实现方式，和两种使用poll或者epoll分别创建echo服务器的方式，具体可看代码注释：

2. 相关代码：

2.1 echoClient.cpp
#include <iostream>
#include <cstdio>
#include <cstring>#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <unistd.h>#define ERR_EXIT(m) \do {\perror(m); \exit(EXIT_FAILURE); \} while(0)int main() {int sock;struct sockaddr_in svrAddr, localAddr;socklen_t addrlen = sizeof(sockaddr);sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);if (sock < 0)ERR_EXIT("socket");memset(&svrAddr, 0, sizeof(svrAddr));svrAddr.sin_family = AF_INET;svrAddr.sin_port = htons(8888);svrAddr.sin_addr.s_addr = inet_addr("127.0.0.1");if (connect(sock, (sockaddr *)&svrAddr, sizeof(svrAddr)) < 0)ERR_EXIT("connect");if (getsockname(sock, (sockaddr *)&localAddr, &addrlen) < 0)ERR_EXIT("getsockname");std::cout << "ip = " << inet_ntoa(localAddr.sin_addr)<< " port = " << ntohs(localAddr.sin_port) << std::endl;char sendBuf[1024] = {0};char recvBuf[1024] = {0};while (fgets(sendBuf, sizeof(sendBuf), stdin) != NULL){write(sock, sendBuf, strlen(sendBuf));read(sock, recvBuf, sizeof(recvBuf));fputs(recvBuf, stdout);memset(sendBuf, 0, sizeof(sendBuf));memset(recvBuf, 0, sizeof(recvBuf));}close(sock);return 0;
}
2.2 echoServer_poll.cpp
#include <iostream>
#include <vector>
#include <string>#include <cstdio>
#include <cstring>#include <arpa/inet.h>
#include <fcntl.h>
#include <netinet/in.h>
#include <unistd.h>#include <signal.h>
#include <poll.h>
#include <sys/socket.h>#define ERR_EXIT(m) \do {\perror(m); \exit(EXIT_FAILURE); \} while(0)using PollfdList = std::vector<pollfd>;int main()
{//忽略系统提示的一些错误信号/*signal(para1,para2)para1:信号类型para2:信号处理函数(可以自定义)讲解参考：https://blog.csdn.net/u013271656/article/details/114537411*/signal(SIGPIPE, SIG_IGN);signal(SIGCHLD, SIG_IGN);//创建一个监听套接字(非阻塞套接字)int listenfd;listenfd = socket(PF_INET, SOCK_STREAM | SOCK_NONBLOCK | SOCK_CLOEXEC, IPPROTO_TCP);if(listenfd < 0){ERR_EXIT("socket");}//设置地址struct sockaddr_in srvAddr;memset(&srvAddr,0,sizeof(srvAddr));//初始化srvAddr.sin_family = AF_INET;srvAddr.sin_port = htons(8888);srvAddr.sin_addr.s_addr = htonl(INADDR_ANY);//设置地址的重复利用int on = 1;if(setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) < 0){ERR_EXIT("setsockopt");}//绑定if(bind(listenfd, (sockaddr *)&srvAddr, sizeof(srvAddr)) < 0){ERR_EXIT("bind");}//监听if(listen(listenfd, SOMAXCONN) < 0){ERR_EXIT("listen");}//使用poll并关注pollin事件struct pollfd pfd;pfd.fd = listenfd;pfd.events = POLLIN;//储存poll的描述符PollfdList pollfds;pollfds.push_back(pfd);int nready;struct sockaddr_in peerAddr;socklen_t peerlen;int connfd;int idlefd;//空闲描述符//循环处理while (true) {//取事件nready = poll(pollfds.data(), pollfds.size(), -1);if(nready == -1){if(errno == EINTR){continue;}ERR_EXIT("poll");}else if(nready == 0){continue;}//如果有POLLIN事件if(pollfds[0].revents & POLLIN){//接受peerlen = sizeof(peerAddr);connfd = ::accept4(listenfd, (sockaddr *)&peerAddr, &peerlen, SOCK_NONBLOCK | SOCK_CLOEXEC);//剔除空闲连接if (connfd == -1) {if (errno == EMFILE) {close(idlefd);idlefd = accept(listenfd, NULL, NULL);close(idlefd);idlefd = open("/dev/null", O_RDONLY | O_CLOEXEC);continue;}else ERR_EXIT("accept4");}//加入到监听pfd.fd = connfd;pfd.events = POLL_IN;pfd.revents = 0;pollfds.push_back(pfd);--nready;//连接成功std::cout << "ip = " << inet_ntoa(peerAddr.sin_addr)<< " port = " << ntohs(peerAddr.sin_port) << std::endl;if (nready == 0)continue;}//std::cout << "pollfds size: " << pollfds.size() << std::endl;//std::cout << "nready fds: " << nready << std::endl;//遍历判断哪些套接字产生了事件for (auto it = pollfds.begin() + 1; it != pollfds.end() && nready > 0; ++it) {//如果是可读事件if (it->revents & POLL_IN) {--nready;connfd = it->fd;char buf[1024] = {0};//读取数据int ret = read(connfd, buf, 1024);if (ret == -1)ERR_EXIT("read");if (ret == 0) {std::cout << "client closed" << std::endl;it = pollfds.erase(it);--it;close(connfd);continue;}std::cout << buf << std::endl;//将接收的消息返回给客户端write(connfd, buf, strlen(buf));}}}return 0;
}
2.3 echoServer_epoll.cpp
#include <iostream>
#include <vector>
#include <string>
#include <algorithm>#include <cstdio>
#include <cstring>#include <arpa/inet.h>
#include <fcntl.h>
#include <netinet/in.h>
#include <unistd.h>#include <signal.h>
#include <sys/epoll.h>
#include <sys/socket.h>#define ERR_EXIT(m) \do {\perror(m); \exit(EXIT_FAILURE); \} while(0)using EventList = std::vector<epoll_event>;int main()
{signal(SIGPIPE, SIG_IGN);signal(SIGCHLD, SIG_IGN);//创建一个监听套接字(非阻塞套接字)int listenfd;listenfd = socket(PF_INET, SOCK_STREAM | SOCK_NONBLOCK | SOCK_CLOEXEC, IPPROTO_TCP);if(listenfd < 0){ERR_EXIT("socket");}//设置地址struct sockaddr_in srvAddr;memset(&srvAddr,0,sizeof(srvAddr));//初始化srvAddr.sin_family = AF_INET;srvAddr.sin_port = htons(8888);srvAddr.sin_addr.s_addr = htonl(INADDR_ANY);//设置地址的重复利用int on = 1;if(setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) < 0){ERR_EXIT("setsockopt");}//绑定if(bind(listenfd, (sockaddr *)&srvAddr, sizeof(srvAddr)) < 0){ERR_EXIT("bind");}//监听if(listen(listenfd, SOMAXCONN) < 0){ERR_EXIT("listen");}std::vector<int> clients;int epollfd = epoll_create(EPOLL_CLOEXEC);//使用EPOLLIN并关注EPOLLIN事件struct epoll_event event;event.data.fd = listenfd;event.events = EPOLLIN;epoll_ctl(epollfd, EPOLL_CTL_ADD, listenfd, &event);//储存epoll的描述符EventList events(16);struct sockaddr_in peerAddr;socklen_t peerlen;int connfd;int idlefd;//空闲描述符int nready;//循环处理while (true) {//取事件nready = epoll_wait(epollfd, events.data(), static_cast<int>(events.size()), -1);if(nready == -1){if(errno == EINTR){continue;}ERR_EXIT("epoll_wait");}else if(nready == 0){continue;}if (static_cast<size_t>(nready) == events.size()) {events.resize(events.size() * 2);} for (auto e : events) {if (e.data.fd == listenfd) {peerlen = sizeof(peerAddr);connfd = ::accept4(listenfd, (sockaddr *)&peerAddr, &peerlen, SOCK_NONBLOCK | SOCK_CLOEXEC);if (connfd == -1) {if (errno == EMFILE) {close(idlefd);idlefd = accept(listenfd, NULL, NULL);close(idlefd);idlefd = open("/dev/null", O_RDONLY | O_CLOEXEC);continue;}else ERR_EXIT("accept4");}clients.push_back(connfd);event.data.fd = connfd;event.events = EPOLLIN;epoll_ctl(epollfd, EPOLL_CTL_ADD, connfd, &event);std::cout << " connection from ip = " << inet_ntoa(peerAddr.sin_addr)<< " port = " << ntohs(peerAddr.sin_port) << std::endl;}else if (e.events & EPOLLIN) {connfd = e.data.fd;char buf[1024] = {0};int ret = read(connfd, buf, 1024);if (ret == -1)ERR_EXIT("read");if (ret == 0) {std::cout << "client closed" << std::endl;event = e; epoll_ctl(epollfd, EPOLL_CTL_DEL, connfd, &event);clients.erase(std::remove(clients.begin(), clients.end(), connfd), clients.end());close(connfd);continue;}std::cout << "msg: " << buf << std::endl;write(connfd, buf, strlen(buf));}}}return 0;
}

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

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

相关文章

C语言中的 sizeof 运算符

C语言中的 sizeof 运算符

在 C 语言中&#xff0c;sizeof 是一个运算符&#xff0c;用于获取给定类型或变量的字节大小。它返回一个 size_t 类型的值&#xff0c;表示以字节为单位的对象大小。 sizeof 运算符有以下特点&#xff1a; 用法&#xff1a;sizeof 运算符可以应用于数据类型或表达式。计算静…
阅读更多...
酷开科技以创新为动力用大数据提升品牌认知

酷开科技以创新为动力用大数据提升品牌认知

在21世纪的今天&#xff0c;我们生活在一个被互联网深深改变的世界。互联网不仅改变了我们的生活方式&#xff0c;也正在改变我们的思维方式和工作方式。而互联网作为一种新的发展趋势&#xff0c;更是为我们提供了无数的机会和无限可能性&#xff0c;从电子商务时代到社交网络…
阅读更多...
CSP-何以包邮？

CSP-何以包邮？

题目描述 新学期伊始&#xff0c;适逢顿顿书城有购书满 x 元包邮的活动&#xff0c;小 P 同学欣然前往准备买些参考书。 一番浏览后&#xff0c;小 P 初步筛选出 n 本书加入购物车中&#xff0c;其中第 i 本&#xff08;1≤i≤n&#xff09;的价格为 ai 元。 考虑到预算有限&am…
阅读更多...
scala编码

scala编码

1、Scala高级语言 Scala简介 Scala是一门类Java的多范式语言&#xff0c;它整合了面向对象编程和函数式编程的最佳特性。具体来讲Scala运行于Java虚拟机&#xff08;JVM)之上&#xff0c;井且兼容现有的Java程序&#xff0c;同样具有跨平台、可移植性好、方便的垃圾回收等特性…
阅读更多...
ubuntu server 20.04 备份和恢复 系统 LTS

ubuntu server 20.04 备份和恢复 系统 LTS

ubuntu server 20.04 备份和恢复 系统 LTS tar命令系统备份与恢复&#xff08;还原or新装&#xff09; 备份系统 cd / su root tar cvpzf backup.tgz --exclude/tmp --exclude/run --exclude/dev --exclude/snap --exclude/proc --exclude/lostfound --exclude/backup.tgz …
阅读更多...
启动游戏出现concrt140.dll错误的8种解决方法

启动游戏出现concrt140.dll错误的8种解决方法

在计算机使用过程中&#xff0c;我们经常会遇到一些错误提示&#xff0c;其中之一就是找不到concrt140.dll文件。这个错误通常会导致程序无法正常运行&#xff0c;给用户带来困扰。本文将介绍找不到concrt140.dll无法继续执行代码的8个方法&#xff0c;同时探讨concrt140.dll丢…
阅读更多...
LinuxBasicsForHackers笔记 -- 文件系统和存储设备管理

LinuxBasicsForHackers笔记 -- 文件系统和存储设备管理

设备目录/dev Linux 有一个特殊的目录&#xff0c;其中包含代表每个连接设备的文件&#xff1a;相应命名的 /dev 目录。 /dev中有很多设备列表。 特别令人感兴趣的是设备 sda1、sda2、sda3、sdb 和 sdb1&#xff0c;它们通常是硬盘驱动器及其分区以及 USB 闪存驱动器及其分区…
阅读更多...
理解基于 Hadoop 生态的大数据技术架构

理解基于 Hadoop 生态的大数据技术架构

转眼间&#xff0c;一年又悄然而逝&#xff0c;时光荏苒&#xff0c;岁月如梭。当回首这段光阴&#xff0c;不禁感叹时间的匆匆&#xff0c;仿佛只是一个眨眼的瞬间&#xff0c;一年的旅程已成为过去&#xff0c;而如今又到了画饼的时刻了 &#xff01; 基于 Hadoop 生态的大数…
阅读更多...
固态硬盘SSD

固态硬盘SSD

目录 1.2 组成1.3 读写性能特性1.4 与机械硬盘相比的特点1.5 磨损均衡技术 \quad \quad SSD基于闪存技术Flash Memory, 属于电可擦除ROM, 即EEPROM \quad 1.2 组成 \quad \quad \quad 系统对固态硬盘的读写是以页为单位的 固态硬盘里的块相当于机械硬盘里的磁道 固态硬盘里的页…
阅读更多...
Redis基础系列-持久化

Redis基础系列-持久化

Redis基础系列-持久化 文章目录 Redis基础系列-持久化1. 什么是持久化2. 为什么要持久化3. 持久化的两种方式3.1 持久化方式1&#xff1a;RDB(redis默认持久化方式)3.11 配置步骤-自动触发3.12 配置步骤-手动触发3.12 优点3.13 缺点3.14 检查和修复RDB快照文件3.15 哪些情况会触…
阅读更多...
每天一个Linux命令 -- (7)more命令

每天一个Linux命令 -- (7)more命令

欢迎阅读《每天一个Linux命令》系列&#xff01;在本篇文章中&#xff0c;将介绍Linux系统下的more命令&#xff0c;它用于逐屏显示文件的内容。 概念 more命令是Linux系统下的文件逐屏显示命令&#xff0c;用于逐屏显示文件的内容。 命令操作 more命令的语法如下&#xff1…
阅读更多...
ubuntu22.04 安装cuda

ubuntu22.04 安装cuda

CUDA&#xff08;Compute Unified Device Architecture&#xff09;是由 NVIDIA 开发的一种并行计算平台和编程模型。它允许开发者利用 NVIDIA 的 GPU&#xff08;图形处理单元&#xff09;进行高效的计算处理。CUDA 通过提供一系列的 C、C 和 Fortran 扩展&#xff0c;使得开发…
阅读更多...
我的NPI项目之Android电源系列 -- 关于剩余充满时间的问题（一）

我的NPI项目之Android电源系列 -- 关于剩余充满时间的问题（一）

我的新项目是基于高通最新的5G平台&#xff0c;但是由于还没有拿到EVT。所以&#xff0c;就在目旧的平台和OS上进行学习。遇到第一个问题就是插上type-c之后&#xff0c;充满剩余时间异常的问题。 问题描述&#xff0c;在充电过程中&#xff0c;显示充满时间为“0 min left unt…
阅读更多...
9.基于SpringBoot3+I18N实现国际化

9.基于SpringBoot3+I18N实现国际化

1. 新建资源文件 在resources目录下新建目录i18n, 然后 新建messages_en.properties文件 user.login.erroraccount or password error&#xff01;新建messages_zh_CN.properties文件 user.login.error帐户或密码错误&#xff01;2. 新建LocaleConfig.java文件 Configurati…
阅读更多...
2004-2021年上市公司环境规制强度相关数据

2004-2021年上市公司环境规制强度相关数据

2004-2021年上市公司环境规制强度相关数据 1、时间&#xff1a;2004-2021年 2、指标&#xff1a;年份、股票代码、股票简称、行业名称、行业代码、省份、城市、区县、行政区划代码、城市代码、区县代码、首次上市年份、上市状态、所属省份-工业增加值_亿元、所属省份-治理废气…
阅读更多...
Flink流批一体计算（24）：Flink SQL之mysql维表实时关联

Flink流批一体计算（24）：Flink SQL之mysql维表实时关联

目录 1.维表 2.数据准备 创建源数据 创建维度表 创建Sink表 3.配置任务 Flink SQL创建kafka源表 Flink SQL创建MySQL维表 Flink SQL创建MySQL结果表 编写计算任务 核验数据 1.维表 目前在实时计算的场景中&#xff0c;大多数都使用过MySQL、Hbase、redis作为维表引擎…
阅读更多...
PTA：计算总分

PTA：计算总分

题干 请编写一个函数sum&#xff0c;函数的功能是&#xff1a;计算一个由结构体表示的包含多门课程成绩组成的学生的总成绩。 函数接口定义&#xff1a; double sumScore(struct student stu); 其中 stu是用户传入的参数。函数须返回学生的总成绩。 裁判测试程序样例&#x…
阅读更多...
【华为数据之道学习笔记】3-7 报告数据治理

【华为数据之道学习笔记】3-7 报告数据治理

报告数据是指对数据进行处理加工后&#xff0c;用作业务决策依据的数据。它用于支持报告和报表的生成。 用于报告和报表的数据可以分为如下几种。 用于报表项数据生成的事实表、指标数据、维度。 用于报表项统计和计算的统计函数、趋势函数及报告规则。 用于报表和报告展示的…
阅读更多...
AVFormatContext编解码层：理论与实战

AVFormatContext编解码层：理论与实战

文章目录 前言一、FFmpeg 解码流程二、FFmpeg 转码流程三、编解码 API 详解1、解码 API 使用详解2、编码 API 使用详解 四、编码案例实战1、示例源码2、运行结果 五、解码案例实战1、示例源码2、运行结果 前言 AVFormatContext 是一个贯穿始终的数据结构&#xff0c;很多函数都…
阅读更多...
前后端分离项目跨域请求

前后端分离项目跨域请求

一、前端vue项目 在项目中创建request.js文件&#xff0c;添加以下内容 import axios from "axios"; const api axios.create({ //这里配置的是后端服务提供的接口baseURL: "http://localhost:8080/web-demo",timeout: 1000} ); export default api; …
阅读更多...
最新文章

Copyright @ 2022~2023