解密 Go 框架在物联网领域的成功案例

package main

import (
    "fmt"
    "log"

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

const (
    broker   = "mqtt://localhost:1883"
    qos      = 1
    topic    = "sensor-data"
    clientid = "iot-gateway"
)

func main() {
    // 创建 MQTT 客户端
    opts := mqtt.NewClientOptions()
    opts.AddBroker(broker)
    opts.SetClientID(clientid)
    client := mqtt.NewClient(opts)

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

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

    // 发布传感器数据
    for {
        data := "Sensor data: 123"
        token := client.Publish(topic, qos, false, data)
        token.Wait()
    }
}