Go语言实现mqtt通信

可以使用 paho.mqtt.golang 库进行 MQTT 通信，在使用该库之前需要先安装 mosquitto 服务器并启动。

以下是一个简单的 MQTT 发布程序示例:

package main

import (
    "fmt"
    "os"
    "time"

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

func main() {
    // 创建 MQTT 客户端
    opts := MQTT.NewClientOptions().AddBroker("tcp://localhost:1883")
    client := MQTT.NewClient(opts)

    token := client.Connect() // 连接到服务器
    token.Wait()
    if err := token.Error(); err != nil {
        fmt.Println(err)
        os.Exit(1)
    }

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

    // 等待 1 秒后关闭连接
    time.Sleep(1 * time.Second)
    client.Disconnect(250)
}

该程序发布了一个消息到名为 "mytopic" 的主题。可以通过订阅该主题来接收消息。