golang框架在物联网与边缘计算中的运用

package main

import (
    "context"
    "fmt"
    "log"
    "net/http"
    "os"

    "github.com/go-chi/chi/v5"
    "github.com/eclipse/paho.mqtt.golang"
)

const (
    mqttServer = "mqtt.example.com"
    mqttPort = 1883
    mqttTopic = "my-topic"
)

func main() {
    // 初始化 MQTT 客户端
    opts := mqtt.NewClientOptions()
    opts.AddBroker(fmt.Sprintf("tcp://%s:%d", mqttServer, mqttPort))
    client := mqtt.NewClient(opts)
    if err := client.Connect(context.Background()); err != nil {
        log.Fatal(err)
    }

    // 起一个 HTTP 服务来接收设备数据
    r := chi.NewRouter()
    r.Post("/data", func(w http.ResponseWriter, r *http.Request) {
        body := r.Body
        data, err := ioutil.ReadAll(body)
        if err != nil {
            log.Printf("Error reading body: %v", err)
            w.WriteHeader(http.StatusBadRequest)
            return
        }

        // 发布数据到 MQTT 主题
        client.Publish(context.Background(), mqttTopic, 0, false, data)
        w.WriteHeader(http.StatusOK)
    })

    //启动 HTTP 服务
    port := os.Getenv("PORT")
    if port == "" {
        port = "8080"
    }
    log.Printf("Listening on port %s", port)
    if err := http.ListenAndServe(":"+port, r); err != nil {
        log.Fatal(err)
    }
}