const mqttClient = new MqttClient('mqtt://broker.emqx.io');
// 連接并訂閱
mqttClient.connect().then(() => {
    mqttClient.subscribe('home/sensor', (topic, message) => {
        console.log(`[${topic}] ${message}`);
    });
    // 發(fā)布消息
    mqttClient.publish('home/light', 'ON');
});
// 頁(yè)面卸載時(shí)斷開連接
window.addEventListener('beforeunload', () => mqttClient.disconnect());

/**
 * 
 * 調(diào)用方式如下
 * const mqttClient = new MqttClient('mqtt://your-broker-url');
 * mqttClient.connect();
 * mqttClient.subscribe('your/topic', (topic, message) => {
 * console.log(`${topic}: ${message}`);
 * });
 * 
 * 在頁(yè)面銷毀時(shí)斷開連接，釋放資源（防止罵娘）
 * mqttClient.disconnect();
 * */
   import mqtt from 'mqtt';
// 定義MqttClient類
class MqttClient {
	// 構(gòu)造函數(shù)，接收broker的URL和客戶端ID（可選）
	constructor(brokerUrl, clientId = `client-${Math.random().toString(16).substr(2, 8)}`, username = '', password = '') {
		this.brokerUrl = brokerUrl; // 存儲(chǔ)broker的URL
		this.clientId = clientId; // 存儲(chǔ)客戶端ID，如果沒有提供則生成一個(gè)隨機(jī)的
		this.client = null; // 初始化mqtt客戶端為null
		this.reconnectCount = 0; // 添加重連計(jì)數(shù)器
		this.maxReconnectAttempts = 5; // 設(shè)置最大重連次數(shù)
		this.username = username;
		this.password = password;
	}
	/**
	 * 連接到MQTT broker的方法，返回Promise
	 */
	connect() {
		return new Promise((resolve, reject) => {
			const options = {
				clientId: this.clientId,
				clean: true,
				connectTimeout: 4000,
				reconnectPeriod: 1000,
				username: this.username, // 添加用戶名配置
				password: this.password // 添加密碼配置
			};
			this.client = mqtt.connect(this.brokerUrl, options);
			this.client.on('connect', () => {
				console.log('M_connected');
				this.reconnectCount = 0; // 連接成功后重置計(jì)數(shù)器
				resolve(true);
			});
			this.client.on('error', (error) => {
				console.error('M_error:', error);
				reject(error);
			});
			this.client.on('close', () => {
				console.log('M_connection closed');
				reject(new Error('Connection closed'));
			});
			this.client.on('offline', () => {
				console.log('M_client offline');
				reject(new Error('Client offline'));
			});
			this.client.on('reconnect', () => {
				this.reconnectCount++;
				console.log(`M_reconnecting... (Attempt ${this.reconnectCount}/${this.maxReconnectAttempts})`);
				if (this.reconnectCount >= this.maxReconnectAttempts) {
					this.client.end(); // 達(dá)到最大重連次數(shù)后斷開連接
					reject(new Error('Max reconnection attempts reached'));
				}
			});
		});
	}
	/**
	 * 訂閱主題的方法，接收主題和回調(diào)函數(shù)作為參數(shù)
	 * @param {string} topic 
	 * @param {fun} callback 
	 */
	subscribe(topic, callback) {
		this.client.subscribe(topic, { qos: 1 }, (error) => { // 使用qos 1保證消息至少被傳遞一次，2 網(wǎng)絡(luò)開銷較大，不推薦用 0
			if (error) {
				console.error('Subscribe error:', error);
			} else {
				// 監(jiān)聽消息事件，當(dāng)收到消息時(shí)調(diào)用回調(diào)函數(shù)，receivedTopic與訂閱主題匹配的主題
				this.client.on('message', (receivedTopic, message) => {
					callback(receivedTopic, message.toString()); // 調(diào)用回調(diào)函數(shù)處理消息
				});
			}
		});
	}
	/**
	 * 發(fā)布消息到指定主題的方法，接收主題、消息和qos（可選）作為參數(shù)
	 * @param {string} topic 
	 * @param {string|Buffer} message 
	 * @param {number} qos 
	 */
	publish(topic, message, qos = 1) {
		this.client.publish(topic, message, { qos }, (error) => { // 使用指定的qos發(fā)布消息
			if (error) {
				console.error('Publish error:', error);
			} else {
				console.log(`Published message to topic: ${topic}`);
			}
		});
	}
	/**
	 * 斷開與MQTT broker連接的方法
	 */
	disconnect() {
		// this.client.end();
		if (this.client?.connected) {
			this.client.end(); // 斷開連接
		}
	}
}
export default MqttClient;