Verbinden Sie Go mit dem Eclipse Paho Go Client 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.
mqtt-code-samples/goKlonen Sie die vollständigen, lauffähigen Beispiele. Stars und Pull Requests sind willkommen. Auf GitHub ansehen Kein Konto nötig: Verbinden Sie sich mit broker.connectmq.com auf Port 1883 und publizieren Sie in wenigen Sekunden.
package main
import (
"fmt"
"time"
mqtt "github.com/eclipse/paho.mqtt.golang"
)
func main() {
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)
opts := mqtt.NewClientOptions().AddBroker("tcp://broker.connectmq.com:1883")
// Jeder Client braucht eine eindeutige Client-ID
opts.SetClientID(fmt.Sprintf("go-%d", time.Now().UnixNano()))
// Bei Verbindungsabbruch automatisch neu verbinden
opts.SetAutoReconnect(true)
// Wird ausgeführt, sobald die Verbindung steht
opts.SetOnConnectHandler(func(c mqtt.Client) {
// Temperatur-Topic abonnieren
c.Subscribe(topic, 1, func(_ mqtt.Client, m mqtt.Message) {
fmt.Printf("%s: %s\n", m.Topic(), m.Payload())
})
})
client := mqtt.NewClient(opts)
if t := client.Connect(); t.Wait() && t.Error() != nil {
panic(t.Error())
}
// Messwert als JSON publizieren
client.Publish(topic, 1, false, `{"temperature":21.5}`).Wait()
// Client am Laufen halten
select {}
}
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-BrokerNutzen 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.
package main
import (
"crypto/tls"
"fmt"
"time"
mqtt "github.com/eclipse/paho.mqtt.golang"
)
func main() {
topic := "your-project/sensors/temperature"
// Mit Ihrem privaten ConnectMQ-Broker auf Port 8883 verbinden
opts := mqtt.NewClientOptions().AddBroker("ssl://YOUR_BROKER_HOST:8883")
// Benutzername und Passwort aus Ihrem ConnectMQ-Dashboard
opts.SetUsername("YOUR_USERNAME")
opts.SetPassword("YOUR_PASSWORD")
// TLS: Der CA-Speicher des Systems prüft das Broker-Zertifikat
opts.SetTLSConfig(&tls.Config{MinVersion: tls.VersionTLS12})
// Jeder Client braucht eine eindeutige Client-ID
opts.SetClientID(fmt.Sprintf("go-%d", time.Now().UnixNano()))
// Bei Verbindungsabbruch automatisch neu verbinden
opts.SetAutoReconnect(true)
// Wird ausgeführt, sobald die Verbindung steht
opts.SetOnConnectHandler(func(c mqtt.Client) {
// Temperatur-Topic abonnieren
c.Subscribe(topic, 1, func(_ mqtt.Client, m mqtt.Message) {
fmt.Printf("%s: %s\n", m.Topic(), m.Payload())
})
})
client := mqtt.NewClient(opts)
if t := client.Connect(); t.Wait() && t.Error() != nil {
panic(t.Error())
}
// Messwert als JSON publizieren
client.Publish(topic, 1, false, `{"temperature":21.5}`).Wait()
// Client am Laufen halten
select {}
}
Installieren Sie Eclipse Paho Go, 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.
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.
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.
Verbinden Sie Python mit paho-mqtt mit einem MQTT-Broker.
Beispiel ansehenVerbinden Sie Node.js mit MQTT.js mit einem MQTT-Broker.
Beispiel ansehenVerbinden Sie einen ESP32 per WLAN mit der Arduino-Bibliothek PubSubClient mit einem MQTT-Broker.
Beispiel ansehenPublizieren und abonnieren Sie über die Kommandozeile mit mosquitto_pub und mosquitto_sub.
Beispiel ansehenVerbinden Sie Java mit dem Eclipse Paho Java Client mit einem MQTT-Broker.
Beispiel ansehenVerbinden Sie C# und .NET mit MQTTnet mit einem MQTT-Broker.
Beispiel ansehenVerbinden Sie Rust mit dem Crate rumqttc mit einem MQTT-Broker.
Beispiel ansehenVerbinden Sie Dart- und Flutter-Apps mit dem Paket mqtt_client mit einem MQTT-Broker.
Beispiel ansehenVerbinden Sie native iOS-Apps (Swift) und Android-Apps (Kotlin) mit einem MQTT-Broker.
Beispiel ansehenVerbinden Sie Home Assistant mit einem MQTT-Broker und machen Sie aus MQTT-Nachrichten Sensoren.
Beispiel ansehenVerbinden Sie Node-RED mit einem importierbaren Flow mit einem MQTT-Broker.
Beispiel ansehenTesten 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-BrokerWenn 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 startenKonto anlegen, Broker-Zugangsdaten erhalten und das erste Gerät verbinden — ohne Server, die installiert, gepatcht oder skaliert werden müssen.
