怎样为Golang搭建物联网开发环境 支持MQTT和CoAP协议栈

go version

go get github.com/eclipse/paho.mqtt.golang

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

var connectHandler mqtt.OnConnectHandler = func(client mqtt.Client) {
    fmt.Println("Connected")
}

func main() {
    opts := mqtt.NewClientOptions().AddBroker("tcp://broker.emqx.io:1883")
    opts.SetClientID("go-mqtt-client")
    opts.OnConnect = connectHandler

    client := mqtt.NewClient(opts)
    if token := client.Connect(); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }

    // 订阅某个主题
    token := client.Subscribe("iot/test", 1, nil)
    token.Wait()
}

go get github.com/plgd-dev/go-coap/v2

import (
    "fmt"
    "log"
    "net"

    "github.com/plgd-dev/go-coap/v2"
)

func handler(w coap.ResponseWriter, r *coap.Request) {
    fmt.Printf("Got message: %+v\n", r.Payload)
    w.SetPayload([]byte("Hello from CoAP server"))
}

func main() {
    mux := coap.NewServeMux()
    mux.Handle("/test", coap.HandlerFunc(handler))

    ln, err := net.ListenUDP("udp", &net.UDPAddr{IP: net.IPv4zero, Port: 5683})
    if err != nil {
        log.Fatalf("Error setting up listener: %v", err)
    }

    log.Println("Starting CoAP server on :5683")
    server := &coap.Server{
        Handler: mux,
        Conn:    ln,
    }
    log.Fatal(server.Serve())
}

/cmd
  /main.go         # 启动入口
/pkg
  /mqtt            # MQTT 相关逻辑
  /coap            # CoAP 相关逻辑
  /config          # 配置读取
  /utils           # 工具函数