网络进程：广播、组播、流式域、报式域(套接字)

1.广播

1.1广播发送端模型(类似UDP客户端)

程序代码：

#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)
		//套接字描述符，套接字要设置的层(应用层)、指定层内属性(允许广播)
		//设置该属性容器起始地址，参数4的大小
	{
		perror("setsockopt error");
		return -1;
	}
	//绑定，非必要
	//填充接收端地址信息结构体
	struct sockaddr_in cin;
	cin.sin_family=AF_INET;
	cin.sin_port=htons(6789);
	cin.sin_addr.s_addr=inet_addr("192.168.125.255");
	//发送消息
	char sbuf[128]="";
	while(1)
	{
		printf("请输入>>>");
		fgets(sbuf,sizeof(sbuf),stdin);
		sbuf[strlen(sbuf)-1]=0;
		//发送到广播地址
		sendto(sfd,sbuf,sizeof(sbuf),0,(struct sockaddr*)&cin,sizeof(cin));
		printf("发送成功\n");
	}
	//关闭套接字
	close(sfd);
	return 0;
}

1.2广播接收端模型(类似UDP服务器端)

程序代码：

#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(6789);
	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[128]="";
	while(1)
	{
		//清空数组
		bzero(rbuf,sizeof(rbuf));
		//接受信息
		recvfrom(rfd,rbuf,sizeof(rbuf),0,0,0);
		printf("收到消息:%s\n",rbuf);
	}
	//关闭套接字
	close(rfd);
	return 0;
}

运行结果：

2. 组播

2.1组播发送端模型(类型UDP客户端)

程序代码：

#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 sin;
	sin.sin_family=AF_INET;
	sin.sin_port=htons(9999);
	sin.sin_addr.s_addr=inet_addr("224.1.2.3");
	//发送消息
	char sbuf[128]="";
	while(1)
	{
		printf("请输入>>>");
		fgets(sbuf,sizeof(sbuf),stdin);
		sbuf[strlen(sbuf)-1]=0;
		sendto(rfd,sbuf,strlen(sbuf),0,(struct sockaddr*)&sin,sizeof(sin));
		printf("发送成功\n");
	}
	close(rfd);
	return 0;
}

2.2组播接收端模型(类似UDP服务器端)

程序代码：

#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;
	}
	printf("rfd=%d\n",rfd);
	//设置加入多播族
	struct ip_mreqn imr;
	imr.imr_multiaddr.s_addr=inet_addr("224.1.2.3");
	imr.imr_address.s_addr=inet_addr("192.168.125.227");
	imr.imr_ifindex=2;//网卡编号
	if(setsockopt(rfd,IPPROTO_IP,IP_ADD_MEMBERSHIP,&imr,sizeof(imr))==-1)
	{
		perror("setsockopt error");
		return -1;
	}
	printf("加入组播成功\n");
	//填充地址信息结构体
	struct sockaddr_in rin;
	rin.sin_family=AF_INET;
	rin.sin_port=htons(9999);
	rin.sin_addr.s_addr=inet_addr("224.1.2.3");
	if(bind(rfd,(struct sockaddr*)&rin,sizeof(rin))==-1)
	{
		perror("bind error");
		return -1;
	}
	char rbuf[128]="";
	while(1)
	{
		bzero(rbuf,sizeof(rbuf));
		recv(rfd,rbuf,sizeof(rbuf),0);
		printf("收到:%s\n",rbuf);
	}
	close(rfd);
	return 0;
}

运行结果：

3.流式域套接字

3.1流式域套接字服务器端

程序代码：

#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;
		}
	}
	//2.绑定套接字文件
	//2.1填充地址信息结构体
	struct sockaddr_un sun;
	sun.sun_family=AF_UNIX;
	//字符串不能用赋值运算符赋值
	strcpy(sun.sun_path,"./mysocket");
	//2.2绑定
	if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1)
	{
		perror("bind error");
		return -1;
	}
	printf("bind success\n");
	//3.监听
	if(listen(sfd,128)==-1)
	{
		perror("listen error");
		return -1;
	}
	printf("listen success\n");
	//4.阻塞等待客户端连接请求
	//定义容器接收客户端地址信息
	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;
	}
	printf("有新客户发来连接请求\n");
	//5.数据收发
	char rbuf[128]="";
	while(1)
	{
		bzero(rbuf,sizeof(rbuf));
		int res=recv(newfd,rbuf,sizeof(rbuf),0);
		if(res==0)
		{
			printf("客户端已下线\n");
			break;
		}
		printf("[%s]:%s\n",cun.sun_path,rbuf);
		//连接一个笑脸回复
		strcat(rbuf,"*_*");
		//发送回去
		send(newfd,rbuf,strlen(rbuf),0);
		printf("发送成功\n");
	}
	close(sfd);
	close(newfd);
	return 0;
}

