嵌入式养成计划-30-网络编程----多点通信--单播--广播--组播

2023-10-09 13:21
文章标签 广播 养成 编程 网络 嵌入式 计划 30 多点通信 单播 组播

本文主要是介绍嵌入式养成计划-30-网络编程----多点通信--单播--广播--组播，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

六十六、多点通信

66.1 网络属性相关函数

  • getsockopt
  • setsockopt
功能：获取/设置网络属性;
原型：#include <sys/types.h>          /* See NOTES */#include <sys/socket.h>int getsockopt(int sockfd, int level, int optname,
void *optval, socklen_t *optlen);int setsockopt(int sockfd, int level, int optname,
const void *optval, socklen_t optlen);
参数：  int sockfd：指定要设置哪个套接字的网络属性;int level：指定要控制的层次等级;SOL_SOCKET：指定的是应用层 ，通用套接字选项;IPPROTO_TCP：指定要控制的是TCP;IPPROTO_UDP：UDPIPPROTO_IP:  IPint optname：指定操作名称，选项名称。在第二个参数指定要层次后，该参数用于指定控制该层次的什么;---- SOL_SOCKET	: man 7 socket ----1. SO_BROADCAST     是否允许广播（只有UDP允许广播） ---》optval: int*类型2. SO_REUSEADDR     是否允许端口快速重用            ---》optval: int*类型，且是个bool类型;---- IPPROTO_TCP	: man 7 TCP -------- IPPROTO_UDP	: man 7 UDP -------- IPPROTO_IP	: man 7 IP ----1. IP_ADD_MEMBERSHIP     加入组播（多播组）  ----》optval : struct ip_mreqn*类型struct ip_mreqn {struct in_addr imr_multiaddr; /* IP multicast group address */struct in_addr imr_address;   /* IP address of local interface */int            imr_ifindex;   /* interface index */};void *optval：除非有另外说明，否则optval都是int*类型socklen_t *optlen/socklen_t optlen：optval指针指向的真实的数据类型大小;
返回值：成功，返回0;失败，返回-1，更新errno;

在这里插入图片描述

  • 示例 ：
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>int main(int argc, const char *argv[])
{int sfd = socket(AF_INET, SOCK_DGRAM, 0);if(sfd < 0){perror("socket");return -1;}printf("socket create success \n");socklen_t len;int reuse = 100;//设置允许端口快速重用if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0){perror("setsockopt");return -1;}printf("设置允许端口快速重用\n");//判断默认情况下是否允许端口快速重用len = sizeof(reuse);if(getsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, &len) < 0){perror("getsockopt");return -1;}printf("%d\n", reuse);//设置允许广播int broad = 1;if(setsockopt(sfd, SOL_SOCKET, SO_BROADCAST, &reuse, sizeof(reuse)) < 0){perror("setsockopt");return -1;}printf("设置允许广播\n");//判断默认情况下是否允许广播len = sizeof(broad);if(getsockopt(sfd, SOL_SOCKET, SO_BROADCAST, &broad, &len) < 0)                {perror("getsockopt");return -1;}printf("broad = %d\n", broad);//获取接收缓冲区的大小int rcvbuf;len = sizeof(rcvbuf);if(getsockopt(sfd, SOL_SOCKET, SO_RCVBUF, &rcvbuf, &len) < 0){perror("getsockopt");return -1;}printf("rcvbuf = %dbytes %dkb\n", rcvbuf, rcvbuf/1024);struct timeval tm;len = sizeof(tm);if(getsockopt(sfd, SOL_SOCKET, SO_RCVTIMEO, &tm, &len) < 0){perror("getsockopt");return -1;}printf("%lds %ldus\n", tm.tv_sec, tm.tv_usec);close(sfd);return 0;
}

66.2 多点通信

66.2.1 单播

  • 主机之间一对一的通讯模式，
  • 每次只有两个实体相互通讯，发送方和接收方都是唯一确定。

66.2.2 广播

66.2.2.1 概念

  1. 主机之间一对多的通信模式。
  2. 在同一个局域网内的所有主机都可以接收到广播信息，
  3. 禁止广播数据穿过路由器，即限制在当前局域网内。防止影响大面积主机。
  4. 只有UDP才能广播。
  5. 广播地址：有效网络号+全是1的主机号。
    1. 192.168.114.83 ----》C类IP地址—》网络号前24bit —》192.168.114.255
    2. 192.168.125.229 ----》C类IP地址—》网络号前24bit —》192.168.125.255
    3. 144.1.2.3 ----》B类IP地址—》网络号前16bit —》144.1.255.255
    4. 255.255.255.255

