IO模型-----聊天室

news2024/11/27 14:46:23

运行1个服务器和2个客户端 实现效果： 服务器和2个客户端互相聊天，服务器和客户端都需要使用select模型去实现 服务器要监视2个客户端是否连接，2个客户端是否发来消息以及服务器自己的标准输入流 客户端要监视服务器是否发来消息以及客户端自己的标准输入流 在不开线程的情况下，实现互相聊天

服务器端

#include<myhead.h>

#define SER_PORT 9999  //服务器端口
#define SER_IP "192.168.43.200"  //服务器ip


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);

	//将端口号快速重用
	int reuse=-1;
	if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))==-1)
	{
		perror("setsockpt error");
		return -1;
	}
	printf("端口号快速重用成功\n");

	//2.为套接字绑定ip地址和端口号
	//2.填充地址信息结构体
	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地址
	int client_arr[100]={0};//存放客户端套接字数组中客户端的个数
	int client_count=0;//表示客户端套接字数组中有多少个客户端

	//2.2绑定工作
	if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1)
	{
		perror("bind error");
		return -1;
	}
	//3.将套接字设置成被动监听状态
	if(listen(sfd,100)==-1)
	{
		perror("listen error");
		return -1;
	}
	printf("listen success\n");
	//3.1定义一个文件描述符集合
	fd_set readfds;
	//3.2初始化
	FD_ZERO(&readfds);

	//3.3将要监视的描述符添加到set里面
	//监视服务器的标准输入流
	FD_SET(0,&readfds);
	FD_SET(sfd,&readfds);
	//记录当前容器中最大的文件描述符
	int maxfd=sfd;
	//存储客户端地址信息结构体数组
	struct sockaddr_in cin_arr[1024];

	//4.阻塞等待客户端的链接请求
	int newfd=-1;
	//4.1定义变量用来接收客户端的信息
	struct sockaddr_in cin;  //用来接收客户端的信息
	socklen_t addrlen =sizeof(cin); //用于接收长度
	char wbuf[128]=""; // 搬运工
	while(1)
	{
		fd_set temp =readfds;
		//判断是否有文件描述符被激活
		int res=select(FD_SETSIZE,&temp,0,0,0);
		if(res==-1)
		{
			perror("select error");
			return -1;
		}
		//当程序执行自此表示有文件描述符被激活
		for(int i=0;i<=maxfd;i++)
		{
			//查找是什么事件触发了文件描述符被激活（当前集合是被覆盖的，只剩下被激活的文件描述符)
			int res=FD_ISSET(i,&temp);
			if(res==0)
			{
				continue;
			}
			//程序执行至此表示i是被触发事件的文件描述符
			//判断sfd是否触发
			if(i==sfd)
			{
				//接收连接请求
				int newfd=accept(sfd,(struct sockaddr*)&cin,&addrlen);
				if(newfd==-1)
				{
					perror("accept error");
					return -1;
				}
				printf("已成功连接一个客户端\n");
				//将新连接的客户端加入监视列表，下一次循环，碰到select就能监视到
				FD_SET(newfd,&readfds);
				//将客户端地址信息结构体放入客户端地址信息数组中
				cin_arr[newfd]=cin;
				//更新最大文件描述符
				if(maxfd<newfd)
				{
					maxfd=newfd;
				}
			}
			//判断是否是标准输入流触发该事件
			else if(0==i)
			{
				//从终端上读取数据
				fgets(wbuf,sizeof(wbuf),stdin);
				wbuf[strlen(wbuf)-1]=0;
				printf("发送给客户端的消息>>>%s\n",wbuf);
				//将该消息发送给所有客户端
				for(int i=4;i<=maxfd;i++)
				{
					if(send(i,wbuf,strlen(wbuf),0)==-1)
					{
						perror("发送error");
						return -1;
					}
				}
				printf("发送成功\n");
			}
			else
			{
				//说明是某个客户端发来的消息
				//数据收发
				char buf[128]="";
				//清空容器
				bzero(buf,sizeof(buf));
				//从客户端套接字中读取数据
				int res=recv(i,buf,sizeof(buf),0);
				if(res==-1)
				{
					perror("read error");
					return -1;
				}
				else if(res==0)
				{
					printf("客户端已经下线\n");
					close(i);
					//将当前文件描述符移除
					FD_CLR(i,&readfds);
					//更新最大文件描述符
					for(int j=maxfd;j>=sfd;j--)
					{
						if(FD_ISSET(j,&readfds))
						{
							maxfd =j;
							break;
						}
					}
					continue;
				}
				//正常收到客户端发来的消息
				printf("[%s:%d]:%s\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),buf);
			}
		}
	}
	//关闭监听
	close(sfd);

	return 0;
}

客户端

