QT QTcpServer::incomingConnection(qintptr handle) 没有触发？

Posted 2023-02-16

【中文标题】QT QTcpServer::incomingConnection(qintptr handle) 没有触发？

【英文标题】：QT QTcpServer::incomingConnection(qintptr handle) not firing?

【发布时间】：2015-07-30 09:30:48

【问题描述】：

我第一次尝试使用 Qt 创建多线程服务器。通常人们会使用QTcpServer::nextPendingConnection()返回的套接字指针和已经烘焙的套接字句柄——但是由于我在一个单独的线程上与连接客户端进行交互，我需要使用来自QTcpServer的qintptr handle单独创建套接字::incomingConnection（qintptr 句柄）。经过一个非常沉闷、充满错误的调试会话后，我设法将问题追查到 QTcpServer::incomingConnection() 从未被解雇？

有没有人遇到过类似的问题 - Qt 的最新版本有什么变化？

这些是我尝试过的：

QTcpServer::incomingConnection(qintptr handle) QTcpServer::incomingConnection(qintptr socketDescriptor) QTcpServer::incomingConnection(int handle)

编辑：

创建服务器实例：

TestServer *myServer = new TestServer();
myServer->initializeServer(1234);

调用者：

void TestServer::initializeServer(quint16 port)


mainServer = new QTcpServer(this);

mainServer->listen(QHostAddress::Any, port);

qDebug() << "Listening for connections on port: " << port;

服务器现在正在监听。当客户端连接时，应该调用incomingConnection(qintptr handle)：

void TestServer::incomingConnection(qintptr socketDescriptor)

TestClient *client = new TestClient(this);
client->setSocket(socketDescriptor);

调用者：

void TestClient::setSocket(quint16 socketDescr)

socket = new QTcpSocket(this);

socket->setSocketDescriptor(socketDescr);

connect(socket, SIGNAL(connected()),this,SLOT(connected()));
connect(socket, SIGNAL(disconnected()),this,SLOT(disconnected()));
connect(socket, SIGNAL(readyRead()),this,SLOT(readyRead()));

在 connect() 信号上调用：

void TestClient::connected()
   
qDebug() << "Client connected..."; // This debug never appears in the console, since QTcpServer::incomingConnection isn't being fired.

【问题讨论】：

请附上一些你遇到错误的代码

您是否继承了 QTcpServer 以重新实现 QTcpServer::incomingConnection()？有关示例，请参见 Threaded Fortune 服务器：doc.qt.io/qt-5/qtnetwork-threadedfortuneserver-example.html

是的，我已经对它进行了子类化并重新实现了它——我没有像财富服务器示例中那样添加 Q_DECLARE_OVERRIDE 宏。我会试一试并报告。

~~我没有像 Fortune server-example 那样添加 Q_DECLARE_OVERRIDE 宏。我会试一试并报告。 ~~ - 即使使用 Q_DECL_OVERRIDE 仍然无法正常工作。

【参考方案1】：

您的代码有一些错误：

在TestServer 你的QTcpServer 可能是聚合的，但你需要继承它。在这种情况下，您尝试覆盖 incomingConnection() 方法，但您没有基类，您只需创建新的 incomingConnection()，而不是覆盖。 您从incomingConnection() 获得qintptr descriptor 变量，但在setSocket() 方法中设置quint16 类型。 您可能会混合使用服务器客户端和您自己的客户端，它们只是获取传入连接并处理套接字数据。

我在下面写了一些小例子来帮助你理解 tcp 客户端-服务器通信。

服务器部分

主要部分是服务器本身：

#include <QTcpServer>

class TestServer: public QTcpServer

public:
    TestServer(QObject *parent = 0);
    void incomingConnection(qintptr handle) Q_DECL_OVERRIDE;
;

看看吧：我没有聚合QTcpServer，而是继承了它。在这种情况下，您可以正确覆盖incomingConnection() 方法。 在构造函数中，我们只是使用listen() 方法启动服务器进行监听：

