package com.ruoyi.device.mqtt;

import org.eclipse.paho.client.mqttv3.MqttException;
import org.springframework.stereotype.Component;

@Component
public class MQSubscribe {

	/**
	 * 订阅某个主题：MQTT服务器向WEB服务器发送数据
	 *主题：也称为底层网关唯一标识
	 * @param topic 设备编号，与底层交互的唯一标识
	 * @param qos MQTT服务器向WEB服务器发送数据
	 *            qos为0：只向WEB服务器发送一次；
	 *            qos为1：至少向WEB服务器发送一次，接收方会响应一个报文；
	 *            qos为2：两者会进行至少两次请求/响应流程，避免数据在传输中的丢失
	 */
	private static void subscribe(String topic, int qos) {
		try {
			MQClient.getClient().subscribe(topic,qos);
		} catch (MqttException e) {
			e.printStackTrace();
		}
	}

	/**
	 * 订阅某个主题，通信质量：qos默认为0
	 * 主题：也称为底层网关唯一标识
	 * @param topic 设备编号，与底层交互的唯一标识
	 */
	public static void subscribe_0(String topic) {
		subscribe(topic, 0);
	}

	/**
	 * 订阅某个主题，通信质量：qos默认为1
	 * 主题：也称为底层网关唯一标识
	 * @param topic 设备编号，与底层交互的唯一标识
	 */
	public void subscribe_1(String topic) {
		subscribe(topic, 1);
	}

	/**
	 * 订阅某个主题，通信质量：qos默认为2
	 * 主题：也称为底层网关唯一标识
	 * @param topic 设备编号，与底层交互的唯一标识
	 */
	public void subscribe_2(String topic) {
		subscribe(topic, 2);
	}

	public void OffSubscribe(String topic) {
		try {
			MQClient.getClient().unsubscribe(topic);
		} catch (MqttException e) {
			e.printStackTrace();
		}
	}
}