#include<myhead.h>
#define SER_PORT 9999             //与服务器保持一致
#define SER_IP  "192.168.43.200"    //服务器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("cfd = %d\n", cfd);             //3

    
    //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");

	//准备描述符集合
	fd_set readfds;
	//初始化集合
	FD_ZERO(&readfds);
	//要监视的描述符添加
	FD_SET(cfd,&readfds);
	FD_SET(0,&readfds);
 	//4、数据收发
    char buf[128] = "";
    while(1)
    {
		fd_set temp=readfds;
		select(FD_SETSIZE,&temp,0,0,0);

		if(FD_ISSET(0,&temp))
		{
        	printf("请输入>>>");
        	fgets(buf, sizeof(buf), stdin);         //从终端获取一个字符串
        	buf[strlen(buf)-1] = 0;
        	//将数据发送给服务器
        	send(cfd, buf, strlen(buf), 0);
        	printf("发送成功\n");
		}
		if(FD_ISSET(cfd,&temp))
		{
			//清空容器
			bzero(buf,sizeof(buf));
			//接收服务器发来的消息
			recvfrom(cfd,buf,sizeof(buf),0,NULL,NULL);
			printf("收到服务器的消息为:%s\n",buf);
		}
    }
    
    //5、关闭套接字
    close(cfd);

    return 0;
}

2>思维导图

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

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

相关文章

Elasticsearch 安装 windows

Elasticsearch 安装 windows

1&#xff0c;下载Elasticsearch Download Elasticsearch | Elastic 2,下载的压缩包解压后 3&#xff0c;进入bin文件夹&#xff0c;双击 elasticsearch.bat 启动 4&#xff0c;修改配置 启动成功后先关掉了ctrlc关掉 进入config文件夹&#xff0c;打开文件 elasticsearch.ym…
阅读更多...
力扣 1425带限制的子序列和

力扣 1425带限制的子序列和

这是一道 动态规划加单调队列的题&#xff0c;重点加强单调队列知识的学习 回归本题&#xff0c;这个题中&#xff0c;动态规划的部分略去&#xff0c;状态转移方程可求 单调队列部分 1维护队头 if(i-sta.front() k) sta.pop_front(); 2维护队尾 while(!sta.empty() &…
阅读更多...
企业级web应用服务器tomcat

企业级web应用服务器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 二、tomcat的功能介绍 2.1 安装 tomcat 环境准备 2.1.1 安装java环境 2.1.2 安装并启动tomcat …
阅读更多...
C++：模板 II（非类型模板参数，特化，分离编译）

C++：模板 II（非类型模板参数，特化，分离编译）

目录 非类型模板参数 模板的特化 函数模板特化 类模板特化 全特化 偏特化 引用特化 指针特化 模板分离编译 非类型模板参数 什么是非类型模板参数&#xff1f; 顾名思义&#xff0c;它的类型形参并不是一个类型&#xff0c;就是用一个常量来作为类模板或函数模板的…
阅读更多...
（软件测试）基础2

（软件测试）基础2

1.等价类划分法 步骤&#xff1a; 2.编写数据用例 例题&#xff1a;参考基础1中的手机号实例 2.边界值分析法
阅读更多...
p8 Run的流程和Docker原理

p8 Run的流程和Docker原理

docker run的运行原理图 docker是怎么工作的&#xff1f; docker是一个cs的一个结构的系统docker的守护进程运行在宿主机上面通过socket进行访问 其实就是看下面的这个图&#xff0c;通过客户端的命令来操作docker的守护进程然后启动一些容器&#xff0c;默认容器是不启动的 …
阅读更多...
凡图公益行：凡图家庭教育以行动筑梦，点亮孩子心中的光芒

凡图公益行：凡图家庭教育以行动筑梦，点亮孩子心中的光芒

在教育的路上&#xff0c;每一步都承载着未来的希望&#xff0c;凡图(山东)教育科技集团有限公司一直致力于为每一个孩子及家庭提供最优质的心理咨询服务。 在这样的背景下&#xff0c;凡图家庭教育以独特的使命感和责任感&#xff0c;成为了众多家庭信赖的伙伴。 也因此成为…
阅读更多...
【 打印菱形】打印菱形

【 打印菱形】打印菱形

打印菱形 C语言实现&#xff0c;具体代码&#xff1a; #include<stdio.h>int main(){int i,j,k;// 上半部分for(i0;i<3;i){for(j0;j<2-i;j)printf(" ");for(k0;k<2*i;k)printf("*");printf("\n");}// 下半部分for(i0;i<2;i)…
阅读更多...
文件上传真hard

文件上传真hard