TestServer::TestServer(QObject *parent):
    QTcpServer(parent)

    if (this->listen(QHostAddress::Any, 2323)) 
        qDebug() << "Server start at port: " << this->serverPort();
     else 
        qDebug() << "Start failure";
    

然后是覆盖incomingConnection()的时间：

void TestServer::incomingConnection(qintptr handle)

    qDebug() << Q_FUNC_INFO << " new connection";
    SocketThread *socket = new SocketThread(handle);

    connect(socket, SIGNAL(finished()), socket, SLOT(deleteLater()));
    socket->start();

我创建了处理传入数据的SocketThread 对象：

#include <QThread>
#include <QObject>

class QTcpSocket;

class SocketThread: public QThread

    Q_OBJECT
public:
    SocketThread(qintptr descriptor, QObject *parent = 0);
    ~SocketThread();

protected:
    void run() Q_DECL_OVERRIDE;

private slots:
    void onConnected();
    void onReadyRead();
    void onDisconnected();

private:
    QTcpSocket *m_socket;
    qintptr m_descriptor;
;

我们继承自 QThread 以使我们的服务器多线程，因此我们必须重写 run() 方法：

SocketThread::SocketThread(qintptr descriptor, QObject *parent)
    :  QThread(parent), m_descriptor(descriptor)




void SocketThread::run()

    qDebug() << Q_FUNC_INFO;
    m_socket = new QTcpSocket;
    m_socket->setSocketDescriptor(m_descriptor);

    connect(m_socket, SIGNAL(readyRead()),    this, SLOT(onReadyRead()), Qt::DirectConnection);
    connect(m_socket, SIGNAL(disconnected()), this, SLOT(onDisconnected()), Qt::DirectConnection);

    exec();

这样我们初始化我们的QTcpSocket，设置套接字描述符，用readyRead()和disconnected()信号连接它并启动事件循环。

void SocketThread::onReadyRead()

    QDataStream in(m_socket);
    in.setVersion(QDataStream::Qt_5_5);

    QString message;
    in >> message;
    qDebug() << message;

    m_socket->disconnectFromHost();


void SocketThread::onDisconnected()

    m_socket->close();
    // Exit event loop
    quit();

在onReadyRead()，只需从客户端读取一些QString，将其写入控制台并断开与主机的连接。在onDisconnected() 我们close 套接字连接并退出事件循环。

客户端部分

这只是示例和难闻的风格，但我在QPushButton::clicked 信号上的MainWindow 类创建到服务器的连接：

void MainWindow::on_pushButton_clicked()

    QTcpSocket *client = new QTcpSocket;
    connect(client, SIGNAL(connected()), this, SLOT(connected()));
    connect(client, SIGNAL(disconnected()), client, SLOT(deleteLater()));

    client->connectToHost(QHostAddress::LocalHost, 2323);
    client->waitForConnected();

    if (client->state() != QAbstractSocket::ConnectedState ) 
        qDebug() << Q_FUNC_INFO << " can't connect to host";
        delete client;
        return;
    
    QByteArray block;
    QDataStream out(&block, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_5_5);
    out << QString("Hello");
    out.device()->seek(0);
    client->write(block);


void MainWindow::connected()

    qDebug() << Q_FUNC_INFO << " client connected";

我创建了新的QTcpSocket，将其连接到信号并尝试连接到主机（在我的情况下是本地主机）。等待连接并检查套接字状态。如果一切正常，我会写信给套接字QString - 只是示例。

这是组织多线程客户端-服务器架构的一种可能方法，我希望它对您有所帮助，并发现您的错误。

【讨论】：

@t3ft3l--如果按照您的建议实施，但incommingConnection() 永远不会被解雇，原因是什么？

@user3085931 确保：1) 您的服务器正确启动 2) 客户端使用正确的 ip/端口连接到服务器 3) 某些防火墙或防病毒软件没有阻止客户端和服务器之间的网络通信。在服务器端做错事真的很难——实现非常简单明了。我想，您的客户端连接或防火墙/防病毒拦截器存在一些问题

@t3ft3l--我很好，服务器正在侦听正确的端口和 any IP。客户端本身能够连接（根据SIGNAL(connected())），这是奇怪的行为