如何让两个多播套接字侦听具有相同端口的两个多播通道

Posted 2023-02-17

【中文标题】如何让两个多播套接字侦听具有相同端口的两个多播通道

【英文标题】：How to have two multicast sockets listen to two multicast channels with same port

【发布时间】：2013-12-19 20:59:32

【问题描述】：

我大致有以下多播套接字代码。它工作正常。现在我需要在同一台机器上加入两个多播频道，比如 224.10.13.18 - 55001 224.10.13.34 - 55001

根据它来自哪个 IP 地址，我需要以不同的方式处理该消息。

问题是如何使用为端口值相同的多播通道创建两个套接字，以便每个套接字仅返回对发送到该通道的数据的读取。

  /* create socket to join multicast group on */
  socket_file_descriptor_ = socket ( AF_INET, SOCK_DGRAM, IPPROTO_UDP );
  if ( socket_file_descriptor_ < 0 ) 
     // fprintf ( stderr, "cannot open socket \n");
      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 ) 
       // fprintf ( stderr, "MulticastReceiverSocket setsockopt() SOL_SOCKET SO_REUSEADDR failed\n");
        exit(1);
      
   

  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) 
   // std::cerr << "setsockopt() failed in IP_ADD_MEMBERSHIP " << listen_ip_ << ": "<< listen_port_ << std::endl;
      exit(1);
   


  /* 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 ) 
   // fprintf ( stderr, "%s cannot bind %s:%d \n", "MulticastReceiverSocket", listen_ip_.c_str(), listen_port_ ) ;
     exit(1);
   

【问题讨论】：

问题是？这里没有问题，并且您没有提供错误消息表明您发布的代码不起作用，但是尝试在添加成员之前进行绑定。

我不知道我是否理解正确：1.您想在一个端口上的一台机器上监听两台不同的机器，并根据连接到您的机器来操作，或者 2.您想听在两个不同的 IP 地址（我想是 2 个不同的网卡）上，并根据谁连接到什么机器而采取行动

@fernando.reyes 你没有。两者都不是。他想收听排除 (1) 的多播，并且他正在使用排除 (2) 的 INADDR_ANY。您似乎不知道实际的多播是什么，这排除了您可以回答问题的任何可能性。

两个通道的数据都可以通过同一个接口访问。如果端口不同，我可以使用上面的代码创建两个套接字，每个套接字只会在该通道上返回数据。但是，如果通道具有相同的端口值，则会出现这种情况。我想弄清楚如何处理重叠的端口值。

@EJP 我尽我所能编辑问题以提供我确切问题的上下文。我相信这是一个相当普遍的问题，解决方案应该对其他人有用。我是起草代码繁重问题的新手。感谢您的帮助。

【参考方案1】：

您只需要一个插座即可。如果在调用setsockopt 时设置IP_PKTINFO 选项，则可以使用recvmsg 获取struct in_pktinfo，其中将包含目标IP 地址。然后你可以根据它选择如何处理数据包。

借用https://***.com/a/5309155/1687119（为简洁起见，删除了错误检查）：

// sock is bound AF_INET socket, usually SOCK_DGRAM
// include struct in_pktinfo in the message "ancilliary" control data
setsockopt(sock, IPPROTO_IP, IP_PKTINFO, &opt, sizeof(opt));
// the control data is dumped here
char cmbuf[0x100];
// the remote/source sockaddr is put here
struct sockaddr_in peeraddr;
// if you want access to the data you need to init the msg_iovec fields
struct msghdr mh = 
    .msg_name = &peeraddr,
    .msg_namelen = sizeof(peeraddr),
    .msg_control = cmbuf,
    .msg_controllen = sizeof(cmbuf),
;
recvmsg(sock, &mh, 0);
for ( // iterate through all the control headers
    struct cmsghdr *cmsg = CMSG_FIRSTHDR(&mh);
    cmsg != NULL;
    cmsg = CMSG_NXTHDR(&mh, cmsg))

    // ignore the control headers that don't match what we want
    if (cmsg->cmsg_level != IPPROTO_IP ||
        cmsg->cmsg_type != IP_PKTINFO)
    
        continue;
    
    struct in_pktinfo *pi = CMSG_DATA(cmsg);
    // at this point, peeraddr is the source sockaddr
    // pi->ipi_spec_dst is the destination in_addr
    // pi->ipi_addr is the receiving interface in_addr

【讨论】：

@humble-debugger 这回答了你的问题吗？