c++ - 来自 QSocket 的 readyRead() 信号的行为

Question

我刚刚遇到了来自 QUdpSocket 的 readyRead() 信号的困难时期，虽然我找到了一个解决方案，但我仍然不确定我做了什么，但我想更准确地了解我的解决方案为什么有效。这是我的情况:

我连接到一个发出通知的服务器。当我收到它们时，即当我的 QUdpSocket 发出 onReadyRead() 时，我会处理通知:解压数据、检查数据的来源等。这是在继承 QObject 的自定义对象中完成的。

然后该对象发出信号“notificationReceived”，以便其他对象可以处理通知:notificationReceived() 信号连接到 processNotification() 插槽。

processNotification() 依次执行一些操作，包括向服务器执行新的 GET 请求。服务器接收请求并响应它。然而，来自 QUdpSocket 的 readyRead() 信号并没有在我的应用程序中发出，它就像从未从服务器接收到数据报一样。

但是，当我调用“my_socket->hasPendingDatagrams()”时，它返回 true，我可以读取实际存在的数据报，该数据报与我在 GET 请求中想要的内容相对应:

MyCustomObject::MyCustomObject(QObject* parent){
    // constructor
    my_socket = new QUdpSocket(this);

    if (!m_socket->bind(QHostAddress::Any, m_port, QAbstractSocket::ShareAddress))
        qDebug() << "Could not bind to port" << m_port << m_socket->errorString();

    connect(m_socket, SIGNAL(readyRead()), this, SLOT(onReadyRead()));
}

void MyCustomObject::onReadyRead(){
    QHostAddress hostAddress;
    QByteArray data;
    quint16 port;

    while (m_socket->hasPendingDatagrams()) {
        data.resize(my_socket->pendingDatagramSize());
        my_socket->readDatagram(data.data(), data.size(), &hostAddress, &port);
    }

    processResponse(data, hostAddress, port);
}

void MyCustomObject::processNotification(QByteArrayData){
    // do some checking and reading of data
    // when finished:
    getNewData();
}

void MyCustomObject::getNewData(){
    // instantiate data, hostAdress, port. In other words :
    // create the request in the form of a datagram to be sent
    my_socket->writeDatagram(data, hostAdress, port);
}

所以我尝试了解 readyRead() 信号并理解为什么在这种情况下它没有发出。特别是这篇文章给了我一个线索: http://www.qtforum.org/article/1118/2/signal-readyread-doesn-t-work.html

它讲述线程问题。但是我的应用程序是从 QGuiApplication 运行的，所有事情都是在一个线程中完成的(据我所知，我实际上对线程了解不多)。

最后，我的解决方案是:在收到 notificationReceived() 信号后，直接从 processNotification() 槽中，我不执行 GET 请求，而是使用 QTimer::singleShot 调用 GET 请求。所以我做了类似(简化)的事情:

void processNotification(QByteArray data){
    // check some conditions
    // process the data, and when finished:

   QTimer::singleShot(1000, this, SLOT(getData()));
}

getRequest() 负责将 GET 发送到服务器，这次检测到服务器的响应(my_socket 发出 readyRead() 信号)。虽然我仍然不确定为什么。

注意:如果我不使用，在 notificationReceived() 第一个发出的信号和从最终触发的 slot() 调用 getRequest() 之间发出/接收了多少 signal()、slot() 并不重要一个 QTimer 最后它不起作用。

Answer 1

我认为您的问题是您在同一个线程和事件循环中执行所有操作。

即在您的 readyRead() 插槽中，您正在调用 processResponse(...) 并且会立即执行，然后当 processResponse 发出“notificationReceived()”信号并调用 processNotification() 时，它最终会调用 getNewData()。

所有这些调用都将“在线”完成(请参阅有关 Qt 的 DirectConnetion 的信号链接)，因此您基本上是在请求 newData 的同时仍在 readyRead() 函数调用中。

如果服务器在您的代码流返回到正常事件循环之前响应，那么您将错过新的 readyRead() 调用。

为什么使用 QTimer 解决了您的问题？因为基本上您是在推迟 getNewData 并且您的调用堆栈将离开 readyRead() 并在您实际请求一些新数据之前进入正常的事件循环。