3.2流式域套接字客户端

程序代码：

#include<myhead.h>
int main(int argc, const char *argv[])
{
	//1.创建用于通信的套接字文件描述符
	int cfd=socket(AF_UNIX,SOCK_STREAM,0);
	if(cfd==-1)
	{
		perror("socket error");
		return -1;
	}
	printf("cfd=%d\n",cfd);
	//判断套接字文件是否存在，如果存在删除
	if(access("./mysocket1",F_OK)==0)
	{
		//存在删除
		if(unlink("./mysocket1")==-1)
		{
			perror("unlink error");
			return -1;
		}
	}
	//2.绑定(不绑定，系统不会绑定)
	//2.1填充地址信息结构体
	struct sockaddr_un cun;
	cun.sun_family=AF_UNIX;
	strcpy(cun.sun_path,"./mysocket1");
	//2.2绑定
	if(bind(cfd,(struct sockaddr*)&cun,sizeof(cun))==-1)
	{
		perror("bind error");
		return -1;
	}
	printf("bind success\n");
	//3.连接服务器
	//3.1填充要连接的服务器地址信息结构体
	struct sockaddr_un sun;
	sun.sun_family=AF_UNIX;
	strcpy(sun.sun_path,"./mysocket");
	//3.2连接服务器
	if(connect(cfd,(struct sockaddr*)&sun,sizeof(sun))==-1)
	{
		perror("connect error");
		return -1;
	}
	printf("connect success\n");
	//4.数据收发
	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);
		printf("发送成功\n");
		//判断发送的数据
		if(strcmp(wbuf,"quit")==0)
		{
			break;
		}
		//接收服务器发来的消息
		//清空数据
		bzero(wbuf,sizeof(wbuf));
		recv(cfd,wbuf,sizeof(wbuf),0);
		printf("收到消息：%s\n",wbuf);
	}
	close(cfd);
	return 0;
}

运行结果：

4.报式域套接字

4.1报式域套接字服务器端

程序代码：

#include<myhead.h>
int main(int argc, const char *argv[])
{
	//创建套接字
	int sfd=socket(AF_UNIX,SOCK_DGRAM,0);
	//SOCK_DGRAM使用UDP报式套接字通信
	if(sfd==-1)
	{
		perror("socket error");
		return -1;
	}
	printf("sfd=%d\n",sfd);
	//域套接字绑定函数，只能绑定一个不存在的套接字文件
	//绑定前判断当前文件是否存在
	if(access("./linux",F_OK)==0)
	{
		//文件存在删除
		if(unlink("./linux")==-1)
		{
			perror("unlink error");
			return -1;
		}
	}
	//绑定
	//填充地址信息结构体
	struct sockaddr_un sun;
	sun.sun_family=AF_UNIX;
	strcpy(sun.sun_path,"./linux");
	//绑定
	if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1)
	{
		perror("bind error");
		return -1;
	}
	//数据收发
	char buf[128]="";
	//定义变量存放客户端地址信息结构体
	struct sockaddr_un cun;
	socklen_t socklen=sizeof(cun);
	while(1)
	{
		//清空数组
		bzero(buf,sizeof(buf));
		//从套接字文件读取消息
		recvfrom(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cun,&socklen);
		printf("[%s]:%s\n",cun.sun_path,buf);
		//将字符串连接后回发
		strcat(buf,"*_*");
		//if(write(sfd,buf,sizeof(buf))==-1)
		if(sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cun,sizeof(cun))==-1)
		{
			perror("write error");
			return -1;
		}
		printf("发送成功\n");
	}
	//关闭套接字
	close(sfd);
	return 0;
}

4.2报式域套接字客户端

程序代码：

#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("./unix",F_OK)==0)
	{
		//文件存在，删除
		if(unlink("./unix")==-1)
		{
			perror("unlink error");
			return -1;
		}
	}
	//绑定
	//填充地址信息结构体
	struct sockaddr_un cun;
	cun.sun_family=AF_UNIX;
	strcpy(cun.sun_path,"./unix");
	//绑定
	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,"./linux");
	//数据收发
	char buf[128]="";
	while(1)
	{
		printf("请输入>>>");
		fgets(buf,sizeof(buf),stdin);
		buf[strlen(buf)-1]=0;
		//发送给服务器
		sendto(cfd,buf,sizeof(buf),0,(struct sockaddr*)&sun,sizeof(sun));
		if(strcmp(buf,"quit")==0)
			break;
		//接收服务器发来的消息
		recvfrom(cfd,buf,sizeof(buf),0,NULL,NULL);
		printf("收到消息:%s\n",buf);
	}
	//关闭套接字
	close(cfd);
	return 0;
}