255.255.255.255：给所有网络中的所有网段发送广播数据，但是由于不能穿过路由器，所以只能发送给当前局域网内主机。

66.2.2.2 广播的发送方流程 ----》类似UDP客户端

  1. socket 创建报式套接字
  2. setsockopt 设置允许广播 level: SOL_SOCKET optname: SO_BROADCAST
  3. bind 非必须绑定
  4. 填充接收方的地址信息，给sendto函数使用
    1. IP：广播IP：有效网络号+全是1的主机号 或者 255.255.255.255（需要与接收方绑定时候指定的一致）
      (PS：不允许填0.0.0.0，若接收方发送方均填0.0.0.0，会默认使用127.0.0.1通信)
    2. .PORT：需要与接收方绑定的一致。
  5. sendto 发送数据
  6. close 关闭套接字

66.2.2.3 广播的接收方流程 ----》类似UDP服务器

  1. socket 创建报式套接字
  2. 填充接收方自身的地址信息，给bind函数使用
    1. IP：广播IP：有效网络号+全是1的主机号 或者 255.255.255.255 或者 0.0.0.0(任意IP地址)
      1. 0.0.0.0：当调用bind函数绑定后，会将本机所有可用IP地址绑定到套接字上。
      2. 所有可用IP：本机IP(192.168.125.5), 127.0.0.1本地环回IP, 广播IP, 组播IP
    2. PORT：1024~49151范围；
  3. bind 必须绑定
  4. recvfrom 接收数据
  5. close 关闭套接字

66.2.2.4 广播示例代码

  • 发送方
    #include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>                                                                
#include <unistd.h>
#include <string.h>#define ERR_MSG(msg) do{\fprintf(stderr, "__%d__ ", __LINE__);\perror(msg);\
}while(0)#define SER_PORT 8888           //接收方绑定的端口号
#define SER_IP "192.168.125.255"  //广播IPint main(int argc, const char *argv[])
{//创建报式套接字int cfd = socket(AF_INET, SOCK_DGRAM, 0);if(cfd < 0){ERR_MSG("socket");return -1;}printf("socket create success cfd=%d\n", cfd);//设置允许广播int broad = 1;if(setsockopt(cfd, SOL_SOCKET, SO_BROADCAST, &broad, sizeof(broad)) < 0){ERR_MSG("setsockopt");return -1;}printf("设置允许广播成功\n");//绑定客户端自身的地址信息---》非必须绑定//若不绑定则操作系统会给客户端绑定本机IP及随机端口//填充地址信息结构体给sendto函数使用，想发给谁就填谁的地址信息//真实的地址信息结构体根据地址族指定 AF_INET: man 7 IPstruct sockaddr_in sin;sin.sin_family      = AF_INET;          //必须填AF_INET;sin.sin_port        = htons(SER_PORT);      //接收方绑定的端口号sin.sin_addr.s_addr = inet_addr(SER_IP);    //接收方绑定的IPchar buf[128] = "";ssize_t res = 0;while(1){bzero(buf, sizeof(buf));printf("请输入>>> ");fgets(buf, sizeof(buf), stdin);buf[strlen(buf)-1] = 0;//发送数据, 主动发送给指定接收放，例如这里可以主动发给接收方if(sendto(cfd, buf, sizeof(buf), 0, (struct sockaddr*)&sin, sizeof(sin)) < 0){ERR_MSG("sendto");return -1;}printf("sendto success\n");}//关闭套接字close(cfd);return 0;
}
  • 接收方
    #include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>                                                            
