Présentation Chiheb Ameur ABID 2/ 32

Mise en place d’une application IOT

Plan

1 Mise en place d’une application IOT

Conception et implémentation des objets connectés
2 Développer un client MQTT sur RPI

Dr. Ing. Chiheb Ameur ABID

Contact: chiheb.abid@fst.utm.tn

Année universitaire : 2021 - 2022

Présentation Chiheb Ameur ABID 3/ 32 Présentation Chiheb Ameur ABID 4/ 32
Mise en place d’une application IOT Mise en place d’une application IOT

Architecture d’une application IOT Protocole de communication MQTT

Architecture d’une application IOT

MQTT en bref

å MQTT (Message Queue Telemetry Transport)

å Un protocole de messagerie publish-subscribe basé sur le protocole TCP/IP utilisé pour la
communication M2M
å Possibilité de sécuriser le transport de messages en SSL/TLS et par identification de
l’utilisateur
å Taille maximale d’un message : 256 Mo
Présentation Chiheb Ameur ABID 5/ 32 Présentation Chiheb Ameur ABID 6/ 32
Mise en place d’une application IOT Mise en place d’une application IOT

Protocole de communication MQTT Protocole de communication MQTT

MQTT en bref
Qualité de service (QoS)
å La Qualité de Service (QoS) est un accord qui définit la garantie de livraison d’un message
spécifique et le type d’authentification utilisé
å Il y a trois niveaux de QoS dans MQTT

¶ QoS 0 : Au plus une fois

å Le message est distribué une fois au plus, ou n’est pas distribué du tout.
å Les messages sont envoyés par des publieurs (les publishers) sur un canal appelé Topic
å Sa distribution via le réseau n’est pas accompagnée d’un accusé de réception.
å Les messages peuvent être lus par les abonnés (les subscribers)
å Le message n’est pas stocké. Le message peut être perdu si le client est déconnecté ou si le
å Les Topics (ou les canaux d’informations) peuvent avoir une hiérarchie qui permet de serveur échoue.
sélectionner finement les informations que l’on désire.
å Le mode de transfert le plus rapide. Il est parfois appelé "autonome après diffusion".
å Corps des messages : format JSON
Présentation Chiheb Ameur ABID 7/ 32 Présentation Chiheb Ameur ABID 8/ 32
Mise en place d’une application IOT Mise en place d’une application IOT

Protocole de communication MQTT Protocole de communication MQTT

QoS 0 : At most once (fire and forget)

· QoS 1 : Au moins une fois
å Le message est toujours distribué au moins une fois.
å Si l’expéditeur ne reçoit pas d’accusé de réception, le message est renvoyé avec
l’indicateur DUP défini jusqu’à la réception de l’accusé de réception
å Le message doit être stocké localement au niveau de l’expéditeur et du destinataire jusqu’à
ce qu’il soit traité.
å Le message est supprimé de l’expéditeur une fois qu’il a reçu un accusé de réception de la
part du destinataire.
Présentation Chiheb Ameur ABID 9/ 32 Présentation Chiheb Ameur ABID 10/ 32
Mise en place d’une application IOT Mise en place d’une application IOT

Protocole de communication MQTT Protocole de communication MQTT

QoS 1 : At least once

¸ QoS 2 : Une seule fois
å Le message est toujours distribué une seule fois
å Le message doit être stocké localement au niveau de l’expéditeur et du destinataire jusqu’à
ce qu’il soit traité
å Le mode de transfert le plus sûr, mais le plus lent
å Il faut au moins deux paires de transmissions entre l’expéditeur et le destinataire
¶ L’expéditeur transmet le message et reçoit un accusé de réception du destinataire
indiquant qu’il a stocké le message. Si l’expéditeur ne reçoit pas d’accusé de
réception, le message est renvoyé avec l’indicateur DUP défini jusqu’à la réception
de l’accusé de réception.
· L’expéditeur dit au destinataire qu’il peut terminer le traitement du message,
PUBREL. Si l’expéditeur ne reçoit pas d’accusé de réception du message PUBREL, le
message PUBREL est renvoyé jusqu’à la réception de l’accusé de réception.
L’expéditeur supprime le message qu’il a enregistré lors de la réception de l’accusé
de réception au message PUBREL
Présentation Chiheb Ameur ABID 11/ 32 Présentation Chiheb Ameur ABID 12/ 32
Mise en place d’une application IOT Mise en place d’une application IOT

