0

我不是 boost 专家，我正在尝试使用 boost::asio。一切都很好，直到我做的事情搞砸了。不幸的是，我不确定我做了什么... =P

这是发生的事情：

我有一个服务器，它是一个 C++ Builder 应用程序，它打开我的客户端应用程序（Visual Studio C++ DLL）连接的套接字。

当我尝试向套接字写入内容时，我没有收到任何错误，但服务器会收到这样的字符串：“\0SomeText”。我不知道 \0 是从哪里来的。

下面的一些代码可能会解决问题：

    void CometClient::SendCommand()
{
    if (socket_.is_open())
    {
        TCommands::iterator it = pending_commands.begin();
        while (it != pending_commands.end())
        {
            std::vector<char> vctCommand;
            vctCommand.assign((*it).begin(), (*it).end());
            vctCommand.push_back('\n');
            boost::shared_ptr<std::vector<char> > ptr_command = boost::make_shared<std::vector<char> > (vctCommand);

            boost::asio::async_write(socket_, boost::asio::buffer( *ptr_command ) ,
                boost::bind(&CometClient::handle_write_request, this,
                    boost::asio::placeholders::error, ptr_command )
                );
            it = pending_commands.erase(it);
        }

    }
    else
    {
        // Something
    }
}

void CometClient::handle_write_request(const boost::system::error_code& err, boost::shared_ptr< std::vector<char> > command)
{
    if (!err)
    {
        std::vector<char> * ptr = command.get();
        boost::asio::async_read_until(socket_, response_, "\n",
            boost::bind(&CometClient::handle_read_content, this,
            boost::asio::placeholders::error));
    }
    else
    {
        // Something
    }
}

任何帮助将不胜感激。

提前致谢！

编辑：

这是我在 janm 回答后得到的：

    void CometClient::SendCommand()
{
    // bConnected tells me if the server has already answered me and Connected just tells me if the socket is open (will change in the near future)
    if (Connected() && pending_commands.size() && bConnected)
    {
        std::vector<char> vctCommand;
        std::string sCommand(pending_commands.front().c_str());
        pending_commands.pop_front();
        vctCommand.assign(sCommand.begin(), sCommand.end());
        vctCommand.push_back('\n');
        boost::shared_ptr<std::vector<char> > ptr_command = boost::make_shared<std::vector<char> > (vctCommand);

        boost::asio::async_write(socket_, boost::asio::buffer( *ptr_command, sCommand.length() ) ,
            boost::bind(&CometClient::handle_write_request, this,
            boost::asio::placeholders::error, ptr_command )
            );
    }
    else
    {
        // Something
    }
}

void CometClient::handle_write_request(const boost::system::error_code& err, boost::shared_ptr< std::vector<char> > command)
{
    if (!err)
    {
        std::vector<char> * ptr = command.get();
        boost::asio::async_read_until(socket_, response_, "\n",
            boost::bind(&CometClient::handle_read_content, this,
            boost::asio::placeholders::error));
        SendCommand();
    }
    else
    {
        // Something
    }
}
4

2 回答 2

2

您正在生成多个并发调用async_write(). 这些调用不保证是原子的或按顺序的。原因是它async_write()是通过多次调用来实现的async_write_some()，调用者必须确保只有一个async_write()在进行中，就像任何一次一样。

更好的方法是从队列中取出第一个命令并在完成处理程序中启动下一个写入。这可能是您意想不到的虚假字节的原因。

要检查的另一件事是您的向量是否确实包含您认为它们包含的内容。使用调试器或发出的日志输出检查这一点。

于 2013-07-04T02:07:53.257 回答
0

我将把它留在这里只是为了记录。

问题之一正是 janm 所说的，实际上我正在对 async_write 进行多次并发调用。我ve fixed that and it wasn不够。与朋友交谈时，我们发现我发送的字符串大小错误，所以我稍微更改了代码，下面我将粘贴最后的方法，它有效。=)

我学到了什么：

  • 注意不要对 async_write 进行多次并发调用
  • 注意为了发送正确的字节数
  • 请记住在 async_write 调用结束之前保持缓冲区内容处于活动状态

非常感谢@janm

void CometClient::AddCommand(std::string _command)
{
    pending_commands.push_back(_command);
    ExecuteCommands();
}

void CometClient::ExecuteCommands()
{
    if (Conectado() && pending_commands.size())
    {
        boost::asio::async_write(socket_, boost::asio::buffer( pending_commands.front(), pending_commands.front().length() ) ,
            boost::bind(&CometClient::handle_write_request, this,
            boost::asio::placeholders::error)
            );
    }
    else
    {
        // Something
    }
}

void CometClient::handle_write_request(const boost::system::error_code& err)
{
    if (!err)
    {
        pending_commands.pop_front();
        boost::asio::async_read_until(socket_, response_, "\n",
            boost::bind(&CometClient::handle_read_content, this,
            boost::asio::placeholders::error));
        ExecuteCommands();
    }
    else
    {
        // Something
    }
}
于 2013-07-04T18:34:42.067 回答