MQTT-Wrapper

MQTT-Wrapper package provides easy-to-use MQTTv3 and MQTTv5 connection for Go projects.

It supports Request/Response pattern for MQTTv5 connection.

Usage

• Import the package

import( 
    mqtt "github.com/alihanyalcin/mqtt-wrapper"
)

• Create a local variable using MQTTConfig struct and fill the necessary fields for the connection.

config := mqtt.Config{
    Brokers:              []string{"127.0.0.1:1883"},
    ClientID:             "",
    Username:             "",
    Password:             "",
    Topics:               []string{"topic"},
    QoS:                  0,
    Retained:             false,
    AutoReconnect:        false,
    MaxReconnectInterval: 5,
    PersistentSession:    false,
    KeepAlive:            15,
    TLSCA:                "",
    TLSCert:              "",
    TLSKey:               "",
    Version:              mqtt.V3, // use mqtt.V5 for MQTTv5 client.
}

• Then, create a connection to MQTT broker(s).

client, err := config.CreateConnection()
if err != nil {
    log.Fatal(err)
}

• To disconnect from broker(s)

client.Disconnect()

• To publish a message to broker(s) with a specific topic

err = client.Publish("topic", "message")
if err != nil {
    log.Fatal(err)
}

• To handle new messages

client.Handle(func(topic string, payload []byte) {
    log.Printf("Received on [%s]: '%s'", topic, string(payload))
})

Check examples for more information about MQTTv5 client.