同一个 boost tcp 套接字对象上的多个连接

Question

#include <cstdlib>
#include <iostream>
#include <memory>
#include <utility>
#include <boost/asio.hpp>

using boost::asio::ip::tcp;

class session
  : public std::enable_shared_from_this<session>
{
public:
  session(tcp::socket socket)
    : socket_(std::move(socket))
  {
  }

  void start()
  {
    do_read();
  }

private:
  void do_read()
  {
    auto self(shared_from_this());
    socket_.async_read_some(boost::asio::buffer(data_, max_length),
        [this, self](boost::system::error_code ec, std::size_t length)
        {
          if (!ec)
          {
            do_write(length);
          }
        });
  }

  void do_write(std::size_t length)
  {
    auto self(shared_from_this());
    boost::asio::async_write(socket_, boost::asio::buffer(data_, length),
        [this, self](boost::system::error_code ec, std::size_t /*length*/)
        {
          if (!ec)
          {
            do_read();
          }
        });
  }

  tcp::socket socket_;
  enum { max_length = 1024 };
  char data_[max_length];
};

class server
{
public:
  server(boost::asio::io_service& io_service, short port)
    : acceptor_(io_service, tcp::endpoint(tcp::v4(), port)),
      socket_(io_service)
  {
    do_accept();
  }

private:
  void do_accept()
  {
    acceptor_.async_accept(socket_,
        [this](boost::system::error_code ec)
        {
          if (!ec)
          {
            std::make_shared<session>(std::move(socket_))->start();
          }

          do_accept();
        });
  }

  tcp::acceptor acceptor_;
  tcp::socket socket_;
};

int main(int argc, char* argv[])
{
  try
  {
    if (argc != 2)
    {
      std::cerr << "Usage: async_tcp_echo_server <port>\n";
      return 1;
    }

    boost::asio::io_service io_service;

    server s(io_service, std::atoi(argv[1]));

    io_service.run();
  }
  catch (std::exception& e)
  {
    std::cerr << "Exception: " << e.what() << "\n";
  }

  return 0;
}

多个会话正在使用同一个 boost::ip::tcp::socket 对象。在 do_accept() 函数中，在每次传入连接时，我们都会创建一个新的会话对象，并通过右值引用（即 std::move()）将 socket_ 传递给它。

假设我们有两个活动连接（S1 和 S2）。结构大致如下

因此 S1 和 S2 将使用相同的 socket_ 到 read/write 消息 from/to 网络。

我有两个问题：

第一次连接一切正常，为什么第二次连接就可以了？我们不是已经把socket_的所有权转移到第一个session了吗？
如何确保将回复发送到正确的客户端？每当有东西到达套接字时，两个 async_read_some 中的任何一个都不能被触发吗？

Answer 1

For the first connection everything is fine, but why is the second connection supposed to work all right? Haven't we already transferred the ownership of socket_ to the first session?

从套接字移开后，套接字恰好本质上是"empty"或"newly created"。这就是它起作用的原因。

不，套接字对象不 "magically" 与移动的实例共享身份。事实上，身份只不过是底层套接字句柄，显然不是共享的。

But what happens in case of a second connection, as we are using the same socket in all connections?

你不是。您没有使用相同的套接字句柄。您也没有使用相同的 asio::ip::tcp::socket 对象实例。

同一个 boost tcp 套接字对象上的多个连接

Multiple connections on the same boost tcp socket object

c++

boost

boost-asio