我有个毛病就是碰到一个陌生的东西感兴趣的时候, 先研究怎么开启&关闭, 然后跑起来再看效果, 中间碰到什么问题再说. 用最快的速度先用上, 然后优化的事情随着使用熟练度上升自然也清楚瓶颈在哪里了

那么这篇文章也是这样, 就是使用go怎么使用mqtt通信, 不涉及原理, 文章止步于能跑起来一个demo, 后续怎么开发, 怎么使用就看个人体验了, 也不是一篇文章能记录下来的

测试环境

macOS 10.15.6

go 1.14.6 darwin/amd64

安装/启动 mosquitto

go应用使用mqtt通信协议的时候, 是作为client端使用的, server端自然需要一个服务来承载, 好在有协议作者提供的一个应用, 就是 mosquitto

mac执行命令

1

brew install mosquitto

下载完毕后, 启动服务

1

mosquitto -c /usr/local/etc/mosquitto/mosquitto.conf

至于配置文件里字段的含义, 去其他文章里找找, 不耽误demo的运行

golang mqtt 的 demo

先拉取包

1
2
3

go get github.com/eclipse/paho.mqtt.golang
go get github.com/gorilla/websocket
go get golang.org/x/net/proxy

然后找一个demo运行起来, 至于demo从哪找到, 直接就这个包里呗github.com/eclipse/paho.mqtt.golang

源文件地址

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

/*
 * Copyright (c) 2013 IBM Corp.
 *
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *    Seth Hoenig
 *    Allan Stockdill-Mander
 *    Mike Robertson
 */

package main

import (
	"fmt"
	"log"
	"os"
	"time"

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

var f mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
	fmt.Printf("TOPIC: %s\n", msg.Topic())
	fmt.Printf("MSG: %s\n", msg.Payload())
}

func main() {
	// 打印程序运行结果, 感觉干扰视线就把 mqtt.DEBUG个注释掉
	mqtt.DEBUG = log.New(os.Stdout, "", 0)
	mqtt.ERROR = log.New(os.Stdout, "", 0)
	// 这里使用的本地地址
	opts := mqtt.NewClientOptions().AddBroker("tcp://0.0.0.0:1883").SetClientID("gotrivial")
	opts.SetKeepAlive(2 * time.Second)

	// 这里需要注入一个client收到消息后对消息处理的方法
	opts.SetDefaultPublishHandler(f)
	opts.SetPingTimeout(1 * time.Second)

	// 启动一个链接
	c := mqtt.NewClient(opts)
	if token := c.Connect(); token.Wait() && token.Error() != nil {
		panic(token.Error())
	}

	// 订阅一个topic
	if token := c.Subscribe("go-mqtt/sample", 0, nil); token.Wait() && token.Error() != nil {
		fmt.Println(token.Error())
		os.Exit(1)
	}

	// 向topic发布消息, SetDefaultPublishHandler里收消息
	for i := 0; i < 5; i++ {
		text := fmt.Sprintf("this is msg #%d!", i)
		token := c.Publish("go-mqtt/sample", 0, false, text)
		token.Wait()
	}

	time.Sleep(6 * time.Second)

	if token := c.Unsubscribe("go-mqtt/sample"); token.Wait() && token.Error() != nil {
		fmt.Println(token.Error())
		os.Exit(1)
	}

	c.Disconnect(250)

	time.Sleep(1 * time.Second)
}

demo里提供的地址国内估计用不了, 换成本地mosquitto的就行了, 然后运行一下就能看到效果了, 如果想了解更多的用法, 就翻翻那个包里其他的用例

扩展资料

初识 MQTT

Mosquitto man page

golang client各种demo