C/S架构学习之使用epoll实现TCP特大型并发服务器

  • epoll实现TCP特大型并发服务器的流程:
  • 一、创建套接字(socket函数):
  • 通信域选择IPV4网络协议、套接字类型选择流式
	int sock_fd = socket(AF_INET,SOCK_STREAM,0); //通信域选择IPV4、套接字类型选择流式
  • 二、填充服务器和客户机的网络信息结构体:
  • 1.分别定义服务器网络信息结构体变量serveraddr和客户机网络信息结构体变量clientaddr
  • 2.分别求出服务器和客户机的网络信息结构体变量的内存空间大小,以作备用;
  • 3.网络信息结构体清0
  • 4.使用IPV4网络协议AF_INET
  • 5.在终端预留服务器端主机的IP地址inet_addr(argv[1])
  • 6.在终端预留服务器端网络字节序的端口号htons(atoi(argv[2]))
	struct sockaddr_in serveraddr; //定义服务器网络信息结构体变量struct sockaddr_in clientaddr;socklen_t serveraddr_len = sizeof(serveraddr);//求出服务器结构体变量的内存空间大小socklen_t clientaddr_len = sizeof(clientaddr);//求出客户机结构体变量的内存空间大小memset(&serveraddr,0,serveraddr_len); //服务器结构体清零memset(&clientaddr,0,clientaddr_len);//客户机结构体清零serveraddr.sin_family = AF_INET;  //使用IPV4网络协议serveraddr.sin_addr.s_addr = inet_addr(argv[1]);  //IP地址serveraddr.sin_port = htons(atoi(argv[2]));//网络字节序的端口号
  • 三、设置允许端口复用(setsockopt函数):
  • setsockopt函数:
  • 功能:设置套接字属性;
