下面是一个使用Qt编写WebSocket服务端和客户端进行数据交互的示例代码。
WebSocket服务端代码:
#include <QtCore/QCoreApplication>
#include <QtWebSockets/QtWebSockets>
class Server : public QObject
{
Q_OBJECT
public:
explicit Server(QObject *parent = nullptr)
: QObject(parent), m_server(nullptr)
{
m_server = new QWebSocketServer(QStringLiteral("WebSocket Server"), QWebSocketServer::NonSecureMode, this);
connect(m_server, &QWebSocketServer::newConnection, this, &Server::onNewConnection);
if (m_server->listen(QHostAddress::Any, 1234))
qInfo() << "Server started on port" << m_server->serverPort();
else
qWarning() << "Failed to start server!";
}
private slots:
void onNewConnection()
{
QWebSocket *socket = m_server->nextPendingConnection();
connect(socket, &QWebSocket::textMessageReceived, this, [this, socket](const QString &message) {
qInfo() << "Received message:" << message;
// Example: Echo back the received message to the client
socket->sendTextMessage(message);
});
connect(socket, &QWebSocket::disconnected, this, [this]() {
QWebSocket* socket = qobject_cast<QWebSocket*>(sender());
if (socket) {
socket->deleteLater();
qInfo() << "Client disconnected";
}
});
qInfo() << "New client connected:" << socket->peerAddress().toString() << ":" << socket->peerPort();
}
private:
QWebSocketServer *m_server;
};
int main(int argc, char *argv[])
{
QCoreApplication app(argc, argv);
Server server;
return app.exec();
}
#include "main.moc"
WebSocket客户端代码:
#include <QtCore/QCoreApplication>
#include <QtWebSockets/QtWebSockets>
class Client : public QObject
{
Q_OBJECT
public:
explicit Client(QObject *parent = nullptr)
: QObject(parent), m_socket(nullptr)
{
m_socket = new QWebSocket();
connect(m_socket, &QWebSocket::connected, this, [this]() {
qInfo() << "Connected to server";
// Example: Send a message to the server
m_socket->sendTextMessage("Hello from client");
});
connect(m_socket, &QWebSocket::textMessageReceived, this, [this](const QString &message) {
qInfo() << "Received response:" << message;
m_socket->close(); // Close the connection after receiving the response
});
connect(m_socket, static_cast<void(QAbstractSocket::*)(QAbstractSocket::SocketError)>(&QWebSocket::errorOccurred), this,
[this](QAbstractSocket::SocketError socketError){
qWarning() << "Connection error:" << socketError;
if (m_socket->state() == QAbstractSocket::UnconnectedState)
m_socket->deleteLater();
});
m_socket->open(QUrl(QStringLiteral("ws://localhost:1234"))); // Connect to the server
}
private:
QWebSocket *m_socket;
};
int main(int argc, char *argv[])
{
QCoreApplication app(argc, argv);
Client client;
return app.exec();
}
#include "main.moc"
上述代码演示了一个简单的WebSocket服务端和客户端通信。服务端接收来自客户端的消息,并将其原样返回给客户端。你可以根据需求在服务端和客户端中实现更复杂的交互逻辑。
请确保正确安装并链接QtWebSockets模块。
内容由零声教学AI助手提供,问题来源于学员提问