UDP的组播发送与接收C语言测试和nc接收组播测试

组播这个东西,很多年前用过一次。本身的原理不复杂,未知的是使用的环境,受使用环境的影响有多大,还是那句废话,具体问题具体分析。

发送端代码multicast.c

#include <stdio.h>  
#include <stdlib.h>  
#include <string.h>  
#include <unistd.h>  
#include <sys/types.h>  
#include <sys/socket.h>  
#include <netinet/in.h>  
#include <arpa/inet.h>  
#include <netdb.h>  
  
#define MULTICAST_ADDR "224.0.0.1" // 组播地址  
#define MULTICAST_PORT 9990       // 组播端口  
  
int main(int argc, char *argv[]) {  
    int sockfd;  
    struct sockaddr_in local,addr;  
    char message[] = "Hello, multicast!";  
  
    // 1. 创建UDP套接字  
    if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {  
        perror("socket creation failed");  
        exit(EXIT_FAILURE);  
    }  
  
    // 2. 设置套接字选项以允许组播  
    int reuse = 1;  
    if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0) {  
        perror("setsockopt (SO_REUSEADDR) failed");  
        exit(EXIT_FAILURE);  
    }

    int yes = 1;  
    if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) {  
        perror("setsockopt");  
        exit(1);  
    }  
  
    // 3. 绑定套接字(可选,通常不需要)  
    // ...  
    local.sin_family = AF_INET;  
    // 假设你想绑定到本地的IP地址 "192.168.1.100",你可以通过inet_addr或inet_pton来设置  
    local.sin_addr.s_addr = inet_addr("192.168.0.3");  
    // 或者使用inet_pton来处理IPv6地址  
    // if (inet_pton(AF_INET, "192.168.0.3", &serv_addr.sin_addr) <= 0) {  
    //     perror("inet_pton failed");  
    //     exit(EXIT_FAILURE);  
    // }  
    local.sin_port = htons(12345); // 假设端口是12345  
  
    // 4. 构造组播地址结构  
    memset(&addr, 0, sizeof(addr));  
    addr.sin_family = AF_INET;  
    addr.sin_addr.s_addr = inet_addr(MULTICAST_ADDR);  
    addr.sin_port = htons(MULTICAST_PORT);  
  
    // 5. 发送数据  
    if (sendto(sockfd, message, strlen(message), 0, (const struct sockaddr *)&addr, sizeof(addr)) < 0) {  
        perror("sendto failed");  
        exit(EXIT_FAILURE);  
    }  
  
    // 6. 接收数据(如果需要)  
    // ...  
  
    // 7. 关闭套接字  
    close(sockfd);  
  
    return 0;  
}

接收端代码multicast_recv.c

#include <stdio.h>  
#include <stdlib.h>  
#include <string.h>  
#include <unistd.h>  
#include <sys/types.h>  
#include <sys/socket.h>  
#include <netinet/in.h>  
#include <arpa/inet.h>  
#include <netdb.h>  
  
#define MULTICAST_ADDR "224.0.0.1" // 组播地址  
#define MULTICAST_PORT 9990       // 组播端口  
#define BUFFER_SIZE 1024            // 接收缓冲区大小  
  
