package fr.zng.xxzx.mqtt2;
import javax.swing.JTextArea;

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttPersistenceException;
import org.eclipse.paho.client.mqttv3.MqttTopic;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import fr.zng.xxzx.common.cacheData.ZngCacheData;
import fr.zng.xxzx.common.entity.MqttConfigEntity;
import fr.zng.xxzx.common.util.CommUtil;
import fr.zng.xxzx.common.util.StringUtil;
import fr.zng.xxzx.main.XmtApplication;
/**
 * 
 * Title:Server
 * Description: 服务器向多个客户端推送主题，即不同客户端可向服务器订阅相同主题
 * @author chenrl
 * 2016年1月6日下午3:29:28
 */
public class Server2 {

    public static String HOST = "";
    public static String SUBSCRIBETOPIC = "";
//    public static String SUBSCRIBETOPIC2 = "ChinaXMT/DangeraRubo/UpPayEndMsg";
//    public static String SUBSCRIBETOPIC3 = "ChinaXMT/DangeraRubo/OpenUpMsg";
    public static String SUBSCRIBETOPIC2 = "";
    public static String SUBSCRIBETOPIC3 = "";
    public static String TOPIC = "";
    public static String TOPIC2 = "";
    public static String clientid = "";
    public static MqttTopic topic;
    public static MqttTopic topic2;
    public static int connectTimeOut = 10;
    public static int keepAlive = 20;
    private static MqttClient client;
    public static String userName = "";
    public static String passWord = "";

    public MqttMessage message;
    private JTextArea jta;
    private MqttConfigEntity en;
    
    public Server2(JTextArea jta,MqttConfigEntity en) throws MqttException {
        // MemoryPersistence设置clientid的保存形式，默认为以内存保存
    	clientid = "server"+System.currentTimeMillis();
    	this.en = en;
    	client = new MqttClient(HOST, clientid, new MemoryPersistence());
    	this.jta = jta;
    	connect();
    }

    public static void topic() {
    	topic = client.getTopic(TOPIC);
    }
    public static void topic2() {
        topic2 = client.getTopic(TOPIC2);
    }
    
    private void connect() {
        MqttConnectOptions options = new MqttConnectOptions();
        options.setCleanSession(false);
        options.setUserName(userName);
        options.setPassword(passWord.toCharArray());
        // 设置超时时间
        options.setConnectionTimeout(connectTimeOut);
        // 设置会话心跳时间
        options.setKeepAliveInterval(keepAlive);
        try {
        	if(en.getType() == 0) {
        		client.setCallback(new PushCallbackBc(Server2.this,jta));
                client.connect(options);
        	} else {
        		client.setCallback(new PushCallback2(Server2.this,jta));
                client.connect(options);
        	}
            
            
            CommUtil.doPrint(jta, "MQTT:", "连接成功");
            ZngCacheData.isConnect = 1;
            XmtApplication.changeConnectState(1);
            //订阅消息  
            int[] Qos  = {1};  
            
            if(StringUtil.isNotEmpty(SUBSCRIBETOPIC)) {
            	String[] topic1 = {SUBSCRIBETOPIC};  
                client.subscribe(topic1, Qos);
                CommUtil.doPrint(jta, "MQTT:", "开始订阅主题"+SUBSCRIBETOPIC);
            }
            
            if(StringUtil.isNotEmpty(SUBSCRIBETOPIC2)) {
            	String[] topic2 = {SUBSCRIBETOPIC2};  
                client.subscribe(topic2, Qos);
                CommUtil.doPrint(jta, "MQTT:", "开始订阅主题"+SUBSCRIBETOPIC2);
            }
            
            if(StringUtil.isNotEmpty(SUBSCRIBETOPIC3)) {
            	String[] topic3 = {SUBSCRIBETOPIC3};  
                client.subscribe(topic3, Qos);
                CommUtil.doPrint(jta, "MQTT:", "开始订阅主题"+SUBSCRIBETOPIC3);
            }
           
        } catch (Exception e) {
            e.printStackTrace();
            client = null;
        	CommUtil.doPrint(jta, "MQTT:", "连接失败："+e.getMessage());
        }
    }

    public void publish(MqttTopic topic , MqttMessage message) throws MqttPersistenceException,
            MqttException {
        MqttDeliveryToken token = topic.publish(message);
        token.waitForCompletion();
        System.out.println("message is published completely! "
                + token.isComplete());
    }

    public static void close() {
//    	if(client!=null) {
//    		try {
//				client.disconnect();
//				client.close();
//			} catch (MqttException e) {
//				e.printStackTrace();
//			}
//    	}
    	
//    	if(singleton!=null) {
//    		singleton = null;
//    	}
    }
    
    public static void main(String[] args) throws MqttException {
//        Server server = new Server();
//        
//        for(int i=0;i<100;i++){
//        	  server.message = new MqttMessage();
//              server.message.setQos(2);
//              server.message.setRetained(true);
//              server.message.setPayload(("给客户端124推送的信息"+i).getBytes());
//              server.publish(server.topic , server.message);
//        }
//
//        server.message = new MqttMessage();
//        server.message.setQos(2);
//        server.message.setRetained(true);
//        server.message.setPayload("给客户端125推送的信息".getBytes());
//        server.publish(server.topic125 , server.message);
//
//        System.out.println(server.message.isRetained() + "------ratained状态");
    }
}