#include <sys/types.h>#include <sys/socket.h>int setsockopt(int sockfd, int level, int optname,const void *optval, socklen_t optlen);	/*参数:sockfd:套接字level:	选项的级别套接字API级别		SOL_SOCKETTCP级别			IPPROTO_TCPIP级别			IPPROTO_IPoptname:选项的名字套接字API级别SO_BROADCAST	是否允许发送广播SO_RCVBUF		接收缓冲区的大小SO_SNDBUF		发送缓冲区的大小SO_RCVTIMEO		接收超时时间参数使用的是 struct timeval 结构体如果超时了 函数调用会立即返回-1并将错误码置成 EAGAINSO_SNDTIMEO			发送超时时间SO_REUSEADDR		端口复用TCP级别TCP_NODELAY		使能/禁用Nagle算法IP级别IP_ADD_MEMBERSHIP	设置加入多播组optval:	选项的值没有特殊说明时 使用的都是int类型optlen:optval的大小返回值:成功 	0失败 	-1 	重置错误码*/
  • 特别注意:
  • 使用setsockopt设置允许端口复用时,其在代码的位置在填充网络信息结构体和bind之间;
	int reuse = 1;if(-1 == (setsockopt(sock_fd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)))){perror("setsockopt error");exit(-1);}
  • 四、套接字和服务器的网络信息结构体进行绑定(bind函数):
	int ret = bind(sock_fd,(struct sockaddr *)&serveraddr,serveraddr_len);
  • 五、套接字设置成被动监听(listen函数):
	int ret1 = listen(sock_fd, 5);
  • 六、创建红黑树(epoll_create函数):
	#include <sys/epoll.h>int epoll_create(int size);/*功能:创建epoll/创建epoll实例的描述符参数:size:参数已经被忽略了,只需要填写大于0的值即可返回值:epoll_create 调用成功时会返回一个非负整数epfd,表示新创建的 epoll 实例的文件描述符,如果调用失败则返回 -1,并设置 errno 变量以指示具体错误原因*/
	int epfd = epoll_create(1);if(-1 == epfd){perror("epoll_create error");exit(-1);}
  • 七、定义事件结构体变量和存放就绪事件描述符的数组:
  • 事件结构体epoll_event用于描述一个文件描述符上的事件;
			typedef union epoll_data {void        *ptr;int          fd;  uint32_t     u32;uint64_t     u64;} epoll_data_t;   struct epoll_event {uint32_t     events;      //EPOLLIN 读 / EPOLLOUT 写epoll_data_t data;        //存放用户的数据};    
struct epoll_event event;struct epoll_event events[N];
  • 八、将关心的文件描述符加入到红黑树(epoll_ctl函数):
  • 功能:epoll的控制操作或者用于向 epoll 实例中添加、修改、删除事件;
  • epoll_ctl函数:
	int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);/*参数:epfd:epoll的文件描述符op:控制方式EPOLL_CTL_ADD:添加EPOLL_CTL_MOD:修改EPOLL_CTL_DEL:删除fd:被操作的文件描述符event:(事件)结构体指针返回值:    成功返回0,失败返回-1 置位错误码*/
	//添加要检测事件的描述符event.events = EPOLLIN;event.data.fd = sock_fd;//将关心的文件描述符加入到红黑树if(-1 == (epoll_ctl(epfd,EPOLL_CTL_ADD,sock_fd,&event))){perror("epoll_ctl error");exit(-1);}
  • 九、等待文件描述符中的事件是否就绪,成功则返回就绪的文件描述符的个数(epoll_wait函数):
  • epoll_wait函数:
	int epoll_wait(int epfd, struct epoll_event *events,int maxevents, int timeout);/*参数:epfd:epoll的文件描述符events:准备好的事件的结构体地址maxevents:返回的最大的文件描述符的个数timeout:超时>0 :毫秒级别的超时时间=0 :立即返回=-1:不关心超时时间返回值:成功返回准备好的文件描述符的个数返回0代表超时时间到了失败返回-1置位错误码*/
		if(-1 == (ret = epoll_wait(epfd,events,N,-1))){perror("epoll_wait error");exit(-1);}	
  • 十、遍历就绪的文件描述符集,判断哪些文件描述符已经准备就绪:
		for(int i = 0; i < ret; ++i){...}
  • 十一、找到实际就绪的事件的文件描述符,并且接收来自客户端的数据(recv函数)和给客户端发送应答消息(send函数):
			if(events[i].data.fd == sock_fd){//获取连接成功后新的客户端new_fd = accept(sock_fd,(struct sockaddr *)&clientaddr,&clientaddr_len);if(-1 == new_fd){perror("accept error");exit(-1);}printf("文件描述符[%d]客户端[%s:%d]连接到了服务器\n",new_fd,inet_ntoa(clientaddr.sin_addr),ntohs(clientaddr.sin_port));//添加要检测的文件描述符event.events = EPOLLIN;event.data.fd = new_fd;if(-1 == (epoll_ctl(epfd,EPOLL_CTL_ADD,new_fd,&event))){perror("epoll_ctl error");exit(-1);}printf("文件描述符[%d]成功挂载在红黑树上\n",new_fd);}else{memset(buf,0,sizeof(buf));int old_fd = events[i].data.fd;if(-1 == (nbytes = recv(old_fd,buf,sizeof(buf),0))){perror("recv error");exit(-1);}else if(0 == nbytes){printf("文件描述符[%d]客户端断开了服务器\n",old_fd);//关闭对应的文件描述符close(old_fd);//剔除挂在树上对应的文件描述符epoll_ctl(epfd,EPOLL_CTL_DEL,old_fd,&event);}if(!strncmp(buf,"quit",4)){printf("文件描述符[%d]客户端退出了服务器\n",old_fd);//关闭对应的文件描述符close(old_fd);//剔除挂在树上对应的文件描述符epoll_ctl(epfd,EPOLL_CTL_DEL,old_fd,&event);}printf("文件描述符[%d]客户端发来数据[%s]\n",old_fd,buf);//组装应答消息strcat(buf,"-----k");//给客户端发送应答消息send(old_fd,buf,sizeof(buf),0); 
  • 十二、关闭套接字(close函数):
	close(sock_fd);

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

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

相关文章

MySQL的查询计划(EXPLAIN)

核心关注指标 在MySQL的查询计划&#xff08;EXPLAIN&#xff09;中&#xff0c;可以查看以下一些重要的指标来评估查询性能和索引使用情况&#xff1a; type&#xff1a;表示查询的访问类型&#xff0c;可以是常见的取值如"ref"、"eq_ref"、"range…

python+requests+unittest执行自动化接口测试!

1、安装requests、xlrd、json、unittest库 <1>pip 命令安装&#xff1a; pip install requests pip install xlrd pip install json pip install unittest <2> pycharm里安装 2、利用Page Object Model 设计理念创建六类Python Package(也可根据项目要求具体实施…

企业安全—DevSecOps概述详情

0x00 前言 SDL存在的问题在于体量过于庞大&#xff0c;不利于快速进行适配和进行&#xff0c;所以就有了DevSecOps&#xff0c;实际上是因为敏捷开发也就是DevOps的推进&#xff0c;并且坐上了云服务模式的火车&#xff0c;所以这一系列的东西都开始普及。DevSecOps作为DevOps…

vue3项目报错The template root requires exactly one element.eslint-plugin-vue

解决方案&#xff1a; 1.禁用 Vetur 并改用Volar》它现在是 Vue 3 项目的官方推荐。【必须重启vsCode】 从官方迁移指南&#xff1a; 建议使用带有我们官方扩展 Volar (opens new window) 的 VSCode&#xff0c;它为 Vue 3 提供了全面的 IDE 支持。 2.package.json文件中 &…

什么是蓝桥杯?什么是蓝桥STEMA考试?

第十五届蓝桥大赛赛事安排? STEMA考试11月(考试时间11月26日) STEMA考试1月(2024年1月) STEMA考试3月(2024年3月) 第十五届蓝桥杯省赛(2024年4月待定) 第十五届蓝桥杯国赛(2024年5月待定) 注:以上时间具体以组委会官方发布为准。 01.蓝桥杯 蓝桥杯全国软件和…

linux java 启动脚本

#!/bin/sh## java env #export JAVA_HOME/data/jdk1.8.0_121 #export JRE_HOME$JAVA_HOME/jre## service name #当前目录 SERVICE_DIR$(cd dirname $0; pwd) echo "$SERVICE_DIR" #jar包路径 JAR_DIRls -ltr $SERVICE_DIR/*.jar| tail -1 echo "JAR_DIR $JAR_DI…

强化学习------PPO算法

目录 简介一、PPO原理1、由On-policy 转化为Off-policy2、Importance Sampling&#xff08;重要性采样&#xff09;3、off-policy下的梯度公式推导 二、PPO算法两种形式1、PPO-Penalty2、PPO-Clip 三、PPO算法实战四、参考 简介 PPO 算法之所以被提出&#xff0c;根本原因在于…

#力扣:2315. 统计星号@FDDLC

2315. 统计星号 - 力扣&#xff08;LeetCode&#xff09; 一、Java class Solution {public int countAsterisks(String s) {int cnt 0;boolean flag true;for(char c: s.toCharArray()) {if(c |) flag !flag;else if(c * && flag) cnt;}return cnt;} }

什么是可重入,什么是可重入锁? 它用来解决什么问题?

可重入 可重入是多线程并发编程里面一个比较重要的概念&#xff0c;简单来说&#xff0c;就是在运行的某个函数或者代码&#xff0c;因为抢占资源或者中断等原因导致函数或者代码的运行中断&#xff0c;等待中断程序执行结束后&#xff0c;重新进入到这个函数或者代码中运行&am…

Python----break关键字对while...else结构的影响

案例&#xff1a; 女朋友生气&#xff0c;要求道歉5遍&#xff1a;老婆大人&#xff0c;我错了。道歉到第三遍的时候&#xff0c;媳妇埋怨这一遍说的不真诚&#xff0c;是不是就是要退出循环了&#xff1f;这个退出有两种可能性&#xff1a; ① 更生气&#xff0c;不打算原谅…

【Qt之QSetting】介绍及使用

概述 QSettings类提供了一种持久的、与平台无关的应用程序设置存储功能。 用户通常期望一个应用能在不同会话中记住其设置&#xff08;窗口大小和位置&#xff0c;选项等&#xff09;。在Windows上&#xff0c;这些信息通常存储在系统注册表中&#xff1b;在macOS和iOS上&…

Jenkins自动化测试

学习 Jenkins 自动化测试的系列文章 Robot Framework 概念Robot Framework 安装Pycharm Robot Framework 环境搭建Robot Framework 介绍Jenkins 自动化测试 1. Robot Framework 概念 Robot Framework是一个基于Python的&#xff0c;可扩展的关键字驱动的自动化测试框架。 它…

修复VS2015没有代码提示的问题【已解决】

问题描述 在Visual Studio 中编写代码时&#xff0c;发现使用库函数的时候&#xff0c;在类对象后输入点后&#xff0c;并没有出现类对应的成员信息的提示。 解决过程 1&#xff09;方法1&#xff1a; 百度“vs 没有代码提示”&#xff0c;搜索解决方案。 方案1&#xff1…

lossBN

still tips for learning classification and regression关于softmax的引入和作用分类问题损失函数 - MSE & Cross-entropy⭐Batch Normalization&#xff08;BN&#xff09;⭐想法&#xff1a;直接改error surface的landscape&#xff0c;把山铲平feature normalization那…

Hive分区表和分桶表

1.分区表 1.1 概念 Hive 中的表对应为 HDFS 上的指定目录,在查询数据时候,默认会对全表进行扫描,这样时间和性能的消耗都非常大。 分区为 HDFS 上表目录的子目录,数据按照分区存储在子目录中。如果查询的 `where` 字句的中包含分区条件,则直接从该分区去查找,而不是扫描整…

python实现PDF表格与文本分别导出EXCEL

现需将pdf 转换至Excel &#xff0c; 目前实现方式&#xff1a;将PDF的TABLE部分与 非 TABLE部分分别导出至Excel两个sheet中 1&#xff09;、识别PDF中的表格块 2&#xff09;、将PDF转换为Word格式 3&#xff09;、提取Word中非表格的文本数据 4&#xff09;、对文本与表格重…

Qt 实现侧边栏滑出菜单效果

1.效果图 2.实现原理 这里做了两个widget&#xff0c;一个是 展示底图widget&#xff0c;一个是 展示动画widget。 这两个widget需要重合。动画widget需要设置属性叠加到底图widget上面&#xff0c;设置如下属性&#xff1a; setWindowFlags(Qt::FramelessWindowHint | Qt::…

Java提升技术,进阶为高级开发和架构师的路线

原文网址&#xff1a;Java提升技术&#xff0c;进阶为高级开发和架构师的路线-CSDN博客 简介 Java怎样提升技术&#xff1f;怎样进阶为高级开发和架构师&#xff1f;本文介绍靠谱的成长路线。 首先点明&#xff0c;只写业务代码是无法成长技术的。提升技术的两个方法是&…

【Docker】Docker-Compose内置DNS负载均衡失效问题

Docker Compose实现负载均衡 还是对前面的例子docker-compose.yml稍微修改&#xff1a; version: "3.8"services:flask-demo:build:context: .dockerfile: Dockerfileimage: flask-demo:latestenvironment:- REDIS_HOSTredis-server- REDIS_PASS${REDIS_PASS}healt…

软考-入侵检测技术原理与应用

本文为作者学习文章&#xff0c;按作者习惯写成&#xff0c;如有错误或需要追加内容请留言&#xff08;不喜勿喷&#xff09; 本文为追加文章&#xff0c;后期慢慢追加 by 2023年10月 入侵检测技术概念 入侵检测技术是指一种计算机安全技术&#xff0c;旨在监测计算机系统、…