保持MQTT Go客户端运行_course

<div class="post-text" itemprop="text"> <p>I think it is a silly question, I need a MQTT Client to keep running after connection and subscription. I never encountered the problem because my MQTT clients are always coupled with an HTTP server, and when launching a HTTP server, the code don't stop running. </p> <p>But in the present use case I only need a MQTT Client to subscribe to some topic and stay alive.</p> <p>Here is what I do (the function just connect to a broker and subcribe to one topic.)</p> <pre class="lang-golang prettyprint-override"><code>func main() { godotenv.Load("./.env") _initMqttConnection() } </code></pre> <p>I need the client to stay connected and not stop just after the subscription is done. </p> <p>How to perform that simple thing ?</p> <p>Edit 1 : Complete Code </p> <p></p><div class="snippet" data-lang="js" data-hide="false" data-console="true" data-babel="false"> <div class="snippet-code"> <pre class="snippet-code-js lang-js prettyprint-override"><code>package main import ( "encoding/json" "fmt" "log" "net/http" "os" "path/filepath" "strings" "github.com/yosssi/gmq/mqtt" "github.com/yosssi/gmq/mqtt/client" "github.com/joho/godotenv" "github.com/skratchdot/open-golang/open" ) var cli *client.Client func _initMqttConnection() { cli = client.New(&amp;client.Options{ ErrorHandler: func(err error) { fmt.Println(err) }, }) defer cli.Terminate() log.Println("Connecting to " + os.Getenv("mqtt_host")) err := cli.Connect(&amp;client.ConnectOptions{ Network: "tcp", Address: os.Getenv("mqtt_host"), UserName: []byte(os.Getenv("mqtt_user")), Password: []byte(os.Getenv("mqtt_password")), ClientID: []byte("mqtt_video_launcher"), }) if err != nil { log.Println("Error 1") panic(err) } log.Println("Connected to MQTT") topic_to_sub := []byte("/" + os.Getenv("video_topic")) err = cli.Subscribe(&amp;client.SubscribeOptions{ SubReqs: []*client.SubReq{ &amp;client.SubReq{ TopicFilter: topic_to_sub, QoS: mqtt.QoS0, Handler: func(topicName, message []byte) { //do struff with message fmt.Println(string(topicName), string(message)) }, }, }, }) if err != nil { panic(err) } log.Println("Subscription OK : " + string(topic_to_sub[:len(topic_to_sub)])) } func main() { godotenv.Load("./.env") _initMqttConnection() }</code></pre> </div> </div> <p>The temporary solution I use is adding : </p> <pre><code>http.ListenAndServe(":", nil) </code></pre> <p>at the end. </p> </div>