运行结果：

流程图：

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

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

相关文章

cmd模式下启动mysql

cmd模式下启动mysql

1.打开cmd输入services.msc&#xff0c;找到MYSQL&#xff0c;右击属性&#xff0c;找到可执行文件路径&#xff0c;加载到环境变量。 2.打开cmd&#xff0c;启动MYSQL&#xff1a;输入net start mysql; 3.登陆MYSQL&#xff0c;需要管理权限&#xff1b; 输入&#xff1a;my…
阅读更多...
【OBS】stream-labs-desktop 编译运行采坑全攻略

【OBS】stream-labs-desktop 编译运行采坑全攻略

▒ 目录 ▒ &#x1f6eb; 导读需求开发环境 1️⃣ 安装yarn安装 2️⃣ 安装依赖库&#xff1a;yarn installcertificate has expiredelectronnpm:25.9.3 couldnt be built successfully 3️⃣ 启动desktop项目编译调试模式启动启动缓慢问题 4️⃣ 打包&#x1f6ec; 文章小结…
阅读更多...
sentinel docker 基础配置学习

sentinel docker 基础配置学习

1&#xff1a;去官网下载 Releases alibaba/Sentinel GitHub 2&#xff1a;保存到linux 3&#xff1a;编写dockerfile FROM openjdk:8-jreLABEL authors"xxx" #第二步创建一个文件夹Z RUN mkdir /app #第三步复制jar 到app 下 COPY xxxxxx-1.8.7.jar /app/#第四…
阅读更多...
动态规划（算法竞赛、蓝桥杯）--背包DP求具体方案

动态规划（算法竞赛、蓝桥杯）--背包DP求具体方案

1、B站视频链接&#xff1a;E20 背包DP 求具体方案_哔哩哔哩_bilibili #include <bits/stdc.h> using namespace std; const int N1010; int v[N],w[N]; int f[N][N],p[N][N];int main(){int n,m;cin>>n>>m;for(int i1;i<n;i)cin>>v[i]>>w[i…
阅读更多...
云计算 3月5号 （DNS域名解析及部署）

云计算 3月5号 （DNS域名解析及部署）

DNS域名解析服务 1.DNS介绍 DNS 是域名系统 (Domain Name System) 的缩写&#xff0c;是因特网的一项核心服务&#xff0c;它作为可以将域名和IP地址相互映射的一个分布式数据库&#xff0c;能够使人更方便的访问互联网&#xff0c;而不用去记住能够被机器直接读取的IP数串。…
阅读更多...
UD效果广告

UD效果广告

1.定义 全称Unidesk&#xff0c;是由阿里旗下大数据运营平台“阿里妈妈”推出的数字营销引流平台。UD投放将其他媒体的流量通过相关的广告创意导入到天猫店铺。 2.UD投放优化技巧 &#xff08;1&#xff09;不起量排查&#xff1a; 可以从账户问题、计划数量不足、计划设置…
阅读更多...
c语言经典测试题11

c语言经典测试题11

1.题1 #include <stdio.h> int main() { int a[] {1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12}, *p a 5, *q NULL; *q *(p5); printf("%d %d\n", *p, *q); return 0; }上述代码的运行结果是什么呢&#xff1f; 我们来分析一下&#xff1a;我们创建了一个数…
阅读更多...
美易官方《盘前：美国股指期货温和走低》

美易官方《盘前：美国股指期货温和走低》

美国股指期货在盘前交易中温和走低&#xff0c;市场情绪在美联储主席鲍威尔即将作证前显得谨慎。投资者对即将公布的证词内容充满期待&#xff0c;以寻求对美联储未来货币政策的更多线索。 鲍威尔即将在国会作证&#xff0c;这是市场关注的焦点事件之一。他的证词可能会对美元汇…
阅读更多...
删除有序链表中重复的数字Ⅱ

删除有序链表中重复的数字Ⅱ

