Go语言实现mqtt协议 代码实例

下面是一个使用 Go 语言实现 MQTT 协议的基本代码示例，实现了 MQTT 的连接、发布和订阅功能，仅供参考：

package main

import (
    "fmt"
    "log"
    "os"
    "os/signal"
    "syscall"
    "time"

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

func main() {
    // 创建 MQTT 客户端实例
    opts := mqtt.NewClientOptions().AddBroker("tcp://localhost:1883")
    opts.SetClientID("go-mqtt-demo")

    client := mqtt.NewClient(opts)

    // 连接 MQTT 服务器
    if token := client.Connect(); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }

    // 订阅主题
    if token := client.Subscribe("test/topic", 0, nil); token.Wait() && token.Error() != nil {
        log.Fatal(token.Error())
    }

    // 定义消息处理函数
    messageHandler := func(client mqtt.Client, msg mqtt.Message) {
        fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic())
    }

    // 设置消息处理函数
    client.SetDefaultPublishHandler(messageHandler)

    // 发布消息
    text := "Hello MQTT"
    token := client.Publish("test/topic", 0, false, text)
    token.Wait()

    // 等待消息处理
    time.Sleep(time.Second)

    // 断开连接
    client.Disconnect(250)
    fmt.Println("Disconnected from MQTT broker.")
}

以上代码实现了连接到 MQTT 服务器，订阅主题，发布消息，并设置了消息处理函数。可以使用 Eclipse Paho MQTT Go 等第三方库来方便地实现 MQTT 协议的相关功能。