聊天室项目

news2025/1/16 0:47:20

服务器

#include <myhead.h>
#define SER_IP "192.168.122.39"
#define SER_PORT 8888
typedef struct Node  //链表存储客户端的所有信息
{
	struct sockaddr_in cin;  //存储客户端的网络地址信息
	struct Node *next;
}*List;
typedef struct Message//消息结构体
{
	char type;
	char name[20];
	char text[128];
}msg_t;
struct sockaddr_in cin;  //客户端地址信息结构体

//单链表节点创建函数
List create_node()
{
	List p=(List)malloc(sizeof(struct Node));
	if(NULL==p)
		return NULL;
	p->next=NULL;
	return p;
}
//客户端链表尾插
List insert_rear(List head,struct sockaddr_in cin)
{
	List s=create_node();
	if(NULL==s)
		return head;
	s->cin=cin;

	if(NULL==head)
	{
		head=s;
		return s;
	}else{
	List p=head;
	while(p->next!=NULL)
		p=p->next;
	p->next=s;
	return head;
	}
}
//客户端接入服务器通知函数
void chat_all_join(List head,msg_t msg,int sfd)
{
	List p=head;
	char buf[50]="";
	while(p->next!=NULL)
	{
		snprintf(buf,sizeof(buf),"[%s:%d]%s加入聊天室\n",inet_ntoa(p->cin.sin_addr),\
							ntohs(p->cin.sin_port),msg.name);
		sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));
		p=p->next;
	}
}
//客户端消息转发函数
void chat_all(List head,struct Message msg,int sfd,struct sockaddr_in cin)
{
	List p=head;
	char rbuf[200]="";
	while(p->next!=NULL)
	{
		snprintf(rbuf,sizeof(rbuf),"[%s:%d]%s:%s\n",inet_ntoa(p->cin.sin_addr),\
				ntohs(p->cin.sin_port),msg.name,msg.text);
		sendto(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));
		p=p->next;
	}
		snprintf(rbuf,sizeof(rbuf),"[%s:%d]%s:%s\n",inet_ntoa(p->cin.sin_addr),\
				ntohs(p->cin.sin_port),msg.name,msg.text);
		sendto(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));
	
}
//客户端发送退出消息函数
void chat_all_quit(List head,struct Message msg,int sfd)
{
	char wbuf[200]="";	
	List p=head;
	while(p->next!=NULL)
	{
		snprintf(wbuf,sizeof(wbuf),"[%s:%d]%s:退出了聊天室\n",inet_ntoa(p->cin.sin_addr),\
				ntohs(p->cin.sin_port),msg.name);
		sendto(sfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));
		p=p->next;
	}
	snprintf(wbuf,sizeof(wbuf),"[%s:%d]%s:退出了聊天室\n",inet_ntoa(p->cin.sin_addr),\
			ntohs(p->cin.sin_port),msg.name);
	sendto(sfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));
}
//链表中删除该地址信息
List exit_chat(List head)
{
	if(head->next==NULL)//只有一个客户端时
	{
		free(head);
		head=NULL;
		return head;
	}

	List p=head;
	while(p->next!=NULL)  //两个以上客户端
	{
		if(memcmp(&(p->next->cin),&cin,sizeof(cin))==0)//找到p下一个节点地址信息符合的
		{
			List del=p->next;
			p->next=del->next;
			free(del);del=NULL;
			break;
		}else{
			p=p->next;
		}
	}
	return head;
}
int main(int argc, const char *argv[])
{
	//创建通信的套接字文件描述符
	int sfd=-1;
	if((sfd=socket(AF_INET,SOCK_DGRAM,0))==-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(SER_PORT);
	sin.sin_addr.s_addr=inet_addr(SER_IP);
	if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1)
	{
		perror("bind error");
		return -1;
	}

	//准备文件描述符容器
	fd_set readfds,tempfds;
	FD_ZERO(&readfds);
	FD_SET(0,&readfds);
	FD_SET(sfd,&readfds);
	int maxfd=sfd;

	//定义变量存放客户端地址信息结构体,及客户端消息
	struct sockaddr_in cin;
	socklen_t socklen=sizeof(cin);
	struct Message msg;

	List head=NULL;
	char buf[128]="";
	while(1)
	{
		tempfds=readfds;
		if(select(maxfd+1,&tempfds,NULL,NULL,NULL)==-1)
		{
			perror("select error");
			return -1;
		}
		
		//收到消息
		if(FD_ISSET(sfd,&tempfds))
		{
			recvfrom(sfd,&msg,sizeof(msg),0,(struct sockaddr*)&cin,&socklen);
			switch(msg.type)
			{
			case 'L':  //客户端加入
				{
					head=insert_rear(head,cin);  //尾插入链表
					chat_all_join(head,msg,sfd);		
					printf("[%s:%d]%s加入聊天室\n",inet_ntoa(cin.sin_addr),\
							ntohs(cin.sin_port),msg.name);
				};
				break;
			case 'C':  //客户端消息
				{
					chat_all(head,msg,sfd,cin);
					printf("[%s:%d]%s:%s\n",inet_ntoa(cin.sin_addr),\
						ntohs(cin.sin_port),msg.name,msg.text);
				};
				break;
			case 'Q':  //客户端退出
				{
					chat_all_quit(head,msg,sfd);
					printf("[%s:%d]%s退出聊天室\n",inet_ntoa(cin.sin_addr),\
							ntohs(cin.sin_port),msg.name);
					head=exit_chat(head);
				};
				break;
			default:
				printf("type error\ttype=%c\n",msg.type);
				return -1;
			}
		}
		//发送消息
		if(FD_ISSET(0,&tempfds))
		{
			memset(buf,0,sizeof(buf));
			fgets(buf,sizeof(buf),stdin);
			buf[strlen(buf)-1]='\0';
			
			char wbuf[56]="";
			snprintf(wbuf,sizeof(wbuf),"***system***%s\n",buf);
			List p=head;
			while(p!=NULL)
			{
				sendto(sfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));
				p=p->next;
			}
		}
	}
	return 0;
}

