Boost Asio: 检查套接字是否可读/可写能力

Question

Boost Asio: 检查套接字是否可读/可写能力

c++socketsboostboost-asio

3

在我的应用程序中，我需要同时使用asio创建的套接字和原生的套接字（来自C Postgresql库）。

我需要的是能够在boost的io_service类实例上获取有特定套接字的通知，以便将其置于非阻塞可读/可写状态，但不执行实际的读取/写入操作（这将由第三方库完成），也就是说，仅仅使用select()/poll()。

通过将缓冲区长度设置为0并传递给async_read_some()函数，可以实现吗？

我进行了快速测试，确实调用async_read_some()并传递零长度的缓冲区会触发读事件处理程序，但我不确定它是否是在对应套接字句柄上等待真正的“可读”状态的select()/poll()阻塞之后才执行的。

- Dmitry Sychov

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Tanner Sansbury · Accepted Answer

这通常被称为反应器式操作。

通过向异步操作提供boost::asio::null_buffers，可以获得这些操作。反应器式操作提供了一种在可以执行读取或写入操作时被通知的方式，并且可用于与第三方库集成，使用共享内存池等。 Boost.Asio 文档提供了一些信息和以下示例代码：

ip::tcp::socket socket(my_io_service);
...
socket.non_blocking(true);
...
socket.async_read_some(null_buffers(), read_handler);
...
void read_handler(boost::system::error_code ec)
{
  if (!ec)
  {
    std::vector<char> buf(socket.available());
    socket.read_some(buffer(buf));
  }
}

Boost.Asio还提供了一个官方的非阻塞示例，演示如何与希望直接在套接字上执行读写操作的库集成。

提供一个零长度的缓冲区给操作通常会导致无操作，因为操作的完成条件已经满足而没有尝试执行任何I/O。这里是一个完整的示例demonstrating，演示了两者之间的差异：

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

// This example is not interested in the handlers, so provide a noop function
// that will be passed to bind to meet the handler concept requirements.
void noop() {}

void print_status(
  const boost::system::error_code& error,
  std::size_t bytes_transferred,
  boost::asio::ip::tcp::socket& socket)
{
  std::cout << "error: " << error.message() << "; "
               "transferred: " << bytes_transferred << "; "
               "available: " << socket.available() << std::endl;
}

int main()
{
  using boost::asio::ip::tcp;

  // Create all I/O objects.
  boost::asio::io_service io_service;
  tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 0));
  tcp::socket socket1(io_service);
  tcp::socket socket2(io_service);

  // Connect the sockets.
  acceptor.async_accept(socket1, boost::bind(&noop));
  socket2.async_connect(acceptor.local_endpoint(), boost::bind(&noop));
  io_service.run();
  io_service.reset();

  std::array<char, 512> buffer;

  // Reading into a zero-length buffer is a no-op and will be
  // considered immediately completed.
  socket1.async_receive(boost::asio::buffer(buffer, 0), 
    boost::bind(&print_status,
      boost::asio::placeholders::error,
      boost::asio::placeholders::bytes_transferred,
      boost::ref(socket1))
  );
  // Guarantee the handler runs.
  assert(1 == io_service.poll());
  io_service.reset();

  // Start a reactor-style read operation by providing a null_buffer.
  socket1.async_receive(boost::asio::null_buffers(),
    boost::bind(&print_status,
      boost::asio::placeholders::error,
      boost::asio::placeholders::bytes_transferred,
      boost::ref(socket1))
  );
  // Guarantee that the handler did not run.
  assert(0 == io_service.poll());
  // Write to the socket so that data becomes available.
  boost::asio::write(socket2, boost::asio::buffer("hello"));  
  assert(1 == io_service.poll());
}

输出：

error: Success; transferred: 0; available: 0
error: Success; transferred: 0; available: 6