3.19网络编程

 

select实现的TCP并发服务器

#include <myhead.h>
#define SER_IP "192.168.141.134" 
#define SER_PORT 8888           
int main(int argc, const char *argv[])
{// 1、创建一个套接字int sfd = -1;sfd = socket(AF_INET, SOCK_STREAM, 0);if (sfd == -1){perror("socket error");return -1;}printf("%d success sfd = %d\n", __LINE__, sfd); // 3// 端口号快速重用int reuse = 1;if (setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){perror("setsockopt error");return -1;}// 2、绑定IP地址和端口号// 2.1填充地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;                sin.sin_port = htons(SER_PORT);          sin.sin_addr.s_addr = inet_addr(SER_IP); // 2.2 绑定if (bind(sfd, (struct sockaddr *)&sin, sizeof(sin)) == -1){perror("bind error");return -1;}printf("%d  bind success\n", __LINE__);// 3、将套接字设置成被动监听状态if (listen(sfd, 128) == -1){perror("listen error");return -1;}printf("%d  listen success\n", __LINE__);// 4、阻塞等待客户端的链接请求int newfd = -1;// 定义结构体变量接收对方地址信息结构体struct sockaddr_in cin;          // 用于接收客户端地址信息结构体socklen_t addrlen = sizeof(cin); // 用于接收客户端结构体的大小char sbuf[128] = "";             // 服务器输入数据内容// 11、定义一个文件描述符集合fd_set readfds, tempfds;// 22、将集合清空FD_ZERO(&readfds);// 33、将要被检测的文件描述符放入集合FD_SET(0, &readfds);FD_SET(sfd, &readfds);int maxfd = sfd;                  // 最大文件描述符struct sockaddr_in cin_arr[1024]; // 结构体数组while (1){tempfds = readfds;int res = select(maxfd + 1, &tempfds, NULL, NULL, NULL); if (res == -1){perror("select error");return -1;}else if (res == 0){printf("time out\n");return -1;}// 当程序执行到此,说明集合中有事件产生,此时集合中只剩下本次触发事件的文件描述符for (int i = 0; i <= maxfd; i++){// 如果不是触发事件的文件描述符,直接跳过if (!FD_ISSET(i, &tempfds)){continue;}// 程序执行至此,表示当前i这个文件描述符触发了事件// 判断sfd是否触发事件if (i == sfd){if ((newfd = accept(sfd, (struct sockaddr *)&cin, &addrlen)) == -1){perror("accept error");return -1;}printf("[%s  %d]:发来连接请求\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));// 将客户端地址信息结构体放入数组容器中cin_arr[newfd] = cin;// 将newfd放入readfds容器中页参与检测FD_SET(newfd, &readfds);// 可能要更新maxfdif (newfd > maxfd){maxfd = newfd;}}else// 判断0号文件描述符是否触发事件if (0 == i){fgets(sbuf, sizeof(sbuf), stdin); // 从终端输入数据sbuf[strlen(sbuf) - 1] = 0;printf("触发了键盘输入事件:%s\n", sbuf);// 将该消息发送给所有客户端for (int i = 4; i <= maxfd; i++){send(i, sbuf, sizeof(sbuf), 0);}printf("发送成功\n");}else{// 说明某个客户端发来消息了,遍历所有的客户端,判断是哪个发来的消息// 5、收发数据char rbuf[128] = ""; // 用于接收客户发发来的数据// 将容器清空bzero(rbuf, sizeof(rbuf)); // memset(rbuf, 0, sizeof(rbuf));// 从套接字中读取数据‘int res = recv(i, rbuf, sizeof(rbuf) - 1, 0);if (res == 0){printf("客户端已经下线\n");// 关闭跟客户端通信的套接字close(i);// 将当前文件描述符移除容器FD_CLR(i, &readfds);// 可能要更新maxfdfor (int k = maxfd; k >= sfd; k--){if (FD_ISSET(k, &readfds)){maxfd = k;break;}}continue;}printf("[%s  %d]: %s\n", inet_ntoa(cin_arr[i].sin_addr), ntohs(cin_arr[i].sin_port), rbuf);// 加个笑脸再回回去strcat(rbuf, "*_*");send(i, rbuf, strlen(rbuf), 0);printf("发送成功\n");}}}// 6、关闭服务器close(sfd);return 0;
}

poll实现的TCP客户端

