Codebeispiele

MQTT-Beispiel für Rust

Verbinden Sie Rust mit dem Crate rumqttc mit einem MQTT-Broker. Starten Sie auf dem kostenlosen öffentlichen Broker und verbinden Sie denselben Code anschließend mit einem sicheren privaten Broker auf ConnectMQ.

Bibliothek
rumqttc
Installation
cargo add rumqttc
Quellcode auf GitHubmqtt-code-samples/rustKlonen Sie die vollständigen, lauffähigen Beispiele. Stars und Pull Requests sind willkommen. Auf GitHub ansehen

1. Auf dem kostenlosen öffentlichen Broker testen

Kein Konto nötig: Verbinden Sie sich mit broker.connectmq.com auf Port 1883 und publizieren Sie in wenigen Sekunden.

main.rs
use rumqttc::{Client, Event, MqttOptions, Packet, QoS};
use std::time::Duration;

fn main() {
    let topic = "your-project/sensors/temperature"; // Eindeutiges Topic-Präfix verwenden: Jeder kann den öffentlichen Broker mitlesen

    // Mit dem kostenlosen öffentlichen Broker verbinden (kein Konto nötig) (Jeder Client braucht eine eindeutige Client-ID)
    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);

    // Temperatur-Topic abonnieren
    client.subscribe(topic, QoS::AtLeastOnce).unwrap();
    // Messwert als JSON publizieren
    client.publish(topic, QoS::AtLeastOnce, false, r#"{"temperature":21.5}"#).unwrap();

    // Client am Laufen halten
    for event in connection.iter() {
        if let Ok(Event::Incoming(Packet::Publish(p))) = event {
            println!("{}: {}", p.topic, String::from_utf8_lossy(&p.payload));
        }
    }
}

Kostenloser öffentlicher MQTT-Broker

Der öffentliche Broker wird gemeinsam genutzt: Jeder kann Ihre Topics abonnieren. Senden Sie darüber niemals Passwörter, personenbezogene Daten oder vertrauliche Informationen.

Mehr zum kostenlosen öffentlichen MQTT-Broker

2. Mit ConnectMQ in Produktion gehen

Nutzen Sie für echte Geräte statt des öffentlichen Brokers einen privaten Serverless-MQTT-Broker auf ConnectMQ: TLS-Verschlüsselung, Benutzername und Passwort für jedes Gerät sowie Zugriffskontrolle pro Topic, vollständig verwaltet. Starten Sie im Free-Plan — ohne Kreditkarte.

Ersetzen Sie YOUR_BROKER_HOST, YOUR_USERNAME und YOUR_PASSWORD durch die Werte aus Ihrem ConnectMQ-Dashboard.

main.rs
use rumqttc::{Client, Event, MqttOptions, Packet, QoS, Transport};
use std::time::Duration;

fn main() {
    let topic = "your-project/sensors/temperature";

    // Mit Ihrem privaten ConnectMQ-Broker auf Port 8883 verbinden (Jeder Client braucht eine eindeutige Client-ID)
    let mut options = MqttOptions::new("rust-example", "YOUR_BROKER_HOST", 8883);
    options.set_keep_alive(Duration::from_secs(30));
    // Benutzername und Passwort aus Ihrem ConnectMQ-Dashboard
    options.set_credentials("YOUR_USERNAME", "YOUR_PASSWORD");
    // TLS: Der CA-Speicher des Systems prüft das Broker-Zertifikat
    options.set_transport(Transport::tls_with_default_config());
    let (client, mut connection) = Client::new(options, 10);

    // Temperatur-Topic abonnieren
    client.subscribe(topic, QoS::AtLeastOnce).unwrap();
    // Messwert als JSON publizieren
    client.publish(topic, QoS::AtLeastOnce, false, r#"{"temperature":21.5}"#).unwrap();

    // Client am Laufen halten
    for event in connection.iter() {
        if let Ok(Event::Incoming(Packet::Publish(p))) = event {
            println!("{}: {}", p.topic, String::from_utf8_lossy(&p.payload));
        }
    }
}

FAQ zu MQTT mit Rust

Wie verbinde ich Rust mit einem MQTT-Broker?

Installieren Sie rumqttc, verbinden Sie sich mit dem Broker-Host auf Port 1883 (oder 8883 mit TLS), abonnieren Sie dann ein Topic und publizieren Sie Nachrichten darauf. Die Beispiele auf dieser Seite verbinden sich mit dem kostenlosen öffentlichen Broker broker.connectmq.com und mit einem privaten ConnectMQ-Broker.

Gibt es einen kostenlosen MQTT-Broker zum Testen von Rust?

Ja. broker.connectmq.com ist ein kostenloser öffentlicher MQTT-Broker, für den Sie kein Konto benötigen. Jeder kann seine Topics mitlesen, nutzen Sie ihn daher nur für Tests und mit einem eindeutigen Topic-Präfix.

Wie sichere ich eine MQTT-Verbindung mit Rust ab?

Verbinden Sie sich über TLS auf Port 8883 mit Benutzername und Passwort aus Ihrem ConnectMQ-Dashboard und geben Sie jedem Gerät eigene Zugangsdaten und Topic-Berechtigungen, statt den öffentlichen Broker zu verwenden.

Kostenloser öffentlicher MQTT-Broker

Testen Sie jedes Beispiel auf broker.connectmq.com – ohne Registrierung, mit MQTT 3.1.1 und 5, TCP, TLS und WebSocket.

Mehr zum kostenlosen öffentlichen MQTT-Broker

Sicheres Serverless-MQTT für die Produktion

Wenn echte Geräte dazukommen, führen Sie denselben Code auf einem privaten, vollständig verwalteten ConnectMQ-Broker mit TLS und eigenen Zugangsdaten pro Gerät aus.

Kostenlos starten

Ihr privater MQTT-Broker ist nur wenige Klicks entfernt

Konto anlegen, Broker-Zugangsdaten erhalten und das erste Gerät verbinden — ohne Server, die installiert, gepatcht oder skaliert werden müssen.