Node.js SDK Access Example

Development Environment

Node.js 8.0.0 or later is used. Download it from the Node.js official website. After installation, run the following command to check the version:

node --version

Sample Code

1. Create a JavaScript file (for example, HwIotAmqpClient.js) on the local computer and save the following sample code to the file. Modify related connection parameters by referring to AMQP Client Access.

   const container = require('rhea');
   // Obtain the timestamp.
   var timestamp = Math.round(new Date());
   
   // Set up a connection.
   var connection = container.connect({
        // Access domain name. For details, see AMQP Client Access.
        'host': '${UUCID}.iot-amqps.cn-north-4.myhuaweicloud.com',
        'port': 5671,
        'transport': 'tls',
        'reconnect': true,
        'idle_time_out': 8000,
        // Method to assemble username. For details, see AMQP Client Access.
         'username': 'accessKey=${yourAccessKey}|timestamp=' + timestamp + '|instanceId=${instanceId}',
        // accessCode. For details, see AMQP Client Access.
        'password': '${yourAccessCode}',
        'saslMechannisms': 'PLAIN',
        'rejectUnauthorized': false,
        'hostname': 'default',
   });
   
   // Create a Receiver connection. You can use DefaultQueue.
   var receiver = connection.open_receiver('${yourQueue}');
   
   // Callback function for receiving messages pushed from the cloud
   container.on('message', function (context) {
        var msg = context.message;
        var content = msg.body;
        console.log(content);
        // Send an ACK message. Note that the callback function should not contain time-consuming logic.
        context.delivery.accept();
    });

2. Go to the directory where the HwIotAmqpClient.js file is located and run the following command to install the rhea library:

   npm install rhea

   After installation, the project files shown in the following figure are displayed.

   

3. Run the following command to start the AMQP client:

   node HwIotAmqpClient.js

4. Running result examples

• Successful subscription:

  If the following log information is displayed, the AMQP client successfully subscribes to the IoT platform and obtains data from the platform.

  

• Failed subscription:

  The following log indicates that the AMQP client authentication fails on the IoT platform. Check whether the access code is correct and whether the difference between the timestamp and the standard time is greater than 5 minutes.