非Boost版Asio在JUCE应用中读取时报‘错误文件描述符’原因排查

我写了一个简单的Asio TCP服务器，代码如下：

using asio::ip::tcp;

class Client
{
public:
    Client(tcp::socket&& openedSocket)  : socket(std::move(openedSocket)), readBuffer(1024)
    {
        socket.async_read_some(asio::buffer(readBuffer.data(), readBuffer.size()), std::bind(&Client::handleRead, this, std::placeholders::_1, std::placeholders::_2));
    }

private:
    void handleRead(const asio::error_code& error, size_t numRead)
    {
        if(error)
        {
            std::cout << error.message() << std::endl;
        }
        else
        {
            std::cout << "Reading" << std::endl;
        }
    
        socket.async_read_some(asio::buffer(readBuffer.data(), readBuffer.size()), std::bind(&Client::handleRead, this, std::placeholders::_1, std::placeholders::_2));
    }

    tcp::socket socket;
    std::vector<uint8_t> readBuffer;
};

class Server
{
public:
    Server()  : acceptor(context, tcp::endpoint(tcp::v4(), 3030))
    {
        try
        {
            startAccept();
            context.run();
        }
        catch(const std::exception& e)
        {
            std::cout << e.what() << std::endl;
        }
    }

private:
    void startAccept()
    {
        acceptor.async_accept(std::bind(&Server::handleAccept, this, std::placeholders::_1, std::placeholders::_2));
    }

    void handleAccept(const asio::error_code& error, tcp::socket socket)
    {
        if(!error)
        {
            clients.push_back(std::make_unique<Client>(std::move(socket)));
        }
        else
        {
            std::cout << error.message() << std::endl;
        }
    
        startAccept();
    }

    asio::io_context context;
    tcp::acceptor acceptor;

    std::vector<std::unique_ptr<Client>> clients;
};

这段代码在普通main函数中实例化Server类运行正常，能成功读取数据。但在JUCE应用中，从JUCE消息线程实例化Server类后，客户端可以成功连接，但所有读取操作都会触发bad file descriptor（错误文件描述符）错误。

原因分析 #

• IO上下文阻塞JUCE消息线程：Server构造函数中直接调用context.run()，会阻塞JUCE的消息线程。JUCE消息线程是单线程事件循环，被阻塞后无法处理自身消息队列，可能导致Asio异步IO操作调度异常，甚至触发socket文件描述符被意外回收。
• 线程模型冲突：Asio异步操作依赖独立的IO上下文线程执行回调，将context.run()放在JUCE消息线程中，会导致两个事件循环抢占同一线程资源。当JUCE消息线程被Asio的run占用时，JUCE内部资源管理逻辑可能异常，间接导致socket失效。
• socket生命周期异常：虽然用std::unique_ptr管理Client对象，但如果IO上下文未在独立线程运行，异步读取回调可能在socket已被销毁后才执行，此时文件描述符已无效，触发错误。

解决方案 #

1. 单独启动线程运行Asio IO上下文 #

修改Server类，将IO上下文的run放到独立线程中执行，避免阻塞JUCE消息线程：

class Server
{
public:
    Server()  : acceptor(context, tcp::endpoint(tcp::v4(), 3030))
    {
        try
        {
            startAccept();
            // 启动后台线程运行IO上下文
            ioThread = std::thread([this]() { context.run(); });
        }
        catch(const std::exception& e)
        {
            std::cout << e.what() << std::endl;
        }
    }

    ~Server()
    {
        // 停止IO上下文并等待线程结束
        context.stop();
        if (ioThread.joinable())
            ioThread.join();
    }

private:
    // 原有的startAccept、handleAccept方法保持不变

    asio::io_context context;
    tcp::acceptor acceptor;
    std::vector<std::unique_ptr<Client>> clients;
    std::thread ioThread; // 新增线程成员
};

2. 遵循JUCE线程规范 #

JUCE的消息线程仅用于处理UI交互和消息分发，所有耗时、阻塞或异步IO操作都应放到后台线程执行，避免影响应用响应性和资源管理。

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