MQTT消息队列mosquitto的java方式实现客户端订阅

本文档实现MQTT客户端订阅与服务器段消息接收，已成功通过测试，包含一个订阅客户端和服务器端消息发送，mqtt之mosquitto服务器搭建详解

package example;

import java.util.concurrent.ScheduledExecutorService;  
import org.eclipse.paho.client.mqttv3.MqttClient;  
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;  
import org.eclipse.paho.client.mqttv3.MqttException;  
import org.eclipse.paho.client.mqttv3.MqttTopic;  
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;  
  
public class ClientMQTT {  
  
    public static final String HOST = “tcp://localhost:1883“;  
    public static final String TOPIC = “topic11“;  
    private static final String clientid = “client11“;  
    private MqttClient client;  
    private MqttConnectOptions options;  
    private String userName = “admin“;  
    private String passWord = “password“;  
  
    private ScheduledExecutorService scheduler;  
  
    private void start（） {  
        try {  
            // host为主机名，clientid即连接MQTT的客户端ID，一般以唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存  
            client = new MqttClient（HOST clientid new MemoryPersistence（））;  
            // MQTT的连接设置  
            options = new MqttConnectOptions（）;  
            // 设置是否清空session这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接  
            options.setCleanSession（true）;  
            // 设置连接的用户名  
            options.setUserName（userName）;  
            // 设置连接的密码  
            options.setPassword（passWord.toCharArray（））;  
            // 设置超时时间 单位为秒  
            options.setConnectionTimeout（10）;  
            // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制  
            options.setKeepAliveInterval（20）;  
            // 设置回调  
            client.setCallback（new PushCallback（））;  
            MqttTopic topic = client.getTopic（TOPIC）;  
            //setWill方法，如果项目中需要知道客户端是否掉线可以调用该方法。设置最终端口的通知消息  
            options.setWill（topic “close“.getBytes（） 2 true）;  
  
            client.connect（options）;  
            //订阅消息  
            int[] Qos  = {1};  
            String[] topic1 = {TOPIC};  
            client.subscribe（topic1 Qos）;  
  
        } catch （Exception e） {  
            e.printStackTrace（）;  
        }  
    }  
  
    public static void main（String[] args） throws MqttException {  
        ClientMQTT client = new ClientMQTT（）;  
        client.start（）;  
    }  
}  

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       2772  2017-05-22 16:31  MQTT相关文档\ClientMQTT.java

     文件    1014498  2017-05-21 21:22  MQTT相关文档\LoRaWAN Network Server V1.0安装手册.pdf

     文件     126960  2017-05-16 08:58  MQTT相关文档\mqtt-client-1.14.jar

     文件         57  2017-05-23 08:45  MQTT相关文档\mqtt服务器配置.txt

     文件       1807  2017-05-22 16:33  MQTT相关文档\PushCallback.java

     文件       3368  2017-05-22 21:42  MQTT相关文档\ServerMQTT.java

     目录          0  2017-05-23 08:43  MQTT相关文档

----------- ---------  ---------- -----  ----

              1149462                    7