9

我正在尝试编写一段代码，它会定期尝试使用 QTcpSocket 连接到服务器，直到服务器启动并准备好。客户端还应该在服务器关闭时自动并定期尝试重新连接，直到它再次启动或用户手动关闭程序。

我所做的是订阅 QTcpSocket 的已连接和错误信号。当我捕捉到错误信号时，我基本上会再次调用 connectToHost 方法。

我的代码会定期尝试连接到主机，直到服务器准备好（这部分工作正常）。但是，问题是当服务器关闭时，它永远无法重新连接。当连接断开时，我按预期收到 RemoteHostClosedError 。但是，在同一方法中再次调用 connectToHost 方法（我在其中捕获 RemoteHostClosedError）后，我什么也没得到。甚至 QTcpSocket 对象也不会发出错误信号。

我在下面给出了我的代码。

TcpServerConnector::TcpServerConnector( SocketSettings socketSettings, QObject* parent)
: QObject(parent), socket(new QTcpSocket())
{
    this->connect(this->socket, SIGNAL(connected()), this, SLOT(connectionSuccess_Handler()), Qt::DirectConnection);
    this->connect(this->socket, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(connectionError_Handler(QAbstractSocket::SocketError)), Qt::DirectConnection);
}


void TcpServerConnector::connectionError_Handler( QAbstractSocket::SocketError error )
{
    switch (error)
    {
    case QAbstractSocket::AddressInUseError:
        this->logger.log(LogLevel::ERR, "SOCKET ERROR: Address is already in use");
        break;
    case QAbstractSocket::ConnectionRefusedError:
        this->logger.log(LogLevel::ERR, "SOCKET ERROR: Connection refused");
        break;
    case QAbstractSocket::HostNotFoundError:
        this->logger.log(LogLevel::ERR, "SOCKET ERROR: Host not found");
        break;
    case QAbstractSocket::RemoteHostClosedError:
        this->logger.log(LogLevel::ERR, "SOCKET ERROR: Remote host closed");            
        break;  
    }


    this->socket->abort();
    this->socket->close();
    this->logger.log(LogLevel::DEBUG, "Reconnecting...");
    SystemUtil::sleepCurrentThread(1000);
    this->socket->connectToHost(ip_address, port);
}

}

我在调用 connectToHost 方法之前和之后检查 QTcpSocket 的状态（我在这里给出的最后一行）。在调用 connectToHost 之前，状态为 UnconnectedState，在调用 connectToHost 之后，其状态变为 Connecting。没有什么意外。但是，它既不能连接到服务器，也不能发出错误信号。

任何的想法？

注意：QTcpSocket 的 connectToHost 方法是第一次在内部调用。

4

3 回答 3

5

对于可能遇到类似情况的人，QTcpSocket的reset方法解决了这个问题。

于 2012-07-22T18:18:41.200 回答
1

我遇到了这种情况，这是解决方案：

    connect(&tcpClient, SIGNAL(disconnected()), SLOT(ReconnectToHost()));


    void ReconnectToHost(){tcpClient.connectToHost(theServerAddress, port);}
于 2013-07-11T11:34:54.470 回答
1

我遇到过这样的问题。我做错了什么是我试图QTcpSocket::connectToHost()从我班的一个插槽中连接到QTcpSocket::error()信号。最后我在这篇文章中找到了解决方案。

如果我没记错的话，问题是你不能从这个插槽中重新连接，因为在QTcpSocket::error()发出信号并且控制流从你的处理程序返回到QTcpSocket发出这个信号的 ' 方法之后，就会发生一些重要的事情，或者你以某种方式破坏套接字的逻辑。

不是一个优雅但仍然是一行代码的解决方案是在QMetaObject::invokeMethod(m_socket, "connectToHost", Qt::QueuedConnection); 您的handle_socket_error()插槽被调用后调用。

请注意，如果您调用QMetaObject::invokeMethod自定义方法，则必须将其注册为插槽。

UPD：真丢脸，但 Qt 的QAbstractSocket::error()信号文档中提到了这个问题。

于 2018-05-27T12:29:39.703 回答