同一提升 TCP 套接字对象上的多个连接
Multiple connections on the same boost tcp socket object
在这个例子(async_tcp_echo_server.cpp(,
#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(。结构大致如下所示
Server
|
|_ socket_
/
/
/
S1 S2
因此,S1 和 S2 将使用相同的socket_
从/向网络读取/写入消息。
我对此有两个问题:
对于第一个连接,一切都很好,但是为什么第二个连接应该正常工作?我们不是已经将
socket_
的所有权转移到第一届会议了吗?如何确保将回复发送到正确的客户端?每当有东西到达插座时,两个
async_read_some
中的任何一个都不会被触发吗?
对于第一个连接,一切都很好,但是为什么第二个连接应该正常工作?我们不是已经将socket_的所有权转移到第一届会议了吗?
从套接字移出后,套接字恰好基本上是"空的"或"新创建的"。这就是这起作用的原因。
不,套接字对象不会"神奇地"与移动的实例共享标识。实际上,标识只不过是底层套接字句柄,显然没有共享。
但是,当我们在所有连接中使用相同的套接字时,在第二个连接的情况下会发生什么?
你不是。您没有使用相同的套接字句柄。您也不使用相同的asio::ip::tcp::socket
对象实例。
相关文章:
- 如何在qt中将信号和插槽与另一个对象连接 --解决了
- QObject::连接无法将信号连接到*this*对象的插槽
- 如何在Qt中连接来自不同窗口的两个对象?
- Qt:如何通知对象已建立涉及它的信号槽连接
- 在线程 A 中创建一个 std::thread 对象,在线程 B 中连接
- 通过 COM 对象连接 x64 应用程序时出现问题
- 使用信号和插槽连接多个 UI 对象
- 如何正确解析 Java+C++ TCP 连接中的 JSON 对象?
- 为什么信号连接会使套接字客户端对象失效?
- 同一提升 TCP 套接字对象上的多个连接
- 可以在 QObject::connect() C++中连接 QML 对象现有信号?
- 从新分配的内存中连接到对象
- 销毁 qml 对象后的信号槽连接
- 如何连接两个不同的对象
- 如何在不使用对象的情况下连接字符串、整数和浮点数
- 数据库连接对象的名称游标的历史记录是什么
- 无法连接对象 xcode 4.2
- 寻找连接对象的字符串表示的惯用方法
- 是否有可能在c++代码中从mysql函数返回连接对象?
- 处理连接对象时出现分段错误