Exemplo MQTT em Go

package main

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

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

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

	// Conecta ao seu broker privado do ConnectMQ na porta 8883
	opts := mqtt.NewClientOptions().AddBroker("ssl://YOUR_BROKER_HOST:8883")
	// Usuário e senha do seu painel do ConnectMQ
	opts.SetUsername("YOUR_USERNAME")
	opts.SetPassword("YOUR_PASSWORD")
	// TLS: o repositório de CAs do sistema verifica o certificado do broker
	opts.SetTLSConfig(&tls.Config{MinVersion: tls.VersionTLS12})
	// Cada cliente precisa de um client ID único
	opts.SetClientID(fmt.Sprintf("go-%d", time.Now().UnixNano()))
	// Reconecta automaticamente se a conexão cair
	opts.SetAutoReconnect(true)
	// Executado quando a conexão é estabelecida
	opts.SetOnConnectHandler(func(c mqtt.Client) {
		// Assina o tópico 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())
	}
	// Publica uma leitura em JSON
	client.Publish(topic, 1, false, `{"temperature":21.5}`).Wait()
	// Mantém o cliente em execução
	select {}
}