如何用Asio与C++实现可用P2P连接？代码故障排查求助

核心错误点分析 #

• 悬空引用的错误码成员：构造函数中ec被初始化为对参数的引用，若调用时传入临时对象或局部变量，变量销毁后ec会变成悬空引用，后续所有错误判断都会出现未定义行为。应将ec改为值类型，而非引用。
• 静态回调导致的对象混淆：AwaitConnection里的acceptHandler是静态std::function，多个Peer对象会共享这个静态变量，第一次捕获的this会被后续对象覆盖，回调时会操作错误的实例。必须去掉static，每次调用时创建独立的回调函数。
• 未启动Asio事件循环：Asio的异步操作依赖io_context.run()处理事件回调，你的代码里没有调用这个方法，所以async_accept的回调永远不会触发，程序无法响应连接请求。
• 错误处理逻辑混乱：每次Asio操作后没有立即检查错误，错误码会被后续操作覆盖，无法定位具体失败原因；比如acceptor.open失败后仍继续执行bind，属于无效操作。
• Acceptor初始化冗余：构造函数中默认初始化acceptor，后续在Connect中再次open，可能导致重复打开的错误；应在需要监听时再完成acceptor的初始化流程。

修正后的代码示例 #

#include <asio.hpp>
#include <iostream>
#include <functional>

class Peer
{
public:
    Peer(asio::io_context& _context, std::string _IP, int _port);
    void Connect();
    bool isConnected() const { return connected; }

private:
    void AwaitConnection();
    asio::io_context& context;
    asio::ip::tcp::endpoint endpoint;
    asio::ip::tcp::socket socket;
    asio::ip::tcp::acceptor acceptor;
    bool connected;
};

Peer::Peer(asio::io_context& _context, std::string _IP, int _port) :
    context(_context),
    endpoint(asio::ip::address::from_string(_IP), _port),
    socket(_context),
    acceptor(_context),
    connected(false)
{
}

void Peer::Connect()
{
    std::cout << "Looking for connection..." << std::endl;
    asio::error_code ec;
    socket.connect(endpoint, ec);
    
    if (!ec)
    {
        std::cout << "Connected!" << std::endl;
        connected = true;
        return;
    }
    
    std::cout << "Connection failed: " << ec.message() << std::endl;
    socket.close(ec); // 关闭失败的socket
    
    // 初始化acceptor并开始监听
    acceptor.open(endpoint.protocol(), ec);
    if (ec)
    {
        std::cout << "Acceptor open failed: " << ec.message() << std::endl;
        return;
    }
    
    acceptor.set_option(asio::ip::tcp::acceptor::reuse_address(true), ec);
    if (ec)
    {
        std::cout << "Set reuse address failed: " << ec.message() << std::endl;
        acceptor.close(ec);
        return;
    }
    
    acceptor.bind(endpoint, ec);
    if (ec)
    {
        std::cout << "Bind failed: " << ec.message() << std::endl;
        acceptor.close(ec);
        return;
    }
    
    acceptor.listen(asio::socket_base::max_listen_connections, ec);
    if (ec)
    {
        std::cout << "Listen failed: " << ec.message() << std::endl;
        acceptor.close(ec);
        return;
    }
    
    std::cout << "Waiting for connection..." << std::endl;
    AwaitConnection();
}

void Peer::AwaitConnection()
{
    acceptor.async_accept(socket, [this](const asio::error_code& error)
    {
        if (!error)
        {
            std::cout << "Connection established!" << std::endl;
            connected = true;
        }
        else
        {
            std::cout << "Accept failed: " << error.message() << std::endl;
            // 可在此处重新尝试监听：AwaitConnection();
        }
    });
}

// 示例入口函数
int main()
{
    asio::io_context context;
    Peer peer(context, "127.0.0.1", 12345);
    
    peer.Connect();
    context.run(); // 必须启动事件循环
    
    return 0;
}

额外说明 #

• P2P场景局限：当前逻辑仅适用于同一局域网无NAT限制的场景，公网P2P需要STUN/TURN/ICE协议实现NAT穿透，否则不同NAT后的节点无法直接建立TCP连接。
• 异步操作注意事项：Asio异步操作必须保证io_context持续运行，若需处理多事件，可使用io_context::work防止事件循环提前退出。

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