#include <arpa/inet.h>
#include <netinet/in.h>
#include <unistd.h>
#include <string.h>#define ERR_MSG(msg) do{\fprintf(stderr, "__%d__ ", __LINE__);\perror(msg);\
}while(0)#define PORT 8888               //端口号的网络字节序，1024~49151
#define IP "192.168.125.255"  //广播int main(int argc, const char *argv[])
{//创建报式套接字int sfd = socket(AF_INET, SOCK_DGRAM, 0);if(sfd < 0){ERR_MSG("socket");return -1;}printf("socket create success sfd=%d\n", sfd);//填充地址信息结构体给bind函数使用//真实的地址信息结构体根据地址族指定 AF_INET: man 7 IPstruct sockaddr_in sin;sin.sin_family      = AF_INET;          //必须填AF_INET;sin.sin_port        = htons(PORT);      //端口号的网络字节序，1024~49151sin.sin_addr.s_addr = inet_addr(IP);    //广播IP//绑定接收方自身的地址信息if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin)) < 0){ERR_MSG("bind");return -1;}printf("bind success\n");struct sockaddr_in cin;     //存储发送放的地址信息socklen_t addrlen =sizeof(cin);char buf[128] = "";ssize_t res = 0;while(1){bzero(buf, sizeof(buf));//接收数据 --->同时存储这个数据包是从哪里来的，即发送的地址res = recvfrom(sfd, buf, sizeof(buf), 0, (struct sockaddr*)&cin, &addrlen);if(res < 0){ERR_MSG("recvfrom");return -1;}printf("[%s:%d] : %s\n", \inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), buf);}//关闭套接字close(sfd);return 0;
}

66.2.3 组播

66.2.3.1 概念

  1. 广播的方式是给同一网段下的所有主机发送数据，过多的广播会占用大量带宽，影响正常通信
  2. 主机之间一对一组的通信方式，只有加入了同一个小组的主机可以接收到此组内的所有数据。
  3. 组播IP：D类IP地址：224.0.0.0~239.255.255.255

66.2.3.2 组播的发送方流程 —》类似UDP客户端

  1. socket 创建报式套接字
  2. bind 非必须绑定
  3. 填充接收方的地址信息，给sendto函数使用
    1. IP：组播IP：224.0.0.0~239.255.255.255
      PS：不允许填0.0.0.0，若接收方发送方均填0.0.0.0，会默认使用127.0.0.1通信)
    2. PORT：需要与接收方绑定的一致。
  4. sendto 发送数据
  5. close 关闭套接字

66.2.3.3 组播的接收方流程 —》类似UDP服务器

  1. socket 创建报式套接字
  2. setsockopt 加入小组（加入多播组）加入的小组与绑定的小组必须一致
    level：IPPROTO_IP
    optname: IP_ADD_MEMBERSHIP
  3. 填充接收方自身的地址信息，给bind函数使用
    1. .IP：组播IP：224.0.0.0-239.255.255.255 或者 0.0.0.0(任意IP地址)
      1. 0.0.0.0：当调用bind函数绑定后，会将本机所有可用IP地址绑定到套接字上。
      2. 所有可用IP：本机IP(192.168.125.5), 127.0.0.1本地环回IP, 广播IP, 组播IP
    2. .PORT：1024~49151范围；
  4. bind 必须绑定
  5. recvfrom 接收数据
  6. close 关闭套接字

66.2.3.4 加入多播组

功能：设置网络属性;
原型：#include <sys/types.h>          /* See NOTES */#include <sys/socket.h>int setsockopt(int sockfd, int level, int optname, const void *optval, socklen_t optlen);
参数：  int sockfd：指定要设置哪个套接字的网络属性;int level：指定要控制的层次等级;IPPROTO_IP:  IPint optname：指定操作名称，选项名称。在第二个参数指定要层次后，该参数用于指定控制该层次的什么;---- IPPROTO_IP : man 7 IP ----1. IP_ADD_MEMBERSHIP     加入组播（多播组）  ----》optval : struct ip_mreqn*类型struct ip_mreqn {struct	in_addr imr_multiaddr; /* IP multicast group address */     指定要加入的组播IP的网络字节序struct	in_addr imr_address;   /* IP address of local interface */  本机IP的网络字节序int		imr_ifindex;   /* interface index */      网络设备索引号（网卡编号）1. ifconfig查看本机的网卡名: ens33。终端输入ip ad找到ens33对应的编号：22. if_nametoindex("网卡名")，返回值就是编号。if_nametoindex("ens33")3. 填0，自动（默认网卡）};void *optval：除非有另外说明，否则optval都是int*类型socklen_t *optlen/socklen_t optlen：optval指针指向的真实的数据类型大小;
返回值：成功，返回0;失败，返回-1，更新errno;

在这里插入图片描述

66.2.3.5 组播示例代码

  • 发送方
    #include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <unistd.h>
