1var mqtt = require('mqtt');
2
3function ArrayToString(fileData) {
4    var dataString = "";
5    for (var i = 0; i < fileData.length; i++) {
6        dataString += String.fromCharCode(fileData[i]);
7    }
8
9    return dataString;
10}
11
12function onConnect() {
13    // subscribe
14    mqttClient.subscribe({
15        topic: '/hello',
16        success: function() {
17            console.log('subscribe [/hello] success');
18        }
19    });
20
21    // publish
22    setInterval(function () {
23        mqttClient.publish({
24        topic: '/hello',
25        message: 'this is AMP mqtt test',
26        success: function() {
27            console.log('publish [/hello] success');
28        }
29        });
30    }, 2 * 1000);
31}
32
33// create mqtt client
34var mqttClient = mqtt.createClient({
35  host: 'mqtt.eclipse.org',
36  port: 1883,
37  username: 'aiot',
38  password: '123',
39  success: function() {
40    console.log('mqtt connected');
41  },
42  fail: function() {
43    console.log('mqtt connect failed');
44  }
45});
46
47mqttClient.on('connect', function() {
48    console.log('mqtt connected');
49    onConnect();
50});
51
52mqttClient.on('message', function(topic, payload) {
53  console.log('[' + topic + ']  message: ' + ArrayToString(payload));
54});