在同一端口上接收多个组播源 – 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));
[编辑澄清bind()实际上可能包含多播地址。]
因此，应用程序正在连接多个多播组，并将发送到其中任何一个的消息接收到同一端口。 SO_REUSEPORT允许您将多个套接字绑定到同一端口。 除端口外， bind()需要一个IP地址。 INADDR_ANY是一个包罗万象的地址，但也可以使用IP地址，包括多播地址。 在这种情况下，只有发送到该IP的数据包才会被传送到套接字。 即你可以创建几个套接字，每个多播组一个。 bind()每个套接字到（group_addr，port），并加入group_addr。 然后，发往不同组的数据将显示在不同的套接字上，您将能够以这种方式区分它。
我测试了以下适用于FreeBSD：
#include #include #include #include #include #include #include #include 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或等效来全部读取它们。
经过几年面对这个linux奇怪的行为，并使用前面的答案中描述的绑定解决方法，我意识到ip（7）联机帮助页描述了一个可能的解决方案：
IP_MULTICAST_ALL（自Linux 2.6.31起）
此选项可用于将组播消息的传递策略修改为绑定到通配符INADDR_ANY地址的套接字。 参数是一个布尔整数（默认为1）。 如果设置为1，则套接字将从整个系统上全局加入的所有组接收消息。 否则，它将仅从已在此特定套接字上显式连接的组（例如，通过IP_ADD_MEMBERSHIP选项）传递消息。
然后，您可以使用以下命令激活filter以接收已连接组的消息：
int mc_all = 0; if ((setsockopt(sock, IPPROTO_IP, IP_MULTICAST_ALL, (void*) &mc_all, sizeof(mc_all))) < 0) { perror("setsockopt() failed"); }
在Redhat Bug 231899中讨论了这个问题以及解决它的方法来启用IP_MULTICAST_ALL，这个讨论包含重现问题并解决它的测试程序。
假设使用IPv4，请使用setsockopt()和IP_PKTINFO或IP_RECVDSTADDR具体取决于您的平台。 这与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数据包的多播地址。 您现在可以处理特定于您正在接收的每个多播流（多播地址）的接收数据包。