使用 Qt 通过 TCP 套接字分部分发送 xml 消息

Question

我们正在编写一个项目，其中有一个客户端生成 xml 请求，将它们发送到服务器，服务器解析该请求并以 xml 字符串返回所请求的信息。

当 xml 回复很小时，应用程序工作正常，但当它们超过大约 2500 个字符时，它们有时会在客户端被截断。我说有时是因为当客户端和服务器在同一台机器上运行并通过主地址 127.0.0.1 进行通信时，回复会被很好地解析。但是，当客户端和服务器位于不同的计算机上并通过 LAN 进行通信时，客户端会将消息剪切为大约 2500 个字符。

通信是通过 tcp 套接字完成的。我们使用Qt，客户端有一个qTCPsocket，服务器有一个qTCPserver和一个指向qtcpsocket的指针。

我们认为解决这个问题的一个可能的解决方案是分段发送 xml，按字符数或标记分隔。虽然我们很容易将消息分成几部分，但发送这些部分并让客户端或服务器读取这些部分并将其编译为一个 xml 请求会给我们带来麻烦。

举例来说，我们想要测试让客户端分多个部分发送请求。

这是我们发送请求的客户端函数调用。 xmlReq 在其他位置生成并传入。作为将消息分成几部分的示例，我们从 xml 请求中删除结束标记，然后将其作为另一部分发送。

QString ClientConnection::sendRequest(QString xmlReq)
{

    this->xmlRequest = xmlReq;

    QHostAddress addr(address);

    QList<QString> messagePieces;
    xmlRequest.remove("</message>");

    messagePieces.append(xmlRequest);
    messagePieces.append("</message>");


    client.connectToHost(addr,6789);

    if(client.waitForConnected(30000))
    {
        for(int i = 0; i < messagePieces.length();i++)
        {  
            client.write(messagePieces[i].toAscii(),messagePieces[i].length()+1);
            qDebug() << "Wrote: " << messagePieces[i];
        }
    }


    char message[30000] = {0};

    xmlReply = "";

    if(client.waitForReadyRead(30000)){


        client.read(message,client.bytesAvailable());


    }else{
        xmlReply = "Server Timeout";
    }

    client.close();
    xmlReply = (QString) message;

    return xmlReply;

}

接下来是我们的服务器代码。它的编写方式是从客户端读取消息，直到看到 xml 结束消息标记，然后处理数据并将回复发送回客户端。

这是启动服务器的代码。

//Start the server, pass it the handler so it can perform queries
    connect(&server, SIGNAL(newConnection()), this, SLOT(acceptConnection()));
    server.listen(QHostAddress::Any, 6789);

当它获得一个新连接时，它会调用acceptConnection槽，它看起来像这样

    void CETServer::acceptConnection()
{
    client = server.nextPendingConnection();
    connect(client, SIGNAL(readyRead()), this, SLOT(startRead()));
}

startRead看起来像这样：

void CETServer::startRead()
{
    char buffer[1024*30] = {0};

    client->read(buffer, client->bytesAvailable());

    QString readIn;

    readIn = (QString) buffer;

    ui->statusText->appendPlainText("Received: " + readIn);

    //New messages in will be opened with the xml version tag
    //if we receive said tag we need to clear our query
    if (readIn.contains("<?xml version =\"1.0\"?>",Qt::CaseSensitive))
    {
        xmlQuery = "";
    }

    //add the line received to the query string
    xmlQuery += readIn;

    //if we have the clsoe message tag in our query it is tiem to do stuf with the query
    if(xmlQuery.contains("</message>"))
    {
        //do stuff with query

        ui->statusText->appendPlainText("Query received:" + xmlQuery);

        QString reply = this->sqLite->queryDatabase(xmlQuery);
        xmlQuery = "";

        this->commandStatus(reply);

        if(client->isWritable()){
            //write to client
            client->write(reply.toAscii(),reply.length()+1);
            ui->statusText->appendPlainText("Sent to client: " + reply);
            client->close();

        }
    }}

在我看来，start read的编码方式是这样的：每当客户端写入消息时，服务器都会读取它并将其附加到服务器存储的 xmlRequest。如果消息包含 xml 结束标记，则它会处理该请求。

但是，如果客户端连续进行写入，服务器不会读取所有写入，而只会读取第一个写入，并且永远不会收到 xml 结束标记，因此不会处理任何请求。

我需要回答的问题是为什么服务器不响应客户端的多次写入？我应该如何制作它，以便我可以发送一个 xml 字符串，分成几部分，并让服务器读取所有部分并将其再次转换为一个字符串？

Answer 1

在 TCP 中，有一个称为最大段大小的东西。在数据传输初始化之前，双方在SYN握手阶段决定MSS。这就是您的数据被分割的原因。

你只有一个 client.read() 。服务器将为每次处理的读取发送回复。您需要在客户端使用类似的机制来处理读取。一个读取直到读取 N 个字节的函数。您可以在数据传输开始时发送值 N。

Answer 2

这是由于 TCP 协议的“流”性质而发生的。数据被分成许多数据包，在您的应用程序中，您实际上只读取其中的一部分（bytesAvailable() 不一定等于其他主机发送的字节数，它只是数据包中有多少可用字节。套接字缓冲区）。
你所要做的就是在客户端和服务器之间建立一个简单的协议。例如，客户端首先发送 STX 字符，然后发送 XML，最后发送 ETX 字符。
当服务器看到 STX 字符时，它会将所有内容读入缓冲区，直到 EXT 字符。
其他方法 - 以网络字节顺序发送 4 字节整数，指示 XML 数据的大小（以字节为单位），然后发送 XML。另一台主机必须接收该整数，将其转换为其本机字节顺序，然后将指定数量的数据从套接字读取到缓冲区。

Answer 3

COMP 3004 我明白了。这样的噩梦，我们一直在尝试使用 QXmlStreamReader 和 QXmlStreamWriter。作者很好，很简单，但读者却是一场噩梦，我们一直在尝试使用 PrematureEndOfDocument 错误作为断点，以了解还有更多数据。