QTcpSocket readyRead信号在传输数据时停止发射

我在使用QT-Framework为自己编写一些网络应用程序时偶然发现了一个问题 . 我非常喜欢信号/插槽系统，但我感觉我在这里遇到了竞争状态 .

我的服务器正在快速发送小的“电报”，因为它们不值得自己的TCP数据包（很好） .

在客户端，我使用套接字readyRead-slot并处理我的处理程序槽“socketHasData”中的incomming数据 .

问题是，当执行插槽内的代码时，似乎不会重新发出信号 .

我绕了它一个循环，这有点帮助（我收到更多的电报） . 看起来如果退出循环但不退出插槽然后接收数据，则跳过信号 . 执行从插槽返回后，我的客户端卡住并等待数据堆积在套接字缓冲区中 .

我能做什么？是否可以根据QT进行此次活动？我明白了什么问题吗？如何以这种方式实现基于电报的数据传输？

这里的问题似乎已经解决了：How to make sure that readyRead() signals from QTcpSocket can't be missed?但我没有提到上述错误：

• 我没有调用waitForReadyRead

• 我没有进入任何事件循环

• 我不使用除主线程之外的任何线程

并且仍然遇到问题 .

以下是一些具有相关行为的示例代码：

服务器

#include <QCoreApplication>
#include <QTcpServer>
#include <QTcpSocket>

#include <iostream>

using namespace std;

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    QTcpServer *tcpServer = new QTcpServer(NULL);

    tcpServer->listen(QHostAddress("127.0.0.1"), 5573);
    tcpServer->waitForNewConnection(-1);

    QTcpSocket *socket = tcpServer->nextPendingConnection();

    QByteArray telegram;

    for (int i = 0; i < 10000; ++i) {

        telegram.clear();

        QString message = "Test number " + QString::number(i);

        // Each "telegram" is just that string and an incrementing number.

        telegram.append(static_cast<char>(message.length()));
        telegram.append(message.toLocal8Bit());

        socket->write(telegram);
    }

    socket->flush();
    socket->close();

    tcpServer->close();

    return a.exec();
}

客户

#include "mainwindow.h"
#include "ui_mainwindow.h"

MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
    ui->setupUi(this);
}

MainWindow::~MainWindow() {
    delete ui;
}

void MainWindow::on_pushButton_clicked() {

    this->socket = new QTcpSocket(this);
    this->socket->connectToHost("127.0.0.1", 5573);

    connect(this->socket, SIGNAL(readyRead()), this, SLOT(socketHasData()));
}

void MainWindow::socketHasData() {

    do {

        QByteArray header = this->socket->read(1);

        int length = header.at(0);

        while (this->socket->bytesAvailable() < length);

        QByteArray payload = this->socket->read(length);

        qDebug() << "[RX]" << QString::fromLocal8Bit(payload);

    } while (this->socket->atEnd() == false); // I added the loop, which helps somewhat
}

Client-Header

#ifndef MAINWINDOW_H
#define MAINWINDOW_H

#include <QMainWindow>
#include <QTcpSocket>

namespace Ui {
class MainWindow;
}

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    explicit MainWindow(QWidget *parent = 0);
    ~MainWindow();

private slots:
    void on_pushButton_clicked();

    void socketHasData();
private:
    Ui::MainWindow *ui;

    QTcpSocket *socket;
};

#endif // MAINWINDOW_H