Python 2.7 socket.sendto组播消息无法发出问题排查求助

我正在编写Python 2.7程序，通过mDNS发现特定设备，且仅能使用标准模块，因此只能基于socket模块实现该功能。当前实现代码如下，但发送的组播消息未被Wireshark捕获，似乎并未离开本机，且无任何错误信息输出，恳请帮忙排查问题：

# configure socket
mcast_port = 5353
mcast_grp = ('224.0.0.251', mcast_port)

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sock.settimeout(5)

ttl = struct.pack('b', 5)
sock.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_TTL, ttl)
sock.setsockopt(socket.SOL_IP, socket.SO_REUSEADDR, 1)
sock.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_LOOP, 1)

try:
  bytes_send = sock.sendto(query_msg, mcast_grp)
    if bytes_send != len(query_msg):
      print("Something wrong here")
except socket.error as e:
  self.log_data("Socket Error", "discover: " + str(e))
  sock.shutdown(socket.SHUT_RDWR)
  sock.close()
except Exception as e:
  self.log_data("Error", "discover: " + str(e))
  sock.shutdown(socket.SHUT_RDWR)
  sock.close()

• 修正代码缩进错误
  你代码中if bytes_send != len(query_msg):的缩进层级错误，这会触发Python语法异常。若实际运行代码无报错，可能是粘贴版本与运行版本不一致，先修正缩进：

  try:
      bytes_send = sock.sendto(query_msg, mcast_grp)
      if bytes_send != len(query_msg):
          print("Something wrong here")
  except socket.error as e:
      self.log_data("Socket Error", "discover: " + str(e))
      sock.shutdown(socket.SHUT_RDWR)
      sock.close()
  except Exception as e:
      self.log_data("Error", "discover: " + str(e))
      sock.shutdown(socket.SHUT_RDWR)
      sock.close()
  

• 验证query_msg的mDNS格式合法性
  mDNS查询必须严格遵循DNS协议的二进制格式，若query_msg为空或格式错误，即使发送成功也不会被识别为mDNS流量。可以先构造标准测试查询包：

  import struct
  
  # 构造符合规范的mDNS查询包
  query_id = struct.pack('!H', 0x1234)  # 随机查询ID
  flags = struct.pack('!H', 0x0000)     # 标准查询，禁用递归
  qdcount = struct.pack('!H', 1)        # 1个查询项
  ancount = struct.pack('!H', 0)
  nscount = struct.pack('!H', 0)
  arcount = struct.pack('!H', 0)
  
  # 编码DNS查询名（例如查询HTTP服务的A记录）
  def encode_dns_name(name):
      parts = name.split('.')
      encoded = b''
      for part in parts:
          encoded += struct.pack('B', len(part)) + part.encode('utf-8')
      encoded += b'\x00'  # 域名结束符
      return encoded
  
  query_name = encode_dns_name('_http._tcp.local')
  qtype = struct.pack('!H', 1)    # A记录类型
  qclass = struct.pack('!H', 1)   # IN类
  
  query_msg = query_id + flags + qdcount + ancount + nscount + arcount + query_name + qtype + qclass
  

• 调整Socket绑定与多播参数

  1. mDNS规范要求使用5353端口，你的代码未绑定端口，需添加绑定操作：

     sock.bind(('', mcast_port))  # 绑定到所有接口的5353端口
     

  2. 临时关闭多播环回（避免消息仅在本机循环）：

     sock.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_LOOP, 0)
     

• 排查系统与捕获工具配置

  • 检查防火墙：Windows/Linux防火墙可能拦截5353端口的UDP多播流量，临时关闭或添加允许规则。
  • 调整Wireshark捕获配置：确保选择正确的物理网络接口（不要选环回接口），使用捕获过滤器udp port 5353。

内容的提问来源于stack exchange，提问作者Tob