Protocole de communication MQTT Principales versions du protocole MQTT

QoS 2 : Exactly once

Principales versions du protocole MQTT

å MQTT-SN v1.2, standardisé par IBM, 14-11-2013.
Z SN : Sensor Network
Z Variation destinée aux réseaux qui ne sont pas basés sur TCP/IP tel que le Zigbee
å MQTT v3.1, standardisé par Eurotech and IBM, 2010.
å MQTT v3.1.1, standardisé par OASIS (Organization for the Advancement of Structured
Information Standards), 10-12-2015.
å MQTT v5.0, standardisé par OASIS, 07-03-2019.
Z Ajout de date d’expiration pour les messages
Z Association des alias pour les topics
Z etc.
Présentation Chiheb Ameur ABID 13/ 32 Présentation Chiheb Ameur ABID 14/ 32
Mise en place d’une application IOT Mise en place d’une application IOT

Brokers en ligne gratuits Les topics et les jokers (wildcards)

Brokers MQTT en ligne gratuits

Les topics et les jokers (wildcards)
Broker Serveur Port
å Les topics sont organisés de manière hiérarchique (comme un système de fichiers)
iot.eclipse.org 1883 / 8883
Mosquitto Z Chaque sub-topic est séparé par le cractère /
test.mosquitto.org 1883 / 8883 / 8884
Mosca test.mosca.io 1883 å Les noms des topics sont sensibles à la casse
HiveMQ broker.hivemq.com 1883 å Exemples
emqx.io broker.emqx.io 1883 ou 8883 (TCP / TLS) Z <country>/<region>/<town>/<house>/energyConsumption
maqiatto.com 1883 Z <country>/<region>/<town>/<house>/solarEnergy
MoQiatto Z <country>/<region>/<town>/<building>/alarmState
Nécessite l’ouverture d’un compte
flespi mqtt.flespi.io 443 (SSL) ou 80 (non-SSL)
Présentation Chiheb Ameur ABID 15/ 32 Présentation Chiheb Ameur ABID 16/ 32
Mise en place d’une application IOT Mise en place d’une application IOT

Les topics et les jokers (wildcards) Les topics et les jokers (wildcards)

Les jokers (wildcards) Sujets commençant par $

å Les jokers permettent l’abonnement à plusieurs topics à la fois å Les sujets commençant par le symbole $ sont réservés aux statistiques internes du broker
Z Ils ne sont utilisés que pour l’abonnement MQTT
å + : joker à un niveau remplace un niveau de sujet å Les clients ne peuvent pas publier de messages sur ces sujets
Z <country>/<region>/<town>/<house>/+ remplace å Pour l’instant, il n’existe pas de normalisation officielle pour ces sujets.
<country>/<region>/<town>/<house>/energyConsumption et Z Dépend du broker
<country>/<region>/<town>/<house>/solarEnergy
å Exemple de sujets
å # : joker multi-niveaux qui permet de s’abonner à l’ensemble des topics existant à un
niveau et aux niveaux plus bas
Z <country>/<region>/<town>/# remplace
<country>/<region>/<town>/<house>/energyConsumption,
<country>/<region>/<town>/<house>/solarEnergy et
<country>/<region>/<town>/<building>/alarmState
Présentation Chiheb Ameur ABID 17/ 32 Présentation Chiheb Ameur ABID 18/ 32
Mise en place d’une application IOT Développer un client MQTT sur RPI

Les topics et les jokers (wildcards) Plan

Bonnes pratiques
1 Mise en place d’une application IOT
å Ne jamais utiliser un slash avant ( / )
Z Le slash avant introduit un niveau de sujet inutile avec un caractère zéro au début
2 Développer un client MQTT sur RPI
å N’utilisez jamais d’espaces dans un sujet
å Gardez le sujet court et concis
å Utilisez uniquement des caractères ASCII, évitez les caractères non imprimables
å Intégrer un identifiant unique ou le Client Id dans le sujet
å Ne vous abonnez pas à #
Présentation Chiheb Ameur ABID 19/ 32 Présentation Chiheb Ameur ABID 20/ 32
Développer un client MQTT sur RPI Développer un client MQTT sur RPI

