Skip to content

Latest commit

 

History

History
113 lines (71 loc) · 2.99 KB

README.md

File metadata and controls

113 lines (71 loc) · 2.99 KB
Raw

Ejemplo de conección a servidor mqtt en node.js

Correr ejemplo

  • Clonar repo:

  • Correr programa:

    • npm i o yarn
    • npm run dev o yarn dev

  • Empezar el partido:

    • mosquitto_pub -t hardware/tennis_court -m 'start'

  • Debieras ver algo como esto:

mqtt-ping-pong.png

Paquetes requeridos en linux para correr mqtt localmente

sudo apt-add-repository ppa:mosquitto-dev/mosquitto-ppa  
sudo apt-get update  
sudo apt-get install mosquitto  
sudo apt-get install mosquitto-clients  
sudo apt clean

Explicación

La parte más importante en la conección inicial a un servidor externo (mqtt, redis, amqp, una database) es poder esperar a que la conección se realize y sólo entonces seguir con la ejecución del resto del programa.

Para esto usamos import, export de ES6 y await

En este archivo export permite exponer la variable mqttClient, la cual en un principio tiene un valor de undefined.

Pero una vez que se llame a la función mqttClientConnect esta será sobreescrita con el objeto representando la conneción al servidor, este seré nuestro cliente.

// src/infrastructure/lib/mqttClient.js

export let mqttClient

export function mqttClientConnect() {
  mqttClient = mqtt.connect(env.mqtt.server, {
    username: env.mqtt.username,
    password: env.mqtt.password,
    port: env.mqtt.port,
  })

  // ...
}

Luego, para poder usar este cliente en cualquier otro archivo usamos import. La gracia de esto, es que aún habiendo sido inicializada como undefined, una vez que la conección se realice, esta variable se actualizará automáticamente.

Esto se debe a que import/export trabajan mediante referencias y no estáticamente como en CommonJS (muy bien explicado en What do ES6 modules export?)

// src/application/singletons/MqttService.js

import { mqttClient } from "@/infrastructure/lib/mqttClient";

Finalmente, en index.js usamos await para esperar a que la conneción se realice antes de seguir adelante a ejecutar hardwareListener.init() que es donde ya se necesita.

El uso de una esctructura IIFE es necesaria para poder uzar await ya que estas siempre deben ir dentro de funciones async

// index.js

import { env } from "@/infrastructure/lib/env"
import { mqttClientConnect } from "@/infrastructure/lib/mqttClient"
import HardwareListener from "@/interfaces/listeners/HardwareListener"

// IIFE para poder usar await
;(async () => {
  await mqttClientConnect()

  new HardwareListener().init()
})()

Tambien podria haberse escrito:

async function init() {
  await mqttClientConnect()

  new HardwareListener().init()
}

init()

Links: