广播、组播域套接字的实现

思维导图：

广播模式：

发送端：

#include <myhead.h>
int main(int argc, const char *argv[])
{
	//创建套接字
	int sfd=socket(AF_INET,SOCK_DGRAM,0);
	if(sfd==-1)
	{
		perror("socket error");
		return -1;
	}
	//设置套接字允许广播属性
	int broadcast=1;
	if(setsockopt(sfd,SOL_SOCKET,SO_BROADCAST,&broadcast,sizeof(broadcast))==-1)
	{
		perror("setsockopt error");
		return -1;
	}
	//填充地址信息结构体
	struct sockaddr_in sin;
	sin.sin_family=AF_INET;
	sin.sin_port=htons(8888);
	sin.sin_addr.s_addr=inet_addr("192.168.125.255");//广播地址
	//绑定(可选)
	
	//发送广播消息
	char sbuf[1024];
	while(1)
	{
		bzero(sbuf,sizeof(sbuf));
		printf("请输入：");
		fgets(sbuf,sizeof(sbuf),stdin);
		sbuf[strlen(sbuf)-1]='\0';
		//发送消息
		sendto(sfd,sbuf,sizeof(sbuf),0,(struct sockaddr*)&sin,sizeof(sin));
		puts("发送成功");
		if(strcmp(sbuf,"end")==0)
		{
			break;
		}
				
	}
	//关闭套接字
	close(sfd);
 
	return 0;
}

接收端：

#include <myhead.h>
int main(int argc, const char *argv[])
{
	//创建套接字
	int rfd=socket(AF_INET,SOCK_DGRAM,0);
	if(rfd==-1)
	{
		perror("socket error");
		return -1;
	}
	//填充地址信息结构体
	struct sockaddr_in rin;
	rin.sin_family=AF_INET;
	rin.sin_port=htons(8888);
	rin.sin_addr.s_addr=inet_addr("192.168.125.255");//广播地址
	//绑定
	if(bind(rfd,(struct sockaddr*)&rin,sizeof(rin))==-1)
	{
		perror("bind error");
		return -1;
	}
	//接收广播消息
	char rbuf[1024];
	while(1)
	{
		bzero(rbuf,sizeof(rbuf));
		//读取消息
		recv(rfd,rbuf,sizeof(rbuf),0);
		printf("收到消息:%s\n",rbuf);
		if(strcmp(rbuf,"end")==0)
		{
			break;
		}
				
	}
	//关闭套接字
	close(rfd);
	return 0;
}

组播模式：

发送端：

#include <myhead.h>
int main(int argc, const char *argv[])
{
	//创建套接字
	int sfd=socket(AF_INET,SOCK_DGRAM,0);
	if(sfd==-1)
	{
		perror("socket error");
		return -1;
	}
	//绑定(可选）
	//接收端地地址信息结构体
	struct sockaddr_in sin;
	sin.sin_family=AF_INET;
	sin.sin_port=htons(8888);
	sin.sin_addr.s_addr=inet_addr("224.1.2.3");
	//发送组播消息
	char sbuf[1024];
	while(1)
	{
		printf("请输入:");
		fgets(sbuf,sizeof(sbuf),stdin);
		sbuf[strlen(sbuf)-1]='\0';
		sendto(sfd,sbuf,sizeof(sbuf),0,(struct sockaddr*)&sin,sizeof(sin));
		puts("发送成功");
		if(strcmp(sbuf,"end")==0)
		{
			break;
		}
	}
	//关闭套接字
	close(sfd);
	return 0;
}

接收端：

#include <myhead.h>
int main(int argc, const char *argv[])
{
	//创建套接字
	int sfd=socket(AF_INET,SOCK_DGRAM,0);
	if(sfd==-1)
	{
		perror("socket error");
		return -1;
	}
	//绑定(可选）
	//接收端地地址信息结构体
	struct sockaddr_in sin;
	sin.sin_family=AF_INET;
	sin.sin_port=htons(8888);
	sin.sin_addr.s_addr=inet_addr("224.1.2.3");
	//发送组播消息
	char sbuf[1024];
	while(1)
	{
		printf("请输入:");
		fgets(sbuf,sizeof(sbuf),stdin);
		sbuf[strlen(sbuf)-1]='\0';
		sendto(sfd,sbuf,sizeof(sbuf),0,(struct sockaddr*)&sin,sizeof(sin));
		puts("发送成功");
		if(strcmp(sbuf,"end")==0)
		{
			break;
		}
	}
	//关闭套接字
	close(sfd);
	return 0;
}

