c++ - 服务器在已经处理请求时收到请求时崩溃

Question

只要一次只发送一个请求，我的服务器代码就可以正常工作。数据流是这样的:客户端做了一些事情，比如点击一个按钮，然后数据被发送到服务器。 uint16_t 类型的 header 被添加到此数据之前，以便服务器知道可用于此请求读取的字节中有多少字节 - 我认为该解决方案可以解决我遇到的问题。在服务器上，我将来自 QTcpSocket 的 readyRead 信号连接到一个读取 header 的函数，如下所示:

void Server::getHeader(){    
    QTcpSocket *client = qobject_cast<QTcpSocket *>(sender());
        if (!client)
            return;

    forever {
        int N = sizeof(uint16_t);
        qint64 bytes = client->bytesAvailable();
        if (bytes < N) break;
        QByteArray buf = client->read(N);
        emit hasData(buf, client); //contains the number of bytes in the stream for this request and a reference to the current client
    }
}

hasData 信号将触发一个函数，该函数将执行与 getHeader 函数相同的操作，但会等待 bytes 字节数可用而不是 sizeof(uint16_t) 字节可用。一旦它发现所需的字节数可用，它就会从流中读取那么多的字节并将它们存储在 char[] 中，然后将其发送到一个可以理解数据的函数(其中出现问题)像这样:

void Server::handleConnection(std::string serverReceiveBuf, QTcpSocket *client){
    receivedData data; //a struct that organizes the data to be easily readable by a human
    QString stringBuilder;
    try{
        data.activityID = serverReceiveBuf.at(0);
        data.stringCount = serverReceiveBuf.at(1);
        int i,
            j = 2, //placeholder for next slot to be used in the receive buffer
            k = 0;
        for (i = 0; i < data.stringCount; i++){ //while there are strings whose lengths we need to document
            data.stringLength.insert(i, serverReceiveBuf.at(2+i));
            j++;
        }
        while(k < data.stringCount){ //while there are strings in the buffer to be put into the data structure
            i = 0;
            while(i < data.stringLength.at(k)){ //while there are characters in the buffer to be built into a string
                stringBuilder.append(serverReceiveBuf.at(j));
                j++;
                i++;
            }
            //we have assembled a string from chars in the buffer
            //now we put them into the struct
            data.stringData << stringBuilder;
            stringBuilder = ""; //empty string builder for next string.
            k++;
        }
    }
    catch(std::exception e){
        qDebug() << "[" << currentTime() << "] " << "An undefined buffer error occurred.";
    }

    //Handle based on activity ID
}

我将此代码放入 try/catch 中以防止服务器崩溃。它现在并不意味着是描述性的。如果我将其取出，一旦我尝试访问应该位于 serverReceiveBuf 中的数据(从可用字节流中读取的字符串)，服务器就会崩溃，因为它是空的。使用 try/catch block ，任何仍在处理中发送的请求都会被忽略，错误消息会显示在服务器控制台上。

现在是令人沮丧的部分:当我尝试使用调试器单步执行代码时，它起作用了。大概是因为在调试器返回处理第二个请求时请求已完成处理。我认为请求应该排队，但显然不是。我是否需要做一些特殊的事情来强制对数据进行排队，以便我可以确保在尝试处理下一个请求之前处理当前请求？

Answer 1

forever 
{
        int N = sizeof(uint16_t);
        qint64 bytes = client->bytesAvailable();
        if (bytes < N) break;
        QByteArray buf = client->read(N);
        emit hasData(buf, client); //contains the number of bytes in the stream for this request and a reference to the current client
}

Qt 是事件驱动的，并依赖于事件来处理信号，例如您的 emit hasData 调用。

假设您的服务器接收到的数据大于 uint16_t 的大小(这很有可能)，服务器将陷入您的永久循环并且无法处理它自己的事件，例如处理您发出 hasData 的调用。

您可以通过在循环底部添加对 QApplication::processEvents() 的调用来测试这一点，以确保 Qt 事件得到处理。理想情况下，您不应该使用该函数，而是重构您的代码，以便它从该函数正常返回，直到收到更多数据进行处理。