Qt：使用 QTcpSocket -> 我可以在套接字上写，但我不能读...

Question

我在 xUbuntu 14.04 上使用 Qt 4.8 GCC 32 位。
我有以下代码，一个 TCP 服务器，我使用它来获取一些远程命令并发送回一些答案 - 通过 TCP 套接字：

struct _MyRequest
{
    unsigned long   Request;
    unsigned long   Data;
} __attribute__((packed));

struct _MyAnswer
{
    unsigned long   Error;
    unsigned long   Filler;
} __attribute__((packed));

_MyRequest request;
_MyAnswer  answer;

RemoteCmdServer::RemoteCmdServer(QObject * parent)
    : QTcpServer(parent)
{
    qDebug() << "Server started";

    listen(QHostAddress("172.31.250.110"), 5004);

    connect(this, SIGNAL(newConnection()), this, SLOT(processPendingRequest()));
}

void RemoteCmdServer::processPendingRequest()
{
    qDebug() << "Process request";

    QTcpSocket * clientConnection = nextPendingConnection();
    connect(clientConnection, SIGNAL(disconnected()), clientConnection, SLOT(deleteLater()));

    // get the request
    int ret = clientConnection->read((char*)&request, sizeof(request));
    qDebug() << "READ: " << ret;
    if(ret == sizeof(request))
    {
        // send answer
        clientConnection->write((char*)&answer, sizeof(answer));
    }

    qDebug() << "Disconnecting...";
    clientConnection->disconnectFromHost();
}   

如果我评论if(ret == sizeof(request)) 行，我就能正确书写。
然而，我无法从套接字读取（我总是得到 0 个字节）。
我 100% 确定我用来向我的应用程序发送数据包的 TCP 工具工作正常。
这是我的应用程序的调试输出：

Server started     
Process request    
READ: 0     
Disconnecting...     

我做错了什么？请指教！

Answer 1

您正在尝试从新连接读取数据而不返回 Qt 事件循环——我认为这不会起作用。

在您接受连接后...

QTcpSocket * clientConnection = nextPendingConnection();

您需要使用类似...的方式连接到它的readyRead 信号

connect(clientConnection, SIGNAL(readyRead()), this, SLOT(my_read_slot()));

其中my_read_slot 是实际执行读取操作的成员函数。

Answer 2

您应该以非阻塞或阻塞方式等待数据。您可以使用waitForReadyRead 以阻塞方式进行操作。

void RemoteCmdServer::processPendingRequest()
{
    qDebug() << "Process request";

    QTcpSocket * clientConnection = nextPendingConnection();
    connect(clientConnection, SIGNAL(disconnected()), clientConnection, SLOT(deleteLater()));

    if (clientConnection->waitForReadyRead())
    {
        // get the request
        QByteArray message = clientConnection->readAll(); // Read message
        qDebug() << "Message:" << QString(message);
    }
    else
    {
        qDebug().nospace() << "ERROR: could not receive message (" << qPrintable(clientConnection->errorString()) << ")";
    }

    qDebug() << "Disconnecting...";
    clientConnection->disconnectFromHost();
}