使用select

news2024/11/24 12:42:48

客户端

服务端

     1	#include<myhead.h>
     2	 
     3	#define SER_PORT 6666       //服务器端口
     4	#define SER_IP "127.0.0.1"  //服务器ip
     5	 
     6	 
     7	int main(int argc, const char *argv[])
     8	{
     9		//创建套接字
    10		int sfd=socket(AF_INET,SOCK_STREAM,0);
    11		if(sfd==-1)
    12		{
    13			perror("socket error");
    14			return -1;
    15		}
    16	 
    17		//绑定 地址和端口号
    18		struct sockaddr_in sin;
    19		sin.sin_family=AF_INET; 
    20		sin.sin_port=htons(SER_PORT); 
    21		sin.sin_addr.s_addr=inet_addr(SER_IP); 
    22		if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1)
    23		{
    24			perror("bind error");
    25			return -1;
    26		}
    27	
    28	
    29		//定义用户套接字数组 个数
    30		int client_arr[100]={0};
    31		int client_count=0;
    32	
    33		//开启监听
    34		if(listen(sfd,128)==-1)
    35		{
    36			perror("listen error");
    37			return -1;
    38		}
    39	
    40		//定义文件描述符集
    41		fd_set readfds;
    42		FD_ZERO(&readfds);
    43	 
    44	
    45		//添加
    46		FD_SET(0,&readfds);
    47		FD_SET(sfd,&readfds);
    48	
    49		//最大的文件描述符
    50		int maxfd=sfd;
    51	
    52		//存储客户端地址信息结构体数组
    53		struct sockaddr_in cin_arr[128];
    54	 
    55		int newfd=-1;
    56	
    57		struct sockaddr_in cin;        //接收客户端的信息
    58		socklen_t addrlen =sizeof(cin); //用于接收长度
    59	
    60		char wbuf[128]=""; // 信息搬运工
    61		while(1)
    62		{
    63			fd_set temp =readfds;
    64	
    65			//判断是否有文件描述符被激活
    66			int res=select(FD_SETSIZE,&temp,0,0,0);
    67			if(res==-1)
    68			{
    69				perror("select error");
    70				return -1;
    71			}
    72	
    73			//当程序执行自此表示有文件描述符被激活
    74			for(int i=0;i<=maxfd;i++)        //遍历文件描述符
    75			{
    76				//查找是什么事件触发了文件描述符被激活
    77				int res=FD_ISSET(i,&temp);
    78				if(res==0)
    79				{
    80					continue;
    81				}
    82	
    83				//程序执行至此表示i是被触发事件的文件描述符
    84				//判断sfd是否触发
    85				if(i==sfd)
    86				{
    87					//接收连接请求
    88					int newfd=accept(sfd,(struct sockaddr*)&cin,&addrlen);
    89					if(newfd==-1)
    90					{
    91						perror("accept error");
    92						return -1;
    93					}
    94					printf("成功连接到一个客户端\n");
    95	
    96					//将新连接的客户端加入监视列表,下一次循环,碰到select就能监视到
    97					FD_SET(newfd,&readfds);
    98					//将客户端地址信息结构体放入客户端地址信息数组中
    99					cin_arr[newfd]=cin;
   100					//更新最大文件描述符
   101					if(maxfd<newfd)
   102					{
   103						maxfd=newfd;
   104					}
   105				}
   106				//判断是否是标准输入流触发该事件
   107				else if(0==i)
   108				{
   109				
   110					fgets(wbuf,sizeof(wbuf),stdin);   //从终端读取消息
   111					wbuf[strlen(wbuf)-1]=0;
   112					printf("发送的消息>>>%s\n",wbuf);
   113	
   114					//将该消息发送给所有客户端
   115					for(int i=4;i<=maxfd;i++)
   116					{
   117						if(send(i,wbuf,strlen(wbuf),0)==-1)
   118						{
   119							perror("send error");
   120							return -1;
   121						}
   122					}
   123					printf("发送成功\n");
   124				}
   125				else
   126				{
   127	
   128					char buf[128]="";
   129	
   130					//清空容器
   131					bzero(buf,sizeof(buf));
   132					//从客户端套接字中读取数据
   133					int res=recv(i,buf,sizeof(buf),0);
   134					if(res==-1)
   135					{
   136						perror("recv error");
   137						return -1;
   138					}
   139	
   140					else if(res==0)
   141					{
   142						printf("用户已经下线\n");
   143						close(i);
   144	
   145						FD_CLR(i,&readfds);      //删除
   146						//更新最大文件描述符
   147						for(int j=maxfd;j>=sfd;j--)
   148						{
   149							if(FD_ISSET(j,&readfds))
   150							{
   151								maxfd =j;
   152								break;
   153							}
   154						}
   155						continue;
   156					}
   157					//正常收到客户端发来的消息
   158					printf("[%s:%d]:%s\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),buf);
   159				}
   160			}
   161		}
   162		//关闭
   163		close(sfd);
   164	 
   165		return 0;
   166	}

