基于BSD Socket API的组播疑问：recvfrom返回地址及代码排查

核心疑问解答 #

• recvfrom()返回的源地址是发送端的IP（11.12.13.14），不是组播地址。组播地址是数据包的目标地址，而recvfrom输出的是数据包的发送方地址，这是UDP的正常行为。
• 你得到0.0.0.0是代码实现存在问题，而非组播机制本身的问题。

代码中的问题分析 #

1. 共用addrlen变量导致地址解析错误
   单播和组播的recvfrom共用了同一个addrlen变量，单播recvfrom调用后会将addrlen更新为实际接收的地址长度（可能小于sizeof(src_addr)），后续组播recvfrom使用这个被修改的值，会导致src_addr无法被正确填充，从而输出0.0.0.0。

2. 使用无效的组播地址
   224.0.0.0是组播地址空间的保留基地址，不能作为实际发送的组播地址使用，应选择224.0.0.1~239.255.255.255范围内的有效地址（比如224.0.0.1是所有主机的组播地址）。

3. 语法错误

   • myinit函数中括号匹配错误：if(sockUnicast >=0)的else分支缺少对应的闭合括号，会导致编译失败。
   • 关闭套接字的函数应为标准的close()，而非soc_close()（疑似笔误）。

4. 组播接收套接字的初始化细节
   虽然绑定INADDR_ANY是允许的，但如果接收端有多个网卡，建议指定具体的网卡IP作为imr_interface.s_addr，避免组播数据包接收异常。

修正后的代码示例 #

/*发送端IP为11.12.13.14
接收端本地IP为20.30.40.50*/

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

int sockUnicast;
int sockMulticast; /*用于组播*/

struct sockaddr_in local_addr;
struct sockaddr_in mcast_addr;

bool issockUnicastConnected = 0;
bool issockMulticastConnected = 0;

void myinit()
{
    sockUnicast = 0;
    sockMulticast = 0;
    
    /*创建单播通信套接字并绑定到可用端口*/
    sockUnicast = socket(AF_INET,SOCK_DGRAM,0);
    
    if(sockUnicast >=0)
    {
        memset(&local_addr, 0, sizeof(local_addr));
        local_addr.sin_family = AF_INET;
        local_addr.sin_addr.s_addr = htonl(INADDR_ANY);
        local_addr.sin_port = htons(4000);
        
        if(bind(sockUnicast, (struct sockaddr*)&local_addr, sizeof(local_addr)) >=0)
        {
            issockUnicastConnected = 1;
        }
        
        /*创建监听组播的套接字*/
        sockMulticast = socket(AF_INET,SOCK_DGRAM,0);
        
        memset(&mcast_addr, 0, sizeof(mcast_addr));
        mcast_addr.sin_family = AF_INET;
        mcast_addr.sin_addr.s_addr = htonl(INADDR_ANY);
        mcast_addr.sin_port = htons(4010);
        
        if(sockMulticast>=0)
        {
            if((bind(sockMulticast, (struct sockaddr*)&mcast_addr, sizeof(mcast_addr)) >= 0))
            {
                struct ip_mreq mreq;
                // 使用有效组播地址
                mreq.imr_multiaddr.s_addr = inet_addr("224.0.0.1");
                // 指定接收端的具体网卡IP，而非INADDR_ANY
                mreq.imr_interface.s_addr = inet_addr("20.30.40.50");
                
                if (setsockopt(sockMulticast, IPPROTO_IP, IP_ADD_MEMBERSHIP , (void*)&mreq, sizeof(mreq))>= 0)
                {
                    issockMulticastConnected = 1;
                }
            }
        }
        else
        {
            close(sockMulticast);
        }
    }
    else
    {
        close(sockUnicast);
    }
}


void mymain()
{
   char buffer[2048];
   struct sockaddr_in src_addr;
   
while(1)
{
    
     if(issockUnicastConnected)
     {
        INT addrlen = sizeof(src_addr); // 每个recvfrom单独初始化addrlen
        ssize_t rec_len = recvfrom(sockUnicast,buffer,sizeof(buffer),0, (struct  sockaddr*)&src_addr, &addrlen);
        char ip_str[32];
        inet_ntop(AF_INET, &(src_addr.sin_addr), ip_str, 32);
        
        printf("Unicast IP address is:: %s\n", ip_str);   
        printf("PORT is: %d\n", ntohs(src_addr.sin_port));
        
        if (rec_len > 0)
        {
          /*处理单播接收的数据*/;
        }
    }
    
     if(issockMulticastConnected)
     {
        INT addrlen = sizeof(src_addr); // 单独初始化addrlen，避免被单播修改
        ssize_t rec_len_multi = recvfrom(sockMulticast,buffer,sizeof(buffer),0, (struct  sockaddr*)&src_addr, &addrlen);
        char ip_str[32];
        inet_ntop(AF_INET, &(src_addr.sin_addr), ip_str, 32);
        
        printf("Multicast IP address is:: %s\n", ip_str);
        printf("PORT is: %d\n", ntohs(src_addr.sin_port));

        if(rec_len_multi > 0)
        {
            /*处理组播接收的数据*/
        }
    }  
  }
}

额外注意事项 #

• 发送端发送组播时，需要确保启用组播权限（可通过IP_MULTICAST_TTL套接字选项设置TTL值，默认是1，限制在本地局域网）。
• 接收端需要加入对应的组播组才能收到数据包，你的代码中已经调用了IP_ADD_MEMBERSHIP，修正地址后即可正常工作。

内容的提问来源于stack exchange，提问作者JohnDoe