C++Boost Asio-如何检测断开连接并列出所有活动连接

Question

我使用Boost asio作为TCP服务器解决方案。我希望我的服务器和客户端通过TCP二进制协议进行通信。

这是我的服务器代码：

服务器.cpp:

#include "Server.h"
#include "Session.h"
using namespace Vibranium;
void Server::do_accept()
{
acceptor_.async_accept(socket_,
[this](boost::system::error_code ec)
{
if (!ec)
{
std::cout << "Connected!" << std::endl;
std::make_shared<Session>(std::move(socket_))->start();
}
do_accept();
});
}

这里是Session.cpp:

#include "Session.h"
void Vibranium::Session::start() {
do_read();
}
void Vibranium::Session::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)
{
std::cout.write(data_, length);
std::cout << "n";
do_write(length);
}
});
}
void Vibranium::Session::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();
}
});
}

这里是Session.h:

#ifndef VIBRANIUM_CORE_SESSION_H
#define VIBRANIUM_CORE_SESSION_H
#include <cstdlib>
#include <iostream>
#include <memory>
#include <utility>
#include <boost/asio.hpp>
using boost::asio::ip::tcp;
namespace Vibranium{
class Session: public std::enable_shared_from_this<Session>
{
public:
Session(tcp::socket socket)
: socket_(std::move(socket))
{
}
void start();
private:
void do_read();
void do_write(std::size_t length);
tcp::socket socket_;
enum { max_length = 1024 };
char data_[max_length];
};
}
#endif //VIBRANIUM_CORE_SESSION_H

以下是我如何启动服务器：

#include "Config.h"
#include "Database/MySQLConnection.h"
#include "Implementation/LoginDatabase.h"
#include "Banner.h"
#include "Server/Server.h"
#include <boost/asio.hpp>
using boost::asio::ip::tcp;
using namespace std;
using namespace Vibranium;
int main() {
//Don't mind Logger::FatalError it's just for coloring!
Banner::Show(Logger::Error,"AuthServer");
Config config("AuthServer");
std::string defaultPort = "8080";
MySQLConnectionInfo mySqlConnectionInfo(config, "LoginDatabaseInfo");
LoginDatabaseConnection loginDatabaseConnection(mySqlConnectionInfo);
loginDatabaseConnection.LoadDatabase();
try
{
boost::asio::io_service io_service;
Server s(io_service, std::stoi(config.GetConfigValue("AuthServerPort", defaultPort)));
io_service.run();
}
catch (std::exception& e)
{
std::cerr << "Exception: " << e.what() << "n";
}
return 0;
}

因此，我在Server::do_accept()中捕获新的连接，很可能在那里我必须填充所有客户端端点的向量。因此，在稍后的阶段，我可以创建一个名为Send的函数来发送到特定客户端，另一个称为Broadcast的函数则发送到所有连接的客户端。

这里有两个问题：

1. 包含所有连接的向量的类型应该是什么？我应该在哪里填
2. 如何检测断开连接，以便从连接的客户端向量中删除客户端

Answer 1

1.包含所有连接的向量的类型应该是什么？我应该在哪里填？

您可以创建一个用于存储客户端的套接字向量：

vector<tcp::socket> clients; // adding by clients.push_back(move(socket)); after accept'ing

或者围绕套接字创建一些包装类并使用它，例如

class Client
{ 
tcp::socket socket;
public:
Client (tcp::socket s) : socket{move(s)} {}
... some other logic

并使用vector<Client>进行存储。

2.如何检测断开连接，以便从连接的客户端向量中删除客户端？

您可以使用读取/写入套接字的第一次失败作为断开连接的指示器，或者定期使用某种"保持活动"消息作为ping消息来检测断开(或过时(的连接。