2

在过去的 5 天里，我一直坚持这一点，我不知道如何继续。

概述：

我有一个与图书馆client UI交互的data handler图书馆，data handler图书馆利用network manager图书馆，这是我的问题所在。

更多信息

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

因此，我将这段代码实现为我自己的一个非常基本的示例，它就像一个魅力，没有任何问题。

我自己改编的财富客户端和服务器备案（基础）

快速说明：

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

问题：

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

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

注意：在这个应用示例和我当前的应用中使用的和相同，并且服务器也在port运行 。ip addressserver-client

更多信息：

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

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

这被复制到我的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;
    }
}

结论：

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

我将非常感谢帮助/建议！

4

1 回答 1

2

在 write 函数的末尾添加一条tcp_con->flush()语句。

为什么/如何工作

您没有readyRead在接收器中收到信号，因为写入的数据被缓冲到套接字中，但实际上并未“通过线路”传输。该flush()命令使缓冲区被传输。从文档

该函数尽可能多地从内部写入缓冲区写入底层网络套接字，而不阻塞。如果写入了任何数据，则此函数返回 true；否则返回 false。

你应该怎么知道

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

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

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

我很确定在财富服务器示例中不需要刷新，因为它们disconnectFromHost位于sendFortune()函数的末尾，并且来自Qt 文档：

尝试关闭套接字。如果有等待写入的未决数据，QAbstractSocket 将进入 ClosingState 并等待直到所有数据都已写入。

如果套接字也被破坏，它也会断开连接，但是从我的代码中可以看出，您也没有这样做，并且缓冲区未满，因此实际上可能没有什么能刺激缓冲区自行刷新。

其他原因可能是：

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