int main(int argc, char *argv[]) {  
    int sockfd;  
    struct sockaddr_in addr;  
    char buffer[BUFFER_SIZE];  
    struct ip_mreq mreq;  
    socklen_t addrlen = sizeof(addr);  
  
    // 1. 创建UDP套接字  
    if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {  
        perror("socket creation failed");  
        exit(EXIT_FAILURE);  
    }  

    int yes = 1;  
    if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) {  
        perror("setsockopt");  
        exit(1);  
    }
  
    // 2. 设置组播地址和端口  
    memset(&addr, 0, sizeof(addr));  
    addr.sin_family = AF_INET;  
    addr.sin_addr.s_addr = htonl(INADDR_ANY); // 绑定到所有可用的网络接口  
    addr.sin_port = htons(MULTICAST_PORT);  
  
    // 3. 绑定套接字(如果需要特定的端口,就绑定;否则,通常不需要绑定)  
    if (bind(sockfd, (struct sockaddr *)&addr, sizeof(addr)) < 0) {  
        perror("bind failed");  
        exit(EXIT_FAILURE);  
    }  
  
    // 4. 设置组播选项  
    mreq.imr_multiaddr.s_addr = inet_addr(MULTICAST_ADDR);  
    mreq.imr_interface.s_addr = htonl(INADDR_ANY); // 或者设置为特定的网络接口IP  
  
    if (setsockopt(sockfd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) < 0) {  
        perror("setsockopt failed");  
        exit(EXIT_FAILURE);  
    }  
  
    // 5. 接收数据  
    printf("Waiting for multicast packets...\n");  
    while (1) {  
        int nbytes = recvfrom(sockfd, buffer, BUFFER_SIZE, 0, (struct sockaddr *)&addr, &addrlen);  
        if (nbytes < 0) {  
            perror("recvfrom failed");  
            exit(EXIT_FAILURE);  
        }  
  
        buffer[nbytes] = '\0'; // 确保字符串以null字符结尾  
        printf("Received: %s\n", buffer);  
    }  
  
    // 6. 关闭套接字(注意:由于我们在一个无限循环中,这行代码实际上不会被执行)  
    close(sockfd);  
  
    return 0;  
}

编译脚本:

#!/bin/bash

echo "hello"
source /opt/fsl-imx-xwayland/5.4-zeus/environment-setup-aarch64-poky-linux
echo $ARCH
aarch64-poky-linux-gcc --sysroot=/opt/fsl-imx-xwayland/5.4-zeus/sysroots/aarch64-poky-linux multicast.c -o multicast
gcc multicast_recv.c -o multicast_recv
sudo cp multicast /home/lkmao/nfsroot/yocto/home/root/
#make
exit 0

设置网关:

测试发现,如果不设置网关,组播数据发不出去。

 route add default gw 192.168.0.1 dev eth1

root@imx8mpevk:~# route add default gw 192.168.0.1 dev eth1
root@imx8mpevk:~# route -n
Kernel IP routing table
Destination     Gateway         Genmask         Flags Metric Ref    Use Iface
0.0.0.0         192.168.0.1     0.0.0.0         UG    0      0        0 eth1
0.0.0.0         0.0.0.0         0.0.0.0         U     0      0        0 eth0
169.254.0.0     0.0.0.0         255.255.0.0     U     0      0        0 eth0
192.168.0.0     0.0.0.0         255.255.255.0   U     0      0        0 eth1
root@imx8mpevk:~#

测试结果

使用nc作为接收端测试

测试的时候,发现,直接监听udp的9990端口就可以,这个有点诧异啊。

nc -ul 9990

组播地址查看

ip maddr show  

开发板的地址: 

root@imx8mpevk:~# ip maddr show dev eth1
3:      eth1
        link  33:33:00:00:00:01
        link  01:00:5e:00:00:01
        link  33:33:ff:07:0b:a5
        link  33:33:00:00:02:02
        link  33:33:00:00:00:fb
        link  01:00:5e:00:00:fb
        inet  224.0.0.251
        inet  224.0.0.1
        inet6 ff02::fb
        inet6 ff02::202
        inet6 ff02::1:ff07:ba5
        inet6 ff02::1
        inet6 ff01::1
root@imx8mpevk:~#

ubuntu的广播查询:

lkmao@lkmao-virtual-machine:~$ ip maddr show dev ens33
2:      ens33
        link  01:00:5e:00:00:01
        link  33:33:00:00:00:01
        link  33:33:ff:9a:b7:5a
        link  01:00:5e:00:00:fb
        link  33:33:00:00:00:fb
        inet  224.0.0.251
        inet  224.0.0.1
        inet6 ff02::fb
        inet6 ff02::1:ff9a:b75a
        inet6 ff02::1
        inet6 ff01::1
lkmao@lkmao-virtual-machine:~$

 根据执行命令可知,默认的组播组都是224.0.0.1,这也说明了,为什么直接执行nc -ul 9990可以接收到组播数据。

