Qt QWebsocket::open 阻塞用户界面

Question

我正在开发一个小型系统，它由多个客户端和一个管理应用程序组成。每个客户端都有一个 QWebSocket 服务器来监听管理员的请求，因此管理员应用需要连接到不同的客户端。

这是我的登录对话框：

在登录之前，我不知道哪个是客户端 IP 地址，因此每次发送登录凭据时，我都需要尝试打开与该 IP 地址的连接。问题是在 Windows UI 中阻塞直到套接字服务器响应或超时，但在 Windows 中它工作正常。

编辑 1： 我遵循了Tung Le Thanh 的建议，因此代码中包含了他的提示。现在主要的问题是ConnectionHelper 不能在没有得到QSocketNotifier 的情况下发出任何信号：不能从另一个线程启用或禁用套接字通知器

我有一个 ConnectionHelper 负责向 WebSocket setver 发送接收数据。

main.cpp

ConnectionHelper *helper = new ConnectionHelper();
LoginDialog dialog(helper);

QThread* thread = new QThread();
helper->moveToThread(thread);
thread->start();

dialog.show();
return a.exec();

LoginDialog 的构造函数：

connect(helper, &ConnectionHelper::onConnectionError, this, &LoginDialog::onCxnError);
connect(helper, &ConnectionHelper::loginInformationReceived, this, &LoginDialog::onLoginInfo);
connect(helper, &ConnectionHelper::cxnEstablished, this, &LoginDialog::onConnected);

已接受的位置：

void LoginDialog::on_buttonBox_accepted()
{
    ui->buttonBox->button(QDialogButtonBox::Ok)->setEnabled(false);
    QString host = ui->lineEditServer->text();
    QString port = ui->lineEditPort->text();
    QString ws = "ws://" + host + ":" + port;
    helper->setUrl(QUrl(ws));
}

void ConnectionHelper::setUrl(QUrl url)
{
        if(!webSocket)
{
    webSocket = new QWebSocket();

    connect(webSocket, &QWebSocket::textMessageReceived, this, &ConnectionHelper::processTextMessage, Qt::QueuedConnection);
    connect(webSocket, &QWebSocket::binaryMessageReceived, this, &ConnectionHelper::processBinaryMessage);
    connect(webSocket, &QWebSocket::disconnected , this, &ConnectionHelper::socketDisconnected);

    connect(webSocket, QOverload<QAbstractSocket::SocketError>::of(&QWebSocket::error)
            , this, [this](QAbstractSocket::SocketError error){
        Q_UNUSED(error)
        emit onConnectionError();
    });

    connect(webSocket, &QWebSocket::connected, this, [=]() {
        emit cxnEstablished();
    });

}
webSocket->open(url);
    webSocket->open(url);
}

void ConnectionHelper::processTextMessage(QString message)
{
    QJsonDocument response = QJsonDocument::fromJson(message.toUtf8());
    QJsonObject objResponse = response.object();

    QString action = objResponse[ACTION_KEY].toString();

    if (action == ACTION_LOGIN)
        emit loginInformationReceived(objResponse);
}

在收到任何响应之前，我会禁用“确定”按钮，并且在 Linux 上可以正常工作，但在 Windows 中，整个 UI 会阻塞并且在收到响应之前变得无响应。

我也尝试将ConnectionHelper 实例移动到另一个线程，但我得到了这样的响应：QSocketNotifier: Socket notifiers cannot be enabled or disabled from another thread

我没有想法，我需要找到一种方法使 webSocket->open(url) 异步或任何类似的东西。

谢谢。

Answer 1

我意识到QWebSocket::open 它是我使用的唯一异步函数。所以我只需要在设置URL和打开socket连接之前有两个线程。

按照 Tung Le Thanh 的回答和一个小技巧，现在一切正常。我的解决方案是在连接打开并开始发出信号后恢复默认威胁。

