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

Question

过去 5 天我一直坚持这个问题，我不知道如何继续。

概览：

我有一个 client UI 与 data handler 库交互，而 data handler 库使用 network manager 库，这就是我的问题所在。

更多信息

首先，QT提供了QTcpServer（Fortune Server)and a QTcpSocket (Fortune Client）之间交互的基本示例。

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

我自己改编的运势client and server备案（基本）

快速说明：

服务器应用程序运行，点击start server，然后在客户端，在字段中输入文本并点击connect to server并显示文本，简单！

问题：

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

它连接到 server，如预期的那样，QTcpServer::newConnection() 被触发，紧接着 client 写入套接字，但 readyRead() 在服务器套接字不会触发，但在给出的示例中会触发。

注：同样的port和ip address用在这个server-client应用例子和我现在的应用中，服务器也是运行.

更多信息：

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

发送到服务器的字符串
return 方法类型

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

代码示例：

//client_UI Class（片段）：

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;
    }
}

结论：

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

非常感谢help/advice！

Answer 1

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

Why/how 这个有效

您没有在接收器中收到 readyRead 信号，因为写入的数据被缓冲到套接字中但实际上并未传输 'over the wire'。 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.

你怎么知道的

在我的例子中，很多 experience/frustration 带有串口和刷新。它相当于套接字调试工具箱中的"have you rebooted it?"。

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

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

我很确定在财富服务器示例中不需要刷新，因为它们 disconnectFromHost 在 sendFortune() 函数的末尾，并且来自 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.

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

其他原因可能是：

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

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

Writing to QTcpSocket does not always emit readyRead signal on opposite QTcpSocket

c++

sockets

qt

qtcpsocket

qtcpserver

Why/how 这个有效

你怎么知道的

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