提升 ASIO 和 UDP 错误答案

【问题标题】：Boost ASIO and UDP Errors提升 ASIO 和 UDP 错误
【发布时间】：2013-03-25 22:45:24
【问题描述】：

我有两个几乎相同的测试程序（A 和 B），它们使用相同的 boost asio UDP 异步代码。

这是接听电话：

_mSocket.async_receive_from(
            boost::asio::buffer(_mRecvBuffer), _mReceiveEndpoint,
            boost::bind(&UdpConnection::handle_receive, this,_mReceiveEndpoint,
            boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred));
// _mReceiveEndpoint is known and good. the buffer is good too.

// 这是处理程序

void handle_receive(const udp::endpoint recvFromEP, const boost::system::error_code& error,std::size_t  bytesRecv/*bytes_transferred*/)
{
    boost::shared_ptr<std::string> message(new std::string(_mRecvBuffer.c_array(),bytesRecv));
    if (!error) 
      {
      doSomeThingGood();
      } 
else {
        cerr << "UDP Recv error : " << error << endl;
    }
}

所以这就是发生的事情，都在本地主机上。

如果我先启动程序“A”，然后程序“B”，“A”会给出 UDP Recv 错误：服务器：10061。程序“A”继续发送正常，“B”接收正常。

你可以在上面的句子中交换'A'和'B'，它仍然是正确的。

如果我通过再次调用 mSocket.async_receive_from 尝试重置错误的读取条件，则会收到错误 10054。

我在网上查过这些错误.....不是很有帮助。

任何人都知道这些是什么意思，如果发生这种情况，我如何在程序内部恢复？有没有办法重置套接字？

健全性检查.... 两个程序都可以在只有两个端口的环回上运行吗？发送 = 20000，接收 = 20001 B 发送 = 20001，B 接收 = 20000

TL;DR 好像我在发送之前尝试收听，我收到一个错误并且我无法从中恢复。如果我在发送后收听，我很好。

-- 编辑 - 似乎 McAfee 主机入侵防护对我做了一些讨厌的事情......如果我在 VS2010 中调试，我会卡在他们的 DLL 中。

谢谢

【问题讨论】：

显然，在您可以在两个进程之间共享端口之前需要进行一些技巧：stackoverflow.com/questions/4364434/…

标签： udp boost-asio socketexception

【解决方案1】：

在我的接收处理程序中，我没有再次调用 _mSocket.async_receive_from()....我只是打印了错误并退出了。

愚蠢的错误，只是在这里发布以防万一它帮助其他人。

同样对于具有不同分辨率的类似问题： _mSocket.set_option(boost::asio::socket_base::reuse_address(true));

如果您有多个侦听器会有所帮助。

【讨论】：

【解决方案2】：

多个消息来源解释说您应该在 Windows 上使用 SO_REUSEADDR。但是没有人提到可以接收带有和绑定套接字的 UDP 消息。下面的代码将套接字绑定到本地的 listen_endpoint，这是必不可少的，因为没有它您可以并且仍然会收到您的 UDP 消息，但默认情况下您将拥有端口的独占所有权。

但是如果你在socket上设置reuse_address(true)（或者在使用TCP时在acceptor上），然后绑定socket，它会允许多个应用程序，或者你自己应用程序的多个实例再做一次，每个人将收到所有消息。

// Create the socket so that multiple may be bound to the same address.
boost::asio::ip::udp::endpoint listen_endpoint(
    listen_address, multicast_port);

// == important part ==
socket_.open(listen_endpoint.protocol());
socket_.set_option(boost::asio::ip::udp::socket::reuse_address(true));
socket_.bind(listen_endpoint);
// == important part ==

boost::array<char, 2000> recvBuffer;
socket_.async_receive_from(boost::asio::buffer(recvBuffer), m_remote_endpoint,
        boost::bind(&SocketReader::ReceiveUDPMessage, this, boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred)

来源： http://www.boost.org/doc/libs/1_45_0/doc/html/boost_asio/example/multicast/receiver.cpp

【讨论】：