2月7日作业

分别通过select、多进程、多线程实现一个并发服务器

#include <myhd.h>
#define IP "192.168.250.100"
#define PORT 8888
int deal_cli_msg(int newfd,struct sockaddr_in cin)
{char buf[128] = "";while(1){bzero(buf,sizeof(buf));int res = recv(newfd,buf,sizeof(buf),0);if(res == 0){printf("客户端已下线\n");break;}else if(res < 0){perror("recv error");return -1;}strcat(buf,"->is read\n");send(newfd,buf,sizeof(buf),0);}close(newfd);return 0;
}
void handler(int signo)
{if(signo == SIGCHLD){while(waitpid(-1,NULL,WNOHANG) > 0);}
}
int main(int argc, const char *argv[])
{int sfd = socket(AF_INET,SOCK_STREAM,0);if(sfd == -1){perror("socket error");return -1;}printf("socket success,sfd = %d\n",sfd);int reuse = 1;if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)) == -1){perror("setsocket 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;}printf("bind success");if(listen(sfd,128) == -1){perror("listen error");return -1;}printf("listen success");struct sockaddr_in cin;cin.sin_family = AF_INET;socklen_t socklen = sizeof(cin);pid_t pid;if(signal(SIGCHLD,handler) == SIG_ERR){perror("signal error");return -1;}while(1){int newfd = accept(sfd,(struct sockaddr*)&cin,&socklen);if(newfd == -1){perror("accept error");return -1;}printf("accept success");pid = fork();if(pid > 0){close(newfd);}else if(pid == 0){close(sfd);deal_cli_msg(newfd,cin);exit(EXIT_SUCCESS);}else{perror("fork error");return -1;}}close(sfd);return 0;
}


#include <myhd.h>
#define PORT 8888
#define IP "192.168.250.100"
struct msg_info
{int newfd;struct sockaddr_in cin;
};
void *deal_cli_msg(void *arg)
{int newfd = ((struct msg_info*)arg) -> newfd;struct sockaddr_in cin = ((struct msg_info*)arg) -> cin;char buf[128] = "";while(1){bzero(buf,sizeof(buf));int res = recv(newfd,buf,sizeof(buf),0);if(res == 0){printf("客户端已下线\n");break;}else if(res < 0){perror("recv error");return NULL;}strcat(buf,"->is read\n");send(newfd,buf,sizeof(buf),0);}close(newfd);pthread_exit(NULL);
}
int main(int argc, const char *argv[])
{int sfd = socket(AF_INET,SOCK_STREAM,0);if(sfd == -1){perror("socket error");return -1;}printf("socket success,sfd = %d\n",sfd);int reuse = 1;if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)) == -1){perror("setsockopt error");return -1;}printf("setsockopt success\n");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;}printf("bind success\n");if(listen(sfd,128) == -1){perror("listen error");return -1;}printf("listen success\n");struct sockaddr_in cin;cin.sin_family = AF_INET;socklen_t socklen = sizeof(cin);while(1){int newfd = accept(sfd,(struct sockaddr*)&cin,&socklen);if(newfd == -1){perror("accept error");return -1;}printf("accept success\n");struct msg_info info = {newfd,cin};pthread_t tid;if(pthread_create(&tid,NULL,deal_cli_msg,&info) != 0){printf("pthread_create error\n");return -1;}if(pthread_detach(tid) != 0){printf("pthread_detach error\n");return -1;}}close(sfd);return 0;
}


