hxmqtt

type MqttClient struct {
	// contains filtered or unexported fields
}

type MqttConf struct {
	Uri      string // 格式"tcp://[ip]:[port]"
	Username string // 用户名
	Password string // 密码

	ConnectedFunc      mqtt.OnConnectHandler      // 连接成功回调函数
	LostConnFunc       mqtt.ConnectionLostHandler // 断开连接回调函数
	DefaultPublishFunc mqtt.MessageHandler        // 默认订阅回调函数
	ClientId           string                     // 客户端id（客户端唯一标识）
	AutoAckDisabled    bool                       // 禁用自动ack
	AutoReconnect      bool
	ConnectTimeout     time.Duration
}