js連接mqtt

項(xiàng)目中要用到mqtt，前端調(diào)用，使用github開(kāi)源的paho-mqtt.js，api還是挺全面的，網(wǎng)上各種教程很全面，但是感覺(jué)代碼過(guò)于雜亂，故而封裝的一下。仿jquery ajax調(diào)用方法。

首先本項(xiàng)目依賴(lài) paho-mqtt.js

1.引用paho-mqtt.js

<script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.js" type="text/javascript"></script>

2.引用封裝的 MqttX.js(源代碼點(diǎn)擊查看)

3.開(kāi)始調(diào)用初始化方法

mqttX.init({
    id:'10',
    ip:'ip地址',
    port:61623,
    success:function(){
        console.log("mqttx連接成功");
        mqttX.subscribe('vp1');
    },
    error:function(){
        console.log("mqttx連接失敗");
    },
    connectLost:function(){
        console.log("mqttx連接丟失");
    },
    onMessage:function(message){
        console.log("mqttx",message);
    }
});

參數(shù)列表

4.其他方法

1.訂閱主題

//訂閱主題
mqttX.subscribe(topic,[qos]);

參數(shù)列表

返回類(lèi)型：boolean

2.取消訂閱

//取消訂閱主題
mqttX.unsubscribe(topic);

參數(shù)列表

返回類(lèi)型：boolean

3.重新連接

//重新連接
mqttX.reconnect();

參數(shù)列表

• 無(wú)參數(shù)

返回類(lèi)型：boolean

4.發(fā)送消息

//發(fā)送消息
mqttX.sendMessage(topic,obj);

參數(shù)列表

返回類(lèi)型：boolean