#include<myhd.h>#define PORT 8888              //端口号
#define IP "192.168.250.100"       //IP地址//封装处理客户端信息函数
int deal_cli_msg(int newfd, struct sockaddr_in cin)
{//5、收发数据使用newfd完成通信char buf[128] = "";while(1){//清空字符串bzero(buf, sizeof(buf));//read(newfd, buf, sizeof(buf));        //从套接字中读取客户端发来的消息int res = recv(newfd, buf, sizeof(buf), 0);        //从套接字中读取客户端发来的消息//buf[strlen(buf)-1] = '\0';//判断收到的结果if(res == 0){printf("客户端已经下线\n");break;}else if(res < 0){perror("recv error");return -1;}printf("[%s:%d]：%s\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), buf);//将读取的信息，加上一些字符发送回去strcat(buf, " -> is read\n");//    write(newfd, buf, sizeof(buf));send(newfd, buf, sizeof(buf), 0); }close(newfd);             //关闭通信的套接字}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("socket success sfd = %d\n", sfd);    //4//设置端口号快速重用int reuse = 1;if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){perror("setsockopt error");return -1;}printf("设置端口快速重用成功 _%d_ %s_ %s_\n", __LINE__, __FILE__, __func__);//2、绑定IP地址和端口号//2.1、填充要绑定的地址信息结构体struct sockaddr_in sin;sin.sin_family     = AF_INET;         //表明是ipv4sin.sin_port     = htons(PORT);        //端口号sin.sin_addr.s_addr = inet_addr(IP);     //IP地址//2.2、绑定if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin))==-1){perror("bind error");return -1;}printf("bind success _%d_ %s_ %s_\n", __LINE__, __FILE__, __func__);//3、将套接字设置成被动监听状态if(listen(sfd, 128) == -1){perror("listen error");return -1;}printf("listen success _%d_ %s_ %s_\n", __LINE__, __FILE__, __func__);//4、阻塞等待客户端连接请求，如果有新的客户端连接，则创建一个新的用于通信的套接字//4.1、定义客户端地址信息结构体struct sockaddr_in cin;             //客户端地址信息结构体cin.sin_family     = AF_INET;socklen_t socklen = sizeof(cin);          //客户端地址信息的大小定义一个用于检测文件描述符的集合fd_set readfds, tempfds;                          //在栈区定义清空容器中的内容FD_ZERO(&readfds);将要检测的文件描述符放入集合中FD_SET(sfd, &readfds);           //将sfd文件描述符放入FD_SET(0, &readfds);             //将0号文件描述符放入//定义一个容器char buf[128] = "";int res = 0;             //接收select的返回值while(1){将集合内容复制一份tempfds = readfds;使用select阻塞等待集合中的文件描述符有事件产生res = select(sfd+1, &tempfds, NULL, NULL, NULL);if(res == -1){perror("select error");return -1;}else if(res == 0){printf("time out\n");return -1;}判断sfd是否还在集合中if(FD_ISSET(sfd, &tempfds)){//4.2、阻塞接收客户端的链接请求，并且获取客户端的地址信息int newfd = accept(sfd, (struct sockaddr*)&cin, &socklen);if(newfd == -1){perror("accept error");return -1;}printf("accept success _%d_ %s_ %s_\n", __LINE__, __FILE__, __func__);deal_cli_msg(newfd,cin);}if(FD_ISSET(0, &tempfds)){//从终端获取数据fgets(buf, sizeof(buf), stdin);       //从终端获取数据buf[strlen(buf)-1]='\0';printf("触发终端输入事件:%s\n", buf);}}//6、关闭所有套接字close(sfd);               //关闭监听return 0;
}

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

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

相关文章

使用Word Embedding+Keras进行自然语言处理NLP

使用Word Embedding+Keras进行自然语言处理NLP

目录 介绍&#xff1a; one-hot&#xff1a; pad_sequences: 建模: 介绍&#xff1a; Word Embedding是一种将单词表示为低维稠密向量的技术。它通过学习单词在文本中的上下文关系&#xff0c;将其映射到一个连续的向量空间中。在这个向量空间中&#xff0c;相似的单词在空间…
阅读更多...
2024年智能算法优化PID参数，ITAE、ISE、ITSE、IAE四种适应度函数随意切换，附MATLAB代码...

2024年智能算法优化PID参数，ITAE、ISE、ITSE、IAE四种适应度函数随意切换，附MATLAB代码...

PID 参数整定就是确定比例系数&#xff08;Kp &#xff09;、积分系数&#xff08;Ki&#xff09;和微分系数&#xff08;Kd &#xff09;的过程&#xff0c;以便使 PID 控制器能够在系统中实现稳定、快速、准确的响应。 本期的主题 采用四种2024年的智能优化算法优化PID的三个…
阅读更多...
【开源】JAVA+Vue+SpringBoot实现毕业生追踪系统

