网络编程 IO多路复用 [select版] (TCP网络聊天室)

//head.h                 头文件

//TcpGrpSer.c        服务器端

//TcpGrpUsr.c        客户端

select函数 

功能：阻塞函数，让内核去监测集合中的文件描述符是否准备就绪，若准备就绪则解除阻塞。

原型：

#include <sys/select.h>#include <sys/time.h>#include <sys/types.h>#include <unistd.h>int select(int nfds, fd_set *readfds, fd_set *writefds,fd_set *exceptfds, struct timeval *timeout);
参数：int nfds：所有集合中最大的文件描述符+1;    fd_set *readfds, fd_set *writefds,fd_set *exceptfds：读集合，写集合，其他集合。用不上的集合填NULL;struct timeval *timeout：设置超时时间; 1) 填NULL,不设置超时时间，会一直阻塞直到文件描述符准备就绪，解除阻塞;2) 设置超时时间；struct timeval {long    tv_sec;         /* seconds */      秒long    tv_usec;        /* microseconds */
微秒};
返回值：>0, 成功，返回成功触发事件的文件描述符个数;=0, 超时了=-1，函数运行失败，更新errno; 操作集合的函数：      void FD_CLR(int fd, fd_set *set);     将指定的fd从集合中删除int  FD_ISSET(int fd, fd_set *set);    判断fd是否在集合中，若存在返回真，否则返回假void FD_SET(int fd, fd_set *set);      将fd添加到集合中void FD_ZERO(fd_set *set);             清空

head.h

#ifndef __HEAD_H__
#define __HEAD_H__#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<strings.h>
#include<unistd.h>
#include<math.h>
#include<errno.h>
#include<fcntl.h>
#include<signal.h>#include<sys/stat.h>
#include<sys/wait.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<sys/shm.h>
#include<sys/time.h>
#include<sys/sem.h>#include<pthread.h>
#include<semaphore.h>#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<sys/select.h>
#include<poll.h>#define NUM 10
#define ERR_MSG(msg) do{\printf("line: %d\n",__LINE__);\perror(msg);\
}while(0)
#define PORT 6666           //端口号的网络字节序  1024～49151
#define IP "192.168.250.100"  //ifconfig查看本机IP  (ipv4)#endif

TcpGrpSer.c

#include "head.h"int main(int argc, const char *argv[])
{//创建流式套接字int sfd = socket(AF_INET,SOCK_STREAM,0);if(sfd<0){ERR_MSG("socket");return -1;}//填充服务器自身的地址信息结构体//真实的地址信息结构体根据地址族制定AF_INET ; man 7 ipstruct sockaddr_in sin; sin.sin_family  = AF_INET;            //必须填充AF_INETsin.sin_port   = htons(PORT);        //端口号的网络字节序  1024～49151sin.sin_addr.s_addr = inet_addr(IP);  //ifconfig查看本机IPint reuse = 1;if(setsockopt(sfd, SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)) < 0) //允许端口快速被重复使用{ERR_MSG("setsockopt");return -1;}//绑定连接if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))<0){ERR_MSG("bind");return -1;}printf("bind success\n");//设置监听if(listen(sfd,128) < 0){ERR_MSG("listen");return -1;}//创建读集合fd_set readfds,tempfds;//清空集合FD_ZERO(&readfds);FD_ZERO(&tempfds);//将集合监测的文件描述符放入集合FD_SET(0,&readfds);FD_SET(sfd,&readfds);//用顺序表存储文件描述符的端口信息//监测文件描述符是否准备就绪int maxfd = sfd;int s_res = 0;struct sockaddr_in cin;socklen_t len = sizeof(cin);struct sockaddr_in savcin[1024];int newfd = -1;char buf[128]="";ssize_t res = 0;while(1){tempfds = readfds;//备份readfdss_res = select(maxfd+1,&tempfds,NULL,NULL,NULL);if(s_res<0){ERR_MSG("select");return -1;}else if(0 == s_res){printf("超时...\n");break;}//与客户端通信for(int i=0;i<=maxfd;i++){if(!FD_ISSET(i,&tempfds))continue;if(0 == i){printf("触发键盘输入事件\n");int sndfd=-1;res=scanf("%d %s",&sndfd,buf);while(getchar() !=10);if(res!=2){printf("请输入正确数据格式：[fd(4~1023)] string\n");		continue;}//判断文件是否合法if(sndfd<sfd||sndfd>1023||!FD_ISSET(sndfd,&readfds)){printf("sndfd = %d 是非法文件描述符\n",sndfd);continue;}if(send(sndfd,buf,sizeof(buf),0)<0){ERR_MSG("send");}bzero(buf,sizeof(buf));}else if(i == sfd){printf("触发客户端连建事件\n");newfd = accept(sfd,(struct sockaddr *)&cin,&len);if(newfd < 0){perror("accept");return -1;}savcin[newfd]=cin;printf("[%s:%d] 客户端连接成功 newfd = %d __%d__ \n",\inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),newfd,__LINE__);//将新生成的newfd添加到readfdsFD_SET(newfd,&readfds);//更新maxfdmaxfd = maxfd > newfd? maxfd:newfd;}else{printf("触发客户端连建事件__%d__\n",__LINE__);bzero(buf,sizeof(buf));//接收数据res = recv(i,buf,sizeof(buf),0);if(res < 0){ERR_MSG("recv");return -1;}else if(0 == res){printf("{%s:%d} sfd = %d,__%d__ 已下线，结束对话\n",\inet_ntoa(savcin[i].sin_addr),ntohs(savcin[i].sin_port),i,__LINE__);     close(i);//关闭文件描述符FD_CLR(i,&readfds);/*	//更新maxfdint j=maxfd;for(;j<=0;j--){if(FD_ISSET(j,&readfds)) break;}maxfd = j;*///更新maxfdwhile(!FD_ISSET(maxfd,&readfds)&&maxfd-->=0);continue;}printf("{%s:%d} sfd = %d : %s,__%d__\n",\inet_ntoa(savcin[i].sin_addr),ntohs(savcin[i].sin_port),i,buf,__LINE__);  //发送数据strcat(buf,"*_*");if(send(i,buf,sizeof(buf),0)<0){ERR_MSG("send");return -1;}printf("发送成功\n");}}}if(close(sfd)<0){ERR_MSG("close");return -1;}return 0;
}