Objectif Présentation du projet Paho MQTT

Architecture générale d’une solution IOT

Paho MQTT en bref
å Projet opensource développé par la fondation Eclipse
å Bibliothèque client Paho MQTT qui implémente les versions 3.1, 3.1.1.1 et 5.0 du
protocole MQTT
å API fournit en C, C ++, Java, Javascript, Python, Go, C#
å Site officiel : http://www.eclipse.org/paho
å Documentation C++ :
https://www.eclipse.org/paho/files/cppdoc/index.html
Présentation Chiheb Ameur ABID 21/ 32 Présentation Chiheb Ameur ABID 22/ 32
Développer un client MQTT sur RPI Développer un client MQTT sur RPI

Installation de la bibliothèque Paho MQTT C++ Installation de la bibliothèque Paho MQTT C++

Installation de la bibliothèque Paho MQTT C++ sur RPI

å Compilation et installation depuis le code source
å Elle nécessite la compilation et l’installation de la bibliothèque de Paho C version 3.1.8
ou supérieure
Compilation et installation de la bibliothèque Paho MQTT C++
å Installer les paquets de dépendances
å Télécharger le code source
Z Outils de compilation : build-essential gcc make cmake
git clone https://github.com/eclipse/paho.mqtt.cpp
Z Utilisation de SSL : libssl-dev
cd paho.mqtt.cpp
Z Construction de la documentation : doxygen
å Compilation avec cmake
cmake -Bbuild -H. -DPAHO_BUILD_STATIC=ON
Compilation et installation de la bibliothèque Paho MQTT C
-DPAHO_BUILD_DOCUMENTATION=TRUE -DPAHO_BUILD_SAMPLES=TRUE
å Télécharger le code source å Installation
git clone https://github.com/eclipse/paho.mqtt.c ; cd sudo cmake --build build/ --target install
paho.mqtt.c sudo ldconfig
å Compilation avec cmake
cmake -Bbuild -H. -DPAHO_ENABLE_TESTING=OFF
-DPAHO_BUILD_STATIC=ON -DPAHO_WITH_SSL=ON
-DPAHO_HIGH_PERFORMANCE=ON
å Installation
sudo cmake --build build/ --target install
sudo ldconfig
Présentation Chiheb Ameur ABID 23/ 32 Présentation Chiheb Ameur ABID 24/ 32
Développer un client MQTT sur RPI Développer un client MQTT sur RPI

Utilisation de la Bibliothèque Paho MQTT Utilisation de la Bibliothèque Paho MQTT

Connexion : la classe mqtt::async_client

å #include <async_client.h>
å La classe mqtt::async_client permet de communiquer avec un broker en utilisant
Connexion : la classe mqtt::token
des méthodes non bloquantes
å Constructeur async_client (const string &serverURI, const string å #include <token.h>
&clientId, iclient_persistence *persistence=nullptr) å La classe mqtt::token fournit un mécanisme pour surveiller les actions asynchrones
Z serverURI : spécifie l’adresse et le port du broker å La méthode wait() permet de bloquer la tâche courante jusqu’à que l’action associée au
Z clienId : une chaine choisie pour identifier le client jeton soit terminée
å La méthode token_ptr connect() permet d’établir la connexion. Elle renvoie un
pointeur sur un jeton permettant de surveiller l’état de la connexion
å La méthode token_ptr disconnect() permet de se déconnecter
å La méthode bool is_connected() indique si une connexion est bien établie
Présentation Chiheb Ameur ABID 25/ 32 Présentation Chiheb Ameur ABID 26/ 32
Développer un client MQTT sur RPI Développer un client MQTT sur RPI

Utilisation de la Bibliothèque Paho MQTT Utilisation de la Bibliothèque Paho MQTT

Exemple : connexion à un broker

Inscription à un sujet
const std::string SERVER_ADDRESS("tcp://localhost:1883");
const std::string CLIENT_ID("paho_cpp_async_subcribe"); å Pour récevoir les messages d’un sujet, il faut d’abord s’inscrire
mqtt::async_client cli(SERVER_ADDRESS, CLIENT_ID); token_ptr mqtt::async_client::subscribe(const string &topicFilter)

// Connect to the server

