作业--day34

使用select完成TCP并发服务器和客户端

server.c

#include <myhead.h>#define PORT 8888
#define IP "192.168.125.137"int main(int argc, const char *argv[])
{int sfd = socket(AF_INET, SOCK_STREAM, 0);if(sfd == -1){perror("socket error");return -1;}int reuse = -1;if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){perror("setsockopt error");return -1;}struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PORT);sin.sin_addr.s_addr = inet_addr(IP);if(bind(sfd, (struct sockaddr *)&sin, sizeof(sin)) == -1){perror("bind error");return -1;}if(listen(sfd, 128) == -1){perror("listen error");return -1;}struct sockaddr_in cin;socklen_t socklen = sizeof(cin);char buf[128] = "";fd_set readfds;FD_ZERO(&readfds);FD_SET(0, &readfds);FD_SET(sfd, &readfds);int res = -1;fd_set tempfds;struct sockaddr_in arr_cin[1024];int maxfd = sfd;while(1){tempfds = readfds;res = select(maxfd+1, &tempfds, NULL, NULL, NULL);if(res == -1){perror("select error");return -1;}else if(res == 0){puts("time out");return -1;}for(int index=0; index<=maxfd; index++){if(!FD_ISSET(index, &tempfds)){continue;}if(index == sfd){int newfd = accept(sfd, (struct sockaddr *)&cin, &socklen);if(newfd == -1){perror("accept error");return -1;}arr_cin[newfd] = cin;printf("[%s: %d] 已连接\n", inet_ntoa(arr_cin[newfd].sin_addr), ntohs(arr_cin[newfd].sin_port));FD_SET(newfd, &readfds);if(newfd > maxfd){maxfd = newfd;}}else if(index == 0){fgets(buf, sizeof(buf), stdin);buf[strlen(buf) - 1] = 0;for(int i=4; i<=maxfd; i++){send(i, buf, sizeof(buf), 0);}}else{bzero(buf, sizeof(buf));int res = recv(index, buf, sizeof(buf), 0);if(res == 0){puts("客户端已下线");close(index);FD_CLR(index, &readfds);for(int i=maxfd; i>0; i--){if(FD_ISSET(i, &readfds)){maxfd = i;break;}}continue;}printf("[%s: %d] %s\n", inet_ntoa(arr_cin[index].sin_addr), ntohs(arr_cin[index].sin_port), buf);strcat(buf, "*_*");send(index, buf, sizeof(buf), 0);}}}close(sfd);return 0;
}

client.c

#include <myhead.h>#define PORT 8888
#define IP "192.168.125.137"int main(int argc, const char *argv[])
{int cfd = socket(AF_INET, SOCK_STREAM, 0);if(cfd == -1){perror("socket error");return -1;}struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PORT);sin.sin_addr.s_addr = inet_addr(IP);if(connect(cfd, (struct sockaddr*)&sin, sizeof(sin)) == -1){perror("connect error");return -1;}fd_set readfds;fd_set tempfds;FD_ZERO(&readfds);FD_SET(0, &readfds);FD_SET(cfd, &readfds);int res = -1;struct sockaddr_in arr_cin[1024];char buf[128] = "";while(1){tempfds = readfds;res = select(cfd+1, &tempfds, NULL, NULL, NULL);if(res == -1){perror("select error");return -1;}else if(res == 0){puts("time out");return -1;}if(FD_ISSET(cfd, &tempfds)){bzero(buf, sizeof(buf));res = recv(cfd, buf, sizeof(buf), 0);if(res == 0){puts("服务器已下线");break;}printf("[%s: %d] %s\n", inet_ntoa(sin.sin_addr), ntohs(sin.sin_port), buf);}if(FD_ISSET(0, &tempfds)){bzero(buf, sizeof(buf));fgets(buf, sizeof(buf), stdin);buf[strlen(buf) - 1] = 0;send(cfd, buf, sizeof(buf), 0);}}close(cfd);return 0;
}

在这里插入图片描述

使用poll完成TCP并发服务器和客户端

server.c

