ipole_edge_server/edge/ipole/mqtt_init.go

package main

import (
	"sync"

	"lc/common/mqtt"
)

// 重导出类型和常量，避免修改所有业务文件
type OptType = mqtt.OptType
type MQTTMessage = mqtt.MQTTMessage

const (
	ToAll   = mqtt.ToAll
	ToCloud = mqtt.ToCloud
	ToEdge  = mqtt.ToEdge
)

var _mqttMgrOnce sync.Once
var _mqttMgr *mqtt.MQTTMgr

func GetMQTTMgr() *mqtt.MQTTMgr {
	_mqttMgrOnce.Do(func() {
		_mqttMgr = mqtt.NewMQTTMgr(mqtt.MQTTMgrConfig{
			CloudServer:   appConfig.Cloud.Mqtt.Server,
			CloudClientID: appConfig.GID + "@" + appname + version,
			CloudUser:     appConfig.Cloud.Mqtt.User,
			CloudPassword: appConfig.Cloud.Mqtt.Password,
			CloudTimeout:  appConfig.Cloud.Mqtt.Timeout,
			EdgeServer:    appConfig.Edge.Mqtt.Server,
			EdgeClientID:  appConfig.GID + "@" + appname + version,
			EdgeUser:      appConfig.Edge.Mqtt.User,
			EdgePassword:  appConfig.Edge.Mqtt.Password,
			EdgeTimeout:   appConfig.Edge.Mqtt.Timeout,
		})
	})
	return _mqttMgr
}