3

我在 boost::asio 下的 udp 广播事务遇到问题，与以下代码片段有关。由于我试图在这种情况下进行广播，所以 deviceIP = "255.255.255.255"。devicePort 是我的设备的指定管理端口。我想使用一个临时的本地端口，所以如果可能的话，我宁愿在连接后不必使用 socket.bind() ，并且代码通过设置 localPort = 0 来支持单播。

boost::asio::ip::address_v4 targetIP = boost::asio::ip::address_v4::from_string(deviceIP);
m_targetEndPoint = boost::asio::ip::udp::endpoint(targetIP, devicePort);

m_ioServicePtr = boost::shared_ptr<boost::asio::io_service>(new boost::asio::io_service);
m_socketPtr = boost::shared_ptr<boost::asio::ip::udp::socket>(new boost::asio::ip::udp::socket(*m_ioServicePtr));
m_socketPtr->open(m_targetEndPoint.protocol());

m_socketPtr->set_option(boost::asio::socket_base::broadcast(true));

// If no local port is specified, default parameter is 0
// If local port is specified, bind to that port.
if(localPort != 0)
{
  boost::asio::ip::udp::endpoint localEndpoint(boost::asio::ip::address_v4::any(), localPort);
  m_socketPtr->bind(localEndpoint);
}

if(m_forceConnect)
  m_socketPtr->connect(m_targetEndPoint);

this->AsyncReceive(); // Register Asynch Recieve callback and buffer
m_socketThread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(&MyNetworkBase::RunSocketThread, this))); // Start thread running io_service process

无论我在以下设置方面做什么，传输工作正常，我可以使用 Wireshark 查看从设备返回的响应数据包如预期。这些响应数据包也是广播的，因为设备可能与搜索它的 PC 位于不同的子网中。

这些问题在我看来非常奇怪，但如下：

  1. 如果我指定本地端口并设置 m_forceConnect=false，一切正常，并且我的接收回调会适当地触发。
  2. 如果我在构造函数中设置 m_forceConnect = true，但传入本地端口 0，则传输工作正常，但我的接收回调永远不会触发。我认为这是因为“目标”（m_targetEndpoint）是 255.255.255.255，并且由于设备具有真实 IP，因此响应数据包会被过滤掉。
  3. （我真正想要的）如果 m_forceConnect = false（并且数据是使用 send_to 调用传输的），并且本地端口 = 0，因此采用临时端口，我的 RX 回调立即触发错误代码 10022，我认为这是“无效参数”套接字错误。

谁能建议我为什么不能以这种方式使用连接（未明确绑定且未明确连接）？在这种情况下，我显然不想使用 socket.connect() ，因为我想响应我收到的任何内容。我也不想使用预定义的端口，因为我希望用户能够构造该对象的多个副本而不会发生端口冲突。

有些人可能已经注意到，这样做的总体目标是使用相同的网络接口基类来处理单播和广播情况。显然，对于单播版本，我可以非常高兴地使用 m_socket->connect()，因为我知道设备的 IP，并且我收到响应，因为它们来自连接的 IP 地址，因此我设置 m_forceConnect = true，一切正常.

由于我所有的传输都使用 send_to，我也尝试了 socket.connect(endpoint(ip::addressv4::any(), devicePort)，但是当我尝试时，我得到一个“请求的地址在其上下文中无效”异常它。

我尝试了一个非常严重的黑客攻击：

boost::asio::ip::udp::endpoint localEndpoint(boost::asio::ip::address_v4::any(), m_socketPtr->local_endpoint().port());
m_socketPtr->bind(localEndpoint);

我提取初始临时端口号并尝试绑定到它，但有趣的是，当我尝试绑定时会引发 Invalid Argument 异常。

4

1 回答 1

4

好的，我找到了解决此问题的方法。在linux下没有必要，但是在windows下我发现如果你既没有绑定也没有连接，你必须在调用asynch_recieve_from()之前传输了一些东西，这个调用包含在我的this->asynch_receive()方法中.

我的解决方案是在windows下进行asynch_receive调用之前立即进行空字符串的虚拟传输，因此修改后的代码变为：

m_socketPtr->set_option(boost::asio::socket_base::broadcast(true));

// If no local port is specified, default parameter is 0
// If local port is specified, bind to that port.
if(localPort != 0)
{
  boost::asio::ip::udp::endpoint localEndpoint(boost::asio::ip::address_v4::any(), localPort);
  m_socketPtr->bind(localEndpoint);
}

if(m_forceConnect)
  m_socketPtr->connect(m_targetEndPoint);

// A dummy TX is required for the socket to acquire the local port properly under windoze
// Transmitting an empty string works fine for this, but the TX must take place BEFORE the first call to Asynch_receive_from(...)
#ifdef WIN32
m_socketPtr->send_to(boost::asio::buffer("", 0), m_targetEndPoint);
#endif

this->AsyncReceive(); // Register Asynch Recieve callback and buffer
m_socketThread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(&MyNetworkBase::RunSocketThread, this)));

这在我的书中有点小题大做，但它比实现所有要求将异步接收的调用推迟到第一次传输之后要好得多。

于 2013-08-26T00:10:17.797 回答