Python扭曲框架多播绑定在特定接口上

Question

在谷歌上搜索后，我没有找到以下问题的明确答案： 大致遵循以下指南： http://twistedmatrix.com/documents/10.2.0/core /howto/udp.html#auto3

如何将扭曲的多播侦听器绑定到仅多播地址和特定或所有接口。

在查看reactor.listenMulticast时，它不提供硬件接口的抽象，仅提供由IP地址表示的伪接口。我找不到仅绑定到特定接口或所有接口的多播地址（例如 224.0.0.1）的方法。 谁能提供这方面的进一步信息？

Answer 1

reactor.listenMulticast 返回一个twisted.internet.udp.MulticastPort 对象。该对象拥有您正在侦听的套接字。因此，请保留reactor.listenMulticast的结果并设置适当的套接字选项（在本例中它看起来像SO.BINDTODEVICE）以及以空结尾的设备字符串。

import IN, socket, struct

udp_port = reactor.listenMulticast(8005, MulticastServerUDP())
dev = "eth0" + "\0"
udp_port.socket.setsockopt(socket.SOL_SOCKET, IN.SO_BINDTODEVICE, dev)
reactor.run()

如果直接通过 listenMulticast 调用公开那就太好了，但假设这有效，那将是一个非常简单的补丁。如果这可以解决您的问题，请告诉我。

Answer 2

其他答案可能会解决问题，但有一种“更扭曲”（可能更简单）的方法来侦听多个接口上的多播组。

侦听一个或多个接口上的多播组

要侦听一个或多个接口上的多播组，请在对协议的 Transport.joinGroup() 方法的多次调用中提供每个所需接口的 IP 作为“接口”参数。

下面是一个在我的 Linux 机器上运行的示例，将使您的系统侦听特定接口上的多播。将 IP 地址替换为属于您系统的 IP 地址。

#!/usr/bin/env python

from twisted.internet import protocol
from twisted.internet import reactor

class MyProtocol(protocol.DatagramProtocol):
    def startProtocol(self):
        # Join a multicast group, 224.0.0.9, on the interface belonging
        # to each of these IPs.
        # XXX Replace the interface_ips with one or more IP addresses belonging
        # to your system.
        for interface_ip in ["192.168.2.2", "10.99.1.100"]:
            self.transport.joinGroup("224.0.0.9", interface_ip)

if __name__ == "__main__":
    reactor.listenMulticast(1520, MyProtocol())
    reactor.run()

您可以使用 /sbin/ip maddr show 命令检查接口是否正在侦听新的多播组。在命令输出中找到所需的接口名称，并验证多播组是否显示在其下方。

原始帖子中链接的 UDP 服务器示例应该能够通过更改对 joinGroup() 的调用以包含第二个 IP 地址参数来执行相同的操作，如上所述。

从特定 IP 发送多播

如果您在套接字上接收多播数据，您很可能也想发送多播数据 — 可能是从多个接口发送多播数据。由于它密切相关并且周围的例子很少，所以我将其放在这里。在twisted.internet.protocol.DatagramProtocol对象中，您可以使用self.transport.setOutgoingInterface()方法来控制将用于后续调用self.transport.write()的源IP。显示从多个 IP/接口发送消息的示例：

class MyProtocol(protocol.DatagramProtocol):
    # ...
    def send_stuff(self, msg):
        for src_ip in ["10.0.0.1", "192.168.1.1"]:
            self.transport.setOutgoingInterface(src_ip)
            self.transport.write(msg, ("224.0.0.9", 1520))

假设这些 IP 被分配给两个不同的接口。使用 Wireshark 进行嗅探，您会看到消息从第一个接口发送出去，然后从第二个接口发送出去，使用每个 IP 作为相应传输的源 IP 地址。

Answer 3

一种简单但严厉的方法可能是通过以下方式指定路线：

sudo route add 239.255.0.0 -interface en0 -netmask 255.255.0.0