MQTT

Dispositivos que publicam por um broker MQTT externo, em MQTT simples ou Sparkplug B, com o broker modelado como o nó que todo dispositivo abaixo dele compartilha, e os dados da própria estação publicados num broker.

O driver MQTT lê e escreve as tags de equipamentos que publicam por um broker MQTT externo: um gateway, um sensor sem fio, um fluxo do Node-RED, um nó de borda que fala Sparkplug B. A estação é cliente desse broker: assina os tópicos que as tags dela leem e publica as escritas que você faz, e cada broker pode publicar os dados da própria estação, as tags, as variáveis da Logic e os alarmes listados no cartão Publicar dele, como JSON ou em Sparkplug B. Ela é cliente e não broker, então o equipamento e a estação se conectam os dois a um broker: quando você não tem um, o próprio broker MQTT da estação pode ser esse broker, e ligá-lo adiciona o broker Esta estação a este driver; Instalar um broker mostra como montar um à parte.

Todo dispositivo atrás de um broker usa a mesma conexão, por isso a topologia é Driver → Broker → Dispositivo → Tag: o broker é dono de onde ele responde e de como a estação entra nele, digitados uma vez só; cada dispositivo abaixo dele é dono apenas de como publica, MQTT simples ou Sparkplug B, e das suas tags. Os dois protocolos convivem lado a lado no mesmo broker. Os valores chegam por assinatura, não por leitura cíclica, então nenhum dispositivo ou tag MQTT tem intervalo de leitura.

A página do driver

