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});