c++ - Boost.Asio 套接字被阻止

Question

main.cpp 中的 for 循环调用了一个使用 boost::mutex 并使用 read_until 从套接字读取的函数，它只运行一次，之后就好像被阻塞了。我试过在右括号之前放一个 continue 然后它崩溃了。这可能与线程有关。

// MAIN.CPP

int main(int argc, char* argv[])
{   
    std::cout << "Enter port number: ";
    std::string port;
    std::getline(std::cin, port);
    int tempPort = std::stoi(port);
    Network * network = new Network(tempPort);

    int it = 0;
    boost::thread * t1;
    t1 = new boost::thread([&network, &it]
    {
        while (true)
        {
            boost::asio::ip::tcp::socket * sock = new boost::asio::ip::tcp::socket(network->io_service);
            network->accept(*sock);

            if (network->socketList.size() > 0)
            {
                for (boost::asio::ip::tcp::socket * s : network->socketList)
                {
                    if (s->remote_endpoint().address().to_string() == sock->remote_endpoint().address().to_string())
                    {
                        continue;
                    }
                    else {
                        network->socketList.push_back(sock);
                        std::cout << s->remote_endpoint().address().to_string() << " connected." << std::endl;
                    }
                }
            }
            else {
                network->socketList.push_back(sock);
                std::cout << sock->remote_endpoint().address().to_string() << " connected." << std::endl;
            }
        }
    });

    while (true)
    {
        for (boost::asio::ip::tcp::socket * sock : network->socketList)
        {
            std::cout << "on range-based for loop" << std::endl;
            network->readChatMessage(*(sock));
        }
    }
    t1->join();

    return 0;
}

// NETWORK.CPP
int Network::sendChatMessage(boost::asio::ip::tcp::socket & socket, ChatMessage & message)
{
    try
    {
        boost::system::error_code err;

        boost::asio::streambuf buf;
        {
            std::ostream out(&buf);
            boost::archive::text_oarchive oa(out);
            oa & message;

            std::cout << std::string(message.text.begin(), message.text.end()) << std::endl;
        }

        m.lock();
        write(socket, buf, err);

        if (err)
        {
            std::cout << err.message() << std::endl;
        }

        m.unlock();

        std::cout << "Mensagem enviada com sucesso!" << std::endl;
    }
    catch (std::exception& e)
    {
        std::cout << e.what() << std::endl;
    }

    return 0;
}

int Network::readChatMessage(boost::asio::ip::tcp::socket & socket)
{
    std::cout << "in readChatMessage()" << std::endl;

    boost::system::error_code err;

    boost::asio::streambuf buf;

    m.lock();
    boost::asio::read_until(socket, buf, '\0', err);

    if (err)
    {
        std::cout << err.message() << std::endl;
    }

    m.unlock();

    std::istream in(&buf);
    ChatMessage message;

    boost::archive::text_iarchive ia(in);
    ia & message;

    std::cout << std::string(message.text.begin(), message.text.end()) << std::endl;
    this->sendChatMessage(socket, message);

    return 0;
}

Answer 1

在稍微调试和编辑代码后我能够解决问题，然后我能够看到发生错误:input stream error 由于序列化输入/输出。我正确地处理了错误，在错误发生时解锁了互斥量并且没有让互斥量撤消。

片段:

int Network::readChatMessage(boost::asio::ip::tcp::socket & socket)
{
    std::cout << "in readChatMessage()" << std::endl;

    boost::system::error_code err;

    boost::asio::streambuf buf;

    m.lock();
    boost::asio::read_until(socket, buf, '\0', err);

    if (err)
    {
        m.unlock();
        std::cout << err.message() << std::endl;
        return 0;
    }
    else {

        m.unlock();

        std::istream in(&buf);
        ChatMessage message;

        boost::archive::text_iarchive ia(in);
        ia & message;

        std::cout << std::string(message.text.begin(), message.text.end()) << std::endl;
        this->sendChatMessage(socket, message);
        return 0;
    } 
    m.unlock();

    return 0;
}