3

告诉我如何使用boost::asio::streambufwith boost::asio::async_write。我有一个连接到一个客户端的服务器应用程序。

我为每个连接创建 object tcp_connection。

如果我需要向客户端发送多个连续消息，如何正确创建用于发送数据的缓冲区？

我是否需要同步调用 Send() 因为它们使用全局缓冲区来发送？还是我需要在调用之前创建一个单独的缓冲区async_write？

例如，在使用 IOCP 的 Windows 中，我创建了自己的包含缓冲区的 OVERLAPPED 结构。我在调用 WSASend 之前创建一个缓冲区，并在操作完成后删除，从 OVERLAPPED 结构中提取它。即每个WSASend 都有自己的缓冲区。

怎么办boost::asio::async_write？

我在这里上课tcp_connection

#include <boost/asio.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/bind.hpp>
#include <iostream>

class tcp_connection
    // Using shared_ptr and enable_shared_from_this Because we want to keep the
    // tcp_connection object alive As long as there is an operation that refers to
    // it.
    : public boost::enable_shared_from_this<tcp_connection> {

    tcp_connection(boost::asio::io_service& io) : m_socket(io) {}

    void send(std::string data) {
        {
            std::ostream stream(&send_buffer);
            stream << data;
        }

        std::cout << "Send Data   =" << data                     << std::endl;
        std::cout << "Send Buffer =" << make_string(send_buffer) << std::endl;

        boost::asio::async_write(m_socket, send_buffer,
                                 boost::bind(&tcp_connection::handle_send, this, 
                                     boost::asio::placeholders::error,
                                     boost::asio::placeholders::bytes_transferred));
    }
    void handle_send(const boost::system::error_code &error, size_t);

  private:
    static std::string make_string(boost::asio::streambuf const&) { return "implemented elsewhere"; }
    boost::asio::ip::tcp::socket m_socket;
    boost::asio::streambuf send_buffer;
};
4

2 回答 2

1

要非常小心async_write，你不应该将 s 重叠async_write到同一个流（参见规范http://www.boost.org/doc/libs/1_51_0/doc/html/boost_asio/reference/async_write/overload1.html）。我不确定您是否真的需要异步写入，只要您不需要传输这么多数据并并行执行其他操作......如果您确实需要它，那么您应该确保同步。您可以使用一些锁定机制，在（异步）写入之前获取锁定并在WriteHandler.

于 2015-02-18T09:41:58.043 回答
1

如果缓冲区是连接的本地缓冲区，并且您不在其他线程中访问它，则不需要锁定或复制。这与不使用 Asio 的任何地方都没有什么不同。

您确实需要在同一个套接字上同步操作：为什么我在使用 boost::asio 时需要每个连接的链？

要发送整个缓冲区，只需使用boost::asio::async_write.

注意：您可能应该在完成处理程序的绑定中使用shared_from_this()而不是this

于 2015-02-18T10:46:38.143 回答