在同一个端口上接收多个多点传送 – C,Linux

我有一个应用程序从同一端口上的多个多播源接收数据。 我能够收到数据。 但是,我正在考虑每个组的统计信息(即收到的消息,收到的字节),所有的数据都混在一起。 有谁知道如何解决这个问题? 如果我试图查看发件人的地址,它不是多播地址,而是发送机器的IP地址。

我正在使用以下套接字选项:

struct ip_mreq mreq; mreq.imr_multiaddr.s_addr = inet_addr("224.1.2.3"); mreq.imr_interface.s_addr = INADDR_ANY; setsockopt(s, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)); 

并且:

 setsockopt(s, SOL_SOCKET, SO_REUSEPORT, &reuse, sizeof(reuse)); 

我感谢任何帮助!

Solutions Collecting From Web of "在同一个端口上接收多个多点传送 – C,Linux"

[编辑澄清bind()实际上可能包含多播地址。]

因此,应用程序将加入多个多播组,并将接收到的消息发送到同一个端口。 SO_REUSEPORT允许您将多个套接字绑定到相同的端口。 除了端口, bind()需要一个IP地址。 INADDR_ANY是一个INADDR_ANY地址,但是也可以使用IP地址,包括一个多播地址。 在这种情况下,只有发送到该IP的数据包才会被传送到套接字。 也就是说,您可以创建多个套接字,每个多播组一个套接字。 bind()每个套接字bind()到(group_addr,port),并加入group_addr。 然后,发往不同组的数据将显示在不同的套接字上,您将能够以这种方式区分它。

我测试了以下在FreeBSD上的工作:

 #include <sys/socket.h> #include <stdio.h> #include <string.h> #include <arpa/inet.h> #include <netinet/in.h> #include <sys/param.h> #include <unistd.h> #include <errno.h> int main(int argc, const char *argv[]) { const char *group = argv[1]; int s = socket(AF_INET, SOCK_DGRAM, 0); int reuse = 1; if (setsockopt(s, SOL_SOCKET, SO_REUSEPORT, &reuse, sizeof(reuse)) == -1) { fprintf(stderr, "setsockopt: %d\n", errno); return 1; } /* construct a multicast address structure */ struct sockaddr_in mc_addr; memset(&mc_addr, 0, sizeof(mc_addr)); mc_addr.sin_family = AF_INET; mc_addr.sin_addr.s_addr = inet_addr(group); mc_addr.sin_port = htons(19283); if (bind(s, (struct sockaddr*) &mc_addr, sizeof(mc_addr)) == -1) { fprintf(stderr, "bind: %d\n", errno); return 1; } struct ip_mreq mreq; mreq.imr_multiaddr.s_addr = inet_addr(group); mreq.imr_interface.s_addr = INADDR_ANY; setsockopt(s, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)); char buf[1024]; int n = 0; while ((n = read(s, buf, 1024)) > 0) { printf("group %s fd %d len %d: %.*s\n", group, s, n, n, buf); } } 

如果您运行多个这样的进程,针对不同的多播地址,并向其中一个地址发送消息,则只有相关的进程才能接收到这个进程。 当然,就你而言,你可能会希望在一个进程中拥有所有的套接字,而你必须使用select或者poll或者等价的方法来读取它们。

经过几年,面临这种奇怪的行为,并使用以前的答案中描述的绑定解决方法,我意识到, IP(7)手册页描述了一个可能的解决方案:

IP_MULTICAST_ALL(自Linux 2.6.31起)
此选项可用于将多播消息的传送策略修改为绑定到通配符INADDR_ANY地址的套接字。 参数是一个布尔整型(默认为1)。 如果设置为1,则套接字将从整个系统中全局加入的所有组接收消息。 否则,它只会在这个特定的套接字上传递已经明确加入的组的消息(例如通过IP_ADD_MEMBERSHIP选项)。

然后你可以激活过滤器来接收加入组的消息,使用:

 int mc_all = 0; if ((setsockopt(sock, IPPROTO_IP, IP_MULTICAST_ALL, (void*) &mc_all, sizeof(mc_all))) < 0) { perror("setsockopt() failed"); } 

这个问题以及解决启用IP_MULTICAST_ALL的方法在Redhat Bug 231899中讨论过 ,这个讨论包含了测试程序来重现问题并解决它。

使用setsockopt()IP_PKTINFOIP_RECVDSTADDR取决于您的平台,假设IPv4。 结合recvmsg()WSARecvMsg() ,您可以查找每个数据包的源地址目标地址。

Unix / Linux,请注意FreeBSD使用IP_RECVDSTADDR ,同时支持IPv6的IP6_PKTINFO

Windows,也有IP_ORIGINAL_ARRIVAL_IF

更换

mc_addr.sin_addr.s_addr = htonl(INADDR_ANY);

mc_addr.sin_addr.s_addr = inet_addr (mc_addr_str);

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

你也可以看看VLC播放器源码,它显示了来自不同mcast组的一个端口上的许多mcast iptv频道,但是我不知道它是如何分离频道的。

我不得不使用多个套接字,每个套接字查看不同的多播组地址,然后分别统计每个套接字上的统计信息。

如果有办法看到上面答案中提到的“接收者的地址”,我就不知道了。

一个重要的问题也花了我一段时间 – 当我将每个单独的套接字绑定到像大多数python示例一样的空白地址时:

 sock[i].bind(('', MC_PORT[i]) 

我得到了每个套接字上的所有组播数据包(来自所有组播组),这没有任何帮助。 为了解决这个问题,我把每个套接字绑定到它自己的多播组上

 sock[i].bind((MC_GROUP[i], MC_PORT[i])) 

然后它工作。

IIRC recvfrom()为每个发件人提供了不同的读取地址/端口。

您也可以在标识源发件人的每个数据包中放置一个标题。

组播地址将是数据包中接收者的地址而不是发送者的地址。 看看接收器的IP地址。

您可以通过查看收到的数据包的目标IP地址(这将始终是组播地址)来分隔组播流。 这有点牵涉到:

绑定到INADDR_ANY并设置IP_PKTINFO套接字选项。 然后您必须使用recvmsg()来接收多播UDP数据包并扫描IP_PKTINFO控制消息。 这给你一些收到的UDP数据包的边带信息:

 struct in_pktinfo { unsigned int ipi_ifindex; /* Interface index */ struct in_addr ipi_spec_dst; /* Local address */ struct in_addr ipi_addr; /* Header Destination address */ }; 

查看ipi_addr:这将是刚刚收到的UDP数据包的多播地址。 现在您可以处理收到的每个组播流(多播地址)特定的数据包。