#include <myhead.h>
#define SER_PORT 8888			 // 服务器端口号
#define SER_IP "192.168.141.134" // 服务器IP
#define CLI_PORT 9999			 // 客户端口号
#define CLI_IP "192.168.141.134" // 客户端IP
int main(int argc, const char *argv[])
{//1、创建用于连接的客户端套接字int cfd = socket(AF_INET, SOCK_STREAM, 0);if(cfd == -1){perror("socket error");return -1;}printf("socket success cfd = %d\n", cfd);        //3//设置端口号快速重用int reuse = 1;if(setsockopt(cfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) ==-1){perror("setsockopt error");return -1;}printf("端口号快速重用成功\n");//2、绑定端口号和ip地址(非必须)//2.1 填充客户端地址信息结构体struct sockaddr_in cin;cin.sin_family = AF_INET;cin.sin_port = htons(CLI_PORT);cin.sin_addr.s_addr = inet_addr(CLI_IP);//2.2 绑定端口号和IPif(bind(cfd, (struct sockaddr*)&cin, sizeof(cin)) == -1){perror("bind error");return -1;}printf("bind success\n");//3、连接服务器//3.1 填充要连接服务器的地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;      //地址族sin.sin_port = htons(SER_PORT);   //服务器端口号sin.sin_addr.s_addr = inet_addr(SER_IP);    //服务器的IP地址//3.2 连接服务器if(connect(cfd, (struct sockaddr*)&sin, sizeof(sin)) == -1){perror("connect error");return -1;}printf("连接成功!\n");//使用poll完成0号文件描述符和cfd文件描述符的多路复用//11、准备文件描述符容器struct pollfd pfds[2];pfds[0].fd = 0; //文件描述符pfds[0].events = POLLIN;    //检测读事件pfds[1].fd = cfd;       //文件描述符pfds[1].events = POLLIN;    //检测读事件//4、收发数据char wbuf[128] = "";while(1){int res = poll(pfds, 2, -1);        //阻塞检测集合中是否有事件产生if(res == -1){perror("poll error");return -1;}else if(res == 0){printf("time out\n");return -1;}//程序执行至此,说明检测的文件描述符集合中有事件产生//判断是否为0号文件描述符产生事件if(pfds[0].revents == POLLIN){fgets(wbuf, sizeof(wbuf), stdin);    //从终端上获取一个字符串wbuf[strlen(wbuf)-1] = 0;   //判断输入的字符串值if(strcmp(wbuf, "quit") ==0){break;}//将数据发送给服务器send(cfd, wbuf, strlen(wbuf), 0);}//判断释放为cfd文件描述符中产生事件if(pfds[1].revents == POLLIN){//将字符数组清空bzero(wbuf, sizeof(wbuf));recv(cfd, wbuf, sizeof(wbuf)-1, 0);printf("收到服务器消息为:%s\n", wbuf);}}//5、关闭套接字close(cfd);return 0;
}

select实现的TCP客户端