客户端

     1	#include<myhead.h>
     2	typedef struct sockaddr_in addr_in_t;
     3	typedef struct sockaddr addr_t;
     4	typedef struct sockaddr_un addr_un_t;
     5	int main(int argc, const char *argv[])
     6	{
     7		if(argc!=2)
     8		{
     9			printf("请输入正确的端口号\n");
    10			return -1;
    11		}
    12	
    13		int port = atoi(argv[1]);
    14	
    15		//创建描述符
    16		int client = socket(AF_INET,SOCK_STREAM,0);
    17	
    18		//绑定连接服务器
    19		addr_in_t addr;
    20		addr.sin_family=AF_INET;
    21		addr.sin_port=htons(port);
    22		addr.sin_addr.s_addr=inet_addr("127.0.0.1");
    23		if(connect(client,(addr_t*)&addr,sizeof(addr))==-1)
    24		{
    25			perror("connect error");
    26			return -1;
    27		}
    28	
    29		fd_set readfds;  //准备描述符集合
    30		FD_ZERO(&readfds);  //初始化
    31	
    32		FD_SET(client,&readfds);  //将客户端文件描述符加入描述符集合
    33		FD_SET(0,&readfds);  //将标准输入流添加入描述人集合
    34	
    35	
    36		char buf[1024]="";
    37		while(1)
    38		{
    39			//定义一个描述符集合
    40			fd_set temp=readfds;       
    41			select(FD_SETSIZE,&temp,0,0,NULL);       //阻塞
    42	
    43			if(FD_ISSET(client,&temp))
    44			{
    45				//清空
    46				bzero(buf,sizeof(buf));
    47				recv(client,buf,sizeof(buf),0);
    48				printf("接收消息:%s\n",buf);
    49			}
    50	
    51			if(FD_ISSET(0,&temp))
    52			{
    53				printf("请输入>>>");
    54				scanf("%s",buf);
    55				if(strcmp(buf,"q")==0)
    56				{
    57					break;
    58				}
    59	
    60				//发送数据
    61				send(client,buf,strlen(buf),0);
    62	
    63			}
    64		}
    65	
    66		return 0;
    67	}

思维导图

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

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

相关文章

JavaScript(27)——本地存储、数组map和join

介绍 为了满足各种各样的需求&#xff0c;会经常性在本地存储大量的数据&#xff0c;HTML5规范提出了解决方案。 数据存储在用户浏览器中设置、读取方便、甚至页面刷新不丢失数据容量较大&#xff0c;sessionStorage和localStorage约5M左右 localStorage 作用&#xff1a;可…

面临新时代的机遇与挑战,联想凌拓将如何破局?

近年来&#xff0c;IT行业的技术进步日新月异&#xff0c;云计算、大数据、人工智能……各种新兴技术犹如雨后春笋般层出不穷&#xff0c;并且正在给千行百业带来全面的变革甚至重塑。 然而以上提到的所有新兴技术&#xff0c;都离不开数据的存储与管理。那么作为中国乃至全球领…