流式套接字：

服务器：

#include <myhead.h>
int main(int argc, const char *argv[])
{
	//创建套接字
	int sfd=socket(AF_UNIX,SOCK_STREAM,0);
	if(sfd==-1)
	{
		perror("socket error");
		return -1;
	}
	//判断套接字
	if(access("./mysocket",F_OK)==0)
	{
		//存在该文件，需要删除该文件
		if(unlink("./mysocket")==-1)
		{
			perror("unlink error");
			return -1;
		}
	}
	//绑定套接字文件
	//服务器端地址信息结构体
	struct sockaddr_un sun;
	sun.sun_family=AF_UNIX;//地址族
	strcpy(sun.sun_path,"./mysocket");//套接字文件
	if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1)
	{
		perror("bind error");
		return -1;
	}
	if(listen(sfd,128)==-1)
	{
		perror("listen error");
		return -1;
	}
	//客户端地址信息结构体
	struct sockaddr_un cun;
	socklen_t socklen=sizeof(cun);
	int newfd=-1;
	if((newfd=accept(sfd,(struct sockaddr*)&cun,&socklen))==-1)
	{
		perror("accept error");
		return -1;
	}
	char rbuf[128]="";
	while(1)
	{
		bzero(rbuf,sizeof(rbuf));
		recv(newfd,rbuf,sizeof(rbuf),0);
		printf("[%s]:%s\n",cun.sun_path,rbuf);
		if(strcmp(rbuf,"end")==0)
		{
			break;
		}
		strcat(rbuf,"*_*");
		send(newfd,rbuf,strlen(rbuf),0);
		printf("发送成功\n");
	}
	close(sfd);
	close(newfd);
	return 0;
}

客户端：

#include <myhead.h>
int main(int argc, const char *argv[])
{
	//创建套接字
	int cfd=socket(AF_UNIX,SOCK_STREAM,0);
	if(cfd==-1)
	{
		perror("socket error");
		return -1;
	}
	//判断套接字
	if(access("./mysocket1",F_OK)==0)
	{
		//存在该文件，需要删除该文件
		if(unlink("./mysocket1")==-1)
		{
			perror("unlink error");
			return -1;
		}
	}
	//绑定
	//客户端地址信息结构体
	struct sockaddr_un cun;
	cun.sun_family=AF_UNIX;
	strcpy(cun.sun_path,"./mysocket1");
	if(bind(cfd,(struct sockaddr*)&cun,sizeof(cun))==-1)
	{
		perror("bind error");
		return -1;
	}
	//服务器地址信息结构体
	struct sockaddr_un sun;
	sun.sun_family=AF_UNIX;
	strcpy(sun.sun_path,"./mysocket");
	//连接客户端
	if(connect(cfd,(struct sockaddr*)&sun,sizeof(sun))==-1)
	{
		perror("connect error");
		return -1;
	}
	//收发数据
	char wbuf[128];
	while(1)
	{
		bzero(wbuf,sizeof(wbuf));
		printf("请输入:");
		fgets(wbuf,sizeof(wbuf),stdin);
		wbuf[strlen(wbuf)-1]='\0';
		send(cfd,wbuf,strlen(wbuf),0);
		puts("发送成功");
		if(strcmp(wbuf,"end")==0)
		{
			break;
		}
		bzero(wbuf,sizeof(wbuf));
		recv(cfd,wbuf,sizeof(wbuf),0);
		printf("收到服务器回发的消息是：%s\n",wbuf);
	}
	//关闭套接字
	close(cfd);
	return 0;
}

报式套接字：

服务器：

