嵌入式学习-网络编程-Day6、7

news2024/11/24 3:16:08

嵌入式学习-网络编程-Day6

一、思维导图

在这里插入图片描述
在这里插入图片描述

二、作业

1.基于UDP的网络聊天室（2024.1.21号前上交）

项目需求：
1.如果有用户登录，其他用户可以收到这个人的登录信息
2.如果有人发送信息，其他用户可以收到这个人的群聊信息
3.如果有人下线，其他用户可以收到这个人的下线信息
4.服务器可以发送系统信息

框架

在这里插入图片描述

效果图

在这里插入图片描述

服务器端实现

#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/1406034.html

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

相关文章

【论文代码】基于隐蔽带宽的汽车控制网路鲁棒认证-到达时间间隔通道的Java实现（二）

【论文代码】基于隐蔽带宽的汽车控制网路鲁棒认证-到达时间间隔通道的Java实现（二）

文章目录 五、TransmissionThread 抽象类5.1 IAT_thread类5.2 DLC_Thread 六、AttestationProtocol 接口6.1 HardCodedAttestation 七、FilterMash 类7.1 FilterValue 八、其他类8.1 CANAuthMessage8.2 USBtinException8.3 USBtinLibDemo8.4 CANMessage8.5 NoiseThread8.6 Filt…
阅读更多...
Vulnhub靶机：FunBox 4

Vulnhub靶机：FunBox 4

一、介绍 运行环境&#xff1a;Virtualbox 攻击机&#xff1a;kali&#xff08;10.0.2.15&#xff09; 靶机&#xff1a;FunBox 4&#xff08;10.0.2.29&#xff09; 目标&#xff1a;获取靶机root权限和flag 靶机下载地址&#xff1a;https://download.vulnhub.com/funbo…
阅读更多...
11.什么档次的原型模式和我写的一样

11.什么档次的原型模式和我写的一样

在《生化危机》系列电影中&#xff0c;克隆人是个频频出现的话题。保护伞公司为了需求复制出另一个战力相当的战士Alice&#xff0c;不惜克隆成百上千个Alice&#xff0c;然而直到最后&#xff0c;非但没有真正克隆出另一个完美的Alice&#xff0c;就连Alice自己也被证实是保护…
阅读更多...
华为OD机试之阿里巴巴找黄金宝箱(IV) C++

华为OD机试之阿里巴巴找黄金宝箱(IV) C++

题目背景 贫如洗的椎夫阿里巴巴在去砍柴的路上&#xff0c;无意中发现了强盗集团的藏宝地&#xff0c;藏宝地有编号从0-N的箱子&#xff0c;每个箱子上面有一人数字&#xff0c;箱子排列成一个环&#xff0c;编号最大的箱子的下一个是编号为0的箱子。请输出每个箱了贴的数字之…
阅读更多...
REVIT二次开发万能刷

REVIT二次开发万能刷

将这两个参数赋予其他参数 步骤2 将来做个可以调控的版本 using System; using System.Collections.Generic; using System.Lin
阅读更多...
常用界面设计组件 —— 数字输入和显示组件

常用界面设计组件 —— 数字输入和显示组件

2.3 数字输入和显示组件2.3.1 QSpinBox 与 QDoubleSpinBox2.3.2其它数值输入和显示组件 2.3 数字输入和显示组件 2.3.1 QSpinBox 与 QDoubleSpinBox QSpinBox用于整数的显示和输入&#xff0c;一般显示十进制 数&#xff0c;也可以显示二进制、十六进制数&#xff0c;而且可以…
阅读更多...
基于SpringBoot的智慧社区居家养老健康管理系统

基于SpringBoot的智慧社区居家养老健康管理系统

文章目录 项目介绍主要功能截图&#xff1a;部分代码展示设计总结项目获取方式 &#x1f345; 作者主页&#xff1a;超级无敌暴龙战士塔塔开 &#x1f345; 简介&#xff1a;Java领域优质创作者&#x1f3c6;、 简历模板、学习资料、面试题库【关注我&#xff0c;都给你】 &…
阅读更多...
Shell脚本------变量

Shell脚本------变量

目录 一、shell脚本的变量 1、shell脚本的变量是什么&#xff1f; 2、变量的作用 3、变量作用范围 3.1、临时设置 3.2永久设置&#xff0c;需要在/etc/profile文件里添加 4、删除变量 5、变量基础 6、变量命名要求 7、特殊符号 8、整数运算 9、expr算术表达式 二、…
阅读更多...
如何在WordPress网站中添加多语言搜索(2种简单方法)

如何在WordPress网站中添加多语言搜索(2种简单方法)

您想在WordPress网站中添加多语言搜索吗&#xff1f; 如果您有一个多语言 WordPress 网站&#xff0c;那么添加多语言搜索功能可以帮助用户通过使用自己的语言进行搜索来更快地找到信息。 在本文中&#xff0c;我们将向您展示如何在 WordPress 中轻松添加多语言搜索&#xff…
阅读更多...
“深入理解RabbitMQ交换机的原理与应用“

“深入理解RabbitMQ交换机的原理与应用“