#include <string.h>#define ERR_MSG(msg) do{\fprintf(stderr, "__%d__ ", __LINE__);\perror(msg);\
}while(0)                                                                                #define SER_PORT 8888           //接收方绑定的端口号
#define SER_IP "224.1.2.3"  //组播IP : 224.0.0.0-239.255.255.255int main(int argc, const char *argv[])
{//创建报式套接字int cfd = socket(AF_INET, SOCK_DGRAM, 0);if(cfd < 0){ERR_MSG("socket");return -1;}printf("socket create success cfd=%d\n", cfd);//绑定客户端自身的地址信息---》非必须绑定//若不绑定则操作系统会给客户端绑定本机IP及随机端口//填充地址信息结构体给sendto函数使用，想发给谁就填谁的地址信息//真实的地址信息结构体根据地址族指定 AF_INET: man 7 IPstruct sockaddr_in sin;sin.sin_family      = AF_INET;              //必须填AF_INET;sin.sin_port        = htons(SER_PORT);      //组播端口sin.sin_addr.s_addr = inet_addr(SER_IP);    //组播IPchar buf[128] = "";ssize_t res = 0;while(1){bzero(buf, sizeof(buf));printf("请输入>>> ");fgets(buf, sizeof(buf), stdin);buf[strlen(buf)-1] = 0;//发送数据, 主动发送给指定接收放，例如这里可以主动发给接收方if(sendto(cfd, buf, sizeof(buf), 0, (struct sockaddr*)&sin, sizeof(sin)) < 0){ERR_MSG("sendto");return -1;}printf("sendto success\n");}//关闭套接字close(cfd);return 0;
}
  • 接收方
    #include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>                                                                   
#include <netinet/in.h>
#include <unistd.h>
#include <string.h>#define ERR_MSG(msg) do{\fprintf(stderr, "__%d__ ", __LINE__);\perror(msg);\
}while(0)#define PORT 8888               //端口号的网络字节序，1024~49151
#define GRP_IP "224.1.2.3"          //组播IP 224.0.0.0-239.255.255.255
#define LOL_IP "192.168.125.5"      //ifconfig 的本机IPint main(int argc, const char *argv[])
{//创建报式套接字int sfd = socket(AF_INET, SOCK_DGRAM, 0);if(sfd < 0){ERR_MSG("socket");return -1;}printf("socket create success sfd=%d\n", sfd);//加入多播组struct ip_mreqn mq;mq.imr_multiaddr.s_addr = inet_addr(GRP_IP);    //组播IPmq.imr_address.s_addr   = inet_addr(LOL_IP);    //本机IP,ifconfigmq.imr_ifindex = 2;         //网络设备索引号if(setsockopt(sfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mq, sizeof(mq)) < 0){ERR_MSG("setsockopt");return -1;}printf("加入多播组 [%s] 成功\n", GRP_IP);//填充地址信息结构体给bind函数使用//真实的地址信息结构体根据地址族指定 AF_INET: man 7 IPstruct sockaddr_in sin;sin.sin_family      = AF_INET;          //必须填AF_INET;sin.sin_port        = htons(PORT);      //端口号的网络字节序，1024~49151sin.sin_addr.s_addr = inet_addr(GRP_IP);    //组播IP //绑定接收方自身的地址信息if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin)) < 0){ERR_MSG("bind");return -1;}printf("bind success\n");struct sockaddr_in cin;     //存储发送放的地址信息socklen_t addrlen =sizeof(cin);char buf[128] = "";ssize_t res = 0;while(1){bzero(buf, sizeof(buf));//接收数据 --->同时存储这个数据包是从哪里来的，即发送的地址res = recvfrom(sfd, buf, sizeof(buf), 0, (struct sockaddr*)&cin, &addrlen);if(res < 0){ERR_MSG("recvfrom");return -1;}printf("[%s:%d] : %s\n", \inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), buf);}//关闭套接字close(sfd);return 0;
}

这篇关于嵌入式养成计划-30-网络编程----多点通信--单播--广播--组播的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/173132。

相关文章

Linux系统配置NAT网络模式的详细步骤(附图文)

Linux系统配置NAT网络模式的详细步骤(附图文)

