创建 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 连接和断开例程的主要内容,如果未能解决你的问题,请参考以下文章