[CTF]-Reverse:纯逻辑分析题型综合解析

C语言&#xff1a; 字符串爆破&#xff1a; 例题&#xff08;BUUCTF SimpleRev&#xff09;&#xff1a; 查壳 看ida 这里的中心就是两个字符串和一个计算式子&#xff0c;textkillshadow和str2adsfkndcls&#xff0c;计算式子str2[v2] (v1 - 39 - key[v3 % v5] 97) % 26 …

FL Studio24.1.1中文汉化版本下载 附带注册机

嘿&#xff0c;各位音乐制作的小伙伴们&#x1f3a4;&#xff01;今天我要跟大家分享一个超级给力的音乐制作软件——FL Studio24.1.1中文版本。这款软件可是我们这些音乐爱好者的福音啊&#xff01;&#x1f389;&#x1f389;&#x1f389; 让我们来聊聊这款软件的特点吧&…

会声会影剪辑视频收费吗,会声会影最新破解版

会声会影2024&#xff1a;引领视频创作新时代的创新之旅** 在数字时代的浪潮中&#xff0c;视频创作已成为连接世界、表达创意的重要方式。随着技术的不断进步&#xff0c;一款名为“会声会影2024”的视频编辑软件横空出世&#xff0c;它不仅继承了前代产品的优秀传统&#xf…

Node-RED的安装

最近对Node-RED比较感兴趣&#xff0c;因为在上OpenHarmony课程的时候&#xff0c;一直想找一个可以通过MQTT控制设备的低代码客户端解决方案。第一次指导Node-RED是在试用聆思开发板的时候&#xff0c;它的云端就是使用的Node-RED。 在安装Node-RED之前&#xff0c;请确保您的…

嵌入式AI快速入门课程-K510篇 (第四篇 AI概念及理论知识)

第四篇 AI概念及理论知识 文章目录 第四篇 AI概念及理论知识1.人工智能与机器学习1.1 机器学习1.2 模型和拟合1.3 线性回归模型1.3.1 实现简单线性回归1.3.2 简单线性回归代码解析1.3.3 Sklearn实现房价预测模型1.3.4 Sklearn房价预测代码解析 2.深度学习及神经网络2.1 深度学习…

故障频发,给我一个完美的解释...

1.盘点事故 8月19日&#xff0c;网易云音乐「崩了」&#xff0c;网页端报错&#xff0c;App 无法使用&#xff0c;什么原因&#xff1f;你那受影响了吗&#xff1f; 一次更新&#xff0c;一串代码&#xff0c;全球宕机。7月19日下午发生了全球范围内的Windows大面积蓝屏事件&a…

DataStation — 数据界的瑞士军刀,一键解锁数据潜能

DataStation &#xff1a;简化数据查询、脚本编写与可视化&#xff0c;让洞察触手可及。- 精选真开源&#xff0c;释放新价值。 概览 DataStation&#xff0c;一款为数据探索而生的应用程序&#xff0c;它以用户友好的界面和强大的功能&#xff0c;重新定义了数据查询和分析的…

黑神话悟空苹果电脑可以玩吗?MacBook玩黑神话悟空游戏攻略 crossover软件永久激活码分享 crossover免费使用教程

《黑神话&#xff1a;悟空》是由游戏科学公司制作的以中国神话为背景的动作角色扮演游戏&#xff0c;在发行前已备受期待。8月20日10时&#xff0c;备受期待的国产3A游戏大作《黑神话&#xff1a;悟空》正式上线&#xff0c;开售不到一小时&#xff0c;Steam平台上便涌入104.5万…

STM32中断系统之TIM定时中断

文章目录 前言一、TIM定时器简介1.1 定时器的基本功能1.2 时基单元1.3 定时器的其他功能1.4 TIM定时器的分类 二、TIM定时器的内部结构2.1 基本定时器2.2 通用定时器2.3 高级定时器 三、定时中断的基本结构四、时序图4.1 预分频器时序4.2 计数器时序4.3 计数器无预装时序4.4 计…

