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

news2025/1/16 13:45:12

嵌入式学习-网络编程-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/1400912.html

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

相关文章

读书笔记之《万物起源》：宇宙与人类的极简史

读书笔记之《万物起源》：宇宙与人类的极简史

《万物起源&#xff1a;从宇宙大爆炸到文明的兴起》讲述了从大爆炸直到今日&#xff0c;约140亿年间所有重大事物的起源&#xff0c;依次覆盖了量子力学&#xff0c;天体物理学&#xff0c;化学&#xff0c;行星科学&#xff0c;地质学&#xff0c;生物学和人类历史等等学科。 …
阅读更多...
Spring第七天(AOP)

Spring第七天(AOP)

简介 AOP(Aspect Oriented Programing)面向切面编程&#xff0c;一种编程范式&#xff0c;指导开发者如何组织程序结构 作用 在不惊动原始设计的基础上为其进行功能增强 Spring理念&#xff1a;无入侵式/无侵入式 基本概念 连接点(JoinPoint) : 程序执行过程中的任意位置&a…
阅读更多...
Linux：软硬链接的概念与应用

Linux：软硬链接的概念与应用

文章目录 软链接和硬链接软链接的应用场景硬链接的应用场景当前目录和上级目录软硬链接目录和文件的问题 总结 本篇要探讨的主题是关于软硬链接的概念 在Linux系统链接文件中有两种&#xff0c;一种是硬链接&#xff0c;一种是软链接&#xff0c;那么本篇就基于上述的两种链接…
阅读更多...
IDEA的database使用

IDEA的database使用

一、数据据库 在使用database之前&#xff0c;首先你的电脑要安装好了数据库并且启动。 MySQL卸载手册 链接&#xff1a;https://pan.baidu.com/doc/share/AVXW5SG6T76puBOWnPegmw-602323264797863 提取码&#xff1a;hlgf MySQL安装图解 链接&#xff1a;https://pan.baidu.…
阅读更多...
2024年，给程序员的六点建议

2024年，给程序员的六点建议

作为程序员&#xff0c;持续进步和发展是至关重要的。除了技术能力的提升&#xff0c;还有一些关键的行为和思维方式可以帮助工程师在职业生涯中取得更大的成功。本文将提供六个重要的建议&#xff0c;这些建议将帮助程序员在职业生涯中迈出成功的步伐。 走出舒适区 走出舒适区…
阅读更多...
IEEE-2024年第五届人工智能、机器人及控制国际会议(AIRC 2024)

IEEE-2024年第五届人工智能、机器人及控制国际会议(AIRC 2024)

IEEE--2024年第五届人工智能、机器人及控制国际会议(AIRC 2024) 会议时间: 2024年4月22-24日 会议地点: 埃及开罗 埃及英国大学 会议网址:AIRC 2024 | Artificial Intelligence, Robotics and Controlhttps://www.airc.org/ 埃及开罗 埃及英国大学 会议组织单位&#xff1a; 征…
阅读更多...
关于安装Dubbo+zookeeper过程中遇到的许多问题

关于安装Dubbo+zookeeper过程中遇到的许多问题

在学习dubbozookeeper时安装启动dubbo-admin出现的一些问题&#xff1a; 首先我是跟着狂神安装zookeeper&#xff0c;基本下来没什么问题。然后就是安装dubbo-admin&#xff0c;狂神安装的是dubbo-admin-master&#xff0c;但是现在github上已经没有这个版本了&#xff0c;只能…
阅读更多...
[小程序]Http网络请求

[小程序]Http网络请求

一、数据请求限制 出于安全性(bushi)考虑&#xff0c;小程序请求的数据接口必须具备以下两个条件&#xff1a; ①只能请求Https类型 ②必须将接口域名添加到信任列表中 1.配置request合法域名 配置步骤如下&#xff1a;小程序管理后台->开发->开发设置->服务器域名-&g…
阅读更多...
“揭秘Maven：如何成为大数据项目的管理能手？“

“揭秘Maven：如何成为大数据项目的管理能手？“

介绍&#xff1a;Maven是一个项目管理和构建自动化工具&#xff0c;广泛应用于Java项目中。具体来说&#xff1a;项目对象模型&#xff08;POM&#xff09;&#xff1a;Maven通过一个名为POM的模型来描述项目信息&#xff0c;包括项目的坐标、依赖关系、插件目标等。这个模型通…
阅读更多...
从零开始的OpenGL光栅化渲染器构建5-阴影

从零开始的OpenGL光栅化渲染器构建5-阴影

前言 阴影是光线被阻挡的结果&#xff1b;当一个光源的光线由于其他物体的阻挡不能够达到一个物体的表面的时候&#xff0c;那么这个物体就在阴影中了。阴影能够使场景看起来真实得多&#xff0c;并且可以让观察者获得物体之间的空间位置关系。 直接阴影 阴影映射(Shadow Ma…
阅读更多...
【转载】java面试题

