Connectez Rust à un broker MQTT avec la crate rumqttc. Commencez sur le broker public gratuit, puis pointez le même code vers un broker privé et sécurisé sur ConnectMQ.
mqtt-code-samples/rustClonez les exemples complets et prêts à l’emploi. Étoiles et pull requests bienvenues. Voir sur GitHub Aucun compte requis : connectez-vous à broker.connectmq.com sur le port 1883 et publiez vos premiers messages en quelques secondes.
use rumqttc::{Client, Event, MqttOptions, Packet, QoS};
use std::time::Duration;
fn main() {
let topic = "your-project/sensors/temperature"; // Utilisez un préfixe de topic unique : tout le monde peut lire le broker public
// Connexion au broker public gratuit (aucun compte requis) (Chaque client doit avoir un client ID unique)
let mut options = MqttOptions::new("rust-example", "broker.connectmq.com", 1883);
options.set_keep_alive(Duration::from_secs(30));
let (client, mut connection) = Client::new(options, 10);
// Abonnement au topic de température
client.subscribe(topic, QoS::AtLeastOnce).unwrap();
// Publication d’une mesure en JSON
client.publish(topic, QoS::AtLeastOnce, false, r#"{"temperature":21.5}"#).unwrap();
// Maintient le client actif
for event in connection.iter() {
if let Ok(Event::Incoming(Packet::Publish(p))) = event {
println!("{}: {}", p.topic, String::from_utf8_lossy(&p.payload));
}
}
}
Le broker public est partagé : n’importe qui peut s’abonner à vos topics. N’y faites jamais transiter de mots de passe, de données personnelles ou d’informations confidentielles.
À propos du broker MQTT public gratuitPour de vrais appareils, utilisez un broker MQTT serverless privé sur ConnectMQ plutôt que le broker public : chiffrement TLS, un nom d’utilisateur et un mot de passe par appareil et un contrôle d’accès par topic, entièrement managé. Commencez avec l’offre Free, sans carte bancaire.
Remplacez YOUR_BROKER_HOST, YOUR_USERNAME et YOUR_PASSWORD par les valeurs de votre tableau de bord ConnectMQ.
use rumqttc::{Client, Event, MqttOptions, Packet, QoS, Transport};
use std::time::Duration;
fn main() {
let topic = "your-project/sensors/temperature";
// Connexion à votre broker ConnectMQ privé sur le port 8883 (Chaque client doit avoir un client ID unique)
let mut options = MqttOptions::new("rust-example", "YOUR_BROKER_HOST", 8883);
options.set_keep_alive(Duration::from_secs(30));
// Nom d’utilisateur et mot de passe issus du tableau de bord ConnectMQ
options.set_credentials("YOUR_USERNAME", "YOUR_PASSWORD");
// TLS : le magasin CA du système vérifie le certificat du broker
options.set_transport(Transport::tls_with_default_config());
let (client, mut connection) = Client::new(options, 10);
// Abonnement au topic de température
client.subscribe(topic, QoS::AtLeastOnce).unwrap();
// Publication d’une mesure en JSON
client.publish(topic, QoS::AtLeastOnce, false, r#"{"temperature":21.5}"#).unwrap();
// Maintient le client actif
for event in connection.iter() {
if let Ok(Event::Incoming(Packet::Publish(p))) = event {
println!("{}: {}", p.topic, String::from_utf8_lossy(&p.payload));
}
}
}
Installez rumqttc, connectez-vous à l’hôte du broker sur le port 1883 (ou 8883 avec TLS), puis abonnez-vous à un topic et publiez-y des messages. Les exemples de cette page se connectent au broker public gratuit broker.connectmq.com et à un broker ConnectMQ privé.
Oui. broker.connectmq.com est un broker MQTT public gratuit qui ne nécessite aucun compte. Tout le monde peut lire ses topics : utilisez-le uniquement pour vos tests, avec un préfixe de topic unique.
Connectez-vous via TLS sur le port 8883 avec un nom d’utilisateur et un mot de passe issus de votre tableau de bord ConnectMQ, et attribuez à chaque appareil ses propres identifiants et permissions de topic au lieu d’utiliser le broker public.
Connectez Python à un broker MQTT avec paho-mqtt.
Voir l’exempleConnectez Node.js à un broker MQTT avec MQTT.js.
Voir l’exempleConnectez un ESP32 à un broker MQTT via Wi-Fi avec la bibliothèque Arduino PubSubClient.
Voir l’exempleConnectez Go à un broker MQTT avec le client Go Eclipse Paho.
Voir l’exemplePubliez et abonnez-vous en ligne de commande avec mosquitto_pub et mosquitto_sub.
Voir l’exempleConnectez Java à un broker MQTT avec le client Java Eclipse Paho.
Voir l’exempleConnectez C# et .NET à un broker MQTT avec MQTTnet.
Voir l’exempleConnectez vos applications Dart et Flutter à un broker MQTT avec le package mqtt_client.
Voir l’exempleConnectez vos applications natives iOS (Swift) et Android (Kotlin) à un broker MQTT.
Voir l’exempleConnectez Home Assistant à un broker MQTT et transformez les messages MQTT en capteurs.
Voir l’exempleConnectez Node-RED à un broker MQTT avec un flow importable.
Voir l’exempleTestez n’importe quel exemple sur broker.connectmq.com : sans inscription, MQTT 3.1.1 et 5, TCP, TLS et WebSocket.
À propos du broker MQTT public gratuitLe moment venu de connecter de vrais appareils, exécutez le même code sur un broker ConnectMQ privé et entièrement managé, avec TLS et des identifiants par appareil.
Commencer gratuitementCréez un compte, récupérez les identifiants de votre broker et connectez votre premier appareil — aucun serveur à installer, mettre à jour ou dimensionner.