TcpGrpUsr.c

#include "head.h"int main(int argc, const char *argv[])
{//创建流式套接字int sfd = socket(AF_INET,SOCK_STREAM,0);if(sfd<0){ERR_MSG("socket");return -1;}int reuse = 1;if(setsockopt(sfd, SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)) < 0) //允许端口快速被重复使用{ERR_MSG("setsockopt");return -1;}//填充服务器自身的地址信息结构体//真实的地址信息结构体根据地址族制定AF_INET ;struct sockaddr_in sin; sin.sin_family      = AF_INET;            //必须填充AF_INETsin.sin_port        = htons(PORT);        //端口号的网络字节序  1024～49151sin.sin_addr.s_addr = inet_addr(IP);      //ifconfig查看本机IPif(connect(sfd,(struct sockaddr *)&sin,sizeof(sin))<0){perror("connect");return -1;}printf("连接成功\n");//创建集合struct pollfd fds[2];fds[0].fd = 0;fds[0].events = POLLIN;fds[1].fd = sfd;fds[1].events = POLLIN;char buf[128]="";int res=0;while(1){//阻塞方式监测集合res = poll(fds,2,-1);if(res < 0){ERR_MSG("poll");return -1;}else if(0 == res){printf("time out...\n");      //超时break;}//判断0文件描述符是否有POLLIN事件if((fds[0].revents & POLLIN)){fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1] = 0;if(send(sfd,buf,sizeof(buf),0) < 0){ERR_MSG("send");return -1;}printf("发送成功\n");}//判断sfd文件描述符是否有POLLIN事件if(fds[1].revents & POLLIN){//接收数据bzero(buf,sizeof(buf));res = recv(sfd,buf,sizeof(buf),0);if(res<0){ERR_MSG("recv");return -1;}else if(res == 0){printf("[%s:%d] 服务器下线__%d__ \n",\inet_ntoa(sin.sin_addr),ntohs(sin.sin_port),__LINE__);break;}printf("[%s:%d] cfd = %d : %s__%d__ \n",\inet_ntoa(sin.sin_addr),ntohs(sin.sin_port),sfd,buf,__LINE__);}	}if(close(sfd)<0){ERR_MSG("close");return -1;}return 0;
}

 

 

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

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

相关文章

BUG:pm2启动verdaccio报错:Invalid or unexpected toke

BUG:pm2启动verdaccio报错:Invalid or unexpected toke