#include <myhead.h>
#define SER_IP "192.168.141.134" // 服务器IP
#define SER_PORT 8888            // 服务器端口号
int main(int argc, const char *argv[])
{// 1、创建一个套接字int sfd = -1;sfd = socket(AF_INET, SOCK_STREAM, 0);// 参数1:表示创建的是网络通信的套接字// 参数2:表示使用的是TCP通信协议// 参数3:参数2指定了协议,参数3填0即可if (sfd == -1){perror("socket error");return -1;}printf("%d success sfd = %d\n", __LINE__, sfd); // 3// 端口号快速重用int reuse = 1;if (setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){perror("setsockopt error");return -1;}// 2、绑定IP地址和端口号// 2.1填充地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;                // 地址族sin.sin_port = htons(SER_PORT);          // 端口号sin.sin_addr.s_addr = inet_addr(SER_IP); // IP地址// 2.2 绑定if (bind(sfd, (struct sockaddr *)&sin, sizeof(sin)) == -1){perror("bind error");return -1;}printf("%d  bind success\n", __LINE__);// 3、将套接字设置成被动监听状态if (listen(sfd, 128) == -1){perror("listen error");return -1;}printf("%d  listen success\n", __LINE__);// 4、阻塞等待客户端的链接请求int newfd = -1;// 定义结构体变量接收对方地址信息结构体struct sockaddr_in cin;          // 用于接收客户端地址信息结构体socklen_t addrlen = sizeof(cin); // 用于接收客户端结构体的大小char sbuf[128] = "";             // 服务器输入数据内容// 11、定义一个文件描述符集合fd_set readfds, tempfds;// 22、将集合清空FD_ZERO(&readfds);// 33、将要被检测的文件描述符放入集合FD_SET(0, &readfds);FD_SET(sfd, &readfds);int maxfd = sfd;                  // 记录当前容器中的最大文件描述符struct sockaddr_in cin_arr[1024]; // 存储客户端地址信息结构体的数组while (1){// 将readfds备份一份tempfds = readfds;int res = select(maxfd + 1, &tempfds, NULL, NULL, NULL); // 阻塞等待集合中的事件产生if (res == -1){perror("select error");return -1;}else if (res == 0){printf("time out\n");return -1;}// 当程序执行到此,说明集合中有事件产生,此时集合中只剩下本次触发事件// 的文件描述符for (int i = 0; i <= maxfd; i++){// 如果不是触发事件的文件描述符,直接跳过if (!FD_ISSET(i, &tempfds)){continue;}// 程序执行至此,表示当前i这个文件描述符触发了事件// 判断sfd是否触发事件if (i == sfd){if ((newfd = accept(sfd, (struct sockaddr *)&cin, &addrlen)) == -1){perror("accept error");return -1;}printf("[%s  %d]:发来连接请求\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));// 将客户端地址信息结构体放入数组容器中cin_arr[newfd] = cin;// 将newfd放入readfds容器中页参与检测FD_SET(newfd, &readfds);// 可能要更新maxfdif (newfd > maxfd){maxfd = newfd;}}else// 判断0号文件描述符是否触发事件if (0 == i){fgets(sbuf, sizeof(sbuf), stdin); // 从终端输入数据sbuf[strlen(sbuf) - 1] = 0;printf("触发了键盘输入事件:%s\n", sbuf);// 将该消息发送给所有客户端for (int i = 4; i <= maxfd; i++){send(i, sbuf, sizeof(sbuf), 0);}printf("发送成功\n");}else{// 说明某个客户端发来消息了,遍历所有的客户端,判断是哪个发来的消息// 5、收发数据char rbuf[128] = ""; // 用于接收客户发发来的数据// 将容器清空bzero(rbuf, sizeof(rbuf)); // memset(rbuf, 0, sizeof(rbuf));// 从套接字中读取数据‘int res = recv(i, rbuf, sizeof(rbuf) - 1, 0);if (res == 0){printf("客户端已经下线\n");// 关闭跟客户端通信的套接字close(i);// 将当前文件描述符移除容器FD_CLR(i, &readfds);// 可能要更新maxfdfor (int k = maxfd; k >= sfd; k--){if (FD_ISSET(k, &readfds)){maxfd = k;break;}}continue;}printf("[%s  %d]: %s\n", inet_ntoa(cin_arr[i].sin_addr), ntohs(cin_arr[i].sin_port), rbuf);// 加个笑脸再回回去strcat(rbuf, "*_*");send(i, rbuf, strlen(rbuf), 0);printf("发送成功\n");}}}// 6、关闭服务器close(sfd);return 0;
}

poll实现的TCP并发服务器

#include <myhead.h>
#define SER_PORT 8888
#define SER_IP "192.168.141.134"
int main(int argc, const char *argv[])
{//1.创建套接字int sfd  = socket(AF_INET,SOCK_STREAM,0);if(sfd==-1){perror("socket error");return -1;}printf("sfd=%d\n",sfd);//将端口号快速重用函数int reuse =1;if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))==-1){perror("setsockopt error");return -1;}printf("端口号快速重用成功\n");//2.给套接字绑定IP和端口号//2.1填充地址信息结构体struct sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=htons(SER_PORT);sin.sin_addr.s_addr=inet_addr(SER_IP);//2.2绑定if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1){perror("bind error");return -1;}printf("bind success %d\n",__LINE__);//3.将套接字设置成监听状态if(listen(sfd,128)==-1){perror("listen error");return -1;}printf("listen success %d\n",__LINE__);//4.阻塞等待客户端的链接请求//4.1定义容器接收客户端的地址信息struct sockaddr_in cin;   //用于接收地址信息socklen_t socklen = sizeof(cin);  //用于接收地址信息的大小int newfd=-1;//定义一个等待文件描述符结构体数组struct pollfd pfd[10];//填充要等待的文件描述符及事件pfd[0].fd=0;pfd[0].events=POLLIN;pfd[1].fd=sfd;pfd[1].events=POLLIN;int client_num=0;//定义一个地址信息结构体数组,每一个元素对应一个客户端文件描述符struct sockaddr_in cin_arr[1024];while(1){//阻塞监测集合中是否有事件产生int res=poll(pfd,client_num+2,-1);if(res==-1){perror("poll error");return -1;}else if(res==0){printf("time out\n");return -1;}if(pfd[0].revents==POLLIN){char wbuf[128]="";scanf("%s",wbuf);printf("触发了终端输入事件---\n");if(strcmp(wbuf,"quit")==0){break;}//将消息发送给所有客户端for (int i = 4; i <= client_num+3; i++){send(i,wbuf,sizeof(wbuf),0);}}if(pfd[1].revents==POLLIN){//接受客户端的链接if((newfd =accept(sfd,(struct sockaddr*)&cin,&socklen))==-1){perror("accept error");return -1;}printf("您有一个新的客户端[%s:%d]发来连接请求 success %s %s %d\n",\inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),__FILE__,__func__,__LINE__);client_num++;pfd[1+client_num].fd=newfd;pfd[1+client_num].events=POLLIN;printf("客户端连接成功\n");}for(int cli=0;cli<client_num;cli++){if(pfd[cli+2].revents==POLLIN){//跟客户端进行消息通信char buf[128]="";bzero(buf,sizeof(buf));int res=recv(pfd[cli+2].fd,buf,sizeof(buf),0);if(res==0){puts("客户端已经下线");close(pfd[cli+2].fd);client_num--;continue;}printf("收到消息:%s\n",buf);//给客户端发送消息strcat(buf,"=-=");send(pfd[cli+2].fd,buf,sizeof(buf),0);printf("发送成功\n");}}}//6.关闭套接字close(sfd);return 0;
}

 

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

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

