探索 Golang 在嵌入式系统中的强大潜力

package main

import (
    "github.com/eclipse/paho.mqtt.golang"
    "github.com/joeshaw/multierror"
)

const mqttBroker = "mqtt://localhost:1883"

func main() {
    // 创建 MQTT 客户端
    client, err := mqtt.NewClient(&mqtt.ClientOptions{
        ClientID:  "temp-sensor",
        Servers:   []string{mqttBroker},
        Username:  "username",
        Password:  "password",
        CleanSession: true,
    })
    if err != nil {
        // 处理错误
        return
    }

    // 连接到 MQTT 代理
    if token := client.Connect(); token.Wait() && token.Error() != nil {
        // 处理连接错误
        return
    }

    // 创建温度传感器
    sensor, err := dht11.NewDHT11(&dht11.Config{
        Pin: 2,
    })
    if err != nil {
        // 处理传感器错误
        return
    }

    // 定期读取温度并发布到 MQTT 主题
    var errs *multierror.Error
    for {
        temp, hum, err := sensor.Read()
        if err != nil {
            errs = multierror.Append(errs, err)
            continue
        }

        // 将温度发布到 MQTT 主题
        if token := client.Publish("temperature", 0, false, temp); token.Wait() && token.Error() != nil {
            errs = multierror.Append(errs, token.Error())
        }
    }

    // 处理任何收集到的错误
    if errs != nil {
        // 显示错误并打印堆栈跟踪
        // ...
    }
}