客户端

#include <myhead.h>
#define SER_IP "192.168.122.39"
#define SER_PORT 8888
//#define CLI_IP ""
//#define CLI_PORT
struct Message
{
	char type;
	char name[20];
	char text[128];

};
int main(int argc, const char *argv[])
{
	struct Message msg;
	//创建通信用套接字文件描述符
	int cfd=-1;
	if((cfd=socket(AF_INET,SOCK_DGRAM,0))==-1)
	{
		perror("socket error");
	}

	//填写服务器的地址信息结构体
	struct sockaddr_in sin;
	sin.sin_family=AF_INET;
	sin.sin_port=htons(SER_PORT);
	sin.sin_addr.s_addr=inet_addr(SER_IP);
	
	//发送客户端的登录信息
	printf("请输入昵称:");
	fgets(msg.name,sizeof(msg.name),stdin);
	msg.name[strlen(msg.name)-1]='\0';
	msg.type='L';
	if(sendto(cfd,&msg,sizeof(msg),0,(struct sockaddr*)&sin,sizeof(sin))==-1)
	{
		perror("sendto info error");
		return -1;
	}else{
	printf("加入聊天服务器成功\n");
	}
	//准备文件描述符容器
	fd_set readfds,tempfds;
	FD_ZERO(&readfds);
	FD_SET(0,&readfds);
	FD_SET(cfd,&readfds);
	int maxfd=cfd;

	while(1)
	{
		tempfds=readfds;
		int res=select(maxfd+1,&tempfds,NULL,NULL,NULL);
		if(res==-1)
		{
			perror("select error");return -1;
		}
		//发数据
		if(FD_ISSET(0,&tempfds))
		{
			memset(msg.text,0,sizeof(msg.text));
			read(0,msg.text,sizeof(msg.text));
			msg.text[strlen(msg.text)-1]='\0';
			//客户端退出
			if(strcmp(msg.text,"quit")==0)
			{
				msg.type='Q';
				sendto(cfd,&msg,sizeof(msg),0,(struct sockaddr*)&sin,sizeof(sin));
				printf("本机已下线\n");
				close(cfd);
				return 0;
			}
			//与其他客户端通信
			else
			{
				msg.type='C';
				sendto(cfd,&msg,sizeof(msg),0,(struct sockaddr*)&sin,sizeof(sin));
			}
		}

		//收数据
		if(FD_ISSET(cfd,&tempfds))
		{
			char buf[128]="";
			//不接收服务器的地址信息结构体
			recvfrom(cfd,buf,sizeof(buf),0,NULL,NULL);
			printf("%s",buf);
			fflush(stdout);
		}
	}

	return 0;
}

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

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

相关文章

亚信安慧AntDB：“融合+实时”引领数据库创新

亚信安慧AntDB：“融合+实时”引领数据库创新

在当今多变的数据应用场景中&#xff0c;AntDB作为行业领先的超融合流式实时数仓&#xff0c;秉承着“融合实时”的研发理念&#xff0c;全面应对企业日益复杂的数据处理需求。通过SQL接口访问多种执行引擎&#xff0c;AntDB在实现交易、分析等多重能力的“超融合”方面取得了显…
阅读更多...
制片管理工具：提高制片效率的必备工具

制片管理工具：提高制片效率的必备工具

