如何制作具有同步数据读/写功能的多客户端服务器

How to make a multi-client server with synchronous dataread/write functions?

本文关键字:功能 服务器 客户端 何制作 同步 数据      更新时间:2023-10-16

好吧,所以我可能在这里遇到了一个大问题。一直以来,我的代码都基于我可能想要的东西,也就是说,我正在使用同步boost::asio函数和一个可以同时拥有多个客户端的服务器。这是:

void session(tcp::socket socket, std::vector<Player>* pl)
{
debug("New connection! Reading username...n");
/* ...Username verification code removed... */
debug("Client logged in safely as ");
debug(u->name);
debug("n");
for (;;)
{
boost::array<unsigned char, 128> buf;
size_t len = socket.read_some(boost::asio::buffer(buf), error);
if (error == boost::asio::error::eof)
{
debug("Connection ended.n");
break; // Connection closed cleanly by peer.
}
else if (error)
throw boost::system::system_error(error); // Some other error.
DataHeader ins = static_cast<DataHeader>(buf.data()[0]);
std::vector<unsigned char> response;
/* ... Get appropiate response... */
// send response
boost::system::error_code ignored_error;
boost::asio::write(socket, boost::asio::buffer(response), ignored_error);
//debug("Sent ");
//debug(response.size());
//debug("B to client.n");
}
}

正如您从代码中看到的,我在一个非理想的场景中使用read_somewrite函数。现在,问题是,我是如何使这些代码同时可用于多个客户端的?我用了线程:

int main()
{
try
{
boost::asio::io_context io_context;
tcp::acceptor acceptor(io_context, tcp::endpoint(tcp::v4(), 13));
debug("Ready.n");
for (;;)
{
std::thread(session, acceptor.accept(), &players).detach(); // Accept incoming clients
}
}
catch (std::exception& e)
{
std::cerr << e.what() << std::endl;
}
return 0;
}

现在,我从未遇到过这种设置的问题,直到最近,我开始在一台服务器上同时测试多个客户端。这导致服务器多次崩溃,直到现在,我还认为问题只是连接问题。然而,现在我开始怀疑,"问题可能是同步功能吗?">

到目前为止,我看到的所有多客户端服务器的例子都使用异步函数,可能是因为需要它们。所以,我的最后一个问题是,我真的需要异步函数吗?这个代码有什么问题导致它崩溃吗?最后,如果需要异步函数,我该如何实现它们?非常感谢!

正如用户VTT所指出的,尽管这种方法可能会运行一段时间,但由于资源耗尽,最好切换到异步函数,因此,我将重做整个服务器来实现它们。