Boost.Asio异步accept未调用指定处理函数问题求助

尝试用Boost框架搭建支持多客户端的简易Socket服务器，但遇到async_accept函数未调用指定处理函数的问题。对Boost框架不太熟悉，推测是简单问题但不知如何解决。

代码示例 #

#include <boost/asio.hpp>
#include <boost/thread/thread.hpp>
#include <iostream>

using namespace boost::asio;
using ip::tcp;
using std::cout;
using std::endl;
using std::string;
void accept_handler(const boost::system::error_code& error) {
if (!error) {
std::cout << "Success";
} else {
std::cout << "Failed";
  
}
}

void server(int port) {
boost::asio::io_service io_service;
// listen for new connection
tcp::acceptor acceptor_(io_service, tcp::endpoint(tcp::v4(), port));
std::cout << "Listening for Connection\n";
// socket creation
tcp::socket socket_(io_service);
// waiting for the connection
std::cout << "Waiting for Clients\n";
acceptor_.async_accept(socket_, accept_handler);
}

查阅Boost框架文档，文档说明：

"This function is used to ask the io_service to execute the given handler, but without allowing the io_service to call the handler from inside this function."

想了解如何让async_accept自动调用指定的处理函数。

问题核心是Boost.Asio的异步操作依赖io_service的事件循环触发回调，你只调用async_accept发起了异步操作，但没启动io_service的事件循环，导致处理函数永远不会被调用。

关键修改点 #

1. 调用io_service.run()启动事件循环，它会阻塞直到所有异步操作完成或被主动停止。
2. 要支持多客户端，需在accept_handler中再次调用async_accept，确保服务器能持续接收新连接。

修改后的代码示例 #

#include <boost/asio.hpp>
#include <boost/thread/thread.hpp>
#include <iostream>

using namespace boost::asio;
using ip::tcp;
using std::cout;
using std::endl;
using std::string;

void accept_handler(const boost::system::error_code& error, tcp::acceptor& acceptor) {
    if (!error) {
        std::cout << "客户端连接成功\n";
        // 此处可添加对当前客户端的读写逻辑
        
        // 准备接受下一个客户端连接
        tcp::socket new_socket(acceptor.get_io_service());
        acceptor.async_accept(new_socket, [&acceptor](const boost::system::error_code& ec) {
            accept_handler(ec, acceptor);
        });
    } else {
        std::cout << "连接失败: " << error.message() << "\n";
    }
}

void server(int port) {
    boost::asio::io_service io_service;
    tcp::acceptor acceptor_(io_service, tcp::endpoint(tcp::v4(), port));
    std::cout << "监听端口 " << port << "...\n";
    
    tcp::socket socket_(io_service);
    std::cout << "等待客户端连接...\n";
    
    // 用lambda捕获acceptor，传递给处理函数
    acceptor_.async_accept(socket_, [&acceptor_](const boost::system::error_code& ec) {
        accept_handler(ec, acceptor_);
    });
    
    // 启动io_service事件循环，必须调用
    io_service.run();
}

int main() {
    server(8080);
    return 0;
}

补充说明 #

• io_service.run()是异步操作的核心，它负责监听并分发异步事件到对应的处理函数。
• 原代码中的局部socket对象生命周期需注意，修改后通过在处理函数中创建新socket，避免对象提前销毁导致的问题。
• 重复调用async_accept是实现多客户端支持的关键，每次处理完一个连接后，立即准备接受下一个。

内容的提问来源于stack exchange，提问作者gtech