mqtt

示例代码

var mqtt = require('mqtt');

function ArrayToString(fileData) {
    var dataString = "";
    for (var i = 0; i < fileData.length; i++) {
        dataString += String.fromCharCode(fileData[i]);
    }

    return dataString;
}

function onConnect() {
    // subscribe
    mqttClient.subscribe({
        topic: '/hello',
        success: function() {
            console.log('subscribe [/hello] success');
        }
    });
    
    // publish
    setInterval(function () {
        mqttClient.publish({
        topic: '/hello',
        message: 'this is AMP mqtt test',
        success: function() {
            console.log('publish [/hello] success');
        }
        });
    }, 2 * 1000);
}

// create mqtt client
var mqttClient = mqtt.createClient({
  host: 'mqtt.eclipse.org',
  port: 1883,
  username: 'aiot',
  password: '123',
  success: function() {
    console.log('mqtt connected');
  },
  fail: function() {
    console.log('mqtt connect failed');
  }
});

mqttClient.on('connect', function() {
    console.log('mqtt connected');
    onConnect();
});

mqttClient.on('message', function(topic, payload) {
  console.log('[' + topic + ']  message: ' + ArrayToString(payload));
});

createClient(Object options)

创建一个 MQTTClient 实例（客户端），创建时会连接 MQTT 服务端。暂不支持TLS。

入参

Object类型，其属性有：

返回值

• MQTTClient

一个MQTTClient 实例。

MQTTClient 实例

事件

• Event:'close'

当mqtt关闭时，触发close事件。

• Event:'connect'

当mqtt连接成功后，触发connect事件。

• Event:'disconnect'

当mqtt连接断开时，触发'disconnect'事件。

• Event:'message'

当接收到publish数据时，message事件触发。

• Event:'error'

当发生错误时，error事件触发。

属性

• MQTTClient.connected

当前是否连接成功。

方法

• MQTTClient.subscribe(Object option)

订阅topic。

• MQTTClient.unsubscribe(Object option)

取消订阅topic。

• MQTTClient.publish(Object option)

发布消息到指定topic。

• MQTTClient.close()

关闭MQTT Client实例。

• MQTTClient.on(String event, Function callback)

注册MQTT 事件回调函数。

事件：'close'

当mqtt关闭时，触发'close'事件。

事件：'connect'

当mqtt连接成功后，触发'connect'事件。

事件：'disconnect'

当mqtt连接断开时，触发'disconnect'事件。服务端断开连接、主动断开连接、网络发生异常等都会触发该事件。

事件：'message'

当接收到publish数据时，'message'事件触发。回调函数的参数有：

事件：'error'

当发生错误时，'error'事件触发。回调函数的参数有：

MQTTClient.connected

Boolean类型，true代表连接成功，false代表连接断开。false时，底层会一直尝试重连。

MQTTClient.subscribe(Object option)

订阅topic。

入参

Object类型，具体属性为：

MQTTClient.unsubscribe(Object option)

取消订阅的topic。

入参

Object类型，具体属性为：

MQTTClient.publish(Object option)

向指定topic发布消息。

入参

Object类型，具体属性为：

MQTTClient.close()

关闭MQTTClient实例。

MQTTClient.on(String event, Function callback)

监听事件。

入参

事件类型