c++ - 写入 QTcpSocket 并不总是在相反的 QTcpSocket 上发出 readyRead 信号

Question

在过去的 5 天里，我一直被困在这个问题上，我不知道如何继续。

概述:

我有一个客户端 UI，它与一个数据处理程序 库交互，数据处理程序 库使用一个网络管理器 库，这是我的问题所在。

更多信息

首先，QT 为 QTcpServer ( Fortune Server ) 和 QTcpSocket ( Fortune Client ) 之间的交互提供了一个基本示例。

因此，我将这段代码实现为我自己的一个极其基本的示例，它运行起来非常棒，没有任何问题。

我自己改编的财富client和 server备案(基本)

快速解释:

服务器应用程序运行，单击启动服务器，然后在客户端，在字段中输入文本并单击连接到服务器，然后显示文本，简单!

问题:

在我的 network manager 库中执行上面的代码，不会触发 QTcpSocket::readyRead()在上面的服务器应用程序中。

它连接到服务器，其中QTcpServer::newConnection()正如预期的那样，在 client 写入套接字之后立即被触发，但服务器套接字上的 readyRead() 不会触发，但是在给出的示例中会触发。

注意:在这个server-client应用示例和我现在的应用中使用了相同的端口和ip地址，并且服务器也在运行。

更多信息:

上面的代码，我是直接从客户端复制过来的。只有两件事被改变/修改:

• 发送到服务器的字符串
• 方法的返回类型

这被复制到我的 network mannager::write() 方法中。运行我的应用程序时，QMainWindow 的实例通过 data handler 类传递，并创建我的 network manager 类的实例，它继承了 QObject 并实现了 Q_OBJECT 宏。

代码示例:

//client_UI 类(片段):

data_mananger *dman = new data_mananger(this);                //this -> QMainWindow
ReturnObject r = dman->NET_AuthenticateUser_GetToken(Query);

//data_manager 库(片段)

data_mananger::data_mananger(QObject *_parent) :
    parent(_parent)
{}

ReturnObject data_mananger::NET_AuthenticateUser_GetToken(QString Query){
    //Query like "AUTH;U=xyz@a;P=1234"

    //convert query string to char
        QByteArray ba = Query.toLatin1();

    //send query and get QList return
        ReturnCode rCode = networkManager.write(ba);

    //...
}

//netman库(片段)

//.h

class NETMANSHARED_EXPORT netman : public QObject
{
    Q_OBJECT
public
    netman();
    netman(QObject *_parent);
    //...

private:
    QTcpSocket *tcp_con;
    //...
};

//cpp

netman::netman(QObject *_parent) :
    parent(_parent)
{
    tcp_con = new QTcpSocket(parent);
}

        return;
    }
    serverIP.setAddress(serverInfo.addresses().first().toIPv4Address());
}

ReturnCode netman::write(QByteArray message, int portNumber){

    tcp_con->connectToHost(QHostAddress("127.0.0.1"), 5000);

    if (!tcp_con->waitForConnected())
    {
        qDebug(log_lib_netman_err) << "Unable to connect to server";
        return ReturnCode::FailedConnecting;
    }

    if (!tcp_con->isValid()) {
        qDebug(log_lib_netman_err) << "tcp socket invalid";
        return ReturnCode::SocketError;
    }

    if (!tcp_con->isOpen()) {
        qDebug(log_lib_netman_err) << "tcp socket not open";
        return ReturnCode::SocketError;
    }

    //    QByteArray block(message);
    QByteArray block;
    QDataStream out(&block,QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_0);

    out << QString("Hello world");

    if (!tcp_con->write(block)){
        qDebug(log_lib_netman_err) << "Unable to send data to server";
        return ReturnCode::WriteFailed;
    }
    else{
        qDebug(log_lib_netman_info) << "Data block sent";
        return ReturnCode::SentSuccess;
    }
}

结论:

客户端的核心代码已经完全实现了，但是我看不出为什么会出现这个错误。

非常感谢帮助/建议!

Answer 1

在写入函数的末尾添加一个 tcp_con->flush() 语句。

为什么/如何工作

您没有在接收器中收到 readyRead 信号，因为写入的数据正在缓冲到套接字中，但实际上并未“通过线路”传输。 flush() 命令导致缓冲区被传输。来自 the docs

This function writes as much as possible from the internal write buffer to the underlying network socket, without blocking. If any data was written, this function returns true; otherwise false is returned.

你怎么知道

就我而言，在串行端口和刷新方面有很多经验/挫败感。这相当于“你重启了吗？”在套接字调试工具箱中。

如果其他一切正常，您可能不必flush，但它是特定于应用程序的，取决于套接字的生命周期、TCP 窗口大小、套接字选项设置以及各种其他因素。也就是说，我总是刷新，因为我喜欢完全控制我的套接字，并且我想确保数据在我想要的时候传输。我不认为这是 hack，但在某些情况下，它可能表明存在其他问题。同样，特定于应用程序。

为什么缓冲区不能自行刷新？

我很确定在 fortune 服务器示例中不需要刷新，因为它们在 sendFortune() 函数的末尾 disconnectFromHost，并且来自 Qt documentation :

Attempts to close the socket. If there is pending data waiting to be written, QAbstractSocket will enter ClosingState and wait until all data has been written.

如果套接字也被销毁，它也会断开连接，但从我看到的你的代码来看，你也没有这样做，而且缓冲区还没有满，所以可能实际上没有任何东西刺激缓冲区自行刷新.

其他原因可能是:

• 流程控制不会返回到事件循环(阻塞调用等)，因此永远不会执行缓冲区刷新。
• Transmit 发生在循环内部，看起来它会退出(例如 while(dataToTransmit))，但实际上条件永远不会变为 false，这会导致事件循环被阻塞。
• Nagles 算法:缓冲区可能正在等待更多数据，然后再自行刷新以保持高网络吞吐量。您可以通过设置 QAbstractSocket::LowDelayOption 来禁用它，但它可能会对您的吞吐量产生不利影响……它通常用于对延迟敏感的应用程序。