《Linux系统配置NAT网络模式的详细步骤(附图文)》本文详细指导如何在VMware环境下配置NAT网络模式,包括设置主机和虚拟机的IP地址、网关,以及针对Linux和Windows系统的具体步骤,... 目录一、配置NAT网络模式二、设置虚拟机交换机网关2.1 打开虚拟机2.2 管理员授权2.3 设置子
阅读更多...
揭秘Python Socket网络编程的7种硬核用法

揭秘Python Socket网络编程的7种硬核用法

《揭秘PythonSocket网络编程的7种硬核用法》Socket不仅能做聊天室,还能干一大堆硬核操作,这篇文章就带大家看看Python网络编程的7种超实用玩法,感兴趣的小伙伴可以跟随小编一起... 目录1.端口扫描器：探测开放端口2.简易 HTTP 服务器：10 秒搭个网页3.局域网游戏：多人联机对战4.
阅读更多...
Java并发编程必备之Synchronized关键字深入解析

Java并发编程必备之Synchronized关键字深入解析

《Java并发编程必备之Synchronized关键字深入解析》本文我们深入探索了Java中的Synchronized关键字,包括其互斥性和可重入性的特性,文章详细介绍了Synchronized的三种... 目录一、前言二、Synchronized关键字2.1 Synchronized的特性1. 互斥2.
阅读更多...
SpringBoot使用OkHttp完成高效网络请求详解

SpringBoot使用OkHttp完成高效网络请求详解

《SpringBoot使用OkHttp完成高效网络请求详解》OkHttp是一个高效的HTTP客户端,支持同步和异步请求,且具备自动处理cookie、缓存和连接池等高级功能,下面我们来看看SpringB... 目录一、OkHttp 简介二、在 Spring Boot 中集成 OkHttp三、封装 OkHttp
阅读更多...
Linux系统之主机网络配置方式

Linux系统之主机网络配置方式

《Linux系统之主机网络配置方式》：本文主要介绍Linux系统之主机网络配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、查看主机的网络参数1、查看主机名2、查看IP地址3、查看网关4、查看DNS二、配置网卡1、修改网卡配置文件2、nmcli工具【通用
阅读更多...
Python异步编程中asyncio.gather的并发控制详解

Python异步编程中asyncio.gather的并发控制详解

《Python异步编程中asyncio.gather的并发控制详解》在Python异步编程生态中,asyncio.gather是并发任务调度的核心工具,本文将通过实际场景和代码示例,展示如何结合信号量... 目录一、asyncio.gather的原始行为解析二、信号量控制法：给并发装上"节流阀"三、进阶控制
阅读更多...
使用Python高效获取网络数据的操作指南

使用Python高效获取网络数据的操作指南

《使用Python高效获取网络数据的操作指南》网络爬虫是一种自动化程序,用于访问和提取网站上的数据,Python是进行网络爬虫开发的理想语言,拥有丰富的库和工具,使得编写和维护爬虫变得简单高效,本文将... 目录网络爬虫的基本概念常用库介绍安装库Requests和BeautifulSoup爬虫开发发送请求解
阅读更多...
shell脚本自动删除30天以前的文件(最新推荐)

shell脚本自动删除30天以前的文件(最新推荐)

《shell脚本自动删除30天以前的文件(最新推荐)》该文章介绍了如何使用Shell脚本自动删除指定目录下30天以前的文件,并通过crontab设置定时任务,此外,还提供了如何使用Shell脚本删除E... 目录shell脚本自动删除30天以前的文件linux按照日期定时删除elasticsearch索引s
阅读更多...
如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解

如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解

《如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别详解》：本文主要介绍如何通过海康威视设备网络SDK进行Java二次开发摄像头车牌识别的相关资料,描述了如何使用海康威视设备网络SD... 目录前言开发流程问题和解决方案dll库加载不到的问题老旧版本sdk不兼容的问题关键实现流程总结前言作为
阅读更多...
TP-Link PDDNS服将于务6月30日正式停运:用户需转向第三方DDNS服务

TP-Link PDDNS服将于务6月30日正式停运:用户需转向第三方DDNS服务

《TP-LinkPDDNS服将于务6月30日正式停运:用户需转向第三方DDNS服务》近期，路由器制造巨头普联（TP-Link）在用户群体中引发了一系列重要变动,上个月，公司发出了一则通知，明确要求所... 路由器厂商普联（TP-Link）上个月发布公告要求所有用户必须完成实名认证后才能继续使用普联提供的 D
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2