Golang技术在企业级物联网开发中的应用指南

package main

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

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

func main() {
    // 创建 MQTT 客户端
    mqttClient, err := mqtt.NewClient(mqtt.NewClientOptions())
    if err != nil {
        log.Fatal(err)
    }

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

    // 监听 HTTP 请求，收集设备数据
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        if err := r.ParseForm(); err != nil {
            fmt.Fprint(w, "Error parsing form data")
            return
        }

        // 从请求中获取设备数据并发布到 MQTT 主题
        data := r.Form.Get("data")
        if token := mqttClient.Publish("my-topic", 1, false, data); token.Wait() && token.Error() != nil {
            fmt.Fprint(w, "Error publishing data")
            return
        }

        fmt.Fprint(w, "Data successfully received")
    })

    if err := http.ListenAndServe(":8080", nil); err != nil {
        log.Fatal(err)
    }
}

package main

import (
    "encoding/json"
    "fmt"
    "log"
    "net/http"

    "github.com/gorilla/mux"
)

type Device struct {
    ID       string
    Name    string
    Status  string
    Command string
}

var devices []*Device

func main() {
    router := mux.NewRouter()

    // 添加设备
    router.HandleFunc("/devices", addDevice).Methods("POST")

    // 获取设备列表
    router.HandleFunc("/devices", getDevices).Methods("GET")

    // 控制设备
    router.HandleFunc("/devices/{id}/commands", controlDevice).Methods("POST")

    if err := http.ListenAndServe(":8080", router); err != nil {
        log.Fatal(err)
    }
}

func addDevice(w http.ResponseWriter, r *http.Request) {
    var device Device
    if err := json.NewDecoder(r.Body).Decode(&device); err != nil {
        fmt.Fprint(w, "Error parsing JSON")
        return
    }

    devices = append(devices, &device)
    fmt.Fprint(w, "Device added")
}

func getDevices(w http.ResponseWriter, r *http.Request) {
    if err := json.NewEncoder(w).Encode(devices); err != nil {
        fmt.Fprint(w, "Error encoding JSON")
        return
    }
}

func controlDevice(w http.ResponseWriter, r *http.Request) {
    vars := mux.Vars(r)
    for _, device := range devices {
        if device.ID == vars["id"] {
            var command Device
            if err := json.NewDecoder(r.Body).Decode(&command); err != nil {
                fmt.Fprint(w, "Error parsing JSON")
                return
            }

            if err := device.SendCommand(command.Command); err != nil {
                fmt.Fprint(w, "Error sending command")
                return
            }
        }
    }
}