4

以下 MulticastReceiver 实现中似乎存在错误。

在为 <224.0.25.46,13001> 和 <224.0.25.172,13001> 创建两个实例时，我在每个流中获取每个数据包两次。任何指针？我的猜测是 REUSEADDR ？

class MulticastReceiverSocket {
  protected:
    const std::string listen_ip_;
    const int listen_port_;
    int socket_file_descriptor_;
  public:

  MulticastReceiverSocket ( const std::string & listen_ip, 
                            const int listen_port )
    : listen_ip_ ( listen_ip ), listen_port_ ( listen_port ), 
      socket_file_descriptor_ ( -1 )
  { 

  /* create socket to join multicast group on */
  socket_file_descriptor_ = socket ( AF_INET, SOCK_DGRAM, IPPROTO_UDP );
  if ( socket_file_descriptor_ < 0 ) 
    { exit(1); }

  /* set reuse port to on to allow multiple binds per host */
  {
    int flag_on = 1;
    if ( ( setsockopt ( socket_file_descriptor_, SOL_SOCKET, 
                        SO_REUSEADDR, &flag_on,
                        sizeof(flag_on) ) ) < 0 ) 
      { exit(1); }
  }

  McastJoin ( );

  {
    /* construct a multicast address structure */
    struct sockaddr_in mcast_Addr;
    bzero ( &mcast_Addr, sizeof(mcast_Addr) );
    mcast_Addr.sin_family = AF_INET;
    mcast_Addr.sin_addr.s_addr = htonl(INADDR_ANY);
    mcast_Addr.sin_port = htons ( listen_port_ );

    /* bind to specified port onany interface */
    if ( bind ( socket_file_descriptor_, (struct sockaddr *) &mcast_Addr, sizeof ( struct sockaddr_in ) ) < 0 ) 
       { exit(1); } 
  }
}

void McastJoin ( )
{ 
    /* construct an IGMP join request structure */

    struct ip_mreq mc_req;
    inet_pton ( AF_INET, listen_ip_.c_str(), &(mc_req.imr_multiaddr.s_addr) ); 
    mc_req.imr_interface.s_addr = htonl(INADDR_ANY);

    /* send an ADD MEMBERSHIP message via setsockopt */
    if ( ( setsockopt ( socket_file_descriptor_, IPPROTO_IP, IP_ADD_MEMBERSHIP, 
                (void*) &mc_req, sizeof(mc_req))) < 0) 
    {
      printf ("setsockopt() failed in IP_ADD_MEMBERSHIP %s\n", listen_ip_.c_str() );
      exit(1);
    } 

}

inline int ReadN ( const unsigned int _len_, void * _dest_ ) 
{
  if ( socket_file_descriptor_ != -1 )
    {
      return recvfrom ( socket_file_descriptor_, _dest_, _len_, 0, NULL, NULL );
    }
  return -1;
}

请提出建议，当然，请指出可以进行的任何改进和优化。

4

5 回答 5

3

代替

mcast_Addr.sin_addr.s_addr = htonl(INADDR_ANY);

和

mcast_Addr.sin_addr.s_addr = inet_addr (mc_addr_str);

这对我（linux）有帮助，对于每个应用程序，我从一个端口上的单独 mcast 组接收单独的 mcast 流。

您也可以查看 VLC 播放器源，它在一个端口上显示来自不同 mcast 组的许多 mcast iptv 频道，但我不知道它是如何分隔频道的。

于 2011-05-23T04:32:42.280 回答
1

我猜这是因为有多个接口（你加入了组INADDR_ANY）。尝试指定确切的接口。ioctl(2)通过with获取接口地址SIOCGIFADDR。检查您在哪个界面上加入了哪些组netstat -ng。

于 2011-02-10T15:25:56.050 回答
1

您可以采取的一种方法是明智地了解如何加入组，因此与其创建套接字、绑定（使用 REUSEADDR）然后为每对 ip、端口加入组，只需构造一个套接字并绑定到给定的端口，然后在同一个套接字上发出多个 IGMP 连接。

即在您的情况下，仅创建一个套接字，每个端口绑定一次，但加入多个组。唯一的区别是当你发出 read 调用时，你会从一个或另一个组中得到一个数据包，你需要在数据包中有足够的数据来区分。

于 2011-02-10T16:46:35.147 回答
1

这是 Linux 路由的一个特性，每个会话都需要一个唯一的端口/多播组，只要端口匹配，Linux 就会转发任何东西，例如广播数据包。Windows 出人意料地没有这种症状，这大概就是它变慢的原因。

许多商业中间件包强制执行此兼容性要求，例如 TIBCO 的 Rendezvous 不允许重复使用相同的端口或组。

于 2011-02-10T19:22:44.360 回答
1

您是否尝试过关闭环回？我发现如果我有一个合理的 TTL，那么至少在使用 SO_REUSEPORT 时不需要环回来获得一个：

int sock = socket( AF_INET, SOCK_DGRAM, IPPROTO_UDP );
if( sock < 0 )
    exit( -11 );

int on = true;
if( setsockopt ( sock, SOL_SOCKET, SO_REUSEPORT, & on, sizeof( on ) ) < 0 ) 
    exit( -12 );

int off = 0;
if ( setsockopt ( sock, IPPROTO_IP, IP_MULTICAST_LOOP, & off, sizeof( off ) ) < 0 )
    exit( -13 );

int ttl = 3;
if ( setsockopt ( sock, IPPROTO_IP, IP_MULTICAST_TTL, & ttl, sizeof( ttl ) ) < 0 )
    exit( -14 );

如果我打开环回——默认情况下——我也会得到双数据包。

于 2013-03-06T18:07:06.300 回答