创建 websocket 连接和断开例程

Posted

技术标签:

【中文标题】创建 websocket 连接和断开例程【英文标题】:create a websocket connection and disconnection routine 【发布时间】:2018-10-07 20:00:42 【问题描述】:

我正在查看一个 websokect 客户端的示例,但是在 return a.exe() 之后我无法执行例程; 我解释说我需要执行其他例程,但是如果我没有放置 return a.exe ();它没有建立连接并继续执行代码,必须这样做才能避免发生这种情况?

#include <QtCore/QCoreApplication>
#include "sslechoclient.h"

int main(int argc, char *argv[])

    QCoreApplication a(argc, argv);

for (;;;)
    SslEchoClient client(QUrl(QStringLiteral("wss://localhost:1234")));

    Q_UNUSED(client);

//my serial reading application



    return a.exec();

Cpp

#include "sslechoclient.h"
#include <QtCore/QDebug>
#include <QtWebSockets/QWebSocket>
#include <QCoreApplication>

QT_USE_NAMESPACE

SslEchoClient::SslEchoClient(const QUrl &url, QObject *parent) :
    QObject(parent)

    connect(&m_webSocket, &QWebSocket::connected, this, &SslEchoClient::onConnected);
    connect(&m_webSocket, QOverload<const QList<QSslError>&>::of(&QWebSocket::sslErrors),
            this, &SslEchoClient::onSslErrors);
    m_webSocket.open(QUrl(url));


void SslEchoClient::onConnected()

    qDebug() << "WebSocket connected";
    connect(&m_webSocket, &QWebSocket::textMessageReceived,
            this, &SslEchoClient::onTextMessageReceived);
    m_webSocket.sendTextMessage(QStringLiteral("Hello, world!"));


void SslEchoClient::onTextMessageReceived(QString message)

    qDebug() << "Message received:" << message;
    qApp->quit();


void SslEchoClient::onSslErrors(const QList<QSslError> &errors)

    Q_UNUSED(errors);

    // WARNING: Never ignore SSL errors in production code.
    // The proper way to handle self-signed certificates is to add a custom root
    // to the CA store.

    m_webSocket.ignoreSslErrors();

.h

#ifndef SSLECHOCLIENT_H
#define SSLECHOCLIENT_H

#include <QtCore/QObject>
#include <QtWebSockets/QWebSocket>
#include <QtNetwork/QSslError>
#include <QtCore/QList>
#include <QtCore/QString>
#include <QtCore/QUrl>

QT_FORWARD_DECLARE_CLASS(QWebSocket)

class SslEchoClient : public QObject

    Q_OBJECT
public:
    explicit SslEchoClient(const QUrl &url, QObject *parent = nullptr);

private Q_SLOTS:
    void onConnected();
    void onTextMessageReceived(QString message);
    void onSslErrors(const QList<QSslError> &errors);

private:
    QWebSocket m_webSocket;
;

#endif // SSLECHOCLIENT_H

如果您能提供帮助,我将不胜感激。

【问题讨论】:

您好,您应该更详细地解释您运行应用程序所采取的步骤。 我必须读取串口,准备好代码但是我需要创建一个 websokect 连接并发送该数据。我一直在努力修改示例,但无法建立连接。也就是说,做一个读取周期,然后将数据发送到 websocket 服务器这是 QT 示例doc.qt.io/qt-5/qtwebsockets-sslechoclient-main-cpp.html @Piter 为什么需要for(;;)?。 Qt的元素需要事件循环,而那个事件循环是用app.exec();实现的,我不明白为什么要使用for(;;),这相当于一个while true阻塞了Qt的任务,你应该做的是使用实现状态机的信号,如果你有繁重的任务,你应该使用一个新线程。 【参考方案1】:

你的应用程序会不会有点像:

QApplication app(argc, argv);

QWebSocket socket;
// Your stuff
int retValue = app.exec();
// Do some other stuff
return retValue;

?

【讨论】:

套接字需要事件循环来完成它的工作,所以如果事件循环的结束将不起作用。 添加代码行但它没有工作,但是添加更多信息,非常感谢您的时间。 @Piter 在 Qt 中你必须用信号处理所有的逻辑,我推荐你阅读doc.qt.io/qt-5/signalsandslots.html @eyllanesc 我知道,当我问这个问题时没有提供代码,所以逻辑可能是:用套接字做一些事情,一旦完成,做一些其他事情,比如记录结果,写一个文件等. 不需要任何事件循环,但在退出应用程序之前无论出于何种原因都需要在 main 中完成。 重新打开 websokect 连接需要包含哪些内容?,作为参考之前的代码

以上是关于创建 websocket 连接和断开例程的主要内容,如果未能解决你的问题,请参考以下文章

如何使用 OkHttpClient 真正断开与 WebSocket 的连接?

2018-03-26(websocket自动断开连接)

HAProxy + WebSocket 断开连接

nodejs-websocket介绍

如何在WebSocket的服务器侧检测客户端的断开连接

几秒钟后 Websocket 连接断开