一、SpringMVC实现文件上传 1.1.项目结构 1.1.2 控制器方法 RequestMapping("/upload1.do")public ModelAndView upload1(RequestParam("file1") MultipartFile f1) throws IOException {//获取文件名称String originalFilename f1.getOriginalFilename(…
阅读更多...
数据库之Mybatis映射文件、动态SQL

数据库之Mybatis映射文件、动态SQL

目录 1.XML映射文件 2.动态SQL 1.XML映射文件 之前我们执行sql语句是通过注解的方式&#xff0c;还有另外一种方式是通过XML配置文件执行sql语句&#xff0c;这份文件在Mybatis中也称为XML映射文件。 XML配置文件的规范&#xff1a;只有这三条规范都正确的情况下&#xff0…
阅读更多...
基于SSM的二手车交易管理系统的设计与实现 （含源码+sql+视频导入教程+论文）

基于SSM的二手车交易管理系统的设计与实现 （含源码+sql+视频导入教程+论文）

&#x1f449;文末查看项目功能视频演示获取源码sql脚本视频导入教程视频 1 、功能描述 基于SSM的二手车交易管理系统拥有两种角色&#xff1a;管理员和用户 管理员&#xff1a;二手车信息管理、类型管理、定金支付管理、预约到店管理、二手车评估管理、论坛管理、系统管理、…
阅读更多...
数据库Mybatis基础操作

数据库Mybatis基础操作

目录 基础操作 删除 预编译SQL 增、改、查 自动封装 基础操作 环境准备 删除 根据主键动态删除数据&#xff1a;使用了mybatis中的参数占位符#{ }&#xff0c;里面是传进去的参数。 单元测试&#xff1a; 另外&#xff0c;这个方法是有返回值的&#xff0c;返回这次操作…
阅读更多...
stack/queue容器

stack/queue容器

stack容器 std::stack 是 C 标准库中定义的容器适配器&#xff08;container adaptor&#xff09;&#xff0c;它基于其他底层容器&#xff08;如 std::deque、std::list 或 std::vector&#xff09;实现了后进先出&#xff08;LIFO&#xff09;的数据结构。栈容器没有迭代器&…
阅读更多...
JavaScript_10_练习：轮播图

JavaScript_10_练习：轮播图

效果图 代码 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>练习&#xff1a;轮播图</title>…
阅读更多...
OD C卷 - 查找一个有向网络的头节点和尾节点

OD C卷 - 查找一个有向网络的头节点和尾节点

查找一个有向网络的头节点和尾节点 &#xff08;200&#xff09; 在一个有向图中&#xff0c;有向边用两个整数表示&#xff0c;第一个整数表示起始节点&#xff0c;第二个整数表示终止节点&#xff1b;图中只有一个头节点&#xff0c;一个或者多个尾节点&#xff1b;图可能存…
阅读更多...
Linux系统信息排查

Linux系统信息排查

目录 介绍步骤 介绍 1、熟悉查看CPU信息、操作系统信息、用户信息、特殊权限账户、启动项和任务计划的排查命令 2、在进行受害主机排查时&#xff0c;首先要对主机系统进行基本排查&#xff0c;方便对受害主机有一个初步的了解。 3、利用lscpu和uname -a查看系统硬件软件基本…
阅读更多...
JavaScript(28)——正则表达式

JavaScript(28)——正则表达式

定义正则表达式语法&#xff1a; const 变量名 /表达式/ 判断是否有符合规则的字符串&#xff1a; test()方法 用来查看正则表达式与指定的字符串是否匹配 语法&#xff1a; regObj.test(被检测的字符串) //返回布尔值 regObj.exec(字符串) //返回的是数组 <script>…
阅读更多...
基于Docker compose部署Confluence 8.3.4及设置数据持久化存储的总结

基于Docker compose部署Confluence 8.3.4及设置数据持久化存储的总结

基于Docker compose部署Confluence 8.3.4及设置数据持久化存储的总结 一、环境信息二、安装部署三、向导 介绍如何基于Docker、Docker Compose的方式安装部署Confluence 8.3.4&#xff0c;并且设置数据的持久化存储。 一、环境信息 操作系统&#xff1a;CentOS 7.9 Docker Ver…
阅读更多...
C++之多态（下）

C++之多态（下）

目录 多态的实现原理 多态的拓展 单继承中的多态 多继承中的多态 上期&#xff0c;我们学习了多态的基本概念&#xff0c;本期我们来学习多态的实现原理。 多态的实现原理 class Base { public:virtual void func1(){cout << "Base::func1()" <<…
阅读更多...
CUTLASS 中的 47_ampere_gemm_universal_streamk 示例

CUTLASS 中的 47_ampere_gemm_universal_streamk 示例

前一篇文章介绍了 Stream-K: Work-centric Parallel Decomposition for Dense Matrix-Matrix Multiplication on the GPU 论文&#xff0c;下面对其代码实现进行分析。 cutlass 的 examples/47_ampere_gemm_universal_streamk 展示了 GEMM Stream-K 算法在 Ampere 架构上的使用…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023