3

这是来自 Twisted 的以下代码示例，用于处理接收多播。我目前正在收听具有相同客户端的许多组，并且我希望能够打印出某个数据报包来自哪个组。我认为这可以从 datagramReceived 的地址参数中接收；但是，这只给了我一个包含组绑定到的本地 ip 和端口的元组，而不是组本身的地址。

问题：如何在 Twisted 协议/API 中打印来自数据报的多播地址？

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


class MulticastPingClient(DatagramProtocol):

    def startProtocol(self):
        # Join the multicast address, so we can receive replies:
        self.transport.joinGroup("228.0.0.5")
        self.transport.joinGroup("229.0.2.11")
        self.transport.joinGroup("221.3.3.3")
        # Send to 228.0.0.5:8005 - all listeners on the multicast address
        # (including us) will receive this message.
        self.transport.write('Client: Ping', ("228.0.0.5", 8005))

    def datagramReceived(self, datagram, address):
        print "Datagram %s received from %s" % (repr(datagram), repr(address))


reactor.listenMulticast(8005, MulticastPingClient(), listenMultiple=True)
reactor.run()
4

1 回答 1

3

不幸的是，socket APIs Twisted wraps（通过 Python 的标准库）不提供这些信息。我建议为每个多播组使用单独的 DatagramProtocol，并为每个组监听不同的端口。尽管有人仍然可以将 UDP 数据报直接发送到该端口，但您无法将其与多播区分开来。

我有一个模糊的记忆，表明 recvmsg() API 确实提供了必要的信息，尽管我没有时间验证这一点。Twisted 12.1 有一个 recvmsg() 包装器的开头，所以这可能是一种可能的方式来将此功能添加到 Twisted（或您的代码）中，需要做更多的工作。

于 2012-07-09T18:53:55.620 回答