【开源】JAVA+Vue+SpringBoot实现毕业生追踪系统

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 登陆注册模块2.2 学生基本配置模块2.3 就业状况模块2.4 学历深造模块2.5 信息汇总分析模块2.6 校友论坛模块 三、系统设计3.1 用例设计3.2 实体设计 四、系统展示五、核心代码5.1 查询我的就业状况5.2 初始化就业状况5.…
阅读更多...
《Git 简易速速上手小册》第6章：Git 在持续集成/持续部署（CI/CD）中的应用（2024 最新版）

《Git 简易速速上手小册》第6章：Git 在持续集成/持续部署（CI/CD）中的应用（2024 最新版）

文章目录 6.1 CI/CD基础6.1.1 基础知识讲解6.1.2 重点案例&#xff1a;为 Python Web 应用实现 CI/CD6.1.3 拓展案例 1&#xff1a;自动化部署到云平台6.1.4 拓展案例 2&#xff1a;使用 Docker 容器化部署 6.2 Git 与自动化测试6.2.1 基础知识讲解6.2.2 重点案例&#xff1a;为…
阅读更多...
numpy 查漏补缺

numpy 查漏补缺

1. iterating 2. 3. 4. 5. 6. 7. 8. 9.
阅读更多...
【HTML】情人节给npy一颗炫酷的爱心

【HTML】情人节给npy一颗炫酷的爱心

闲谈 兄弟们&#xff0c;这不情人节快要到了&#xff0c;我该送女朋友什么&#x1f381;呢&#xff1f;哦&#xff0c;对了&#xff0c;差点忘了&#xff0c;我好像没有女朋友。不过这不影响我们要过这个节日&#xff0c;我们可以学习技术。举个简单的&#x1f330;&#xff1…
阅读更多...
Linux_进程

Linux_进程

进程创建 进程退出码 进程等待 程序替换 Shell作为命令行解释器是一个进程&#xff0c;它也有自己的数据结构task_struct和代码和数据。为了防止用户输入的指令造成Shell崩溃&#xff0c;所以Shell执行用户输入的指令是通过创建一个子进程来执行的。例如lspwd等等。 一.进程…
阅读更多...
数据工程工程师学习路线图

数据工程工程师学习路线图

数据工程岗位要求 Skill Sets required: - Hands on experience enabling data via Adobe Analytics and/or Google Analytics - Understanding of how customer level data is captured and stitched with behavioural data - Experience working with Testing (QA) and D…
阅读更多...
【Java 数据结构】泛型进阶

【Java 数据结构】泛型进阶

泛型 1 什么是泛型2 引出泛型2.1 语法 3 泛型类的使用3.1 语法3.2 示例3.3 类型推导(Type Inference) 泛型是如何编译的擦除机制裸类型4 泛型的上界4.1 语法4.2 示例4.3 复杂示例 5 泛型方法5.1 定义语法5.2 示例5.3 使用示例-可以类型推导5.4 使用示例-不使用类型推导 6 通配符…
阅读更多...
如何在极低成本硬件上落地人工智能算法 —— 分布式AI

如何在极低成本硬件上落地人工智能算法 —— 分布式AI

一、背景 分布式AI的发展前景非常广阔&#xff0c;随着5G、6G等高速网络通信技术的普及和边缘计算能力的提升&#xff0c;以及AI算法和硬件的不断优化进步&#xff0c;分布式AI将在多个领域展现出强大的应用潜力和市场价值&#xff1a; 1. **物联网&#xff08;IoT&#xff0…
阅读更多...
react【四】css

react【四】css

文章目录 1、css1.1 react和vue css的对比1.2 内联样式1.3 普通的css1.4 css modules1.5 在react中使用less1.6 CSS in JS1.6.1 模板字符串的基本使用1.6.2 styled-components的基本使用1.6.3 接受传参1.6.4 使用变量1.6.5 继承样式 避免代码冗余1.6.6 设置主题色 1.7 React中添…
阅读更多...
正月初五迎财神

正月初五迎财神

