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

嵌入式学习-网络编程-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;
}

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

认识并使用Shiro技术

认识并使用Shiro技术

认识并使用Shiro 一、对Shiro的基本认知1、Shiro是什么&#xff1f;2、Shiro的核心组件是&#xff1f;2.1 Subject2.2 UsernamePasswordToken2.3 Realm&#xff08;重点是&#xff1a;AuthorizingRealm用于授权、AuthenticatingRealm用于认证&#xff09;2.4 SecurityManager2.…
阅读更多...
C#操作pdf之使用itext实现01-生成一个简单的table

C#操作pdf之使用itext实现01-生成一个简单的table

创建.net 8控制台项目 安装itext <PackageReference Include"itext" Version"8.0.2" /><PackageReference Include"itext.bouncy-castle-adapter" Version"8.0.2" /><PackageReference Include"itext.bouncy-cast…
阅读更多...
LabVIEW电能质量监测系统

LabVIEW电能质量监测系统

系统利用LabVIEW开发一个基于LabVIEW的电能质量监测系统&#xff0c;模拟并监测暂态电能质量扰动&#xff0c;如电压骤升、电压骤降、电压波动和暂态振荡等。系统的硬件部分包括高精度的振动传感器和信号调节设备&#xff0c;以及型号为NI9234的数据采集卡和高性能计算机。这些…
阅读更多...
Sqoop故障排除指南：处理错误和问题

Sqoop故障排除指南：处理错误和问题

故障排除是每位数据工程师和分析师在使用Sqoop进行数据传输时都可能遇到的关键任务。Sqoop是一个功能强大的工具&#xff0c;但在实际使用中可能会出现各种错误和问题。本文将提供一个详尽的Sqoop故障排除指南&#xff0c;涵盖常见错误、问题和解决方法&#xff0c;并提供丰富的…
阅读更多...
卡萨帝洗衣机：被模仿也是竞争力

卡萨帝洗衣机：被模仿也是竞争力

如何用一句话形容某家企业的竞争力和领导地位&#xff1f;“某某一出手&#xff0c;就知有没有。”这句话相当匹配。如果再加一条&#xff0c;“被模仿”也恰到好处。 从顶流公司OpenAI&#xff0c;苹果Apple Vision Pro&#xff0c;再到卡萨帝洗衣机&#xff0c;被跟随、模仿…
阅读更多...
Mac M1 Parallels CentOS7.9 Deploy Typecho

Mac M1 Parallels CentOS7.9 Deploy Typecho

一、创建名称空间 kubectl create ns prod二、创建PV & PVC vim local-pv1.yamlapiVersion: v1 kind: PersistentVolume metadata:name: local-pv-1 spec:capacity:storage: 1GiaccessModes:- ReadWriteOncepersistentVolumeReclaimPolicy: RetainstorageClassName: loca…
阅读更多...
华为原生 HarmonyOS NEXT 鸿蒙操作系统星河版 发布！不依赖 Linux 内核

华为原生 HarmonyOS NEXT 鸿蒙操作系统星河版 发布！不依赖 Linux 内核

华为原生 HarmonyOS NEXT 鸿蒙操作系统星河版 发布&#xff01;不依赖 Linux 内核 发布会上&#xff0c;余承东宣布&#xff0c;HarmonyOS NEXT鸿蒙星河版面向开发者开放申请。 申请链接 鸿蒙星河版将实现原生精致、原生易用、原生流畅、原生安全、原生智能、原生互联6大极致原…
阅读更多...
C语言从入门到实战——文件操作

C语言从入门到实战——文件操作

文件操作 前言一、 为什么使用文件二、 什么是文件2.1 程序文件2.2 数据文件2.3 文件名 三、 二进制文件和文本文件四、 文件的打开和关闭4.1 流和标准流4.1.1 流4.1.2 标准流 4.2 文件指针4.3 文件的打开和关闭4.4 文件的路径 五、 文件的顺序读写5.1 顺序读写函数介绍fgetcfp…
阅读更多...
Flink处理函数（2）—— 按键分区处理函数

Flink处理函数（2）—— 按键分区处理函数

按键分区处理函数&#xff08;KeyedProcessFunction&#xff09;&#xff1a;先进行分区&#xff0c;然后定义处理操作 1.定时器&#xff08;Timer&#xff09;和定时服务&#xff08;TimerService&#xff09; 定时器&#xff08;timers&#xff09;是处理函数中进行时间相关…
阅读更多...
pytorch（二）梯度下降算法

pytorch（二）梯度下降算法

