[9] MQTT,mosquitto,Eclipse Paho---MQTT消息格式之SUBACK(消息订阅应答)消息分析

浏览数：35 / 时间：2015年06月20日

0.前言

在上一节中（MQTT消息格式之SUBSCRIBE(消息订阅)消息分析），客户端发送了订阅的消息，这个时候，服务器端收到订阅主题的MQTT消息之后，肯定需要给一个应答，这个应答信息就是SUBACK(消息订阅应答)。消息订阅应答相对来说比较简单。

1.准备步骤

(1) 首先打开WireShark软件，并启动监听

(2) 在Eclipse里面运行下面的代码

[java]view
 plaincopy

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.persist.MemoryPersistence;  

import com.tibco.mqtt.test.CustomMQTTCallBack;  

public class SubScriberExample {  

    /** 

     * @param args 

     */  

    public static void main(String[] args) {  

         String topicFilter ="test";  

         String broker = "tcp://192.168.80.196:1883" ;  

         String clientId = "paho-1" ;  

         MemoryPersistence persistence = new MemoryPersistence();  

          try {  

                 MqttClient sampleClient = new MqttClient(broker, clientId,persistence);  

                 MqttConnectOptions connOpts = new MqttConnectOptions();  

                 connOpts.setCleanSession( false );  

                 System. out .println( "Connecting to broker: " + broker);  

                 sampleClient.connect(connOpts);  

                 System. out .println( "Connected" );  

                 sampleClient.setCallback(new CustomMQTTCallBack());  

                 sampleClient.subscribe(topicFilter,0);  

                 System. out .println( "Subscribe success for: "+topicFilters.toString());  

         } catch (MqttException me) {  

                 System. out .println( "reason " + me.getReasonCode());  

                 System. out .println( "msg " + me.getMessage());  

                 System. out .println( "loc " + me.getLocalizedMessage());  

                 System. out .println( "cause " + me.getCause());  

                 System. out .println( "excep " + me);  

                 me.printStackTrace();  

         }  

    }  

}