Пример сервера WebSocket

Описание

Пример echoserver реализует сервер WebSocket, который эхом отправляет всё, что ему отправляется.

Код

Мы начинаем с создания QWebSocketServer (`new QWebSocketServer()`). После создания мы прослушиваем все локальные сетевые интерфейсы (`QHostAddress::Any`) на указанном порту.

EchoServer::EchoServer(quint16 port, bool debug, QObject *parent) :
    QObject(parent),
    m_pWebSocketServer(new QWebSocketServer(QStringLiteral("Echo Server"),
                                            QWebSocketServer::NonSecureMode, this)),
    m_clients(),
    m_debug(debug)
{
    if (m_pWebSocketServer->listen(QHostAddress::Any, port)) {
        if (m_debug)
            qDebug() << "Echoserver listening on port" << port;
        connect(m_pWebSocketServer, &QWebSocketServer::newConnection,
                this, &EchoServer::onNewConnection);
        connect(m_pWebSocketServer, &QWebSocketServer::closed, this, &EchoServer::closed);
    }
}

Если прослушивание прошло успешно, мы подключаем сигнал `newConnection()` к слоту `onNewConnection()`. Сигнал `newConnection()` будет генерироваться всякий раз, когда новый клиент WebSocket подключается к нашему серверу.

void EchoServer::onNewConnection()
{
    QWebSocket *pSocket = m_pWebSocketServer->nextPendingConnection();

    connect(pSocket, &QWebSocket::textMessageReceived, this, &EchoServer::processTextMessage);
    connect(pSocket, &QWebSocket::binaryMessageReceived, this, &EchoServer::processBinaryMessage);
    connect(pSocket, &QWebSocket::disconnected, this, &EchoServer::socketDisconnected);

    m_clients << pSocket;
}

При получении нового подключения клиентский QWebSocket извлекается (`nextPendingConnection()`), и сигналы, которые нас интересуют, подключаются к нашим слотам (`textMessageReceived()`, `binaryMessageReceived()` и `disconnected()`). Клиентский сокет запоминается в списке, на случай, если нам понадобится им воспользоваться позже (в этом примере с ним ничего не делается).

void EchoServer::processTextMessage(QString message)
{
    QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
    if (m_debug)
        qDebug() << "Message received:" << message;
    if (pClient) {
        pClient->sendTextMessage(message);
    }
}

Всякий раз, когда срабатывает `processTextMessage()`, мы получаем отправителя и, если он корректен, возвращаем исходное сообщение (`sendTextMessage()`). То же самое делается с бинарными сообщениями.

void EchoServer::processBinaryMessage(QByteArray message)
{
    QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
    if (m_debug)
        qDebug() << "Binary Message received:" << message;
    if (pClient) {
        pClient->sendBinaryMessage(message);
    }
}

Единственное отличие заключается в том, что сообщение теперь является QByteArray вместо QString.

void EchoServer::socketDisconnected()
{
    QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
    if (m_debug)
        qDebug() << "socketDisconnected:" << pClient;
    if (pClient) {
        m_clients.removeAll(pClient);
        pClient->deleteLater();
    }
}

Всякий раз, когда сокет отключается, мы удаляем его из списка клиентов и удаляем сокет. Примечание: для удаления сокета лучше использовать `deleteLater()`.