相关文章

Division by Invariant Integers using Multiplication

在处理器中&#xff0c;整数除法的成本通常是整数乘法的几倍&#xff1a; 流水线式的组合乘法器通常在不到10个周期内完成操作&#xff1b;而对于整数除法则没有硬件支持&#xff0c;或者使用的迭代除法器比乘法器慢几倍。 表 1.1 比较了一些处理器上乘法和除法的时间。这张表…

php 页面中下载文件|图片

一、需求 页面中点击下载图片 二、实现 protected function pageLoad(){$filePath $_GET[file];$host $_SERVER[HTTP_HOST];$file http://.$host.$filePath;$fileName basename($filePath);$content file_get_contents($file);ob_clean();$suffixArr explode(., $file…

数据库系统概论-练手题集合【期末复习|考研复习】

前言 总结整理不易&#xff0c;希望大家点赞收藏。 给大家整理了一下数据库系统概论中的练手题&#xff0c;以供大家期末复习和考研复习的时候使用。 数据库系统概论系列文章传送门&#xff1a; 第一章 绪论 第二/三章 关系数据库和标准语言SQL 第四/五章 数据库安全性和完整性…

服务器硬件基础知识和云服务器的选购技巧

概述 服务器硬件基础知识涵盖了构成服务器的关键硬件组件和技术&#xff0c;这些组件和技术对于服务器的性能、稳定性和可用性起着至关重要的作用。其中包括中央处理器&#xff08;CPU&#xff09;作为服务器的计算引擎&#xff0c;内存&#xff08;RAM&#xff09;用于数据临…

zookeeper快速入门(合集)

zookeeper作为一个分布式协调框架&#xff0c;它的创建就是为了方便或者简化分布式应用的开发。除了服务注册与发现之外&#xff0c;它还能够提供更多的功能&#xff0c;但是对于入门来说&#xff0c;看这一篇就够了。后续会讲zookeeper的架构设计与原理&#xff0c;比如zookee…

【学习】软件测试中的二八定理是什么?如何提高测试的效率和质量

软件测试领域的二八定理&#xff0c;是指在软件测试过程中&#xff0c;通常只有20%的测试用例能够发现软件中80%的错误。这一现象表明&#xff0c;软件测试的效率和效果并不成正比&#xff0c;测试用例的数量并不等于发现错误的能力。因此&#xff0c;在软件测试过程中&#xf…

<Linux> 生产者消费者模型

目录 前言&#xff1a; 一、什么是生产者消费者模型 &#xff08;一&#xff09;概念 &#xff08;二&#xff09;生产者消费者之间的关系 &#xff08;三&#xff09;生产者消费者模型特点 &#xff08;四&#xff09;生产者消费者模型的优点 二、基于阻塞队列实现生产…

前端标准 JsDoc 代码片段注释 ( 快速生成代码片段网站 )

{ "快速单行注释": {"prefix": "z","body": [" /**"," * $1"," * param { }"," * return { }"," */"],"description": "快速注释" } } 配置之后…

嵌入式科普(12)西门子PROFINET ERTECH 200P-3路演

目录 一、路演观后感/总结 二、分享两个公众号 2.1 HMS工业网络 2.2 Omdia 三、ERTECH 200P-3资料 四、ERTECH 200P-3路演分享 嵌入式科普(12)西门子PROFINET ERTECH 200P-3路演 一、路演观后感/总结 老罗砸西门子冰箱时候的傲慢 -> 路演的谦逊 国外工程师包吃住差旅…

Linux(openEuler)部署SpringBoot前后端分离项目(Nginx负载均衡)

假如数据库在本地&#xff0c;没有放在Linux中 1.先把数据库中root的主机改成% 2.项目中的数据库链接配置换成本机ip 3.打包 4.把打包好的jar包放到Linux中 一般把jar包放到opt下 5.把前端部分拷贝到Linux的nginx中 5.1在package.json中修改build的值为图中这样 5.2同时由于在…

动态规划(算法竞赛、蓝桥杯)--单调队列优化修建草坪

1、B站视频链接&#xff1a;E44 单调队列优化DP 修剪草坪_哔哩哔哩_bilibili #include <bits/stdc.h> using namespace std; typedef long long LL; const int N1e510; int n,k,q[N]; LL w[N],f[N],sum;int main(){cin>>n>>k; k; //for(int i1;i<n;i){ci…

Vue多文件学习项目综合案例——小兔鲜,黑马vue教程

文章目录 一、项目截图二、主要知识点三、Main.js四、App.vue五、componentsXtxBanner.vueXtxFooter.vueXtxHeaderNav.vueXtxHotBrand.vueXtxNewGoods.vueXtxShortCut.vueXtxTopic.vue 六、stylesbase.csscommon.css 一、项目截图 二、主要知识点 把静态页面拆分成一个个vue组…

数据库简介与MySQL编译安装

1数据库基础 什么是数据库 数据库&#xff08;Database&#xff09;是一个有组织的数据存储系统&#xff0c;用于有效地存储、检索、管理和维护数据。数据库系统允许用户以结构化的方式存储和操作大量数据&#xff0c;并提供了一种可靠的方法来管理和维护这些数据&#xff0c…

数据库的基本概念与安装MySQL

一、数据库的基本概念 1、什么是数据&#xff1f; 描述事物的符合记录包括数字、文字、图形、图像、声音、档案记录等以“记录”形式按统一的格式进行存储 2、什么是表&#xff1f; 将不同的记录组织在一起用来存储具体数据 3、什么是数据库 表的集合&#xff0c;是存储数…

2023年中国电商市场研究报告

研究范畴界定为中国国内2C电商市场 ⚠️ 关键点&#xff1a; 流量红利减少&#xff0c;电商市场进入存量增量 竞争的发展阶段&#xff1b;新兴电商平台不断挑战现有头部电商平台行业地位&#xff1b;消费者更加趋于理性&#xff0c;更加关注低价和服务&#xff1b;市场趋势&…

嵌入式和 Java选哪个?

今日话题&#xff0c;嵌入式和 Java 走哪个?对于嵌入式领域有浓厚兴趣的人&#xff0c;并不会比Java行业薪资低&#xff0c;处于上中游水平。特别是从2020年开始&#xff0c;嵌入式领域受益于芯片产业的兴起&#xff0c;表现出了强劲的增长势头。薪资水平受多方面因素影响。嵌…

AndroidLinux GPIO控制方法

目录 1 GPIO整体架构 2 user space 层 gpio使用方法 2.1 sysfs控制方法 2.1.1 kernel版本区别 2.1.2 /sys/class/gpio 2.1.3 /sys/bug/gpio/devices 2.2 chardev控制方法 2.2.1 chardev 示例代码 2.2.2 示例代码主要步骤描述 2.2.3 include/linux/gpio.h 全部代码 2.3…

mmz批量多页抓取数据-AES.CBC算法-爬虫

目标&#xff1a;mmz多页下载 方法&#xff1a;加一个for循环实现多页的下载 问题&#xff1a;浏览器传输服务器时对页码参数做了加密处理 解决方法&#xff1a; 1、判断加密算法模式&#xff08;mmz是AES-CBC算法&#xff09; 2、找到加密的key和iv 代码&#xff1a; i…

数据可信流通,从运维信任到技术信任

信任 共同观点&#xff1a; 信任是涉及交易或交换关系的基础 身份可确认利益可依赖能力有预期行为有后果 数据流通中的不可信风险 内循环&#xff1a;数据持有方在自己的运维安全域内对自己的额数据使用和安全拥有全责外循环&#xff1a;数据要素在离开持有方安全域后&#…

使用 git 先提交后拉取的时候远程分支不允许问题

问题场景 修改本地代码使用 git 先提交后拉取的时候远程分支不允许的问题 修改本地代码时&#xff0c;远程分支存在其他新提交先执行了 git commit -m xxx update然后再执行 git pull 拉取远程分支代码&#xff0c;出现如下提示 hint: You have divergent branches and need…