void ConnectionHelper::setUrl(QUrl url, QThread* thread)
{
    if(!webSocket)
    {
        webSocket = new QWebSocket();
        connect(webSocket, &QWebSocket::connected, this, [this, thread]() {
            this->moveToThread(thread);
            webSocket->moveToThread(thread);

            emit this->cxnEstablished();
        });

    }
    webSocket->open(url);
}

现在LoginDialog 需要发送它的线程

void LoginDialog::on_buttonBox_accepted()
{
    ui->buttonBox->button(QDialogButtonBox::Ok)->setEnabled(false);
    QString host = ui->lineEditServer->text();
    QString port = ui->lineEditPort->text();
    QString ws = "ws://" + host + ":" + port;
    QMetaObject::invokeMethod(  helper, "setUrl", Qt::QueueConnection,
                Q_ARG( QUrl, QUrl(ws)),
                Q_ARG( QThread*, QThread::currentThread())
    );
}

Answer 2

错误：

QSocketNotifier：不能从另一个线程启用或禁用套接字通知器

当您尝试直接从另一个线程调用网络函数时发生（助手及其 webSocket 在另一个线程中）。请改用 invokeMethod 或信号/槽。

EDIT 1 : 实际上，webSocket 是在调用 ConnectionHelper 构造函数时创建的，它属于主线程。如果 ConnectionHelper 未设置为其父级，则 moveToThread 不允许移动 webSocket。为避免这种情况，必须以 ConnectionHelper 作为父项或在线程已经启动时初始化 webSocket。

注意：如果您的应用程序在对话框 accepted() 被触发（主窗口关闭）后退出，您将看不到发出的信号。

更新 2

    ConnectionHelper::ConnectionHelper(QObject *parent) : QObject(parent)
    {
        webSocket = new QWebSocket(QString(), QWebSocketProtocol::VersionLatest, this);

        connect( webSocket, &QWebSocket::stateChanged, this, [=](QAbstractSocket::SocketState s){
            qDebug() << "Socket state changed : " << s;
        }  );
        connect( webSocket, &QWebSocket::connected, this, [=](){
            emit cxnOk();
            webSocket->sendTextMessage("HELLO");
        } );

        void (QWebSocket::*error_signal)(QAbstractSocket::SocketError err) = &QWebSocket::error;

        connect( webSocket, error_signal, this, [=](QAbstractSocket::SocketError err){
            qDebug() << "On socket error : " << err;
        }  );

        connect( webSocket, &QWebSocket::textMessageReceived, this, [=](QString s){
            qDebug() << "text message received: " << s;
        } );
    }

    void ConnectionHelper::setUrl(QUrl url)
    {
        if( webSocket->state() == QAbstractSocket::ConnectedState ){
            webSocket->close();
        }

        qDebug() << "Open URL: " << url; 
        webSocket->open( url );
    }

ConnectionHelper 实例的初始化：

    QThread * pThread = new QThread();
    m_pHelper = new ConnectionHelper();

    connect( m_pHelper, &ConnectionHelper::cxnOk, this, &MainWindow::onConnectionConnected, Qt::QueuedConnection );

    m_pHelper->moveToThread( pThread );
    pThread->start();

将 setUrl 更改为 slot，然后使用 invokeMethod 将命令发送到帮助程序实例。

    void MainWindow::on_pushButton_clicked()
    {
        QString ws = "ws://echo.websocket.org";
        QMetaObject::invokeMethod( m_pHelper, "setUrl", Qt::QueuedConnection, Q_ARG( QUrl, QUrl(ws) ) );
        qDebug() << "Invoke setUrl ended" ;

    }

    void MainWindow::onConnectionConnected()
    {
        qDebug() << "[MainWindow] On connection connected !!!!";
    }

结果：

    Invoke setUrl ended
    Open URL:  QUrl("ws://echo.websocket.org")
    Socket state changed :  QAbstractSocket::ConnectingState
    Socket state changed :  QAbstractSocket::ConnectedState
    [MainWindow] On connection connected !!!!
    text message received:  "HELLO"