mqtt

mqtt

管理MQTT的连接，以及消息的订阅。

安装

go get -u github.com/lwhu2015/gomqtt

使用

// 初始化MQTT
func initMQTT() {
	// 消息订阅
	for _, sub := range SubTopics {
		gomqtt.Subscribe(gomqtt.SubscribeType{Topic: sub.Topic, Qos: 0, Callback: sub.CallBack, RetryTimes: 0})
	}
	// MQTT配置
	opts := gomqtt.GetClientOptions(&gomqtt.Config{
		Broker:   g.Cfg().GetString("mqtt.broker"),
		Username: g.Cfg().GetString("mqtt.username"),
		Password: g.Cfg().GetString("mqtt.password"),
		CACert:   g.Cfg().GetString("mqtt.cacert"),
		ClientID: guuid.New().String(),
	})

	opts.SetOnConnectHandler(func(client mqtt.Client) {
		glog.Info("MQTT OnConnect.")
	}) // 设置自定义的连接后处理方法
	opts.SetConnectionLostHandler(func(client mqtt.Client, error error) {
		glog.Info("MQTT ConnectionLost.")
	}) // 设置自定义的断开连接后处理方法
	if err := gomqtt.Init(opts); err != nil {
		glog.Fatal("MQTT initialization failed.")
	} else {
		glog.Info("MQTT initialized successfully.")
	}
}