#include <myhead.h>
int main(int argc, const char *argv[])
{
	//创建套接字
	int sfd=socket(AF_UNIX,SOCK_DGRAM,0);
	if(sfd==-1)
	{
		perror("socket error");
		return -1;
	}
	//判断套接字
	if(access("./socket",F_OK)==0)
	{
		//存在该文件，需要删除该文件
		if(unlink("./socket")==-1)
		{
			perror("unlink error");
			return -1;
		}
	}
	//绑定套接字文件
	//服务器端地址信息结构体
	struct sockaddr_un sun;
	sun.sun_family=AF_UNIX;//地址族
	strcpy(sun.sun_path,"./socket");//套接字文件
	if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1)
	{
		perror("bind error");
		return -1;
	}
	//客户端地址信息结构体
	struct sockaddr_un cun;
	socklen_t socklen=sizeof(cun);
	char rbuf[128]="";
	while(1)
	{
		bzero(rbuf,sizeof(rbuf));
		recvfrom(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&cun,&socklen);
		printf("[%s]:%s\n",cun.sun_path,rbuf);
		if(strcmp(rbuf,"end")==0)
		{
			break;
		}
		strcat(rbuf,"*_*");
		sendto(sfd,rbuf,strlen(rbuf),0,(struct sockaddr*)&cun,socklen);
		printf("发送成功\n");
	}
	close(sfd);
	return 0;
}

客户端：

#include <myhead.h>
int main(int argc, const char *argv[])
{
	//创建套接字
	int cfd=socket(AF_UNIX,SOCK_DGRAM,0);
	if(cfd==-1)
	{
		perror("socket error");
		return -1;
	}
	//判断套接字
	if(access("./socket1",F_OK)==0)
	{
		//存在该文件，需要删除该文件
		if(unlink("./socket1")==-1)
		{
			perror("unlink error");
			return -1;
		}
	}
	//绑定套接字文件
	//客户端地址信息结构体
	struct sockaddr_un cun;
	cun.sun_family=AF_UNIX;//地址族
	strcpy(cun.sun_path,"./socket1");//套接字文件
	if(bind(cfd,(struct sockaddr*)&cun,sizeof(cun))==-1)
	{
		perror("bind error");
		return -1;
	}
	//服务器地址信息结构体
	struct sockaddr_un sun;
	sun.sun_family=AF_UNIX;
	strcpy(sun.sun_path,"./socket");
	char wbuf[128]="";
	while(1)
	{
		bzero(wbuf,sizeof(wbuf));
		printf("请输入:");
        fgets(wbuf, sizeof(wbuf), stdin);
        wbuf[strlen(wbuf)-1] = 0;
        //将数据发送给服务器
        sendto(cfd, wbuf, sizeof(wbuf), 0, (struct sockaddr*)&sun, sizeof(sun));		
        printf("发送成功\n");
	if(strcmp(wbuf,"end")==0)
		{
			break;
		}
        //接收服务器回复的消息
        bzero(wbuf, sizeof(wbuf));
 
        recvfrom(cfd, wbuf, sizeof(wbuf), 0, NULL, NULL);
        printf("收到服务器回发的消息为：%s\n", wbuf);
	}
	close(cfd);
	return 0;
}

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

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

相关文章

VS2022连接数据库以及常用的连接函数

VS2022连接数据库以及常用的连接函数

下面是如何配置以及设置VS2022连接数据库 第一步:打开mysql的安装目录&#xff0c;默认安装目录如下&#xff1a;C:\Program Files\MySQL\MySQL Server 8.0&#xff0c;确认 lib 目录和include 目录是否存在。 第二步&#xff1a;打开VS2019&#xff0c;新建一个空工程,控制台…
阅读更多...
STM32 | STM32时钟分析、GPIO分析、寄存器地址查找、LED灯开发(第二天)

STM32 | STM32时钟分析、GPIO分析、寄存器地址查找、LED灯开发(第二天)

STM32 第二天 一、 STM32时钟分析 寄存器&#xff1a;寄存器的功能是存储二进制代码&#xff0c;它是由具有存储功能的触发器组合起来构成的。一个触发器可以存储1位二进制代码&#xff0c;故存放n位二进制代码的寄存器&#xff0c;需用n个触发器来构成 在计算机领域&#x…
阅读更多...
远程桌面连接不上服务器怎么办？

远程桌面连接不上服务器怎么办？