大家好&#xff0c;我是小悟 正月初五&#xff0c;人们在这一天迎接财神&#xff0c;祈求财运亨通、事业顺利。按照习俗&#xff0c;家家户户都会燃放鞭炮、点灯笼、摆设祭品&#xff0c;以示虔诚。 早晨&#xff0c;太阳刚刚升起&#xff0c;大家便早早起床&#xff0c;开始准…
阅读更多...
【数据存储+多任务爬虫】

【数据存储+多任务爬虫】

数据存储 peewee模块 第三方模块&#xff0c;也需要在cmd中安装。 from peewee import *db MySQLDatabase("spider",host"127.0.0.1",port3306,userroot,password123456 )# 类》表 class Person(Model):name CharField(max_length20) # 类型/约束bi…
阅读更多...
核心篇-OSPF技术之序（中）

核心篇-OSPF技术之序（中）

文章目录 一. 实验专题1.1. 实验1&#xff1a;配置多区域OSPF1.1.1. 实验目的1.1.2. 实验拓扑1.1.3. 实验步骤&#xff08;1&#xff09;配置地址&#xff08;2&#xff09;运行OSPF 1.1.4. 实验调试&#xff08;1&#xff09;查看路由器信息&#xff08;2&#xff09;创建环回…
阅读更多...
Spring Boot 笔记 010 创建接口_更新用户头像

Spring Boot 笔记 010 创建接口_更新用户头像

1.1.1 usercontroller中添加updateAvatar&#xff0c;校验是否为url PatchMapping("updateAvatar")public Result updateAvatar(RequestParam URL String avatarUrl) {userService.updateAvatar(avatarUrl);return Result.success();} 1.1.2 userservice //更新头像…
阅读更多...
【UDS】搞懂时间参数

【UDS】搞懂时间参数

文章目录 背景时间参数的定义应用层相关会话层相关传输层相关网络层相关实际案例分析背景 TBD. 时间参数的定义 注意，这些时间参数都是超时阈值，需要理解为什么要有这些阈值，在哪一端判断这些阈值的，无需“死记硬背”它们的含义。 应用层相关 【P2 Client】 P2 Client 的…
阅读更多...
数学建模：K-means聚类手肘法确定k值（含python实现）

数学建模：K-means聚类手肘法确定k值（含python实现）

原理 当K-means聚类的k值不被指定时&#xff0c;可以通过手肘法来估计聚类数量。   在聚类的过程中&#xff0c;随着聚类数的增大&#xff0c;样本划分会变得更加精细&#xff0c;每个类别的聚合程度更高&#xff0c;那么误差平方和&#xff08;SSE&#xff09;会逐渐变小&am…
阅读更多...
YOLOv8改进 | Conv篇 | 利用FasterBlock二次创新C2f提出一种全新的结构（全网独家首发，参数量下降70W）

YOLOv8改进 | Conv篇 | 利用FasterBlock二次创新C2f提出一种全新的结构（全网独家首发，参数量下降70W）

一、本文介绍 本文给大家带来的改进机制是利用FasterNet的FasterBlock改进特征提取网络，将其用来改进ResNet网络，其旨在提高计算速度而不牺牲准确性，特别是在视觉任务中。它通过一种称为部分卷积（PConv）的新技术来减少冗余计算和内存访问。这种方法使得FasterNet在多种设…
阅读更多...
LeetCode、72. 编辑距离【中等，二维DP】

LeetCode、72. 编辑距离【中等，二维DP】

文章目录 前言LeetCode、72. 编辑距离【中等&#xff0c;二维DP】题目链接与分类二维DP 资料获取 前言 博主介绍&#xff1a;✌目前全网粉丝2W&#xff0c;csdn博客专家、Java领域优质创作者&#xff0c;博客之星、阿里云平台优质作者、专注于Java后端技术领域。 涵盖技术内容…
阅读更多...
nvm 安装nodejs教程【详细】

nvm 安装nodejs教程【详细】

目录 一、安装nvm 二、配置镜像 三、安装nodejs 安装 查看正在用的nodejs版本 切换版本 一、安装nvm 双击安装包&#xff1a; 无脑下一步即可&#xff0c;当然你可以自定义你自己的安装目录。 安装完后&#xff0c;打开环境变量&#xff0c;你会发现nvm为我们自动配置好…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023