Client MQTT simple

Simple MQTT Client montre comment créer une application client minimaliste.

Pour utiliser l'application, vous devez d'abord spécifier un hôte, un port, Secure on/off, WebSockets on/off, et un protocole. Cliquez ensuite sur Connecter. Ensuite, vous pouvez vous abonner à un sujet et envoyer un message, que vous recevrez également. Vous pouvez également exécuter l'application deux fois. Publier dans l'une et S'abonner dans l'autre, et les messages seront transmis.

Options de simpleclient

• Host - vous pouvez utiliser test.mosquitto.org ou broker.hivemq.com
• Port - port de connexion, dépendra de la sélection WebSockets et de la sélection Secure
• WebSockets - vous pouvez spécifier : sélectionné (activé) ou non sélectionné (désactivé)
• Secure - vous pouvez spécifier : sélectionné (activé) ou non sélectionné (désactivé)
• Protocole - vous pouvez spécifier
  • mqtt 3.1
  • mqtt 3.1.1
  • mqtt 5.0
• Sujet - Sujet à publier ou auquel s'abonner
• Message - Un message à envoyer sur le sujet si vous le publiez

Paramètres de connexion

Il s'agit des combinaisons habituelles, qui fonctionneront avec test.mosquitto.org. Pour broker.hivemq.com, vérifiez les informations dans les liens. Notez que si le mode sécurisé est activé, il peut être nécessaire d'installer des certificats sur l'ordinateur. Il peut également être nécessaire d'ajouter le certificat au client mqtt dans le code.

• Port 1883, Secure=désactivé, WebSockets=désactivé - mqtt sur tcp
• Port 8883, Secure=enabled, WebSockets=disabled - mqtt over ssl
• Port 8080, Secure=disabled, WebSockets=enabled - mqtt over websockets
• Port 8081, Secure=enabled, WebSockets=enabled - mqtt over secure websockets

Pour plus d'informations sur les courtiers, voir

• https://test.mosquitto.org
• https://broker.hivemq.com
• https://www.hivemq.com/mqtt/public-mqtt-broker

Création d'un client

Tout d'abord, nous utilisons la classe QMqttClient pour créer un client MQTT. La classe fournit des propriétés pour définir un identifiant client unique ainsi que le nom de l'hôte du broker et le port auquel se connecter :

    m_client = new QMqttClient(this);
    m_client->setHostname(ui->lineEditHost->text());
    m_client->setPort(static_cast<quint16>(ui->spinBoxPort->value()));

Nous ne définissons pas l'identifiant du client, qui sera donc automatiquement généré pour nous.

Ensuite, nous nous connectons à QMqttClient::messageReceived() pour recevoir tous les messages envoyés au courtier :

    connect(m_client, &QMqttClient::messageReceived, this, [this](const QByteArray &message, const QMqttTopicName &topic) {
        const QString content = QDateTime::currentDateTime().toString()
                    + " Received Topic: "_L1
                    + topic.name()
                    + " Message: "_L1
                    + message
                    + u'\n';
        ui->editLog->insertPlainText(content);
    });

Lorsque les utilisateurs s'abonnent à des sujets dans le client, nous appelons QMqttClient::subscribe() sur le sujet spécifié :

void MainWindow::on_buttonSubscribe_clicked()
{
    auto subscription = m_client->subscribe(ui->lineEditTopic->text());
    if (!subscription) {
        QMessageBox::critical(this, u"Error"_s,
                              u"Could not subscribe. Is there a valid connection?"_s);
        return;
    }

Dans cet exemple, nous nous abonnons à tous les sujets. Pour plus d'informations sur la manière de recevoir des messages sur des sujets particuliers, voir l'exemple MQTT Subscriptions.

Pour un exemple d'utilisation de la classe QMqttClient dans une application Qt Quick, voir Qt Quick Subscription.

Fichiers :

• simpleclient/CMakeLists.txt
• simpleclient/main.cpp
• simpleclient/mainwindow.cpp
• simpleclient/mainwindow.h
• simpleclient/mainwindow.ui
• simpleclient/simpleclient.pro