yemqtt

type MqttClient struct {
	Broker   string              // IP
	Port     int                 // 端口号
	ClientID string              // 客户端ID
	MClient  mqtt.Client         // 客户端实例
	MOpts    *mqtt.ClientOptions // 客户端配置
	Topic    string              // 主题名称
	// contains filtered or unexported fields
}

type MsgJson struct {
	Level string `json:"level"`
	Msg   string `json:"msg"`
	Time  string `json:"time"`
}

type SubFunc = func(client mqtt.Client, msg mqtt.Message)