package fr.zng.xxzx.mqtt2;

import javax.swing.JTextArea;

import fr.zng.xxzx.common.cacheData.ZngCacheData;
import fr.zng.xxzx.common.entity.MqttConfigEntity;
import fr.zng.xxzx.common.util.CommUtil;

public class CheckMqttServer2 extends Thread{

	private JTextArea jta;
	private MqttConfigEntity en;
	public CheckMqttServer2(JTextArea jta,MqttConfigEntity en) {
		this.jta = jta;
		this.en = en;
	}
	
	@Override
	public void run() {
		int cnt =0;
		
		while (true) {
			try {
				if (ZngCacheData.isConnect == 1) {
					System.out.println("MQTT连接正常");
				} else {
					System.out.println("MQTT连接-------:" + cnt);
					cnt++;
					new Server2(jta,en);
				}
			} catch (Exception e) {
				System.out.println("MQTT连接异常：" + e.getMessage());
				CommUtil.doPrint(jta, "MQTT:", "MQTT连接异常：" + e.getMessage());
				ZngCacheData.isConnect = 0;
			} finally {
				try {
					Thread.sleep(10000);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		}
	}
}