输入命令&#xff1a; pm2 state verdaccio 问题描述&#xff1a; pm2 logs verdaccio报错翻译&#xff1a;数据格式错误 导致我呢提原因&#xff0c;没有找到运行文件&#xff0c; 发现问题&#xff1a;因为命令默认查找verdaccio是去系统盘查找。 解决方式 1&#xff1a;…
阅读更多...
Java+bcprov库实现对称和非对称加密算法

Java+bcprov库实现对称和非对称加密算法

BouncyCastle&#xff0c;即BC&#xff0c;其是一款开源的密码包&#xff0c;包含了大量的密码算法。 本篇主要演示BC库引入&#xff0c;对称加密算法AES、SM4和 非对称加密EC算法的简单实现&#xff0c;以下是实现过程。 一、将BC添加到JRE环境 前提&#xff1a;已安装JRE环…
阅读更多...
C# Socket实际应用案例与属性详解

C# Socket实际应用案例与属性详解

引言 Socket是一个在网络编程中非常常见和重要的概念&#xff0c;它提供了一种通信机制&#xff0c;使不同的计算机之间可以进行数据传输。本文将介绍C#中Socket的实际应用案例&#xff0c;并对Socket的常用属性进行详细解析。 文章目录 1. Socket的实际应用案例2. Socket的属…
阅读更多...
Python命令模式介绍、使用

Python命令模式介绍、使用

一、Python命令模式介绍 Python命令模式&#xff08;Command Pattern&#xff09;是一种行为型设计模式&#xff0c;它允许将请求或操作封装在对象中&#xff0c;并将其作为参数传递给调用对象&#xff0c;以在不同的环境中执行相同的请求或操作。 功能&#xff1a; 将请求或…
阅读更多...
SqlServer读写分离对等发布

SqlServer读写分离对等发布

SqlServer读写分离对等发布: 对等发布支持多主复制。发布服务器将事务流式传输到拓扑中的所有对等方。所有对等节点可以读取和写入更改，且所有更改将传播到拓扑中的所有节点。 注意点： 1.各服务器的数据库名字要保证一样。 2.发布名称必须保持一致。 3.各服务器必须都是…
阅读更多...
【论文阅读】The Deep Learning Compiler: A Comprehensive Survey

【论文阅读】The Deep Learning Compiler: A Comprehensive Survey

论文来源&#xff1a;Li M , Liu Y , Liu X ,et al.The Deep Learning Compiler: A Comprehensive Survey[J]. 2020.DOI:10.1109/TPDS.2020.3030548. 这是一篇关于深度学习编译器的综述类文章。 什么是深度学习编译器 深度学习&#xff08;Deep Learning&#xff09;编译器将…
阅读更多...
【Maven】让maven更高效，优化maven构建项目速度

【Maven】让maven更高效，优化maven构建项目速度

打开idea的setting&#xff0c;找到maven&#xff0c;设置它多线程数&#xff0c;重启后即可&#xff01; 我这里是8&#xff0c;你们可以随便设置。 如下图&#xff1a;
阅读更多...
前端请求传输token到后端的两种方式

前端请求传输token到后端的两种方式

谈谈 cookie & session & jwt - 掘金 前端在每次请求时把token放在请求头中发送给后端&#xff0c;目前有两种方式&#xff1a; 一是通过cookie的形式&#xff0c;即把token放在cookie中&#xff0c;每次浏览器会自动帮我们带过去&#xff0c;不需要我们自己设置。 二…
阅读更多...
flutter实战（01）windows桌面版 修改应用logo、名称、显示位置、显示大小

flutter实战（01）windows桌面版 修改应用logo、名称、显示位置、显示大小

说明&#xff1a;该系列文章主要为flutter在windows桌面平台实战中遇到的一些坑。 1 修改logo 只需要在flutter项目/windows/runner/resources目录下替换原来的应用图标 app_icon.ico即可。 2 修改应用名称、显示位置、显示大小 修改flutter项目/windows/runner/main.cpp 文…
阅读更多...
Github git clone 和 git push 特别慢的解决办法

Github git clone 和 git push 特别慢的解决办法

1.在本地上使用 SSH 命令无法git push 上传 github 项目 2.使用 git clone 下载项目特别慢总是加载不了 解决办法1 将 *** 的连接模式换成&#xff1a;D-i-r-e-c-t&#xff08;好像不太有用&#xff09; 后面再找找能不能再G-l-o-b-a-l 下解决该问题 解决办法 2 mac下直接设…
阅读更多...
自定义AOP记录请求日志

自定义AOP记录请求日志