VMware-Ubuntu共享文件找不到

正常的流程我们实现设置共享目录 然后安装vmware-tool工具 我们先看一下vmware-tool的获取方式&#xff0c;系统安装好了以后&#xff0c;关闭系统将虚拟机设置改成图中配置&#xff0c;然后重启 鼠标右键会看到重新安装vmware-tool不再是灰色&#xff0c;点击重新安装 以1…

一文5000字从0到1使用Jmeter实现轻量级的接口自动化测试

接口测试虽然作为版本的一环&#xff0c;但是也是有一套完整的体系&#xff0c;有接口的功能测试、性能测试、安全测试&#xff1b;同时&#xff0c;由于接口的特性&#xff0c;接口的自动化低成本高收益的&#xff0c;使用一些开源工具或一些轻量级的方法&#xff0c;在测试用…

再有人问你Oracle的SQL性能优化,这篇文章甩给他!

SQL优化对于数据库应用程序的性能、稳定性、可靠性、数据质量、开发效率和管理效率都具有重要意义&#xff0c;以下是给大家分享的一些技巧&#xff01; 1.获取正确的执行计划 1.1 awr执行计划 select * from table(dbms_xplan.display_awr(&sql_id)); --awr中记录的执行…

API网关之Apache ShenYu

Apache ShenYu&#xff08;原名Soul&#xff09;是一个开源的API网关&#xff0c;旨在支持高性能、跨语言和云原生架构。它为管理和控制客户端与服务之间的数据流提供了一种高效且可扩展的解决方案。 文档见 Apache ShenYu 介绍 | Apache ShenYu 以下是Apache ShenYu的详细介…

蓝桥杯2021第十二届蓝桥杯青少年组省赛试题真题

带我去看题解&#xff01;&#xff01;&#xff01; 带我去看题单&#xff01;&#xff01;&#xff01; 目录 第一题&#xff1a;[2021第十二届蓝桥杯青少年组省赛] 字符串 题目背景 题目描述 输入格式 输出格式 输入输出样例 第二题&#xff1a;[2021第十二届蓝桥杯…

谷歌云AI新作:CROME,跨模态适配器高效多模态大语言模型

CROME: Cross-Modal Adapters for Efficient Multimodal LLM https://arxiv.org/pdf/2408.06610 Abstract 研究对象&#xff1a;Multimodal Large Language Models (MLLMs) demonstrate remarkable imagelanguage capabilities, but their widespread use faces challenges in…

转行游戏测试,小白到入门我只用了5天

声明&#xff1a;此篇为 ai123.cn 原创文章&#xff0c;转载请标明出处链接&#xff1a;https://ai123.cn/2183.html Hey朋友们&#xff01;&#x1f44b;有没有想过&#xff0c;AI怎么让游戏测试变得更轻松&#xff1f;&#x1f914;&#x1f3ae;作为刚入行游戏界的小白鼠&am…

使用Node-RED发送数据到巴法云

上一篇博文完成了Node-RED的安装&#xff0c;下面来尝试一下用Node-RED来发送数据到巴法云服务器。 我在教学用MQTT工具的思考-CSDN博客中说过&#xff0c;巴法云支持云云互联&#xff0c;可以连小米、百度&#xff0c;学生使用的兴趣高。所以今天先测试Node-RED和巴法云的连接…

TOMCAT入门到精通

目录 一 WEB技术 1.1 HTTP协议和B/S 结构 1.2 前端三大核心技术 1.2.1 HTML 1.2.2 CSS&#xff08;Cascading Style Sheets&#xff09;层叠样式表 1.2.3 JavaScript 二 WEB框架 2.2后台应用架构 2.2.1单体架构 2.2.2微服务 2.2.3单体架构和微服务比较 三 tomcat的…