Question

172

Connecting nodejs and cloud mqtt

rated 0 times [ 178] [ 6] / answers: 1 / hits: 15686 / 8 Years ago, wed, april 6, 2016, 12:00:00

I am doing a project based on IOT. So I need to connect cloudmqtt and nodejs server.

app.js

// Create a MQTT Client

var mqtt = require('mqtt');



// Create a client connection to CloudMQTT for live data

var client = mqtt.connect('xxxxxxxxxxx', {

  username: 'xxxxx',

  password: 'xxxxxxx' 

});



client.on('connect', function() { // When connected

    console.log(Connected to CloudMQTT);

  // Subscribe to the temperature

  client.subscribe('Motion', function() {

    // When a message arrives, do something with it

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

      // ** Need to pass message out **

    });

  });



});

Then started my server. But nothing is happening(No error message and no warning).Please help me on this?

Answers

Only authorized users can answer the question. Please sign in first, or register a free account.

janettejordynm

Add To Favorites

Follow

Total Points: 550

Total Questions: 94

Total Answers: 98

Location: Senegal

Member since Fri, Aug 21, 2020

4 Years ago

janettejordynm questions

1 Chunk file upload with axios

Tue, Nov 24, 20, 00:00, 4 Years ago

1 Node unable to find module alias defined in tsconfig and package.json

Thu, Jun 18, 20, 00:00, 4 Years ago

1 How to check if an entered answer is correct with HTML code?

Sat, May 23, 20, 00:00, 4 Years ago

1 Can someone explain this piece of Javascript code?

Mon, Apr 6, 20, 00:00, 4 Years ago

1 AES Encryption/Decryption in Node JS similar to Java

Tue, Feb 18, 20, 00:00, 4 Years ago

View All

answered 8 Years ago francokeganr · Accepted Answer

Now the cloudmqtt and nodejs server is connected by giving extra parameters like clientId,keepalive,protocolVersion etc.

app.js

var mqtt = require('mqtt');

var options = {

    port: 15255,

    host: 'mqtt://m11.cloudmqtt.com',

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

    username: 'xxxxxxxxxxxxxxxxxx',

    password: 'xxxxxxxxxxxxxxxxxx',

    keepalive: 60,

    reconnectPeriod: 1000,

    protocolId: 'MQIsdp',

    protocolVersion: 3,

    clean: true,

    encoding: 'utf8'

};

var client = mqtt.connect('mqtt://m11.cloudmqtt.com', options);

client.on('connect', function() { // When connected

    console.log('connected');

    // subscribe to a topic

    client.subscribe('topic1/#', function() {

        // when a message arrives, do something with it

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

            console.log(Received ' + message + ' on ' + topic + ');

        });

    });



    // publish a message to a topic

    client.publish('topic1/#', 'my message', function() {

        console.log(Message is published);

        client.end(); // Close the connection when published

    });

});