golang框架在物联网中的应用

package main

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

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

func main() {
    // 配置 MQTT 服务器地址
    server := "localhost:1883"

    // 创建 MQTT 客户端选项
    opts := mqtt.NewClientOptions()
    opts.AddBroker(server)
    opts.SetClientID("my-client")

    // 创建 MQTT 客户端
    client, err := mqtt.NewClient(opts)
    if err != nil {
        log.Fatal(err)
    }

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

    // 订阅主题
    if token := client.Subscribe("my-topic", 0, func(client mqtt.Client, msg mqtt.Message) {
        fmt.Printf("Received message: %s\n", msg.Payload())
    }); token.Wait() && token.Error() != nil {
        log.Fatal(token.Error())
    }

    // 捕获程序终止信号
    sigc := make(chan os.Signal, 1)
    signal.Notify(sigc, os.Interrupt)
    signal.Notify(sigc, syscall.SIGTERM)

    // 等待程序终止信号
    <-sigc

    // 断开连接并关闭 MQTT 客户端
    client.Disconnect(100)
    client.Close()
}