在进行远程桌面连接时&#xff0c;有时候会遇到连接不上服务器的问题&#xff0c;这给我们的工作和生活带来了很多不便。下面&#xff0c;我们来了解一下解决这个问题的方法和工具。 【天联】组网的介绍 【天联】组网是一款异地组网内网穿透产品&#xff0c;由北京金万维科技有…
阅读更多...
快速上手：在 Android 设备上运行 Pipy

快速上手：在 Android 设备上运行 Pipy

Pipy 作为一个高性能、低资源消耗的可编程代理&#xff0c;通过支持多种计算架构和操作系统&#xff0c;Pipy 确保了它的通用性和灵活性&#xff0c;能够适应不同的部署环境&#xff0c;包括但不限于云环境、边缘计算以及物联网场景。它能够在 X86、ARM64、海光、龙芯、RISC-V …
阅读更多...
Linux网络编程 ——UDP 通信

Linux网络编程 ——UDP 通信

Linux网络编程 ——UDP 通信 1. UDP1.1 UDP 通信1.2 广播1.3 组播&#xff08;多播&#xff09; 2. 本地套接字 1. UDP 1.1 UDP 通信 输入 man 2 sendto 查看说明文档 #include <sys/types.h> #include <sys/socket.h>ssize_t sendto(int sockfd, const void *buf…
阅读更多...
GlusterFS系统内核调优

GlusterFS系统内核调优

转载说明&#xff1a;如果您喜欢这篇文章并打算转载它&#xff0c;请私信作者取得授权。感谢您喜爱本文&#xff0c;请文明转载&#xff0c;谢谢。 相关文章&#xff1a; 分布式存储——GlusterFS 关于GlusterFS的卷 GlusterFS—新手陷阱 GlusterFS常用命令集 前言 本文总…
阅读更多...
深度学习预测分析API：金融领域的Game Changer

深度学习预测分析API：金融领域的Game Changer

&#x1f680; 引言 在这个AI遍地开花的时代&#xff0c;谁能成为金融领域的真正Game Changer&#xff1f;那必然是是深度学习预测分析API。如大脑般高效运转的系统不仅颠覆了传统操作&#xff0c;更是以无与伦比的速度和精度赋予了金融数据以全新的生命。 &#x1f4bc; 广泛…
阅读更多...
Doris实战——特步集团零售数据仓库项目实践

Doris实战——特步集团零售数据仓库项目实践

目录 一、背景 二、总体架构 三、ETL实践 3.1 批量数据的导入 3.2 实时数据接入 3.3 数据加工 3.4 BI 查询 四、实时需求响应 五、其他经验 5.1 Doris BE内存溢出 5.2 SQL任务超时 5.3 删除语句不支持表达式 5.4 Drop 表闪回 六、未来展望 原文大佬的这篇Doris数…
阅读更多...
C# Winform画图绘制圆形

C# Winform画图绘制圆形

一、因为绘制的圆形灯需要根据不同的状态切换颜色，所以就将圆形灯创建为用户控件 二、圆形灯用户控件 1、创建用户控件UCLight 2、设值用户控件大小(30,30)。放一个label标签，AutoSize为false(不自动调整大小)，Dock为Fill(填充)，textaglign为居中显示。 private Color R…
阅读更多...
LLM春招准备（1）

LLM春招准备（1）

llm排序 GPT4V GPT-4V可以很好地理解直接绘制在图像上的视觉指示。它可以直接识别叠加在图像上的不同类型的视觉标记作为指针&#xff0c;例如圆形、方框和手绘&#xff08;见下图&#xff09;。虽然GPT-4V能够直接理解坐标&#xff0c;但相比于仅文本坐标&#xff0c;GPT-4V在…
阅读更多...
【探索AI】二十一 深度学习之第4周：循环神经网络（RNN）与长短时记忆（LSTM）

【探索AI】二十一 深度学习之第4周：循环神经网络（RNN）与长短时记忆（LSTM）

循环神经网络&#xff08;RNN&#xff09;与长短时记忆&#xff08;LSTM&#xff09; RNN的基本原理与结构LSTM的原理与实现序列建模与文本生成任务实践&#xff1a;使用RNN或LSTM进行文本分类或生成任务步骤 1: 数据准备步骤 2: 构建模型步骤 3: 定义损失函数和优化器步骤 4: …
阅读更多...
我选项目和做项目的两大准则