A página do driver MQTT lista brokers em vez de dispositivos. A frase abaixo do cabeçalho diz "Cada broker é uma conexão com um broker MQTT externo. Configure onde ele responde e como a estação entra nele, depois acrescente os dispositivos que publicam por ele." A tabela Brokers MQTT traz Acrescentar broker à direita do título e uma linha por broker: Nome, Endereço (mqtt://host:port, ou mqtts://host:port com TLS, vazio enquanto o broker não tem host), Dispositivos, Estado (um ponto e o estado do broker com o que os dispositivos dele estão fazendo, como "Conectado · 2/2 dispositivos conectados"), depois Abrir e, para Configurar Connector, Habilitar, Desabilitar e Excluir. A tabela vazia diz "Nenhum broker ainda." Um broker que recusou a estação leva o marcador vermelho da árvore depois do nome, e a página nomeia, sob o cabeçalho, os brokers com erro ("1 broker MQTT com erro: Plant").

Na árvore, a linha do driver conta os dois níveis ("1 broker MQTT · 2 dispositivos"), e o cabeçalho da página mostra o número de brokers entre parênteses. No menu Novo… da coluna, a entrada MQTT oferece Novo broker e depois cada broker com o seu próprio Novo dispositivo e os dispositivos dele, e o menu de contexto da linha do driver oferece Acrescentar broker. A barra do driver não tem Descobrir: uma varredura escuta um único broker, por isso ela fica na página do broker. Depois de acrescentado, o driver fica sob a pasta Drivers da árvore, com ou sem broker.

O broker

Acrescentar broker, o Novo broker do menu Novo… e o menu de contexto da linha do driver criam um broker chamado "Novo broker" (depois "Novo broker 2") e desabilitado, para que a conexão dele seja preenchida antes de a estação se conectar. O feed diz isso: "Broker 'Novo broker' acrescentado, desabilitado. Informe onde ele responde e depois habilite." O broker não é aberto: fica destacado na tabela Brokers MQTT da página do driver, para onde a tela vai a partir do Novo… ou do menu de contexto. A página dele, alcançada pelo Abrir da linha dele ou pela linha dele na árvore, traz a frase "Um broker MQTT: onde ele responde e como a estação entra nele. Todo dispositivo abaixo dele compartilha esta conexão." e, no cabeçalho, o estado, o ponto dele e o endereço. Sob o cabeçalho, os dispositivos do broker que têm erro próprio são nomeados ("1 dispositivo com erro: Pump"); enquanto o próprio broker está com erro, os dispositivos apontam para ele: a página de um dispositivo diz "Este dispositivo passa pelo broker MQTT Plant, que está com erro. A página do broker diz por quê."

O cartão Conexão com o broker

Abaixo dos campos, uma frase diz o que o broker e os dispositivos dele estão fazendo, o que ainda falta ao broker, e "Todos os dispositivos sob este broker e o que a estação publica nele compartilham esta conexão: a sessão abre quando o primeiro dispositivo habilitado ou a primeira linha publicada precisa dela." Todo campo continua editável com o broker habilitado. Uma mudança salva em onde ele responde, no transporte, no login, no ID do cliente ou no keep-alive reconecta a sessão única que todo dispositivo abaixo do broker compartilha.

A barra de comandos

O menu de contexto da linha de um broker oferece Acrescentar dispositivo, Habilitar, Desabilitar e Excluir.

Estados do broker

O broker relata a sessão dele separado dos dispositivos, na linha da árvore, na tabela de brokers do driver e no próprio cabeçalho:

A linha da árvore mostra o estado e o número de dispositivos ("Conectado · 2 dispositivos"), e o resumo abaixo do cartão acrescenta o que os dispositivos estão fazendo: "Conectado · 2/2 dispositivos conectados", "Conectado · 1 conectados · 1 com problemas", "Sem sessão · nenhum dispositivo habilitado". Um dispositivo Sparkplug B que anunciou a própria morte tira do ar só a si mesmo: o broker continua Conectado. A sessão fala MQTT 5 e recua para MQTT 3.1.1 com um broker que não fala, começa limpa e se reconecta sozinha, esperando cada vez mais entre as tentativas enquanto o broker continua ausente.

O cartão Descobrir dispositivos

Desenhado só para Configurar Connector, abaixo da frase "Escuta este broker por um tempo: os nós de borda e dispositivos Sparkplug B que se anunciam, e os tópicos sob um filtro."

Descobrir inicia a varredura e vira Cancelar enquanto ela roda. A frase abaixo dos campos diz o que ela vai fazer ("Escuta 192.168.0.20:1883 por 10 s."), e a frase de progresso conta a janela ("Escutando 192.168.0.20:1883 · 4 de 10 s…"). A varredura precisa de um host salvo no broker: até lá o cartão diz "Informe o host do broker e deixe a edição ser salva antes da descoberta." Uma edição pendente no broker é salva primeiro; quando não pode ser, nada começa: "A descoberta não começou porque a edição do broker não pôde ser salva."

O que uma varredura faz no broker:

• Ela se conecta com um ID do cliente próprio, então nunca derruba do broker a sessão dos dispositivos, e pode rodar com o broker habilitado e em uso.
• Ela assina todo tópico Sparkplug B (spBv1.0/#) e o filtro de tópicos. Os certificados de nascimento do Sparkplug B não ficam retidos, por isso um nó de borda ouvido sem um certificado é chamado a se anunciar de novo (o comando Node Control/Rebirth, a única mensagem que a varredura publica); um nó de borda que está rodando responde dentro da janela.
• Cada nó de borda e cada dispositivo atrás dele que se anuncia (NBIRTH, DBIRTH) vira um candidato com as métricas dele como tags, tipadas pelo que o nascimento declara. A tubulação do próprio nó de borda (bdSeq e as métricas Node Control/… e Device Control/…) fica de fora, assim como as métricas que nenhuma tag lê (arrays, conjuntos de dados, templates, conjuntos de propriedades, bytes, arquivos), contadas pelo motivo. Um nó de borda ouvido mas não nascido dentro da janela é oferecido sem tags.
• Com um filtro de tópicos, os tópicos simples ouvidos sob ele viram um candidato próprio: cada tópico é uma tag, ou, num payload JSON, cada valor dentro dele é uma tag pelo caminho do valor (até 32 por tópico, quatro níveis de profundidade, os 8 primeiros elementos de um array). Um número é oferecido como Double, true ou false como Boolean, qualquer outra coisa como String. A lista para em 500 tópicos. Um tópico cujo publicador retém a última mensagem é ouvido na hora; qualquer outro só se publicar durante a janela.
• Nada é salvo até você acrescentar um candidato. Cancelar encerra a janela na hora.

O cartão de resultados, Dispositivos descobertos, lista Publica como (group/edge node, com /device atrás de um nó de borda, ou "Tópicos simples"), Dispositivo (o nome com que acrescentá-lo, editável: o ID do dispositivo ou do nó de borda, ou os níveis do filtro antes do primeiro curinga), Resultado ("12 de 12 tags selecionadas") e Acrescentar dispositivo, que cria o dispositivo sob este broker com essas tags. Uma identidade Sparkplug B já configurada no broker mostra "Já configurado" e oferece Abrir no lugar. Uma varredura que não ouviu nada diz "Nada se anunciou neste broker enquanto a varredura escutava."

Um dispositivo que você já tem acha pela própria página o que ainda não lê: Descobrir tags, no cabeçalho do cartão de tags dele, escuta 10 s no broker dele. Um dispositivo Sparkplug B ouve só o próprio nó de borda, a quem se pede o nascimento enquanto nada é pedido a nenhum outro; um dispositivo simples ouve os tópicos abaixo dos níveis que as tags dele compartilham (plant/oven/# para plant/oven/temperature e plant/oven/count), e todos os tópicos do broker quando elas não compartilham nenhum. Só são oferecidos os valores para os quais ele ainda não tem tag (veja Descobrir as tags de um dispositivo).

O cartão Dispositivos

"Cada dispositivo lê tópicos simples, ou um nó de borda ou dispositivo Sparkplug B. A conexão é herdada do broker e não pode ser mudada aqui." Acrescentar dispositivo cria "Novo dispositivo" sob este broker, habilitado, em MQTT simples, destacado nesta tabela e rolado até ficar à vista: "Dispositivo 'Novo dispositivo' acrescentado em 'Plant'." A tabela lista Dispositivo, Publica como, Tags e Saúde, com Abrir, Habilitar, Desabilitar e Excluir em cada linha; vazia, ela diz "Nenhum dispositivo configurado neste broker." Um dispositivo com erro próprio leva o marcador vermelho da árvore depois do nome.

O cartão Publicar

O último cartão publica os dados da própria estação neste broker, sob a frase "A estação publica cada linha neste broker como JSON no tópico dela sempre que o valor ou a qualidade dele muda, e todas as linhas de novo cada vez que a conexão abre. O broker guarda a última mensagem de cada tópico para quem assinar depois. A estação só assina o tópico de escrita de cada linha em Leitura e escrita." Quem vê o Connector lê o cartão; quem configura o Connector o muda. O broker Esta estação do próprio broker MQTT da estação tem o mesmo cartão.

Em Sparkplug B, a frase abaixo do título diz no lugar dela "A estação é um nó de borda Sparkplug B neste broker: as variáveis e os alarmes do Logic são métricas dele, e cada dispositivo com linhas é um dispositivo Sparkplug B. Ela anuncia todas as métricas quando a conexão abre e sempre que a lista muda, e depois publica cada valor ou qualidade que muda. Só uma linha em Leitura e escrita aceita um valor vindo de um comando.", e abaixo dos campos ID do nó de borda (o nome da estação) mostra o nó de borda como o qual ela publica.

A tabela lista Origem, Tópico e Acesso, por tópico; uma linha cuja origem ainda não foi escolhida diz "Sem origem ainda". Sem nenhuma, ela diz "Nada é publicado neste broker ainda. Adicione uma linha com Nova linha." Em Sparkplug B, a coluna Tópico é Métrica: uma tag depois do dispositivo dela (Oven · Temperature), uma variável ou um alarme pelo nome no nó de borda (Logic/Oven/Setpoint, Alarms/High). Com o broker desabilitado e linhas na lista, um aviso diz "O broker está desabilitado, então nada é publicado até ele ser habilitado." Com uma linha do broker em Leitura e escrita, um segundo aviso diz "As linhas em Leitura e escrita aceitam os valores publicados no tópico de escrita delas. Quem consegue publicar neste broker consegue mudar essas origens, então o usuário e a senha do broker são a única proteção delas." Em Sparkplug B ele diz "As linhas em Leitura e escrita aceitam valores de comandos Sparkplug B (NCMD, DCMD). Quem consegue publicar neste broker consegue mudar essas origens, então o usuário e a senha do broker são a única proteção delas."

Os campos de uma linha são salvos no momento em que mudam:

Abaixo dos campos, uma frase diz o que a linha publica:

Abaixo dessa frase, uma linha em Leitura e escrita mostra o Tópico de escrita dela, o tópico da linha seguido de /set. Em Sparkplug B não há tópico de escrita: uma segunda frase diz a métrica como a qual a linha é publicada, do dispositivo Sparkplug B dela para uma tag, do nó de borda da estação para uma variável e, para um alarme, as cinco métricas sob o nome dele (Active, Acked, State, Priority e Message).

Uma mudança que a lista recusa não é salva: o motivo aparece em vermelho acima dos campos da linha, e a mudança fica na tela para você corrigir.

O que é publicado, e quando, está em Publicação.

Dispositivo

O dispositivo não tem host, porta, credenciais nem intervalo de leitura próprios: tudo isso é do broker. Cada ID Sparkplug B é um único nível de tópico: "Um ID Sparkplug B não pode conter '/', '+' nem '#'." Um broker nomeia um nó de borda ou dispositivo Sparkplug B uma vez só, então um segundo dispositivo com os mesmos IDs de grupo, nó de borda e dispositivo nesse broker é recusado: "O dispositivo Sparkplug B Plant/Line1/Press1 no broker 'Plant' já pertence ao dispositivo 'Press'." Dispositivos de MQTT simples não nomeiam nada próprio no broker, e dois deles podem ler os mesmos tópicos.

A Base URI que o cabeçalho mostra é o endereço de runtime: mqtt://<broker id>?host=…&port=…&tls=0&keepAlive=60&clientId=…&mode=plain, com &silence=… quando o dispositivo define um tempo máximo sem mensagem, e para um dispositivo Sparkplug B mode=sparkplug&group=…&node=…, com &device=… atrás de um nó de borda. Ela nomeia o broker pela identidade estável, nunca pelo nome amigável, e nunca leva o usuário nem a senha.

A cópia de um dispositivo MQTT fica no mesmo broker. Uma cópia Sparkplug B pega a primeira identidade que nenhum dispositivo desse broker tem: o ID mais interno dela, o ID do dispositivo ou, para as métricas do próprio nó de borda, o ID do nó de borda, é numerado do jeito que o nome da cópia é ("Press1 (2)").

Endereçamento da tag

O campo de endereço é Tópico num dispositivo de MQTT simples e Métrica num Sparkplug B, e é obrigatório ("Tópico é obrigatório para este driver."). Uma tag simples tem mais três campos; uma métrica Sparkplug B não tem nenhum, porque leva o próprio tipo e é escrita pelo comando do próprio protocolo.

Os tipos de dado são Boolean, Int16, Int32, Int64, Float, Double, String e DateTime. A prévia somente leitura do endereço no fio é o tópico seguido do que se aplica de path, command e payload (plant/line1/temperature?path=sensors[0].value&command=plant/line1/setpoint), ou o nome da métrica; um caractere que encerraria uma parte (%, ?, &, =, #, +, um espaço) é escrito como %XX.

Leitura

A sessão guarda a última mensagem de cada tópico que assinou, e uma tag lê dela:

Uma tag Boolean aceita true ou false, 1 ou 0, on ou off. Uma tag inteira aceita um número fracionário arredondado e recusa um fora da faixa dela. Uma tag DateTime aceita texto ISO 8601 ou milissegundos Unix. Uma tag String aceita o texto como está, e um objeto ou array JSON como o JSON bruto. Uma métrica Sparkplug B de tipo sem sinal é lida no tipo com sinal imediatamente mais largo (UInt8 como Int16, UInt16 como Int32, UInt32 e UInt64 como Int64), para que a faixa inteira dela seja lida.

Escrita

Uma escrita passa pelo mesmo funil que a de qualquer outro driver: a caixa de escrita recebe o valor de engenharia, e os estágios de conversão são revertidos antes de o valor bruto ser publicado (veja Connector).

Enquanto o broker está inacessível, ou o nó de borda ou o dispositivo anunciou a própria morte, uma escrita é recusada como desconectada e nada é enviado. Uma escrita Sparkplug B numa métrica que o certificado de nascimento não declara é recusada, já que o nó de borda não a aceitaria, e o mesmo vale para um valor que o tipo da métrica não comporta. Uma escrita nunca fica retida: um setpoint retido seria aplicado de novo por todo assinante que se conectasse depois.

Publicação

Esta seção descreve o Formato da publicação em JSON; o Sparkplug B tem a seção seguinte.

Cada linha do cartão Publicar de um broker é publicada no tópico dela, retida, com QoS 1, pela conexão que os dispositivos do broker usam: a estação nunca abre uma segunda conexão com um broker. Um broker usado só para publicar não precisa de dispositivo. Ele fica sob o driver MQTT, e o estado dele (Conectando…, Conectado, Inacessível) é o dessa conexão. Ele publica enquanto está habilitado e a lista tem linhas; não tem chave própria.

Um valor viaja no tipo JSON dele: um número, true ou false, texto, uma data e hora como texto ISO 8601; um número que o JSON não carrega (NaN, um infinito) viaja como null. Uma tag de um dispositivo desabilitado publica null e bad.

A estação lê o que publica e não calcula nada para isso: a última leitura de uma tag, o valor de uma variável, o estado de um alarme. Ela não assina tópico nenhum de uma linha somente leitura, então uma mensagem que outro sistema publica ali nunca chega à estação; uma linha em Leitura e escrita aceita valores no tópico de escrita dela (Escrita de volta). Um agente lê as listas com mqtt_publish_list e as muda com mqtt_publish_upsert e mqtt_publish_delete (Ferramentas):

mqtt_publish_upsert(brokerId: "<id from mqtt_broker_list>", source: "Connector.Simulated.Oven.Temperature")
mqtt_publish_upsert(brokerId: "<id from mqtt_broker_list>", source: "Alarms.Oven.HighTemperature", topic: "plant/oven/alarms/high")
mqtt_publish_upsert(id: "<id from mqtt_publish_list>", access: "ReadAndWrite")
mqtt_publish_list()

Publicação em Sparkplug B

Com Formato da publicação em Sparkplug B, o broker publica a mesma lista pela especificação Sparkplug B, com a estação como um nó de borda: um host Sparkplug B, como o MQTT Engine do Ignition, lista a estação sob o grupo e o nó de borda dela, cada dispositivo abaixo dela e cada métrica com o tipo dela, sem nenhum mapeamento feito à mão. A conexão é a mesma que os dispositivos do broker usam, como em JSON.

Uma / dentro de um nome vira _, então as pastas são os únicos níveis. Dois dispositivos, ou duas métricas, cujos nomes ficam iguais recebem _2, _3 na ordem dos próprios nomes. As linhas mantêm os tópicos delas, nos quais nada é publicado em Sparkplug B e nos quais a lista volta a publicar quando o broker volta para JSON.

Toda mensagem sai em QoS 0, nunca retida, menos o NDEATH. O número de sequência seq começa em 0 a cada NBIRTH e conta cada mensagem depois dele até 255, e então recomeça; o bdSeq conta as conexões, então o NBIRTH e o NDEATH de uma conexão levam o mesmo número. Nada fica numa fila enquanto o broker está fora do ar.

Uma tag é publicada no próprio tipo; uma variável no tipo em que o servidor OPC UA a serve (um número inteiro como Int64, um número real como Double, um valor de apresentação como texto). Cada métrica leva a qualidade na propriedade Quality, a convenção que os hosts Sparkplug B leem: 192 boa, 64 incerta (com o último valor publicado quando a leitura parou de chegar), 0 ruim (a métrica fica então sem valor).

A estação escuta os comandos para o nó de borda sempre, para que um host possa pedir um renascimento, e os comandos para um dispositivo só enquanto uma das linhas dele está em Leitura e escrita. Passar um broker para Sparkplug B faz a conexão dele abrir de novo uma vez, para o broker guardar a última vontade do nó de borda; os dispositivos do broker passam por isso como por qualquer reconexão. A estação é um nó de borda e não uma aplicação host primária: ela não espera a mensagem STATE de um host para nascer.

mqtt_broker_upsert(id: "<id from mqtt_broker_list>", publishFormat: "SparkplugB", sparkplugGroupId: "Plant1")
mqtt_publish_list()

Escrita de volta

Uma linha de um cartão Publicar em Leitura e escrita aceita valores no tópico de escrita dela, o tópico da linha seguido de /set: um painel na nuvem que lê plant/oven/setpoint manda um novo setpoint em plant/oven/setpoint/set. A estação o escreve como um cliente do servidor Modbus ou do servidor OPC UA dela escreve uma linha marcada leitura e escrita.

O diário registra cada escrita com a origem MQTT <nome do broker> na área Connector, como registra a escrita de um operador. Uma mensagem que não foi escrita fica registrada na área Connector, componente MQTT publication, uma vez e depois num resumo a cada poucos minutos enquanto se repete.

O usuário e a senha do broker são a única proteção: quem o broker deixa publicar num tópico de escrita consegue mudar aquela origem, e num broker na nuvem compartilhado com outras pessoas isso é mais gente do que a planta. Dê à conta do painel no broker só os tópicos de que ele precisa. Num broker em Sparkplug B, as mesmas linhas aceitam comandos Sparkplug B (NCMD, DCMD) no lugar de um tópico de escrita (Publicação em Sparkplug B).

"C:\Program Files\mosquitto\mosquitto_pub" -h localhost -u dashboard -P <password> -t plant/oven/setpoint/set -m 65

Segurança

Com Usar TLS, o certificado do broker é aceito de um de dois jeitos: a cadeia e o nome do host dele são validados no repositório de certificados do Windows, como em qualquer conexão HTTPS deste computador, ou você aprovou exatamente esse certificado em Acesso a equipamentos, na página deste driver. Um broker cujo certificado vem de uma autoridade certificadora sua passa a ser confiável quando essa autoridade é instalada no repositório do Windows, e um com certificado autoassinado não precisa de nada instalado depois que o certificado dele é aprovado. A revogação não é conferida, e nada aceita um certificado às cegas: um desconhecido é recusado, o broker fica Inacessível, com o motivo, e os dispositivos dele esperam a aprovação. A senha trafega dentro da conexão TLS; sem TLS ela trafega às claras, como o cartão avisa.

Acesso a equipamentos

Um broker com um certificado autoassinado, ou emitido por uma autoridade própria, apresenta um certificado que nenhuma raiz instalada no Windows garante. Essa raiz não precisa ser instalada neste computador. Com Usar TLS, a primeira conexão é recusada, o broker fica Inacessível, com o motivo, os dispositivos dele mostram Esperando a aprovação do certificado na árvore e nas páginas deles, cujo botão Revisar o certificado abre este cartão no certificado, e o certificado espera em Acesso a equipamentos, no fim da página do driver MQTT, o mesmo cartão que a página do driver OPC UA traz, até você decidir:

Confira a impressão digital com quem administra o broker antes de aprovar o certificado. Uma aprovação aceita aquele certificado e nenhum outro, e só dentro das datas de validade dele; ela substitui a raiz que falta no Windows e o nome que o certificado traz, então um broker alcançado pelo endereço IP conecta mesmo que o certificado dele nomeie outro host, e nada mais do certificado é afrouxado. Quando o broker responde num endereço cujo certificado você aprovou com outro, os dispositivos dele param de ler, o novo espera aqui e a estação avisa "Certificado mudou: <nome>" com um botão Revisar. Uma descoberta no broker pelo cartão Descobrir dispositivos esbarra nas mesmas decisões. Um certificado em que o Windows já confia é aceito como antes e nunca aparece aqui; nada é aprovado automaticamente.

A causa do broker diz o motivo em vez de um erro de TLS sem nome: "O certificado do broker em <host>:<porta> (os primeiros 16 caracteres da impressão digital) espera a sua aprovação em Acesso a equipamentos, na página do driver MQTT. A leitura começa assim que você aprová-lo." Um bloqueado diz "…está bloqueado nesta estação. Revise-o em Acesso a equipamentos, na página do driver MQTT." Um certificado fora das datas de validade, revogado ou com a assinatura quebrada é recusado com esse motivo e nunca é listado, porque nenhuma aprovação o torna válido.

As decisões ficam na pasta de dados da estação, em ua\pki\mqtt, e sobrevivem a um reinício. Os verbos só são desenhados para um papel que pode configurar o Connector, e só agem na janela da própria estação: um navegador em outro aparelho lê o cartão sem mudá-lo, e nenhuma ferramenta de agente aprova um certificado (connector_browse indica os dispositivos do broker com awaitingCertificate). A lista guarda até 100 certificados esperando aprovação; quando está cheia, um novo continua recusado mas não é listado, e o cartão diz isso.

Preparar o broker

Um broker tem de aceitar conexões do computador da estação, e aceitar a entrada da estação. O Eclipse Mosquitto 2, o broker mais comum, não faz nenhuma das duas coisas de fábrica: sem um listener no mosquitto.conf ele só escuta no próprio computador, e quando tem um recusa cliente sem usuário. O MQTT não diz qual broker respondeu, então a estação cita o Mosquitto como o caso comum, nunca como certeza.

Os dois primeiros são ditos na página do broker, no lugar do erro em inglês dele, com estes passos e a porta; os dispositivos dele continuam apontando para o broker. O aviso some sozinho quando a sessão conecta. A marca da árvore e o registro mantêm a causa em inglês, que termina com os mesmos passos do Mosquitto.

Instalar um broker

A estação precisa de um broker ao qual se conectar, e o equipamento também. Onde você não tem nenhum, o Eclipse Mosquitto é um broker pequeno que roda como serviço do Windows:

1. Baixe o instalador para Windows na página de downloads de mosquitto.org e execute-o. Ele instala o serviço Mosquitto Broker em C:\Program Files\mosquitto.

2. De fábrica, o Mosquitto só responde no computador em que roda. Para deixar o equipamento da rede entrar, acrescente um listener e um arquivo de senhas ao mosquitto.conf dessa pasta:

   listener 1883
   password_file C:\Program Files\mosquitto\passwd
   

   Crie o arquivo com a conta que a estação e o equipamento vão usar (o comando pede a senha):

   "C:\Program Files\mosquitto\mosquitto_passwd" -c "C:\Program Files\mosquitto\passwd" station
   

3. Reinicie o serviço num prompt de administrador e libere a entrada da porta TCP 1883 no Firewall do Windows Defender para a rede do equipamento:

   net stop mosquitto
   net start mosquitto
   

4. Na página do broker, informe localhost como Host ou IP quando o broker roda no próprio computador da estação, ou o endereço desse computador nos outros casos, Porta 1883 e a conta que você criou, depois Habilitar.

Para experimentar uma tag simples antes de o equipamento estar conectado, publique um valor de teste retido a partir da mesma pasta e aponte o Tópico de uma tag para ele:

"C:\Program Files\mosquitto\mosquitto_pub" -h localhost -u station -P <password> -t plant/line1/temperature -m 21.5 -r

Limites que vale conhecer

• O driver MQTT é cliente, não broker: o equipamento e a estação se conectam a um broker, o próprio broker MQTT da estação ou outro.
• O cartão Publicar de um broker sai como JSON ou como Sparkplug B, nunca os dois ao mesmo tempo. Em Sparkplug B a estação é um nó de borda, não uma aplicação host primária, e não usa aliases, templates nem valores históricos.
• A estação não é uma aplicação hospedeira Sparkplug B: ela não publica mensagem STATE. Um nó de borda configurado para esperar uma aplicação hospedeira primária antes de publicar fica calado.
• O MQTT simples não diz nada de um publicador que se calou: uma tag simples mantém o último valor que recebeu enquanto a conexão com o broker se mantém, datado pela chegada, a não ser que o dispositivo dela defina um Tempo máximo sem mensagem (s). Um tópico publicado só quando o valor muda não distingue um publicador calado de um valor estável, então o dispositivo dele fica em 0. O Sparkplug B diz, pelo certificado de morte.
• A sessão começa limpa: o que foi publicado enquanto a estação não estava conectada não é reenviado, e é a mensagem retida de um tópico que devolve um valor à tag dele.
• Uma tag lê um tópico, nunca um filtro, e um valor dele; uma métrica Sparkplug B que é um array, um conjunto de dados, um template ou um conjunto de propriedades não é lida.
• Só TCP, com ou sem TLS: nada de MQTT sobre WebSockets, nada de certificado de cliente e nenhum broker mais antigo que o MQTT 3.1.1.
• Um dispositivo não pode ser movido para outro broker: crie-o sob o outro broker e exclua o antigo.