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

相关文章

C语言中%zu的用法解读

《C语言中%zu的用法解读》size_t是无符号整数类型,用于表示对象大小或内存操作结果,%zu是C99标准中专为size_t设计的printf占位符,避免因类型不匹配导致错误,使用%u或%d可能引发... 目录size_t 类型与 %zu 占位符%zu 的用途替代占位符的风险兼容性说明其他相关占位符验证示

C语言进阶(预处理命令详解)

《C语言进阶(预处理命令详解)》文章讲解了宏定义规范、头文件包含方式及条件编译应用,强调带参宏需加括号避免计算错误,头文件应声明函数原型以便主函数调用,条件编译通过宏定义控制代码编译,适用于测试与模块... 目录1.宏定义1.1不带参宏1.2带参宏2.头文件的包含2.1头文件中的内容2.2工程结构3.条件编

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont

Go语言编译环境设置教程

《Go语言编译环境设置教程》Go语言支持高并发(goroutine)、自动垃圾回收,编译为跨平台二进制文件,云原生兼容且社区活跃,开发便捷,内置测试与vet工具辅助检测错误,依赖模块化管理,提升开发效... 目录Go语言优势下载 Go  配置编译环境配置 GOPROXYIDE 设置(VS Code)一些基本

深入理解Go语言中二维切片的使用

《深入理解Go语言中二维切片的使用》本文深入讲解了Go语言中二维切片的概念与应用,用于表示矩阵、表格等二维数据结构,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧... 目录引言二维切片的基本概念定义创建二维切片二维切片的操作访问元素修改元素遍历二维切片二维切片的动态调整追加行动态

Go语言中make和new的区别及说明

《Go语言中make和new的区别及说明》:本文主要介绍Go语言中make和new的区别及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1 概述2 new 函数2.1 功能2.2 语法2.3 初始化案例3 make 函数3.1 功能3.2 语法3.3 初始化

Go语言中nil判断的注意事项(最新推荐)

《Go语言中nil判断的注意事项(最新推荐)》本文给大家介绍Go语言中nil判断的注意事项,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录1.接口变量的特殊行为2.nil的合法类型3.nil值的实用行为4.自定义类型与nil5.反射判断nil6.函数返回的

Go语言数据库编程GORM 的基本使用详解

《Go语言数据库编程GORM的基本使用详解》GORM是Go语言流行的ORM框架,封装database/sql,支持自动迁移、关联、事务等,提供CRUD、条件查询、钩子函数、日志等功能,简化数据库操作... 目录一、安装与初始化1. 安装 GORM 及数据库驱动2. 建立数据库连接二、定义模型结构体三、自动迁

Go语言代码格式化的技巧分享

《Go语言代码格式化的技巧分享》在Go语言的开发过程中,代码格式化是一个看似细微却至关重要的环节,良好的代码格式化不仅能提升代码的可读性,还能促进团队协作,减少因代码风格差异引发的问题,Go在代码格式... 目录一、Go 语言代码格式化的重要性二、Go 语言代码格式化工具:gofmt 与 go fmt(一)

使用Python进行GRPC和Dubbo协议的高级测试

《使用Python进行GRPC和Dubbo协议的高级测试》GRPC(GoogleRemoteProcedureCall)是一种高性能、开源的远程过程调用(RPC)框架,Dubbo是一种高性能的分布式服... 目录01 GRPC测试安装gRPC编写.proto文件实现服务02 Dubbo测试1. 安装Dubb