【转载】java面试题

java面试题大全 何为进程?何为线程?JVM拓展为什么程序计数器、虚拟机栈和本地方法栈是线程私有的呢&#xff1f;为什么堆和方法区是线程共享的呢虚拟机栈和本地方法栈为什么是私有的?一句话简单了解堆和方法区单核 CPU 上运行多个线程效率一定会高吗&#xff1f;创建线程有哪…
阅读更多...
贝锐蒲公英云AP体验：云端快速部署、远程管理，轻松满足办公环境

贝锐蒲公英云AP体验：云端快速部署、远程管理，轻松满足办公环境

公司原本的网络由于采用多个路由器&#xff0c;导致无线信号杂乱&#xff0c;管理不便&#xff0c;且远程办公体验较差&#xff0c;作为IT负责人的我&#xff0c;一直想寻找一个可以实现网络统一管理并有效提升远程工作便捷性的产品。 于是&#xff0c;我决定在公司内部部署贝…
阅读更多...
使 a === 1 a === 2 a === 3 为 true 的几种“下毒“方法

使 a === 1 a === 2 a === 3 为 true 的几种“下毒“方法

前言 这算得上是近些年的前端网红题了&#xff0c;曾经对这种网红题非常抵触&#xff0c;认为非常没有意义。 看到了不少人有做分享&#xff0c;有各种各样的方案&#xff0c;有涉及到 JS 非常基础的知识点&#xff0c;也不得不感叹解题者的脑洞之大。 但是&#xff0c;拿来…
阅读更多...
30、WEB攻防——通用漏洞SQL注入CTF二次堆叠DNS带外

30、WEB攻防——通用漏洞SQL注入CTF二次堆叠DNS带外

文章目录 堆叠注入二次注入DNS注入 堆叠注入 堆叠注入&#xff1a;根据数据库类型决定是否支持多条语句执行&#xff0c;用分号隔开。堆叠注入在代码中被执行是一方面&#xff0c;是否被执行成功又是另一方面。支持数据库类型&#xff1a;Mysql、Mssql等。 在mysql中&#xf…
阅读更多...
react 页签(自行封装)

react 页签(自行封装)

思路&#xff1a;封装一个页签组件&#xff0c;包裹页面组件&#xff0c;页面渲染之后把数据缓存到全局状态实现页面缓存。 浏览本博客之前先看一下我的博客实现的功能是否满足需求&#xff0c;实现功能&#xff1a; - 页面缓存 - 关闭当前页 - 鼠标右键>关闭当前 - 鼠标右…
阅读更多...
【rust/bevy】使用points构造ConvexMesh

【rust/bevy】使用points构造ConvexMesh

目录 说在前面问题提出Rapier具体实现参考 说在前面 操作系统&#xff1a;win11rust版本&#xff1a;rustc 1.77.0-nightlybevy版本&#xff1a;0.12github&#xff1a;这里 问题提出 在three.js中&#xff0c;可以通过使用ConvexGeometry从给定的三维点集合生成凸包(Convex Hu…
阅读更多...
【软考中级-软件设计师】day9：进程资源图、信号量PV操作、死锁和银行家算法

【软考中级-软件设计师】day9：进程资源图、信号量PV操作、死锁和银行家算法

大纲 概述 进程的组成和状态 前趋图 进程资源图 真题 同步与互斥 信号量 生产者和消费者 真题 死锁 线程
阅读更多...
【C++第二课 - 类和对象上 - 入门知识】struct类、class类、访问限定符、this指针

【C++第二课 - 类和对象上 - 入门知识】struct类、class类、访问限定符、this指针

目录 面向过程与面向对象初步认识类的定义struct定义类class定义类 类的访问限定符及封装访问限定符 声明与定义分离this指针类成员的命名问题this 类的实例化类的对象大小的计算成员函数为何不在对象里面类对象大小计算 面向过程与面向对象初步认识 C语言是面向过程的&#x…
阅读更多...
基于Elasticsearch+Logstash+Kibana+Filebeat的日志收集分析及可视化

基于Elasticsearch+Logstash+Kibana+Filebeat的日志收集分析及可视化

sudo rm /var/lib/dpkg/lock* sudo dpkg --configure -a apt update tail -f /var/log/car.log 1.1、项目概述 海量的业务应用&#xff0c;也带来了海量的日志数据&#xff0c;给业务应用的运维带来了新的挑战。例如&#xff0c;我们常用的网约车应用&#xff0c;单个平台…
阅读更多...
六、数组（1）二维数组

六、数组（1）二维数组

一、二维数组定义方式 1、数据类型 数组名[行数][列数]; 2、数据类型 数组名[行数][列数]{{数据1,数据2},{数据3,数据4}}; 3、数据类型 数组名[行数][列数]{数据1,数据2,数据3,数据4}; 4、数据类型 数组名[][列数]{数据1,数据2,数据3,数据4}; 注&#xff1a;第二种定义方式更…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023