Exemplos de código

Exemplo MQTT em Node-RED

Conecte o Node-RED a um broker MQTT com um fluxo pronto para importar. Comece no broker público gratuito e depois aponte o mesmo código para um broker privado e seguro no ConnectMQ.

Código-fonte no GitHubmqtt-code-samples/node-redClone os exemplos completos e prontos para rodar. Estrelas e pull requests são bem-vindos. Ver no GitHub

1. Teste no broker público gratuito

Sem precisar de conta: conecte-se a broker.connectmq.com na porta 1883 e comece a publicar em segundos.

flow.json
[
  { "id": "cmq_broker", "type": "mqtt-broker", "name": "Broker ConnectMQ",
    "broker": "broker.connectmq.com", "port": "1883", "usetls": false,
    "protocolVersion": "4", "keepalive": "60", "cleansession": true },
  { "id": "cmq_inject", "type": "inject", "name": "Envia uma leitura a cada 10 s", "x": 160, "y": 80,
    "props": [{ "p": "payload" }], "payload": "{\"temperature\":21.5}", "payloadType": "json",
    "repeat": "10", "once": true, "wires": [["cmq_out"]] },
  { "id": "cmq_out", "type": "mqtt out", "name": "Publica uma leitura em JSON", "x": 420, "y": 80,
    "topic": "your-project/sensors/temperature", "qos": "1", "retain": "false",
    "broker": "cmq_broker", "wires": [] },
  { "id": "cmq_in", "type": "mqtt in", "name": "Assina o tópico de temperatura", "x": 160, "y": 160,
    "topic": "your-project/sensors/#", "qos": "1", "datatype": "auto-detect",
    "broker": "cmq_broker", "wires": [["cmq_debug"]] },
  { "id": "cmq_debug", "type": "debug", "name": "Executado para cada mensagem de um tópico assinado", "x": 420, "y": 160,
    "active": true, "complete": "payload", "wires": [] }
]

Broker MQTT público gratuito

O broker público é compartilhado: qualquer pessoa pode assinar seus tópicos. Nunca envie senhas, dados pessoais ou qualquer informação confidencial por ele.

Sobre o broker MQTT público gratuito

2. Vá para produção com o ConnectMQ

Para dispositivos reais, use um broker MQTT serverless privado no ConnectMQ em vez do público: criptografia TLS, usuário e senha para cada dispositivo e controle de acesso por tópico, totalmente gerenciado. Comece no plano Free — sem cartão de crédito.

Substitua YOUR_BROKER_HOST, YOUR_USERNAME e YOUR_PASSWORD pelos valores do seu painel do ConnectMQ.

flow.json
[
  { "id": "cmq_tls", "type": "tls-config", "name": "TLS: o repositório de CAs do sistema verifica o certificado do broker", "verifyservercert": true },
  { "id": "cmq_broker", "type": "mqtt-broker", "name": "Broker ConnectMQ",
    "broker": "YOUR_BROKER_HOST", "port": "8883", "usetls": true, "tls": "cmq_tls",
    "protocolVersion": "4", "keepalive": "60", "cleansession": true,
    "credentials": { "user": "YOUR_USERNAME", "password": "YOUR_PASSWORD" } },
  { "id": "cmq_inject", "type": "inject", "name": "Envia uma leitura a cada 10 s", "x": 160, "y": 80,
    "props": [{ "p": "payload" }], "payload": "{\"temperature\":21.5}", "payloadType": "json",
    "repeat": "10", "once": true, "wires": [["cmq_out"]] },
  { "id": "cmq_out", "type": "mqtt out", "name": "Publica uma leitura em JSON", "x": 420, "y": 80,
    "topic": "your-project/sensors/temperature", "qos": "1", "retain": "false",
    "broker": "cmq_broker", "wires": [] },
  { "id": "cmq_in", "type": "mqtt in", "name": "Assina o tópico de temperatura", "x": 160, "y": 160,
    "topic": "your-project/sensors/#", "qos": "1", "datatype": "auto-detect",
    "broker": "cmq_broker", "wires": [["cmq_debug"]] },
  { "id": "cmq_debug", "type": "debug", "name": "Executado para cada mensagem de um tópico assinado", "x": 420, "y": 160,
    "active": true, "complete": "payload", "wires": [] }
]

Perguntas frequentes sobre MQTT com Node-RED

Como conectar Node-RED a um broker MQTT?

Instale mqtt in / mqtt out nodes, conecte-se ao host do broker na porta 1883 (ou 8883 com TLS) e depois assine um tópico e publique mensagens nele. Os exemplos desta página se conectam ao broker público gratuito broker.connectmq.com e a um broker privado do ConnectMQ.

Existe um broker MQTT gratuito para testar Node-RED?

Sim. broker.connectmq.com é um broker MQTT público e gratuito que não exige conta. Qualquer pessoa pode ler seus tópicos, então use-o apenas para testes e com um prefixo de tópico exclusivo.

Como proteger uma conexão MQTT com Node-RED?

Conecte-se via TLS na porta 8883 com um usuário e senha do seu painel do ConnectMQ e, em vez de usar o broker público, dê a cada dispositivo suas próprias credenciais e permissões de tópico.

Broker MQTT público gratuito

Teste qualquer exemplo em broker.connectmq.com — sem cadastro, com MQTT 3.1.1 e 5, TCP, TLS e WebSocket.

Sobre o broker MQTT público gratuito

MQTT serverless seguro para produção

Quando chegar a hora dos dispositivos reais, rode o mesmo código em um broker ConnectMQ privado e totalmente gerenciado, com TLS e credenciais por dispositivo.

Comece grátis

Seu broker MQTT privado está a poucos cliques de distância

Crie uma conta, receba as credenciais do seu broker e conecte seu primeiro dispositivo — sem servidores para instalar, atualizar ou escalar.

MQTT sobre WebSocket: Conecte um Navegador a um Broker MQTT com MQTT.js

Navegadores não conseguem abrir sockets TCP puros, então aplicações web falam MQTT sobre WebSocket. Construa um cliente funcional no navegador e outro em Node.js usando o servidor MQTT público broker.connectmq.com e aprenda a resolver os erros de conexão mais comuns.

9 min de leitura