MQTT moquette 的Server发布主题

Java代码  

package com.etrip.mqtt.future;  

import java.net.URISyntaxException;  

import org.fusesource.mqtt.client.FutureConnection;  

import org.fusesource.mqtt.client.MQTT;  

import org.fusesource.mqtt.client.QoS;  

import org.fusesource.mqtt.client.Topic;  

import org.slf4j.Logger;  

import org.slf4j.LoggerFactory;  

/** 

 *  

 *  

 *  

 * 采用Future式 发布主题  

 *  

 * @author longgangbai 

 */  

public class MQTTFutureServer {  

        private static final Logger LOG = LoggerFactory.getLogger(MQTTFutureServer.class);  

        private final static String CONNECTION_STRING = "tcp://192.168.208.46:1883";  

        private final static boolean CLEAN_START = true;  

        private final static short KEEP_ALIVE = 30;// 低耗网络，但是又需要及时获取数据，，心跳30s  

        public  static Topic[] topics = {  

                        new Topic("china/beijing", QoS.EXACTLY_ONCE),  

                        new Topic("china/tianjin", QoS.AT_LEAST_ONCE),  

                        new Topic("china/henan", QoS.AT_MOST_ONCE)};  

        public final  static long RECONNECTION_ATTEMPT_MAX=6;  

        public final  static long RECONNECTION_DELAY=2000;  

        public final static int SEND_BUFFER_SIZE=2*1024*1024;//发送最大缓冲为2M  

        public static void main(String[] args)   {  

            MQTT mqtt = new MQTT();  

            try {  

                //设置服务端的ip  

                mqtt.setHost(CONNECTION_STRING);  

                //连接前清空会话信息  

                mqtt.setCleanSession(CLEAN_START);  

                //设置重新连接的次数  

                mqtt.setReconnectAttemptsMax(RECONNECTION_ATTEMPT_MAX);  

                //设置重连的间隔时间  

                mqtt.setReconnectDelay(RECONNECTION_DELAY);  

                //设置心跳时间  

                mqtt.setKeepAlive(KEEP_ALIVE);  

                //设置缓冲的大小  

                mqtt.setSendBufferSize(SEND_BUFFER_SIZE);  

                //创建连接