一、什么是制片管理工具 制片管理工具是一种为制片人提供支持和协助的软件或工具&#xff0c;并提供一种集中管理制作进度、任务分配、成本预算、资源管理和进度跟踪的方式。它可以帮助制片人在项目的开发、制作和发布方面更有效地进行规划和监督&#xff0c;确保整个流程能够…
阅读更多...
网络空间资产安全解决方案

网络空间资产安全解决方案

长期以来&#xff0c;我们一直强调要做好网络安全建设&#xff0c;而其中的第一步就是要做好对自身资产的发现和清点&#xff0c;正如大家经常所说的那句话——“你无法保护你看不见的东西”。的确&#xff0c;如果不知道自己拥有什么资产&#xff0c;那么如何去了解与它们相关…
阅读更多...
CVPR 2024 | Modular Blind Video Quality Assessment：模块化无参视频质量评估

CVPR 2024 | Modular Blind Video Quality Assessment：模块化无参视频质量评估

无参视频质量评估 (Blind Video Quality Assessment&#xff0c;BVQA) 在评估和改善各种视频平台并服务用户的观看体验方面发挥着关键作用。当前基于深度学习的模型主要以下采样/局部块采样的形式分析视频内容&#xff0c;而忽视了实际空域分辨率和时域帧率对视频质量的影响&am…
阅读更多...
Tomcat性能调优

Tomcat性能调优

1‍.应用场景/常见内容溢出问题‍ 常见问题为内存溢出&#xff0c;分为堆内存溢出、非堆内存溢出&#xff0c;比较常见的为堆内存溢出&#xff0c;后2类属于非堆内存溢出。 堆溢出&#xff1a; java.lang.OutOfMemoryError:Java heap spcace 原因:项目运行阶段,new的对象过多…
阅读更多...
ubuntu18.04下创建新用户

ubuntu18.04下创建新用户

进入root用户 su - 创建用户 useradd -mr -s /bin/bash minios 参数 r:创建系统账户m:自动在/home目录下创建用户目录s:指定用户登入后使用的shell为/bin/shell minios为自定义的用户名 如果直接用useradd添加用户的话&#xff0c;可能出现没有home下的文件夹&#xff0c…
阅读更多...
C语言指针总结（完结篇）

C语言指针总结（完结篇）

前言 这篇博客终于迎来了指针博客的大结局&#xff0c;本篇主要分析习题来回顾之前的指针总结的知识点&#xff0c;这篇博客的题有点绕&#xff0c;哈哈算是经典了 个人主页&#xff1a;小张同学zkf 若有问题 评论区见 感兴趣就关注一下吧 目录 1. sizeof和strlen的对比 1.1 …
阅读更多...
ROS2学习(七) Foxy版本ros2替换中间件。

ROS2学习(七) Foxy版本ros2替换中间件。

在ros2使用的过程中&#xff0c;一开始选用的foxy版本&#xff0c;后来发现&#xff0c;foxy版本的ros2有很多问题。一个是foxy版本已经停止维护了。另一个问题是这个版本有很多bug, 后续的版本在功能实现上做了很大的改动&#xff0c;甚至说进行了重写。修复的一些问题&#x…
阅读更多...
Sora正在颠覆游戏行业，CEO们该怎么应对？

Sora正在颠覆游戏行业，CEO们该怎么应对？

文 | 魏力 发布 | 大力财经 摘要&#xff1a;AI 提升游戏制作效率&#xff0c;带来多样化和技术突破。在 AI 为游戏行业带来新机遇的时代&#xff0c;游戏公司应如何把握&#xff1f; 随着ChatGPT技术的快速发展&#xff0c;游戏行业正迎来一场AI技术变革。AI技术的应用为游…
阅读更多...
长沙银行数字化案例入选《2024IDC中国金融业数据资产管理实践与案例报告》

长沙银行数字化案例入选《2024IDC中国金融业数据资产管理实践与案例报告》

全球数字化经济浪潮下&#xff0c;以数字技术为代表的的新一轮技术变革正跨步引领经济发展趋势。中国金融业作为2026年底数据要素应用总体目标所聚焦的十二个行业和领域之一&#xff0c;金融业数据资产管理成功经验正逐步被探索应用。 近日&#xff0c;全球权威知名市场调研机构…
阅读更多...
开源的前端思维导图库介绍

开源的前端思维导图库介绍

在开源社区中&#xff0c;有许多优秀的思维导图库可供开发者使用。这些库通常具有丰富的功能和灵活的API&#xff0c;可以满足不同需求的前端开发。以下是一些流行的开源前端思维导图库&#xff0c;以及它们的特点和区别。 1. **MindMap** 特点&#xff1a; - 基于原生…
阅读更多...
神经网络算法——反向传播 Back Propagation

神经网络算法——反向传播 Back Propagation

文章目录 前言 1、反向传播的本质 &#xff08;1&#xff09;前向传播&#xff08;Forward Propagation&#xff09; &#xff08;2&#xff09;反向传播&#xff08;Back Propagation&#xff09; 2、反向传播的原理 &#xff08;1&#xff09;链式法则&#xff08;Chain Rule…
阅读更多...
arm架构服务器使用Virtual Machine Manager安装的kylin v10虚拟机

arm架构服务器使用Virtual Machine Manager安装的kylin v10虚拟机

本文中使用Virtual Machine Manager安装kylin v10的虚拟机 新建虚拟机 新建虚拟机 选择镜像&#xff0c;下一步 设置内存和CPU&#xff0c;下一步 选择或创建自定义存储&#xff08;默认存储位置的磁盘空间可能不够用&#xff09; 点击管理&#xff0c;打开选择存储卷页…
阅读更多...
“轻松掌握财务状况：智能筛选银行卡收支明细，一键统计总花销”

“轻松掌握财务状况：智能筛选银行卡收支明细，一键统计总花销”

在快节奏的现代生活中&#xff0c;财务管理成为我们日常的重要任务。你是否经常为了查看银行卡账户的收支明细而烦恼&#xff1f;是否想要快速统计出账户的总花销&#xff0c;以便更好地掌握自己的财务状况&#xff1f;现在&#xff0c;我们为你带来了一款全新的财务管理工具&a…
阅读更多...
校招中的“熟悉linux操作系统”一般是指达到什么程度？

校招中的“熟悉linux操作系统”一般是指达到什么程度？

校招中的“熟悉linux操作系统”一般是指达到什么程度&#xff1f; 在开始前我有一些资料&#xff0c;是我根据网友给的问题精心整理了一份「Linux的资料从专业入门到高级教程」&#xff0c; 点个关注在评论区回复“888”之后私信回复“888”&#xff0c;全部无偿共享给大家&am…
阅读更多...
【unity小技巧】Unity人物衣服布料系统的探究 —— Cloth组件

【unity小技巧】Unity人物衣服布料系统的探究 —— Cloth组件

文章目录 一、Cloth组件解释基本介绍出于性能的考虑, 可以对Cloth产生影响的Collider只有两种打开编辑模式绘制 二、基本使用1. 创建出一个空物体2. 在空物体上添加cloth组件&#xff0c;可以直接点击Add Component搜索cloth添加&#xff0c;也可以在工具栏 Component–>phy…
阅读更多...
动态规划（算法竞赛、蓝桥杯）--树形DP树的中心

动态规划（算法竞赛、蓝桥杯）--树形DP树的中心

1、B站视频链接&#xff1a;E34 树形DP 树的中心_哔哩哔哩_bilibili #include <bits/stdc.h> using namespace std; const int N20010; int n,a,b,c,ans2e9; struct edge{int v,w;}; vector<edge> e[N]; int d1[N],d2[N],path[N],up[N];//path记录d1 void dfs1(in…
阅读更多...
【Datawhale组队学习：Sora原理与技术实战】

【Datawhale组队学习：Sora原理与技术实战】

Transformersdiffusion技术背景简介 Transformers diffusion背景 近期大火的OpenAI推出的Sora模型&#xff0c;其核心技术点之一&#xff0c;是将视觉数据转化为Patch的统一表示形式&#xff0c;并通过Transformers技术和扩散模型结合&#xff0c;展现了卓越的scale特性。 被…
阅读更多...
iStoreOS系统-HomeAssistant服务下载安装HACS

iStoreOS系统-HomeAssistant服务下载安装HACS

iStoreOS系统-HomeAssistant服务下载安装HACS 1. HACS HACS&#xff08;Home Assistant Community Store&#xff09;是Home Assistant的一个插件商店&#xff0c;它允许用户轻松地浏览、安装和管理各种为Home Assistant开发的自定义插件和集成。通过HACS&#xff0c;用户可以…
阅读更多...
Linux Ubuntu系统安装MySQL并实现公网连接本地数据库【内网穿透】

Linux Ubuntu系统安装MySQL并实现公网连接本地数据库【内网穿透】

文章目录 前言1 .安装Docker2. 使用Docker拉取MySQL镜像3. 创建并启动MySQL容器4. 本地连接测试4.1 安装MySQL图形化界面工具4.2 使用MySQL Workbench连接测试 5. 公网远程访问本地MySQL5.1 内网穿透工具安装5.2 创建远程连接公网地址5.3 使用固定TCP地址远程访问 前言 本文主…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023