0

我写了一个程序，加入源特定的多播组并接收 udp 多播数据包：

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <netdb.h>
#include <unistd.h>
#include <net/if.h>

typedef unsigned int        UINT32;

int join_ssm_group(int s, UINT32 group, UINT32 source, UINT32 inter) {
    struct ip_mreq_source imr; 
    imr.imr_multiaddr.s_addr  = group;
    imr.imr_sourceaddr.s_addr = source;
    imr.imr_interface.s_addr  = inter;
    return setsockopt(s, IPPROTO_IP, IP_ADD_SOURCE_MEMBERSHIP, (char *) &imr, sizeof(imr));  
}

UINT32 LISTEN_INTERFACE = inet_addr("10.10.1.2");

int main(int argc, char *argv[]) {

    if (argc<3) {
        printf(" Use: %s <group> <source> <port>", argv[0]);
        return 1;
    }

    //  Make socket 
    int sd = socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);

    struct sockaddr_in Sender;
    socklen_t SenderAddrSize = sizeof( Sender );

    struct sockaddr_in binda;

    //  Bind it to listen appropriate UDP port
    binda.sin_family = AF_INET;
    binda.sin_port = htons( atoi(argv[3]));
      = INADDR_ANY;
    // binda.sin_addr.s_addr = LISTEN_INTERFACE;
    bind(sd,(struct sockaddr*)&binda, sizeof(binda));

    // Join to group
    join_ssm_group( sd, inet_addr(argv[1]), 
        inet_addr(argv[2]), 
        INADDR_ANY );

    char        buf[65536];
    UINT32      seq;

    while(1) {
        printf("try receive\n");
        int res=recvfrom(sd,(char*)buf,sizeof(buf),0, (struct sockaddr *)& Sender, &SenderAddrSize);
        printf("received\n");
        seq = *(UINT32*)buf;
        printf("scr=:%12s;\tseq=%6d;\tlen=%4d\n", inet_ntoa(Sender.sin_addr), seq, res);
    }

    return 0;
}

它工作正常，但请注意我正在使用binda.sin_addr.s_addr = INADDR_ANY;. netstat 显示：

netstat -a | grep 16002
udp        0      0 0.0.0.0:16002           0.0.0.0:*

当我将它更改为binda.sin_addr.s_addr = LISTEN_INTERFACE;程序停止工作时 - 它无法接收数据包，它会挂起recvfrom。netstat 显示：

netstat -a | grep 16002
udp        0      0 localhost.localdo:16002 0.0.0.0:*

在这两种情况下，tcpdump 都显示数据在线，所以问题是我无法在特定接口上接收数据，只能在所有接口上接收数据。我使用的是 RHEL 7，teaming，LISTEN_INTERFACE 是对应 VLAN 的 IP。为什么我的代码不起作用以及如何解决它？出于性能原因，我不想使用 INADDR_ANY - 侦听所有接口会比侦听某些接口更昂贵。

upd将 LISTEN_INTERFACE 传递给join_ssm_groupand 和binda.sin_addr.s_addr也不起作用。顺便说一句，此类代码的类似 Windows 版本适用于 Windows Server 2008 R2 下的同一台 PC，但在 RHEL 7 中不起作用。我想我应该检查这些：

  • 如果 RHEL 7 在所需端口上的 requreid 接口上接收到数据（答案是 Yes，由 tcpdump 证明）
  • 如果套接字在所需端口上的所需接口上侦听（答案是肯定的，由 netstat 证明？）
  • 如果上面的两个答案都是肯定的，那么调用怎么可能recvfrom不接收数据？

好吧，现在这个问题可能更多地是关于 RHEL 7，而不是关于 c++。

4

1 回答 1

1

当您加入多播组时，您需要指定您正在侦听的同一接口，或者通过循环中的所有接口加入它。

然而，监听所有接口是常态。这不是“慢”，而是一个“好主意”，除非您有特定的理由来限制谁可以连接。

于 2014-11-27T20:21:01.423 回答