#include <myhead.h>#define PORT 8888
#define IP "192.168.125.137"void del_arr(struct pollfd fds[], int *max, int index){for(int i=index; i<(*max)-1; i++){fds[i] = fds[i+1];}(*max) -= 1;
}int main(int argc, const char *argv[])
{int sfd = socket(AF_INET, SOCK_STREAM, 0);if(sfd == -1){perror("socket error");return -1;}int reuse = -1;if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){perror("setsockopt error");return -1;}struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PORT);sin.sin_addr.s_addr = inet_addr(IP);if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin)) == -1){perror("bind error");return -1;}if(listen(sfd, 128) == -1){perror("listen error");return -1;}struct sockaddr_in cin;socklen_t socklen = sizeof(cin);char buf[128] = "";int res = -1;struct pollfd fds[1024];fds[0].fd = 0;fds[0].events = POLLIN;fds[1].fd = sfd;fds[1].events = POLLIN;struct sockaddr_in arr_cin[1024];int newfd = -1;int max = 2;while(1){res = poll(fds, max, -1);if(res < 0){perror("poll error");return -1;}else if(res == 0){puts("time out");return -1;}for(int index=0; index<max; index++){if(fds[index].revents == POLLIN){if(index == 0){bzero(buf, sizeof(buf));fgets(buf, sizeof(buf), stdin);buf[strlen(buf) - 1] = 0;for(int i=2; i<max; i++){send(fds[i].fd, buf, sizeof(buf), 0);}}else if(index == 1){if((newfd = accept(fds[index].fd, (struct sockaddr*)&cin, &socklen)) == -1){perror("accept error");return -1;}fds[max].fd = newfd;fds[max].events = POLLIN;max++;arr_cin[newfd] = cin;printf("[%s: %d] 已上线\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));}else{bzero(buf, sizeof(buf));res = recv(fds[index].fd, buf, sizeof(buf), 0);if(res == 0){puts("客户端已下线");del_arr(fds, &max, index);continue;}printf("[%s: %d] %s\n", inet_ntoa(arr_cin[fds[index].fd].sin_addr), ntohs(arr_cin[fds[index].fd].sin_port), buf);}}}}close(sfd);return 0;
}

client.c

#include <myhead.h>#define PORT 8888
#define IP "192.168.125.137"int main(int argc, const char *argv[])
{int sfd = socket(AF_INET, SOCK_STREAM, 0);if(sfd == -1){perror("socket error");return -1;}int reuse = -1;if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){perror("setsockopt error");return -1;}struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PORT);sin.sin_addr.s_addr = inet_addr(IP);if(connect(sfd, (struct sockaddr*)&sin, sizeof(sin)) == -1){perror("connect error");return -1;}char buf[128] = "";int res = -1;struct pollfd fds[2];fds[0].fd = 0;fds[0].events = POLLIN;fds[1].fd = sfd;fds[1].events = POLLIN;while(1){res = poll(fds, 2, -1);if(res < 0){perror("poll error");return -1;}else if(res == 0){puts("time out");return -1;}if(fds[0].revents == POLLIN){bzero(buf, sizeof(buf));fgets(buf, sizeof(buf), stdin);buf[strlen(buf) - 1] = 0;send(sfd, buf, sizeof(buf), 0);}if(fds[1].revents == POLLIN){bzero(buf, sizeof(buf));res = recv(sfd, buf, sizeof(buf), 0);if(res == 0){puts("服务器已下线");break;}printf("[%s: %d] %s\n", inet_ntoa(sin.sin_addr), ntohs(sin.sin_port), buf);}}close(sfd);return 0;
}

在这里插入图片描述

思维导图

在这里插入图片描述

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

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

相关文章

融了超24亿元舍不得花，放银行吃利息，这家存储创企厉害了

融了超24亿元舍不得花，放银行吃利息，这家存储创企厉害了

引言&#xff1a;AI与大模型风起云涌&#xff0c;为什么催生了这匹存储“黑马”&#xff1f; 【阿明观察 &#xff5c; 科技热点关注】 这家总部设在美国的存储初创公司&#xff0c;真的赶上AI与大模型时代的风口了。Vast Data公司最新再次获得E轮融资1.18亿美元&#xff0c;…
阅读更多...
开放API签名认证的设计并开发对应的SDK

开放API签名认证的设计并开发对应的SDK

1. 为什么需要签名认证呢&#xff1f; 假设我们开放了一个接口&#xff0c;而我们的服务器只允许处理1000个请求&#xff0c;如果这个时候由用户疯狂发送几万个请求&#xff0c;可能会导致服务器宕机&#xff0c;影响其他用户的正常使用。这个情况下我们需要对接口进行限流&am…
阅读更多...
那些令人惊叹的awk简略写法

那些令人惊叹的awk简略写法

​​​​​​​awk是一门美妙的语言&#xff0c;被称为unix命令行工具皇冠上的明珠。它有很多简略写法&#xff0c;用好了可以用极少的代码快速解决问题。 下面就列举一些令人惊叹的awk简略写法&#xff1a; awk {sub(/pattern/, "foobar")} 1 # 无论替换是否成功&…
阅读更多...
在scrapy 使用selenium模拟登录获取cookie

在scrapy 使用selenium模拟登录获取cookie

前言 最近有一点点爬虫需求&#xff0c;想总结一下scrapy框架的一些基本使用方法&#xff0c;加深印象&#xff0c;自己一直习惯使用一些脚本文件运行爬虫&#xff0c;面对数据量非常大&#xff0c;稳定性要求比较高的&#xff0c;效率需求比较高的情况下还是用scrapy较为合适…
阅读更多...
Seata：打造行业首个分布式事务产品

Seata：打造行业首个分布式事务产品

作者&#xff1a;季敏&#xff0c;阿里云分布式事务产品负责人、Seata 开源项目创始人 微服务架构下数据一致性的挑战 微服务开发的痛点 在 2019 年&#xff0c;我们基于 Dubbo Ecosystem Meetup&#xff0c;收集了 2000 多份关于“在微服务架构&#xff0c;哪些核心问题是开…
阅读更多...
【C++】开源：ImGui图形用户界面库配置与使用

【C++】开源：ImGui图形用户界面库配置与使用

&#x1f60f;★,:.☆(&#xffe3;▽&#xffe3;)/$:.★ &#x1f60f; 这篇文章主要介绍ImGui图形用户界面库配置与使用。 无专精则不能成&#xff0c;无涉猎则不能通。——梁启超 欢迎来到我的博客&#xff0c;一起学习&#xff0c;共同进步。 喜欢的朋友可以关注一下&…
阅读更多...
13 v-show指令

13 v-show指令

概述 v-show用于实现组件的显示和隐藏&#xff0c;和v-if单独使用的时候有点类似。不同的是&#xff0c;v-if会直接移除dom元素&#xff0c;而v-show只是让dom元素隐藏&#xff0c;而不会移除。 在实际开发中&#xff0c;v-show也经常被用到&#xff0c;需要重点掌握。 基本…
阅读更多...
TypeScript【泛型1、泛型2、声明合并、命名空间 、模块1、模块2、声明文件简介】(五)-全面详解（学习总结---从入门到深化）

TypeScript【泛型1、泛型2、声明合并、命名空间 、模块1、模块2、声明文件简介】(五)-全面详解（学习总结---从入门到深化）

文章目录 泛型1 泛型2 声明合并 命名空间 模块1 模块2 声明文件简介 泛型1 泛型&#xff08;Generics&#xff09;是指在定义函数、接口或类的时候&#xff0c;不预先指定具体的类型&#xff0c;而在使用的时候再指定类型的一种特性 首先&#xff0c;我们来实现一个函数…
阅读更多...
【蓝桥杯选拔赛真题81】Scratch旅游相册 第十五届蓝桥杯scratch图形化编程 少儿编程创意编程选拔赛真题解析

【蓝桥杯选拔赛真题81】Scratch旅游相册 第十五届蓝桥杯scratch图形化编程 少儿编程创意编程选拔赛真题解析

目录 scratch旅游相册 一、题目要求 编程实现 二、案例分析 1、角色分析
阅读更多...
nuxt学习笔记

nuxt学习笔记

主要看的课程1 课程1 课程2 上手简化版 初始化 1.创建项目 使用官方推荐的npx来安装&#xff1a; (npm的5.2.x版本后默认安装了npx) 首先&#xff0c;确保您已经安装了 yarn、npx&#xff08;默认包含在 npm v5.2 中&#xff09;或 npm (v6.1)。 使用 npx 进行搭建项目&…
阅读更多...
stm32学习总结：4、Proteus8+STM32CubeMX+MDK仿真串口收发

stm32学习总结：4、Proteus8+STM32CubeMX+MDK仿真串口收发

stm32学习总结&#xff1a;4、Proteus8STM32CubeMXMDK仿真串口收发 文章目录 stm32学习总结&#xff1a;4、Proteus8STM32CubeMXMDK仿真串口收发一、前言二、资料收集三、STM32CubeMX配置串口1、配置开启USART12、设置usart中断优先级3、配置外设独立生成.c和.h 四、MDK串口收发…
阅读更多...
Ubuntu 常用命令之 unzip 命令用法介绍

Ubuntu 常用命令之 unzip 命令用法介绍

unzip命令在Ubuntu系统中用于解压缩.zip文件。它可以解压缩一个或多个.zip文件&#xff0c;并将文件解压缩到当前目录或指定的目录。 unzip命令的一般格式 unzip [选项] zipfile [file...]其中&#xff0c;zipfile是要解压的.zip文件&#xff0c;file是.zip文件中的特定文件。…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023