udp多播/组播那些事

在这里插入图片描述

多播与组播

多播(multicast)和组播(groupcast)是相同的概念,用于描述在网络中一对多的通信方式。在网络通信中,单播(unicast)是一对一的通信方式,广播(broadcast)是一对所有的通信方式,而多播(或组播)是一对多的通信方式。

多播/组播通信允许一个发送者将数据包同时传输给多个接收者,这些接收者形成一个接收组(receiving group)或多播组(multicast group)。发送者只需发送一次数据包,而不需要为每个接收者单独发送。

只存在于udp

UDP协议支持多播和广播,而TCP协议不直接支持广播和多播。

UDP协议是一种无连接的协议,它允许应用程序通过多播地址或广播地址发送数据包。多播地址是一个预定义的IP地址范围,用于标识多播组,而广播地址则是一个特殊的IP地址,用于向网络中的所有主机发送数据包。

在UDP中,你可以使用特定的套接字选项设置多播地址,并使用sendto()函数发送数据包到多播组。接收端可以通过加入相同的多播组地址,使用recvfrom()函数接收多播数据包。

相比之下,TCP协议是一种面向连接的协议,它提供可靠的、有序的数据传输。TCP协议不直接支持多播和广播功能,因为它是基于点对点通信模型的,只能通过建立一对一的连接进行数据传输。

多播接收端程序

以下是一个使用C语言编写的简单示例,用于接收和发送多播数据包:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>#define MULTICAST_GROUP "239.0.0.1" // 多播组地址
#define PORT 12345                 // 多播组的端口号
#define MAX_BUFFER_SIZE 1024       // 接收缓冲区大小int main() {int sockfd;struct sockaddr_in multicastAddr;struct sockaddr_in clientAddr;char buffer[MAX_BUFFER_SIZE];// 创建UDP套接字sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0) {perror("socket creation failed");exit(EXIT_FAILURE);}// 设置套接字选项,允许接收多播数据int enable = 1;if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &enable, sizeof(enable)) < 0) {perror("setsockopt SO_REUSEADDR failed");exit(EXIT_FAILURE);}// 绑定到本地地址和端口memset(&clientAddr, 0, sizeof(clientAddr));clientAddr.sin_family = AF_INET;clientAddr.sin_addr.s_addr = INADDR_ANY;clientAddr.sin_port = htons(PORT);if (bind(sockfd, (struct sockaddr *)&clientAddr, sizeof(clientAddr)) < 0) {perror("bind failed");exit(EXIT_FAILURE);}// 加入多播组struct ip_mreq multicastReq;multicastReq.imr_multiaddr.s_addr = inet_addr(MULTICAST_GROUP);multicastReq.imr_interface.s_addr = htonl(INADDR_ANY);if (setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char *)&multicastReq, sizeof(multicastReq)) < 0) {perror("setsockopt IP_ADD_MEMBERSHIP failed");exit(EXIT_FAILURE);}printf("Waiting for multicast messages...\n");while (1) {// 接收多播数据包socklen_t addrLen = sizeof(multicastAddr);ssize_t recvLen = recvfrom(sockfd, buffer, sizeof(buffer), 0, (struct sockaddr *)&multicastAddr, &addrLen);if (recvLen < 0) {perror("recvfrom failed");exit(EXIT_FAILURE);}buffer[recvLen] = '\0';printf("Received multicast message: %s\n", buffer);}// 关闭套接字close(sockfd);return 0;
}

在该示例中,我们使用socket()函数创建了一个UDP套接字,并使用setsockopt()函数设置了SO_REUSEADDR选项,以便允许套接字重新使用本地地址。然后,我们使用bind()函数将套接字绑定到本地地址和端口。

接下来,我们使用IP_ADD_MEMBERSHIP选项加入多播组,指定了多播组地址和本地网络接口。这样,套接字就可以接收到发送到指定多播组的数据包。

最后,我们使用一个循环来持续接收多播数据包。使用recvfrom()函数从套接字接收数据包,并打印接收到的消息。

请注意,接收端和发送端应该使用相同的多播组地址和端口号以进行通信。

多播发送断程序

以下是一个使用C语言编写的简单多播发送示例:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>#define MULTICAST_GROUP "239.0.0.1" // 多播组地址
#define PORT 12345                 // 多播组的端口号int main() {int sockfd;struct sockaddr_in multicastAddr;char *message = "Hello, Multicast!";// 创建UDP套接字sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0) {perror("socket creation failed");exit(EXIT_FAILURE);}// 设置多播组地址和端口号memset(&multicastAddr, 0, sizeof(multicastAddr));multicastAddr.sin_family = AF_INET;multicastAddr.sin_addr.s_addr = inet_addr(MULTICAST_GROUP);multicastAddr.sin_port = htons(PORT);// 发送多播数据包if (sendto(sockfd, message, strlen(message), 0, (struct sockaddr *)&multicastAddr, sizeof(multicastAddr)) < 0) {perror("sendto failed");exit(EXIT_FAILURE);}printf("Multicast message sent.\n");// 关闭套接字close(sockfd);return 0;
}

在这个示例中,我们创建了一个UDP套接字,并设置了多播组的地址和端口号。然后,使用sendto()函数将消息发送到多播组的地址。最后,关闭套接字。

注意事项

对于发送多播数据包的示例,不需要显式地绑定本地端口。

