服务器与客户端之间无论是否带有路由器之间的多播都不事先知道服务器IP以及可能的不同子网

问题描述

我正在编写在Windows（和Linux）PC上运行的Python软件，而PC通过LAN （有或没有路由器）连接到第二台设备。

第二个设备将UDP多播数据包发送到已知的多播组地址和端口。 计算机中的软件配置为属于同一多播组。 只要我的计算机和服务器网络配置都在同一子网中，此方法就可以正常工作。

现在，大多数情况下，我不会事先知道设备的IP，因此我将点对点将计算机直接连接到服务器。 （想象一下IP安全摄像机随附的软件，当您直接连接到摄像机时，无需事先知道并且不在同一子网中，就可以发现或知道摄像机的IP）。例如，我的计算机的IP地址为169.x.x.x / 24，服务器的IP地址为10.1.1.100，但我事先不知道服务器的IP地址。

由于无法控制的原因，该设备无法配置为DHCP服务器，因此无法为我的计算机分配IP，也不能使用DNS。

如何在没有原始捕获的情况下接收UDP多播数据包？

这是我当前用于套接字配置的代码，当计算机和服务器具有相同的子网时，套接字配置可以正常工作。例如10.1.1.100/16和10.1.1.60/16，但也需要如上所述工作。

class MulticastSocket(object):
    """Sends UDP packets to multicast addressses."""

    def __init__(self,bind_ip=None):
        self._create(bind_ip)

    def _create(self,bind_ip):
        self.bind_addr = bind_ip

        # chosen arbitrary from IANA's Scoped Multicast Range
        # https://www.iana.org/assignments/multicast-addresses/multicast-addresses.xhtml#unicast-prefix-based
        self.multicast_group = '239.6.2.86'
        self.multicast_port = 6286

        """Creates a multicast UDP socket"""
        self._sock = socket.socket(socket.AF_INET,socket.soCK_DGRAM,socket.IPPROTO_UDP)
        self._sock.settimeout(6)
        ttl = 2
        self._sock.setsockopt(socket.IPPROTO_IP,socket.IP_MULTICAST_TTL,ttl)
        
        self._sock.setsockopt(socket.soL_IP,socket.IP_MULTICAST_IF,socket.inet_aton(self.bind_addr))
        membership_request = struct.pack('4s4s',socket.inet_aton(self.multicast_group),socket.inet_aton(self.bind_addr))
        self._sock.setsockopt(
            socket.IPPROTO_IP,socket.IP_ADD_MEMBERSHIP,membership_request)

        self._sock.setsockopt(socket.soL_SOCKET,socket.so_REUSEADDR,1)

        
        if sys.platform == 'linux':
            bind_addr = self.multicast_group
        else:
            bind_addr = self.bind_addr if self.bind_addr else ''
        self._sock.bind((bind_addr,self.multicast_port))

    def get(self):
        """use to get the socket object to work with the select as select only accept sockets objects"""
        return self._sock

    def send(self,msg):
        return self._sock.sendto(msg,(self.multicast_group,self.multicast_port))

    def recv(self,len):
        try:
            response = self._sock.recvfrom(len)
            return response
        except socket.timeout:
            return "",""

    def close(self):
        self._sock.close()

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）