深入理解RabbitMQ交换机的原理与应用 引言1. RabbitMQ交换机简介介绍1.1 什么是RabbitMQ&#xff1f;1.1.1 消息中间件的作用1.1.2 RabbitMQ的特点和优势 1.2 RabbitMQ的基本概念1.2.1 队列1.2.2 交换机1.2.3 路由键 1.3 交换机的作用和分类1.3.1 直连交换机&#xff08;direct…
阅读更多...
32、WEB攻防——通用漏洞文件上传二次渲染.htaccess变异免杀

32、WEB攻防——通用漏洞文件上传二次渲染.htaccess变异免杀

文章目录 一、点过滤二、文件删除三、二次渲染四、.htaccess五、过滤php关键函数 一、点过滤 不能写带文件后缀的文件名&#xff1b;IP转数字 二、文件删除 文件依据规则进行删除&#xff0c;删除有两种删除的类型&#xff1a; 什么文件都删除&#xff0c;条件竞争进行绕过…
阅读更多...
linux zabbix监控

linux zabbix监控

zabbix总结 zabbix-server 10051 zabbix-agent 10050 zabbix-proxy 10051 1.监控项&#xff08;模板&#xff09;&#xff1a;获取监控数据 #模板直接链接到新的主机 2.触发器&#xff1a;设置一个值 在非合理区间报警 3.动作&#xff1a;可以帮忙发送通知&#xff08;告…
阅读更多...
深入理解Python循环嵌套

深入理解Python循环嵌套

循环嵌套是一种常见的编程技巧&#xff0c;它可以用于处理多维数据结构、模拟多层逻辑等场景。本文将深入探讨Python中的循环嵌套&#xff0c;包括基本语法、应用场景以及一些最佳实践。 循环嵌套的基本语法 在Python中&#xff0c;循环嵌套指的是在一个循环语句的内部再嵌套另…
阅读更多...
Microsoft Remote Desktop for Mac(远程桌面连接）激活版

Microsoft Remote Desktop for Mac(远程桌面连接）激活版

Microsoft Remote Desktop是一款由微软开发的远程桌面连接工具&#xff0c;它允许用户从另一台计算机或移动设备远程连接到Windows桌面或服务器。 以下是该软件的一些主要特点和功能&#xff1a; 跨平台支持&#xff1a;Microsoft Remote Desktop支持Windows、macOS、iOS和Andr…
阅读更多...
蓝桥杯（C++ 最大开支 优先队列）

蓝桥杯（C++ 最大开支 优先队列）

优先队列&#xff1a; 蓝桥杯&#xff08;C 整数删除 优先队列 &#xff09;-CSDN博客 思路&#xff1a; 1、每个人依此选择项目&#xff0c;每个人选项目时都&#xff08;选择当下花费增加最多的项目&#xff09;&#xff0c;若项目i的门票价格为kxb&#xff0c;那么增加一个…
阅读更多...
爬取的数据可以入表吗？怎样入表？

爬取的数据可以入表吗？怎样入表？

合规是数据入表的前提。当前爬虫数据是非常敏感的&#xff0c;因为爬虫极容易造成两大不合规的问题&#xff1a;一是没有经过个人同意获取数据&#xff0c;二是爬取的数据里可能含有个人敏感信息也是一个问题。现在法律对于这部分非常严苛&#xff0c;如果企业里有50条未获得授…
阅读更多...
RHCE【报警脚本】

RHCE【报警脚本】

要求如下&#xff1a; 根分区剩余空间小于20% 发送告警邮件给自己 配合crond每5分钟检查一次脚本 报警脚本的具体实现如下&#xff1a; #安装mailx(邮件服务包)[rootlocalhost ~]# yum install mailx #编辑邮件系统文件[rootlocalhost ~]# vim /etc/mail.rc#首先注…
阅读更多...
关于在Ubuntu20.04（ROS1 noetic）中使用catkin_make编译时发生的与pyhton版本不兼容的问题解决办法

关于在Ubuntu20.04（ROS1 noetic）中使用catkin_make编译时发生的与pyhton版本不兼容的问题解决办法

今天在另外一台电脑上操作复现【ROS建模&#xff1a;一起从零手写URDF模型】这个博客时&#xff0c;发生了一些问题&#xff0c;特此记录下来 【ROS建模&#xff1a;一起从零手写URDF模型】链接&#xff1a;https://blog.csdn.net/qq_54900679/article/details/135726348?spm…
阅读更多...
CodeWave智能开发平台-3--采购管理系统搭建完整版

CodeWave智能开发平台-3--采购管理系统搭建完整版

摘要 本文是网易数帆CodeWave智能开发平台系列的第15篇&#xff0c;主要介绍了基于CodeWave平台文档的新手入门进行学习&#xff0c;实现一个完整的应用-采购管理系统。 CodeWave智能开发平台-3–采购管理系统搭建完整版 CodeWave参考资源 网易数帆CodeWave开发者社区课程中…
阅读更多...
JFinal项目搭建

JFinal项目搭建

JFinal项目搭建 JFinal项目搭建 JFinal项目搭建 首先创建maven项目&#xff1a; 删掉报错的jsp页面&#xff1a; 在pom.xml中加入坐标&#xff1a; <dependency> <groupId>com.jfinal</groupId> <artifactId>jfinal-undertow</artifactId>…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023