一、UDP 组播核心概念

UDP 通信有三种典型模式，组播是单播和广播的中间形态，能精准向指定一组主机通信，大幅节省网络带宽：

组播核心特性

1. 一台主机可同时加入多个组播组；
2. 组播既支持局域网通信，也可用于广域网（需路由器支持组播路由）；
3. 组播 / 广播属性默认关闭，需通过setsockopt()手动开启；
4. 多播地址仅能作为目的地址，不能作为源地址（和广播地址特性一致）；

二、IPv4 组播地址（D 类地址）

IP 组播通信依赖专属的 D 类 IP 地址，范围224.0.0.0 ~ 239.255.255.255，分为三类：

三、UDP 组播代码实现

3.1 发送方（Sender.cpp）

核心要点：

• 无需绑定（bind）端口；
• 目标地址使用组播地址（示例：224.0.0.88）；
• 循环发送组播数据，模拟持续推送场景。

#include <stdio.h> #include <string.h> #include <stdlib.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <unistd.h> int main(void) { char buf[BUFSIZ]; // 1. 创建UDP套接字 int sockfd = socket(AF_INET, SOCK_DGRAM, 0); if (-1 == sockfd) { perror("socket"); exit(1); } // 2. 配置组播目标地址（组播地址+端口） struct sockaddr_in peer; peer.sin_family = AF_INET; // IPv4协议 peer.sin_port = htons(9000); // 组播端口（需和接收方一致） peer.sin_addr.s_addr = inet_addr("224.0.0.88"); // 组播地址 printf("准备发送组播数据...\n"); // 3. 循环发送组播消息（模拟持续推送） for (int i = 1; ; i++) { sprintf(buf, "新年好,第 %d 次问候！", i); int ret = sendto(sockfd, buf, strlen(buf), 0, (struct sockaddr*)&peer, sizeof(peer)); printf("had send %d bytes: %s\n", ret, buf); sleep(1); // 每秒发送一次 } close(sockfd); // 实际循环不会执行到这里 return 0; }

3.2 接收方（Receiver.cpp）

核心要点：

• 必须绑定（bind）端口和INADDR_ANY地址；
• 通过IP_ADD_MEMBERSHIP加入指定组播组；
• 接收指定次数数据后，通过IP_DROP_MEMBERSHIP退出组播组；
• 测试退出组播组后是否还能接收组播数据。

#include <stdio.h> #include <string.h> #include <stdlib.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <unistd.h> int main(void) { char buf[BUFSIZ]; // 1. 创建UDP套接字 int sockfd = socket(AF_INET, SOCK_DGRAM, 0); if (-1 == sockfd) { perror("socket"); exit(1); } // 2. 绑定端口（接收方必须bind） struct sockaddr_in addr; addr.sin_family = AF_INET; // IPv4协议 addr.sin_port = htons(9000); // 和发送方一致的组播端口 addr.sin_addr.s_addr = INADDR_ANY; // 接收本机所有网卡的组播数据 int ret = bind(sockfd, (struct sockaddr*)&addr, sizeof(addr)); if (-1 == ret) { perror("bind"); exit(1); } // 3. 配置组播组信息（要加入的组播地址+本地网卡） struct ip_mreq req; req.imr_multiaddr.s_addr = inet_addr("224.0.0.88"); // 要加入的组播地址 req.imr_interface.s_addr = INADDR_ANY; // 本机所有网卡 // 4. 加入组播组 ret = setsockopt( sockfd, IPPROTO_IP, // IP层协议 IP_ADD_MEMBERSHIP, // 加入组播组的选项 &req, sizeof(req)); if (ret < 0) { perror("setsockopt(IP_ADD_MEMBERSHIP)"); exit(1); } // 5. 接收10次组播数据（加入组播组期间） printf("已加入组播组，开始接收数据...\n"); for(int i=0; i<10; i++) { struct sockaddr_in from; socklen_t len = sizeof(from); ret = recvfrom(sockfd, buf, sizeof(buf), 0, (struct sockaddr*)&from, &len); printf("【加入组播组】recv from: %s:%d -> %s\n", inet_ntoa(from.sin_addr), ntohs(from.sin_port), buf); } // 6. 退出组播组 ret = setsockopt( sockfd, IPPROTO_IP, IP_DROP_MEMBERSHIP, // 退出组播组的选项 &req, sizeof(req)); if (ret < 0) { perror("setsockopt(IP_DROP_MEMBERSHIP)"); exit(1); } // 7. 测试退出组播组后是否能接收数据（理论上收不到） printf("已退出组播组，尝试接收数据...\n"); for(int i=0; i<10; i++) { struct sockaddr_in from; socklen_t len = sizeof(from); ret = recvfrom(sockfd, buf, sizeof(buf), 0, (struct sockaddr*)&from, &len); printf("【退出组播组】recv from: %s:%d -> %s\n", inet_ntoa(from.sin_addr), ntohs(from.sin_port), buf); } close(sockfd); return 0; }

四、编译与测试

4.1 编译命令

# 编译发送方 g++ Sender.cpp -o sender # 编译接收方 g++ Receiver.cpp -o receiver

4.2 测试步骤

1. 启动接收方：在 1 台或多台同一局域网的主机上执行接收程序

   ./receiver

2. 启动发送方：在任意主机执行发送程序

   ./sender

3. 观察结果：
   • 接收方前 10 次能正常收到组播数据；
   • 退出组播组后，后续无法接收组播数据（recvfrom 会阻塞）。

总结

1. UDP 组播是 “一对一组” 通信，相比广播能大幅节省带宽，支持局域网 / 广域网使用；
2. 组播依赖 IPv4 D 类地址（224.0.0.0~239.255.255.255），不同段地址有不同使用范围；
3. 组播接收方必须 bind 端口，且需通过IP_ADD_MEMBERSHIP加入组播组，退出需用IP_DROP_MEMBERSHIP，发送方无需 bind 仅需指定组播地址。