我选项目和做项目的两大准则

一、项目不在多&#xff0c;做精做透最重要 其实我们做生意做项目的一定要记住&#xff0c;手头上永远要有一样东西&#xff0c;即便是天塌下来你也能挣钱的&#xff0c;我经常称其为基本盘。比如我们手上的CSGO游戏搬砖&#xff0c;可能在经营这个项目的过程中会或多或少的接…
阅读更多...
蓝桥杯练习题——dp

蓝桥杯练习题——dp

五部曲&#xff08;代码随想录&#xff09; 1.确定 dp 数组以及下标含义 2.确定递推公式 3.确定 dp 数组初始化 4.确定遍历顺序 5.debug 入门题 1.斐波那契数 思路 1.f[i]&#xff1a;第 i 个数的值 2.f[i] f[i - 1] f[i - 2] 3.f[0] 0, f[1] 1 4.顺序遍历 5.记得特判 …
阅读更多...
项目管理：实现高效团队协作与成功交付的关键

项目管理：实现高效团队协作与成功交付的关键

在当今竞争激烈的市场环境中&#xff0c;项目管理已成为企业成功的关键因素之一。项目管理不仅涉及时间、成本和资源的有效管理&#xff0c;还涉及到团队协作、风险管理、沟通和交付。本文将探讨项目管理的核心要素&#xff0c;以及如何实现高效团队协作和成功交付。 一、明确项…
阅读更多...
es集群的详细搭建过程

es集群的详细搭建过程

目录 一、VM配置二、集群搭建三、集群配置 一、VM配置 VM的安装 VMware Workstation 15 Pro的安装与破解 VM新建虚拟机 VM新建虚拟机 二、集群搭建 打开新建好的服务器&#xff0c;node1&#xff0c;使用xshell远程连接 下载es&#xff1a;https://www.elastic.co/cn/down…
阅读更多...
【自然语言处理六-最重要的模型-transformer-下】

【自然语言处理六-最重要的模型-transformer-下】

自然语言处理六-最重要的模型-transformer-下 transformer decoderMasked multi-head attentionencoder和decoder的连接部分-cross attentiondecoder的输出AT(Autoregresssive)NAT transformer decoder 今天接上一篇文章讲的encoder 自然语言处理六-最重要的模型-transformer-…
阅读更多...
Carbondata编译适配Spark3

Carbondata编译适配Spark3

背景 当前carbondata版本2.3.1-rc1中项目源码适配的spark版本最高为3.1,我们需要进行spark3.3版本的编译适配。 原始编译 linux系统下载源码后&#xff0c;安装maven3.6.3&#xff0c;然后执行&#xff1a; mvn -DskipTests -Pspark-3.1 clean package会遇到一些网络问题&a…
阅读更多...
SpringCloud-RabbitMQ消息模型

SpringCloud-RabbitMQ消息模型

本文深入介绍了RabbitMQ消息模型&#xff0c;涵盖了基本消息队列、工作消息队列、广播、路由和主题等五种常见消息模型。每种模型都具有独特的特点和适用场景&#xff0c;为开发者提供了灵活而强大的消息传递工具。通过这些模型&#xff0c;RabbitMQ实现了解耦、异步通信以及高…
阅读更多...
如何远程连接MySQL数据库？

如何远程连接MySQL数据库？

在现代互联网时代&#xff0c;远程连接MySQL数据库成为了许多开发者和管理员必备的技能。这不仅方便了数据的共享和管理&#xff0c;还可以使多个团队在全球范围内协同工作。本文将介绍如何通过天联组网实现远程连接MySQL数据库&#xff0c;并实现高效的信息远程通信。 天联组网…
阅读更多...
tomcat nginx 动静分离

tomcat nginx 动静分离

实验目的:当访问静态资源的时候&#xff0c;nginx自己处理 当访问动态资源的时候&#xff0c;转给tomcat处理 第一步 关闭防火墙 关闭防护 代理服务器操作&#xff1a; 用yum安装nginx tomcat &#xff08;centos 3&#xff09;下载 跟tomcat&#xff08;centos 4&#xff0…
阅读更多...
最新文章

Copyright @ 2022~2023