Go结合MQTT实现通信的示例代码

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

package main
import (
?? ?"fmt"
?? ?"log"
?? ?"os"
?? ?"os/signal"
?? ?"time"
?? ?MQTT "github.com/eclipse/paho.mqtt.golang"
)
func main() {
?? ?// 创建 MQTT 客户端配置
?? ?opts := MQTT.NewClientOptions()
?? ?opts.AddBroker("tcp://localhost:1883")
?? ?opts.SetClientID("go-mqtt-client")
?? ?// 创建 MQTT 客户端实例
?? ?client := MQTT.NewClient(opts)
?? ?// 连接到 MQTT 服务器
?? ?if token := client.Connect(); token.Wait() && token.Error() != nil {
?? ??? ?log.Fatal(token.Error())
?? ?}
?? ?// 在连接成功后进行订阅和发布操作
?? ?go func() {
?? ??? ?// 订阅主题
?? ??? ?if token := client.Subscribe("my/topic", 0, nil); token.Wait() && token.Error() != nil {
?? ??? ??? ?log.Fatal(token.Error())
?? ??? ?}
?? ??? ?// 发布消息
?? ??? ?for i := 0; i < 5; i++ {
?? ??? ??? ?text := fmt.Sprintf("Message %d", i)
?? ??? ??? ?token := client.Publish("my/topic", 0, false, text)
?? ??? ??? ?token.Wait()
?? ??? ??? ?fmt.Println("Published:", text)
?? ??? ??? ?time.Sleep(time.Second)
?? ??? ?}
?? ?}()
?? ?// 等待退出信号
?? ?c := make(chan os.Signal, 1)
?? ?signal.Notify(c, os.Interrupt)
?? ?<-c
?? ?// 断开与 MQTT 服务器的连接
?? ?client.Disconnect(250)
}