Java連接MQTT服務-ws方式

特別提示：本人博客部分有參考網絡其他博客，但均是本人親手編寫過並驗證通過。如發現博客有錯誤，請及時提出以免誤導其他人，謝謝！歡迎轉載，但記得標明文章出處： http://www.cnblogs.com/mao2080/

1、Java代碼

package com.mao.mqtt;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
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.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttTopic;

/**
 * 
 * 功能描述：MQTT測試
 * 創建人： [e-mail]
 * 創建時間：2017年7月4日 下午5:08:59
 * 修改人： [e-mail]
 * 修改時間：2017年7月4日 下午5:08:59
 */
public class MQTTTest_tcp {

    /**MQTT服務端ip及端口*/
    private static String host = "ws://ip:8882";

    /**賬號*/
    private static String username = "li2080";

    /**密碼*/
    private static String password = "123";

    /**訂閱的主題*/
    private static String subTopic = "a/b/c";
    
    /**clientID*/
    private static String clientId = "li2080";
    
    /**發布的主題*/
    private static String pubTopic = "a/b/c";

    /**MQTT-Client*/
    private static MqttClient client;
    
    /**MQTT-Client*/
    private static int uuid = 0;

    /**
     * @throws InterruptedException 
     * @throws MqttException */
    public static void main(String[] args) throws InterruptedException, MqttException {
        
        // 訂閱消息的方法
        subscribe();
//        
        publish();
    }

    /**
     * 
     * 描述：訂閱信息
     * @author [e-mail]
     * @created 2017年7月4日 下午4:53:47
     * @since 
     * @return
     */
    public static void subscribe() {
        try {
            // 創建MqttClient
            MQTTTest_tcp.getClient().setCallback(new MqttCallback() {

                public void connectionLost(Throwable arg0) {
                    
                }

                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("MQTT Rece:" + message.toString());
                }

                public void deliveryComplete(IMqttDeliveryToken token) {

                }

            });
            MQTTTest_tcp.getClient().subscribe(subTopic, 0);
            System.out.println("連接狀態:" + client.isConnected());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    /**
     * 
     * 描述：獲取MqttClient
     * @author [e-mail]
     * @created 2017年7月6日 上午9:56:37
     * @since 
     * @return
     * @throws MqttException
     */
    public static MqttClient getClient() throws MqttException{
        try {
            if(client == null){
                client = new MqttClient(host, clientId);
                MqttConnectOptions conOptions = new MqttConnectOptions();
                conOptions.setUserName(username);
                conOptions.setPassword(password.toCharArray());
                conOptions.setCleanSession(true);
                client.connect(conOptions);
            }
            if(!client.isConnected()){
                client.reconnect();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return client;
    }

    /**
     * 
     * 描述：發布信息
     * @author [e-mail]
     * @throws MqttException 
     * @created 2017年7月4日 下午4:53:32
     * @since
     */
    public static void publish() throws MqttException {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        String sendMsg = "{time:"+sdf.format(new Date())+", content:"+com.lds.iot.common.util.UUIDUtil.getLowerLetterNumber(15)+", from: java console}";
        try {
            MqttTopic topic = MQTTTest_tcp.getClient().getTopic(pubTopic);
            MqttMessage message = new MqttMessage(sendMsg.getBytes());
            message.setQos(0);
            topic.publish(message);
            System.out.println("MQTT Send:" + sendMsg);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    
    
}

 

2、Maven配置

<dependency>
      <groupId>org.eclipse.paho</groupId>
      <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
      <version>1.2.0</version>
</dependency>

3、運行效果