题目 题目链接 删除有序链表中重复的元素-II_牛客题霸_牛客网 题目描述 代码实现 class Solution { public:/*** 代码中的类名、方法名、参数名已经指定&#xff0c;请勿修改&#xff0c;直接返回方法规定的值即可** * param head ListNode类 * return ListNode类*/ListNod…
阅读更多...
redis缓存与集群

redis缓存与集群

备份 rdb数据快照&#xff0c;内存数据记录到磁盘&#xff0c;故障重启磁盘读取文件 恢复数据 save主进程进行save阻塞其他命令 bgsave fork子进程rdb不影响其他的 fork主进程得到子进程 共享主进程内存数据 fork读取内存数据写入rdb文件 当主进程执行写操作时 拷贝一份数…
阅读更多...
vs2022 qt 关于lnk2001和2019同时报错的问题

vs2022 qt 关于lnk2001和2019同时报错的问题

需要像qt中添加模块&#xff0c;这里&#xff0c;缺少qtopenglwidgets模块
阅读更多...
MATLAB的基础二维绘图

MATLAB的基础二维绘图

1.plot函数 &#xff08;1&#xff09;plot函数的基本用法 plot(x,y)其中&#xff0c;x和y分别用于存储x坐标和y坐标数据&#xff0c;通常x和y为长度相同的向量。 例如&#xff1a; x[2.3,3.3,4.3,1];y[1.3,2,1.8,3]plot(x,y) (2)plot(x,y,选项&#xff09;其中选项包括颜色…
阅读更多...
超详细的Scrapy框架的基本使用教程

超详细的Scrapy框架的基本使用教程

Scrapy的介绍 scrapy的工作流程&#xff08;重点&#xff01;&#xff01;&#xff01;&#xff09; 如下图所示&#xff1a; 爬虫&#xff1a; 负责向引擎提供要爬取网页的URL&#xff0c;引擎会把这个URL封装成request对象并传递给调度器&#xff0c;把引擎传递过来的resp…
阅读更多...
【送书活动1】基于React低代码平台开发：构建高效、灵活的应用新范式

【送书活动1】基于React低代码平台开发：构建高效、灵活的应用新范式

【送书活动1】基于React低代码平台开发&#xff1a;构建高效、灵活的应用新范式 写在最前面一、React与低代码平台的结合优势二、基于React的低代码平台开发挑战三、基于React的低代码平台开发实践四、未来展望《低代码平台开发实践&#xff1a;基于React》编辑推荐内容简介作者…
阅读更多...
逻辑代数基础（一）（逻辑符号）

逻辑代数基础（一）（逻辑符号）

目录 三种基本运算 与运算 或运算 非运算 复合运算 与非运算 或非运算 与或非运算 异或运算 同或运算 逻辑代数的基本定律和常用公式 逻辑代数的基本定律 常量-常量的运算 常量-变量的运算 特殊定律 逻辑代数的常用公式 逻辑函数 逻辑函数的定义 逻辑函数的约束条件 逻…
阅读更多...
140.乐理基础-音程的转位

140.乐理基础-音程的转位

上一个内容&#xff1a;139.乐理基础-一四五八度为何用纯?-CSDN博客 上一个内容里练习的答案&#xff1a; 本次内容并不会感觉到有多大用处&#xff0c;但要牢牢掌握。 音程的转位&#xff1a; 改变音的高低顺序 比如c-e&#xff0c;c低、e高 音程转位&#xff1a;也就是变成…
阅读更多...
为什么有了HTTP协议，还要有WebSocket协议？

为什么有了HTTP协议，还要有WebSocket协议？

文章目录 使HTTP不断轮询长轮询WebSocket是什么&#xff1f;怎么建立WebSocket连接WebSocket抓包WebSocket的消息格式WebSocket的使用场景总结 平时我们打开网页&#xff0c;比如购物网站某宝。都是点一下列表商品&#xff0c;跳转一下网页就到了商品详情。 从HTTP协议的角度来…
阅读更多...
【C语言】编程题专项练习+答案

【C语言】编程题专项练习+答案

目录 1.删除有序数组中重复的数 2.用除二取余的方法&#xff0c;把任意一个十进制正数的二进制序列输出&#xff08;不考虑溢出&#xff09; 2.1如果是把任意一个十进制整数的二进制序列输出呢&#xff1f; 3.输出一个六行六列的整形矩阵&#xff0c;并输出其转置矩阵。矩阵…
阅读更多...
C++之map

C++之map

1、map介绍 map是C STL的一个关联容器&#xff0c;它提供一对一的数据处理能力。其中&#xff0c;各个键值对的键和值可以是任意数据类型&#xff0c;包括 C 基本数据类型&#xff08;int、double 等&#xff09;、使用结构体或类自定义的类型。 第一个可以称为关键字(key)&…
阅读更多...
盘点国内大厂的10个AI创作工具，看看你都用过哪些？

盘点国内大厂的10个AI创作工具，看看你都用过哪些？

国内大厂的 AI 创作工具&#xff0c;目前已经非常多了&#xff0c;而且有很多都是大家耳熟能详的。 下面整理了一些&#xff0c;包含 AI 绘画、AI 视频、AI 智能体、AI 大模型等多个方向的国内大厂 AI 创作工具。 发现有几款 AI 工具&#xff0c;还真的非常好用。看看这些 AI…
阅读更多...
最新文章

Copyright @ 2022~2023