小结

这个还得具体问题具体分析吧。

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

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

相关文章

MySQL常见面试题自测

文章目录 MySQL基础架构一、说说 MySQL 的架构&#xff1f;二、一条 SQL语句在MySQL中的执行过程 MySQL存储引擎一、MySQL 提供了哪些存储引擎&#xff1f;二、MySQL 存储引擎架构了解吗&#xff1f;三、MyISAM 和 InnoDB 的区别&#xff1f; MySQL 事务一、何谓事务&#xff1…

从老花眼开始

三年前&#xff0c;博主的的火眼金睛开始老花了&#xff0c;表现就是看近处看不清了。人眼对可视距离的标准可以定义为&#xff1a;看手机为近距离&#xff0c;看电脑为中距离&#xff0c;看电视为中距离&#xff0c;看红绿灯为远距离。老花眼就是戴近视眼镜直接看手机看不清了…

苍穹外卖---导入接口文档

一、前后端分离开发流程 第一步&#xff1a;定义接口&#xff0c;确定接口的路径、请求方式、传入参数、返回参数。 第二步&#xff1a;前端开发人员和后端开发人员并行开发&#xff0c;同时&#xff0c;也可自测。 第三步&#xff1a;前后端人员进行连调测试。 第四步&…

嵌入式中间件_3.嵌入式中间件的一般架构

根据嵌入式中间件的不同类型和其应用对象的不同&#xff0c;其架构也有所不同&#xff0c;通常嵌入式中间件没有统一的架构&#xff0c;这里仅仅列举两种中间件架构。 1.消息中间件 1.1消息中间件原理架构 消息中间件是消息传输过程中保存消息的一种容器。它将消息从它的源中…

一文学会消息中间件的基础知识

什么是消息队列 队列数据结构 我们都学习过数据结构与算法相关的内容,消息队列从数据结构来看,就是一个由链表或是数组构成的一个先进先出的数据容器。由链表实现还是数组实现都没关系,它只要满足数据项是先进先出的特点,那么就可以认为它是一个队列结构。队列是只允许在…

使用Notes客户机高效工作

大家好&#xff0c;才是真的好。 年纪越大&#xff0c;发现每天时间越不够用。突然想到一个好办法&#xff0c;找相关书看&#xff0c;学习一下高效工作和生活管理。 刚好&#xff0c;就看到一本《每天节省2小时》&#xff0c;2013年出版&#xff0c;作者是肯尼斯齐格勒。其中…

JupyterLab使用指南(四):JupyterLab的Magic 命令

1. 什么是 Magic 命令 Magic 命令是 JupyterLab 中的一类特殊命令&#xff0c;用于简化和增强代码的执行。它们以 % 或 %% 开头&#xff0c;可以进行各种操作&#xff0c;如时间测量、环境设置、文件操作等。Magic 命令分为行 Magic 命令和单元 Magic 命令两种。 行 Magic 命…

Hi3861 OpenHarmony嵌入式应用入门--中断按键

本篇讲解gpio的中断使用方式。 硬件原理图如下&#xff0c;与上一篇一样的电路 GPIO API API名称 说明 hi_u32 hi_gpio_init(hi_void); GPIO模块初始化 hi_u32 hi_io_set_pull(hi_io_name id, hi_io_pull val); 设置某个IO上下拉功能。 hi_u32 hi_gpio_set_dir(hi_gpio_…

QT day4(对话框 事件机制)

1&#xff1a;思维导图 2&#xff1a; #include "widget.h" #include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget) {ui->setupUi(this);ui->setupUi(this);//去除头部this->setWindowFlag(Qt::Frameles…

找单身狗2

找单身狗2 之前遇到类似的题目的思路&#xff1a; 首先写出这些数的二进制形式&#xff1a; 核心原理 接下来的问题是怎么把5和6分开来&#xff1f; 这里是最后一位进行比较&#xff0c;按位异或是相同为0&#xff0c;相异为1&#xff0c;最后一位从上图看出是1&#xff0c;说…