cout << "Connecting to the MQTT server..." << flush; Z topicFilter : le sujet avec la possibilité d’inclure des jokers
cli.connect()->wait();
å Se désinscrire d’un sujet
...
std::cout << "\nDisconnecting from the MQTT server..." << std::flush; token_ptr mqtt::async_client::unsubscribe(const string &topicFilter)
cli.disconnect()->wait();
std::cout << "OK" << std::endl;
Présentation Chiheb Ameur ABID 27/ 32 Présentation Chiheb Ameur ABID 28/ 32
Développer un client MQTT sur RPI Développer un client MQTT sur RPI

Utilisation de la Bibliothèque Paho MQTT Utilisation de la Bibliothèque Paho MQTT

Lecture des messages

å La lecture bloquante des messages se fait à partir d’une file
const_message_ptr mqtt::async_client::consume_message()

Démarrer la réception des messages Z const_message_ptr : un pointeur sur l’objet encapsulant le message. Si
nullptr : échec de lecture
å Démarrer la réception asynchrone des messages et les stocker dans une file
void mqtt::async_client::start_consuming()
å Lecture non bloquante
bool mqtt::async_client::try_consume_message(const_message_ptr * msg)

å Arrêter la réception des messages et ignorer tout message non lu

void mqtt::async_client::stop_consuming()
La classe message
å Récupérer le nom du sujet d’un message reçu
const string& mqtt::message::get_topic() const

å Renvoyer sous forme d’une chaine de caractère la charge utile d’un message reçu
string mqtt::message::to_string() const
Présentation Chiheb Ameur ABID 29/ 32 Présentation Chiheb Ameur ABID 30/ 32
Développer un client MQTT sur RPI Développer un client MQTT sur RPI

Utilisation de la Bibliothèque Paho MQTT Utilisation de la Bibliothèque Paho MQTT

Exemple : Réception asynchrone et lecture synchrone des messages

const string SERVER_ADDRESS { "tcp://localhost:1883" }; Envoie de messages

const string CLIENT_ID { "paho_cpp_async_consume" };
const string TOPIC { "#" }; å On peut créer une instance de la classe message pour le message à envoyer
int main(int argc, char* argv[]) { message_ptr mqtt::make_message(string_ref topic,binary_ref payload)
mqtt::async_client cli(SERVER_ADDRESS, CLIENT_ID);
cli.start_consuming();
cli.connect()->wait(); Z topic : le sujet
cli.subscribe(TOPIC)->wait();
const_msg_ptr msg;
Z payload : la charge utile du message
while (true) { // Loop to consume read messages
bool reception = cli.try_consume_message(&msg);
å Publier un message
if (reception==true) break;
delivery_token_ptr mqtt::async_client::publish(message_ptr msg)
cout << msg->get_topic() << ": " << msg->to_string() << endl;
delivery_token_ptr mqtt::async_client::publish(string_ref topic, binary_ref payload)
cli.unsubscribe(TOPIC)->wait();
cli.stop_consuming();
cli.disconnect()->wait();
Z topic : le sujet
} Z payload : la charge utile du message
return 0;
}
Présentation Chiheb Ameur ABID 31/ 32 Présentation Chiheb Ameur ABID 32/ 32
Développer un client MQTT sur RPI Développer un client MQTT sur RPI

Utilisation de la Bibliothèque Paho MQTT

Exemple : Réception asynchrone et lecture synchrone des messages M ERCI POUR VOTRE ATTENTION

const string SERVER_ADDRESS {"tcp://localhost:1883"};

const string CLIENT_ID {"paho_cpp_async_publish"};
const string TOPIC { "hello" };
const char* PAYLOAD1 = "Hello World!";
const char* PAYLOAD2 = "Hi there!";

int main(int argc, char* argv[])

{
mqtt::async_client client(SERVER_ADDRESS, CLIENT_ID);
client.connect()->wait();
mqtt::message_ptr pubmsg = mqtt::make_message(TOPIC, PAYLOAD1);

client.publish(pubmsg)->wait_for(TIMEOUT);
cout << "First message was sent..." << endl;
// Now try with itemized publish
mqtt::delivery_token_ptr pubtok;
pubtok = client.publish(TOPIC, PAYLOAD2);
pubtok->wait(); Questions ?
client.disconnect()->wait();
cout << "\nDisconnected" << endl;

return 0;
}