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

2024-06-14 17:12

本文主要是介绍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/bashecho "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:      eth1link  33:33:00:00:00:01link  01:00:5e:00:00:01link  33:33:ff:07:0b:a5link  33:33:00:00:02:02link  33:33:00:00:00:fblink  01:00:5e:00:00:fbinet  224.0.0.251inet  224.0.0.1inet6 ff02::fbinet6 ff02::202inet6 ff02::1:ff07:ba5inet6 ff02::1inet6 ff01::1
root@imx8mpevk:~#

ubuntu的广播查询:

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

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

小结

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

这篇关于UDP的组播发送与接收C语言测试和nc接收组播测试的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1061021

相关文章

性能测试介绍

性能测试是一种测试方法,旨在评估系统、应用程序或组件在现实场景中的性能表现和可靠性。它通常用于衡量系统在不同负载条件下的响应时间、吞吐量、资源利用率、稳定性和可扩展性等关键指标。 为什么要进行性能测试 通过性能测试,可以确定系统是否能够满足预期的性能要求,找出性能瓶颈和潜在的问题,并进行优化和调整。 发现性能瓶颈:性能测试可以帮助发现系统的性能瓶颈,即系统在高负载或高并发情况下可能出现的问题

字节面试 | 如何测试RocketMQ、RocketMQ?

字节面试:RocketMQ是怎么测试的呢? 答: 首先保证消息的消费正确、设计逆向用例,在验证消息内容为空等情况时的消费正确性; 推送大批量MQ,通过Admin控制台查看MQ消费的情况,是否出现消费假死、TPS是否正常等等问题。(上述都是临场发挥,但是RocketMQ真正的测试点,还真的需要探讨) 01 先了解RocketMQ 作为测试也是要简单了解RocketMQ。简单来说,就是一个分

【测试】输入正确用户名和密码,点击登录没有响应的可能性原因

目录 一、前端问题 1. 界面交互问题 2. 输入数据校验问题 二、网络问题 1. 网络连接中断 2. 代理设置问题 三、后端问题 1. 服务器故障 2. 数据库问题 3. 权限问题: 四、其他问题 1. 缓存问题 2. 第三方服务问题 3. 配置问题 一、前端问题 1. 界面交互问题 登录按钮的点击事件未正确绑定,导致点击后无法触发登录操作。 页面可能存在

科研绘图系列:R语言扩展物种堆积图(Extended Stacked Barplot)

介绍 R语言的扩展物种堆积图是一种数据可视化工具,它不仅展示了物种的堆积结果,还整合了不同样本分组之间的差异性分析结果。这种图形表示方法能够直观地比较不同物种在各个分组中的显著性差异,为研究者提供了一种有效的数据解读方式。 加载R包 knitr::opts_chunk$set(warning = F, message = F)library(tidyverse)library(phyl

透彻!驯服大型语言模型(LLMs)的五种方法,及具体方法选择思路

引言 随着时间的发展,大型语言模型不再停留在演示阶段而是逐步面向生产系统的应用,随着人们期望的不断增加,目标也发生了巨大的变化。在短短的几个月的时间里,人们对大模型的认识已经从对其zero-shot能力感到惊讶,转变为考虑改进模型质量、提高模型可用性。 「大语言模型(LLMs)其实就是利用高容量的模型架构(例如Transformer)对海量的、多种多样的数据分布进行建模得到,它包含了大量的先验

业务中14个需要进行A/B测试的时刻[信息图]

在本指南中,我们将全面了解有关 A/B测试 的所有内容。 我们将介绍不同类型的A/B测试,如何有效地规划和启动测试,如何评估测试是否成功,您应该关注哪些指标,多年来我们发现的常见错误等等。 什么是A/B测试? A/B测试(有时称为“分割测试”)是一种实验类型,其中您创建两种或多种内容变体——如登录页面、电子邮件或广告——并将它们显示给不同的受众群体,以查看哪一种效果最好。 本质上,A/B测

C语言 | Leetcode C语言题解之第393题UTF-8编码验证

题目: 题解: static const int MASK1 = 1 << 7;static const int MASK2 = (1 << 7) + (1 << 6);bool isValid(int num) {return (num & MASK2) == MASK1;}int getBytes(int num) {if ((num & MASK1) == 0) {return

MiniGPT-3D, 首个高效的3D点云大语言模型,仅需一张RTX3090显卡,训练一天时间,已开源

项目主页:https://tangyuan96.github.io/minigpt_3d_project_page/ 代码:https://github.com/TangYuan96/MiniGPT-3D 论文:https://arxiv.org/pdf/2405.01413 MiniGPT-3D在多个任务上取得了SoTA,被ACM MM2024接收,只拥有47.8M的可训练参数,在一张RTX

如何确定 Go 语言中 HTTP 连接池的最佳参数?

确定 Go 语言中 HTTP 连接池的最佳参数可以通过以下几种方式: 一、分析应用场景和需求 并发请求量: 确定应用程序在特定时间段内可能同时发起的 HTTP 请求数量。如果并发请求量很高,需要设置较大的连接池参数以满足需求。例如,对于一个高并发的 Web 服务,可能同时有数百个请求在处理,此时需要较大的连接池大小。可以通过压力测试工具模拟高并发场景,观察系统在不同并发请求下的性能表现,从而

C语言:柔性数组

数组定义 柔性数组 err int arr[0] = {0}; // ERROR 柔性数组 // 常见struct Test{int len;char arr[1024];} // 柔性数组struct Test{int len;char arr[0];}struct Test *t;t = malloc(sizeof(Test) + 11);strcpy(t->arr,