在发送端,我们只需创建一个UDP套接字并将数据包发送到多播组的地址。操作系统会自动选择一个本地端口进行发送。

接收端需要绑定本地端口是因为它需要告诉操作系统将接收到的多播数据包发送到哪个端口。

当接收端加入一个多播组时,它需要指定一个本地端口来接收多播数据包。通过将套接字绑定到一个特定的本地端口,操作系统会将接收到的多播数据包传递给该端口上运行的应用程序。

绑定本地端口的步骤通常在接收端的代码中进行,以便接收来自多播组的数据包。在之前提供的多播接收示例中,我们在接收端的代码中使用bind()函数将套接字绑定到本地地址和端口。

简而言之,接收端绑定本地端口是为了告诉操作系统将接收到的多播数据包传递给相应的应用程序,而发送端无需显式地绑定本地端口,操作系统会自动选择一个可用的本地端口进行发送。

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

IDEA相关操作

目录 连接MySQL IDEA配置Maven 配置全局Maven 导入Maven项目 方法一 方法二 安装Mybatisx插件 连接MySQL 填写user和Password之后测试连接 如果是第一次连接需要联网下载数据库连接驱动&#xff0c;安装提示下载即可 如果显示如下错误需要更改时区 Server returns …

count distinct在spark中的运行机制

文章目录 预备 数据和执行语句Expand第一次HashAggregateShuffle and Second HashAggregate最后结果性能原文 预备 数据和执行语句 SELECT COUNT(*), SUM(items), COUNT(DISTINCT product), COUNT(DISTINCT category) FROM orders;假设源数据分布在两个1核的结点上&#xff0…

【DevOps 工具链】软件版本号命名规范 - 3种规则(读这一篇就够了)

文章目录 1、简述2、常见软件的版本号命名规则3、版本号命名规范整理3.1、XYZ/MMP3.1.1、规则3.1.2、确定3.1.3、举例3.1.4、详细规则 3.2、XYZD/MMPD3.3、VRC3.3.1、规则3.3.2、对"Vxxx"的说明3.3.3、对"Rxxx"的说明3.3.4、对"LLL"的说明3.3.5、…

算法导论复习(四)主方法的专题

主方法我们要记住的是什么呢&#xff1f;

Java原来可以这么玩!CV实现多张图片生成视频

前言 比如我像将几张图片变成一个视频的形式发不到短视频平台&#xff0c;虽然短视频平台也有上传图片变成视频的功能&#xff0c;但是我想要具体控制每张图片显示多久后切换到下一个图片&#xff0c;短视频平台目前无法实现&#xff0c;于是乎&#xff0c;我用java代码实现了…

2023版本QT学习记录 -6- UDP通信之UDP接收端

———————UDP接收端——————— &#x1f384;动图演示 &#x1f384;发送端通信步骤思维导图 &#x1f384;添加组件 QT core gui network&#x1f384;添加头文件 #include "qudpsocket.h"&#x1f384;创建接收对象 QUdpSocket *recvsocket;&…

JAVA JDK8时间类之Period、Duration、ChronoUnit的使用【详解】

JAVA JDK8时间类之Period、Duration、ChronoUnit的使用 1. Duration1.1 简介&#xff1a;用于时间间隔(秒、毫秒、纳秒等)1.2 案例 2. Period时间间隔(年、月、日)2.1 简介2.2 案例 3. ChronoUnit3.1 简介案例 4. 案例所有代码&#xff1a; 1. Duration 1.1 简介&#xff1a;用…

基于AT89C51单片机的8位密码锁仿真与实物制作

点击链接获取Keil源码与Project Backups仿真图&#xff1a; https://download.csdn.net/download/qq_64505944/88657969?spm1001.2014.3001.5503 源码获取 C 源码仿真图毕业设计实物制作步骤01 摘要 在日常的生活和工作中, 住宅与部门的安全防范、单位的文件档案、财务报表…

Python如何使用数据库的连接池

Python 数据库连接池 python编程中可以使用pymysql进行数据库连接及增删改查操作&#xff0c;但每次连接mysql请求时&#xff0c;都是独立的去请求访问&#xff0c;比较浪费资源&#xff0c;而且访问数量达到一定数量时&#xff0c;对mysql的性能会产生较大的影响。因此实际使…

QT trimmed和simplified

trimmed&#xff1a;去除了字符串开头前和结尾后的空白&#xff1b; simplified&#xff1a;去除了字符串开头前和结尾后的空白&#xff0c;以及中间内部的空白字符也去掉&#xff08;\t,\n,\v,\f,\r和 &#xff09; 代码&#xff1a; QString str " 1 2 3 4 5 …

主机安全技术措施

目录 身份鉴别 进阶 访问控制 进阶 安全审计 进阶 ​编辑 剩余信息保护 入侵防范 进阶 恶意代码防范 资源控制 身份鉴别 进阶 访问控制 进阶 安全审计 进阶 剩余信息保护 入侵防范 进阶 恶意代码防范 资源控制 ~over~

PaddleOCR 的使用,极简介绍

安装 参考github的官网就可以&#xff1a; github链接 简单的说&#xff0c;就是两句话&#xff1a; python3 -m pip install paddlepaddle-gpu -i https://mirror.baidu.com/pypi/simple pip install "paddleocr>2.0.1" # 推荐使用2.0.1版本 Python下的使用…