golang mqtt发布并订阅 | 那些遇到过的问题

Phi*_*eal 7 go mqtt mosquitto paho

有人知道在哪里可以得到在无限循环中发布和订阅的示例MQTT客户端Go（golang）代码吗？

我正在与在MacO上运行的Mosquitto代理进行消息传递。

更详细地...

1. 从网络获取消息（主题）
2. 根据该消息计算内容
3. 将计算结果发送回网络（主题）

这是我正在使用的代码：

package main

import (
"fmt"
 MQTT "github.com/eclipse/paho.mqtt.golang"
"os"
"time"
)

var knt int

var f MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) 
{ 
   fmt.Printf("MSG: %s\n", msg.Payload())
   text:= fmt.Sprintf("this is result msg #%d!", knt)
   knt++
   token := client.Publish("nn/result", 0, false, text)
   token.Wait()
}

func main() {
   knt = 0

   opts := MQTT.NewClientOptions().AddBroker("tcp://localhost:1883")
   opts.SetClientID("mac-go")
   opts.SetDefaultPublishHandler(f)

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

  if token := c.Subscribe("nn/sensors", 0, nil); token.Wait() && 
     token.Error() != nil {
     fmt.Println(token.Error())
     os.Exit(1)
  }

  time.Sleep(3 * time.Second)
} //end of main

我通过GoDocs查看了一些有关如何保持连接打开的提示，但似乎没有任何相关之处。我当然可以对“订阅”进行无限循环，但这似乎效率很低。