go 语言爬虫库goQuery 的详细使用(知乎日报详情页解析示例)

上一篇《uniapp小程序开发 | 从零实现一款影视类app 》实现了影视小程序的前端和后台接口&#xff0c;虽然包含了大多数小程序应有的知识&#xff0c;但基本还只是涉及网络接口和vue页面的设计。这里介绍下零一个有趣的练手项目&#xff0c;知乎日报。涉及详情页面的html解析&a…

python是TIOBE编程语言排名第一的编程语言,它有什么优点?它的使用场景有哪些?用python打印数字1--100,用python打印九九乘法表怎么写?

Python是TIOBE编程语言排行榜排名第一的编程语言 。 python是一种解释性、交互式、面向对象的跨平台的语言。 python设计者及名称由来 Guido van Rossum 荷兰人---吉多范罗苏姆&#xff0c;是 Python 编程语言的最初设计者&#xff0c;在 Python 社区一直担当终身仁慈独裁者&…

据阿谱尔APO Research调研显示,2023年全球水凝胶市场销售额约为14.2亿美元

根据阿谱尔 (APO Research&#xff09;的统计及预测&#xff0c;2023年全球水凝胶市场销售额约为14.2亿美元&#xff0c;预计在2024-2030年预测期内将以超过5.0%的CAGR&#xff08;年复合增长率&#xff09;增长。 水凝胶有多种应用&#xff0c;包括个人护理、制药、农业及其他…

JavaFX 分页

分页控件用于浏览多个页面。 我们典型地使用对网页的分页控制&#xff0c;例如博客。 在博客页面的底部&#xff0c;我们可以看到一个矩形区域&#xff0c;作为一个数字列表来指示页面索引&#xff0c;以及一个下一个/上一个按钮来链接到下一个/上一个页面。 创建分页控件 分…

保姆级小白就业人工智能(视频+源码+笔记)

&#x1f345;我是小宋&#xff0c; Java学习AI&#xff0c;记录学习之旅。关注我&#xff0c;带你轻松过面试。提升简历亮点&#xff08;14个demo&#xff09; &#x1f345;我的java面试合集已有12W 浏览量。&#x1f30f;号&#xff1a;tutou123com。拉你进专属群。 ⭐⭐你的…

vcs覆盖率相关

查看覆盖率是由哪几个tc覆盖的 选择要查看的覆盖率点&#xff0c;右键选择 show xxx tests&#xff1b; 覆盖率的合并

ARM32开发——中断

&#x1f3ac; 秋野酱&#xff1a;《个人主页》 &#x1f525; 个人专栏:《Java专栏》《Python专栏》 ⛺️心若有所向往,何惧道阻且长 文章目录 中断概念中断分类中断触发条件 中断概念 中断是计算机系统中的一种机制&#xff0c;用于响应外部事件或内部事件,它可以使单片机暂…

四川赤橙宏海商务信息咨询有限公司正规吗?

在数字化浪潮席卷全球的今天&#xff0c;电商行业正以前所未有的速度蓬勃发展。作为这一潮流的佼佼者&#xff0c;抖音电商以其独特的短视频直播模式&#xff0c;吸引了大量消费者和商家的目光。在这一背景下&#xff0c;四川赤橙宏海商务信息咨询有限公司应运而生&#xff0c;…

属于PCIe 7.0的那道光来了~

随着数据洪流的持续涌动与计算密集型应用的爆发式增长&#xff0c;传统的电子互连技术在应对高带宽、低延迟、节能等多维度需求时日益显现其局限性。在这个背景下&#xff0c;光学互连技术以其独特的性能优势&#xff0c;逐渐成为业界瞩目的焦点&#xff0c;被视为未来数据中心…

Android开发系列(三)Jetpack Compose 之TextField

TextField 是一个用于接收用户输入的UI组件。它是Jetpack Compose中的一部分&#xff0c;可以方便地实现用户文本输入的功能。 TextField 允许用户输入一个或多个文本行&#xff0c;可以用于接收用户的文本输入、搜索等操作。它提供了一些常用的功能&#xff0c;如输入验证、键…