Boost.ASIO无法接收Linux下UDP多播数据包问题求助

我尝试在Linux系统上接收UDP多播消息，通过tcpdump可以看到数据包按预期速率传入：

22:04:30.224631 IP <myhostname>.55292 > 239.255.0.1.sdt: UDP, length 638

其中sdt是端口5568的服务名。

我已经完全关闭本机ufw防火墙，并执行了以下命令：

echo 0 > /proc/sys/net/ipv4/icmp_echo_ignore_broadcasts
echo 0 > /proc/sys/net/ipv4/conf/lo/rp_filter
echo 0 > /proc/sys/net/ipv4/conf/enp7s0/rp_filter
route add -net 224.0.0.0 netmask 240.0.0.0 dev lo
ifconfig lo 127.0.0.1 netmask 224.0.0.0 up

我的代码如下：

boost::asio::io_context ctx;
boost::asio::ip::udp::socket socket{ctx};
auto listen_address = boost::asio::ip::make_address_v4("0.0.0.0");
auto mcast_address = boost::asio::ip::make_address_v4("239.255.0.1");
socket.open(boost::asio::ip::udp::v4());
socket.set_option(boost::asio::ip::udp::socket::reuse_address(true));
socket.set_option(boost::asio::ip::multicast::enable_loopback(true));

// 也尝试过绑定listen_address
socket.bind(boost::asio::ip::udp::endpoint(mcast_address, 5568));
socket.set_option(
    boost::asio::ip::multicast::join_group(mcast_address, listen_address));

for(;;)
{
  unsigned char m_data[900]{};
  std::cout << socket.receive(
      boost::asio::mutable_buffer(&m_data[0], std::size(m_data)));
}

但程序始终卡在receive处无法接收数据，换成端口5678的Boost.ASIO官方多播示例也无法工作。请问如何解决以接收这些多播数据包？

以下是关键的排查和修复点：

• 修正绑定地址
  不要直接绑定多播地址，多播组的加入通过join_group完成，绑定多播地址会限制接收范围。应绑定到0.0.0.0（所有接口）或具体网卡IP：

  socket.bind(boost::asio::ip::udp::endpoint(listen_address, 5568));
  

• 调整多播路由接口
  若数据包通过物理网卡enp7s0传入，之前添加到回环接口lo的路由会导致内核无法转发数据包到程序。执行以下命令修正：

  route del -net 224.0.0.0 netmask 240.0.0.0 dev lo
  route add -net 224.0.0.0 netmask 240.0.0.0 dev enp7s0
  

• 验证多播组加入状态
  用ip maddr show命令查看系统已加入的多播组，确认239.255.0.1是否出现在目标网卡接口下。

• 关闭全局反向路径过滤
  除了单个接口的rp_filter，还需关闭全局设置：

  echo 0 > /proc/sys/net/ipv4/conf/all/rp_filter
  

• 尝试异步接收调试
  同步receive可能因阻塞问题无法返回，改用异步接收配合io_context.run()测试：

  void handle_receive(const boost::system::error_code& error, std::size_t bytes_transferred)
  {
      if (!error)
      {
          std::cout << "Received " << bytes_transferred << " bytes\n";
          socket.async_receive(boost::asio::mutable_buffer(m_data, sizeof(m_data)), handle_receive);
      }
  }
  
  // 替换原循环部分
  unsigned char m_data[900]{};
  socket.async_receive(boost::asio::mutable_buffer(m_data, sizeof(m_data)), handle_receive);
  ctx.run();
  

内容的提问来源于stack exchange，提问作者Jean-Michaël Celerier