Ejemplo MQTT con Go

package main

import (
	"crypto/tls"
	"fmt"
	"time"

	mqtt "github.com/eclipse/paho.mqtt.golang"
)

func main() {
	topic := "your-project/sensors/temperature"

	// Conectar a tu broker privado de ConnectMQ en el puerto 8883
	opts := mqtt.NewClientOptions().AddBroker("ssl://YOUR_BROKER_HOST:8883")
	// Usuario y contraseña de tu panel de ConnectMQ
	opts.SetUsername("YOUR_USERNAME")
	opts.SetPassword("YOUR_PASSWORD")
	// TLS: el almacén de CA del sistema verifica el certificado del broker
	opts.SetTLSConfig(&tls.Config{MinVersion: tls.VersionTLS12})
	// Cada cliente necesita un client ID único
	opts.SetClientID(fmt.Sprintf("go-%d", time.Now().UnixNano()))
	// Reconectar automáticamente si se pierde la conexión
	opts.SetAutoReconnect(true)
	// Se ejecuta al establecer la conexión
	opts.SetOnConnectHandler(func(c mqtt.Client) {
		// Suscribirse al topic de temperatura
		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())
	}
	// Publicar una lectura en JSON
	client.Publish(topic, 1, false, `{"temperature":21.5}`).Wait()
	// Mantener el cliente en ejecución
	select {}
}