Aspect Component public class LogAspect {public LogAspect() {System.out.println("LogAspect");}private final static Logger LOG LoggerFactory.getLogger(LogAspect.class);/*** 定义一个切点 TODO 记得替换为自己项目的controller位置*/Pointcut("exec…
阅读更多...
Spring Data【Spring Data Redis、Spring Data ElasticSearch】(二)-全面详解（学习总结---从入门到深化）

Spring Data【Spring Data Redis、Spring Data ElasticSearch】(二)-全面详解（学习总结---从入门到深化）

目录 四、 Spring Data Redis 五、 Spring Data ElasticSearch 四、 Spring Data Redis Redis 是一个基于内存的数据结构存储系统&#xff0c;它可以用作数据库或者缓存。它支持多种 类型的数据结构&#xff0c;这些数据结构类型分别为 String&#xff08;字符串&#xff09…
阅读更多...
lab3 attacklab

lab3 attacklab

phase1 首先&#xff0c;通过这个指令生成前三个阶段要用到的ctarget的反汇编代码objdump -d ./ctarget >> target.s 其次&#xff0c;假设我们的输入文件是touch1.txt&#xff0c;那么运行这个指令就可以去验证是否是正确的./hex2raw <touch1.txt | ./ctarget -q 整…
阅读更多...
MethodInterceptor

MethodInterceptor

目录 1 MethodInterceptor 1.1 /// This will be called via Reflection 1.2 HandleAsync MethodInterceptor /// This will be called via Reflection /// </summary> /// <typeparam name"TResult"></typeparam> /// <param name"…
阅读更多...
Flutter 开发者工具 Android Studio 开发Flutter应用

Flutter 开发者工具 Android Studio 开发Flutter应用

Flutter 开发者工具 在 Android Studio 开发Flutter应用 &#x1f525; Android Studio 版本更新 &#x1f525; Android Studio Check for Update Connection failed ​ 解决方案 如果是运行的是32位的android studio需要在andriod studio的启动目录下找到studio.exe.vmoptio…
阅读更多...
WIZnet W5100S-EVB-Pico DHCP 配置教程（三）

WIZnet W5100S-EVB-Pico DHCP 配置教程（三）

DHCP协议介绍 什么是DHCP&#xff1f; 动态主机配置协议DHCP&#xff08;Dynamic Host Configuration Protocol&#xff09;是一种网络管理协议&#xff0c;用于集中对用户IP地址进行动态管理和配置。 DHCP于1993年10月成为标准协议&#xff0c;其前身是BOOTP协议。DHCP协议由…
阅读更多...
Python批量下载主播照片，实现人脸识别, 进行颜值评分，制作颜值排行榜

Python批量下载主播照片，实现人脸识别, 进行颜值评分，制作颜值排行榜

昨晚一回家&#xff0c;表弟就神神秘秘的跟我说&#xff0c;发现一个高颜值网站&#xff0c;非要拉着我研究一下她们的颜值高低。 我心想&#xff0c;这还得要我一个个慢慢看&#xff0c;太麻烦了~ 于是反手用Python给他写了一个人脸识别代码&#xff0c;把她们的照片全部爬下…
阅读更多...
【华为OD机试】 选修课

【华为OD机试】 选修课

题目描述 现有两门选修课&#xff0c;每门选修课都有一部分学生选修&#xff0c;每个学生都有选修课的成绩&#xff0c;需要你找出同时选修了两门选修课的学生&#xff0c;先按照班级进行划分&#xff0c;班级编号小的先输出&#xff0c;每个班级按照两门选修课成绩和的降序排序…
阅读更多...
【TiDB理论知识 07】SQL执行流程

【TiDB理论知识 07】SQL执行流程

一 DML语句读写流程 1 DML语句读流程概要 用户发出SQL 被协议层接收 Protocal Layer 通过PD获取时间戳 parse模块 解析SQL&#xff0c;通过词法解析 与 语法解析 生成AST语法树 编译SQL Compile模块 ,区分点查 与 非点查&#xff0c;生成执行计划 发送给Executor,从TIKV获…
阅读更多...
AAOS 音频焦点请求

AAOS 音频焦点请求

文章目录 前言基本概念提供给应用来获取音频焦点的apiAAOS中的音频焦点管理交互矩阵duck的实现流程AAOS 测试应用kitchensink焦点相关 前言 本文章的目标是首先了解Android中音频焦点的基本概念&#xff0c;理解代码中相关音频焦点的使用方法。其次理解AAOS 中相关交互矩阵概念…
阅读更多...
最新文章

Copyright @ 2022~2023