Connect MQTT with Node.js

How to connect MQTT connection with Node.js

Connection Code



var mqtt = require('mqtt');

var options = {
    port: 1883,
    host: 'mqtt://m.dominname.com',
    clientId: 'mqttjs_' + Math.random().toString(16).substr(2, 8),
    username: 'username',
    password: 'password',
    keepalive: 60,
    reconnectPeriod: 1000,
    protocolId: 'MQIsdp',
    protocolVersion: 3,
    clean: true,
    encoding: 'utf8'
};
var client = mqtt.connect('mqtt://m.dominname.com',options);

var mqtt = require('mqtt');

var options = {

port: 1883,

host: 'mqtt://m.dominname.com',

clientId: 'mqttjs_' + Math.random().toString(16).substr(2, 8),

username: 'username',

password: 'password',

keepalive: 60,

reconnectPeriod: 1000,

protocolId: 'MQIsdp',

protocolVersion: 3,

clean: true,

encoding: 'utf8'

};

var client = mqtt.connect('mqtt://m.dominname.com',options);

Subscribe and Publish Data



client.on('connect', function() {

    console.log('Connected MQTT');
    client.subscribe("TOPICNAME");


});

client.on('message', function(topic, message) {
    console.log(topic);
    console.log(message);
  
});

client.publish("TOPICNAME", "COMMAND");

client.on('connect', function() {

console.log('Connected MQTT');

client.subscribe("TOPICNAME");

});

client.on('message', function(topic, message) {

console.log(topic);

console.log(message);

});

client.publish("TOPICNAME", "COMMAND");

WeAnswer

See author's posts

Tags: Connect Mqtt

Connection Code

Subscribe and Publish Data

WeAnswer

Configuring Apache for Node.js

Video streaming using Node.js and HTML5

Stream audio from the microphone

How to set EC2 Ubuntu default password

CPU & Memory usage in PHP

Install PHP mcrypt extension on Ubuntu

How to reset or change the MySQL root password?

Connection Code

Subscribe and Publish Data

Leave a Reply Cancel reply

More Stories

You may have missed