文章目录 优化问题梯度下降随机梯度下降 在线性模型训练的时候&#xff0c;一开始并不知道w的最优值是什么&#xff0c;可以使用一个随机值来作为w的初始值&#xff0c;使用一定的算法来对w进行更新 优化问题 寻找使得目标函数最优的权重组合的问题就是优化问题 梯度下降 通…
阅读更多...
【极问系列】springBoot集成elasticsearch出现Unable to parse response body for Response

【极问系列】springBoot集成elasticsearch出现Unable to parse response body for Response

【极问系列】 springBoot集成elasticsearch出现Unable to parse response body for Response 如何解决&#xff1f; 一.问题 #springboot集成elasticsearch组件,进行增删改操作的时候报异常Unable to parse response body for Response{requestLineDELETE /aurora-20240120/…
阅读更多...
编译和链接（翻译环境:预编译+编译+汇编+链接​、运行环境）

编译和链接（翻译环境:预编译+编译+汇编+链接​、运行环境）

一、翻译环境和运行环境​ 在ANSI C的任何一种实现中&#xff0c;存在两个不同的环境。​ 第1种是翻译环境&#xff0c;在这个环境中源代码被转换为可执行的机器指令。​ 第2种是执行环境&#xff0c;它用于实际执行代码。​ VS中编译器&#xff1a;cl.exe &#xff1b;Linux中…
阅读更多...
基于无人机的消防灭火系统设计

基于无人机的消防灭火系统设计

摘要&#xff1a;人类社会的进步&#xff0c;使火灾变得更加频繁且越来越复杂&#xff0c;随着这些年无人机技术的发展&#xff0c;将无人机技术融入消防灭火逐渐变成必然。消防救援采用无人机主要有以下几点原因&#xff1a;一、对火场及火场周围环境信息十分匮乏&#xff0c;…
阅读更多...
LaTeX-OCR安装教程

LaTeX-OCR安装教程

一. 通用安装步骤 1.前置应用 安装LaTeX-OCR首先需要安装Python。在系统自带的应用商店Microsoft Store搜索Python&#xff0c;点击最新版本Python 3.12下载即可。 2.运行powershell Win11按底部状态栏windows徽标在搜索框内搜索 powershell 或者按快捷键 “win 键 R” &am…
阅读更多...
Hack The Box-Sherlocks-Tracer

Hack The Box-Sherlocks-Tracer

靶场介绍 A junior SOC analyst on duty has reported multiple alerts indicating the presence of PsExec on a workstation. They verified the alerts and escalated the alerts to tier II. As an Incident responder you triaged the endpoint for artefacts of interest…
阅读更多...
毫米波雷达4D点云生成（基于实测数据）

毫米波雷达4D点云生成（基于实测数据）

本期文章分享TI毫米波雷达实测4D点云生成的代码&#xff0c;包含距离、速度、水平角度、俯仰角度&#xff0c;可用于日常学习。 处理流程包含&#xff1a;数据读取和解析、MTI、距离估计、速度估计、非相干累积、2D-CFAR、水平角估计、俯仰角估计、点云生成、坐标转换等内容。…
阅读更多...
用MATLAB函数在图表中建立模型

用MATLAB函数在图表中建立模型

本节介绍如何使用Stateflow图表创建模型&#xff0c;该图表调用两个MATLAB函数meanstats和stdevstats。meanstats计算平均值&#xff0c;stdevstats计算vals中值的标准偏差&#xff0c;并将它们分别输出到Stateflow数据平均值和stdev。 请遵循以下步骤&#xff1a; 1.使用以下…
阅读更多...
04 SpringBoot整合Druid/MyBatis/事务/AOP+打包项目

04 SpringBoot整合Druid/MyBatis/事务/AOP+打包项目

整合Druid 项目结构&#xff1a; 引入依赖&#xff1a; <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaL…
阅读更多...
Docker 部署考核

Docker 部署考核

Docker安装 安装必要的系统工具 yum install -y yum-utils device-mapper-persistent-data lvm2 添加docker-ce安装源&#xff1a; yum-config-manager --add-repo https://download.docker.com/linux/centos/docker-ce.repo 配置阿里云Docker Yum源: yum-config-manager --ad…
阅读更多...
4个值得使用的免费爬虫工具

4个值得使用的免费爬虫工具

在信息时代&#xff0c;数据的获取对于各行业都至关重要。而在数据采集的众多工具中&#xff0c;免费的爬虫软件成为许多用户的首选。本文将专心分享四款免费爬虫工具&#xff0c;突出介绍其中之一——147采集软件&#xff0c;为您揭示这些工具的优势和应用&#xff0c;助您在数…
阅读更多...
最新文章

Copyright @ 2022~2023