qt写一个websocket服务端，和客户端进行数据交互-QT开发中文网

下面是一个使用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助手提供，问题来源于学员提问