Rilasciato FB MQTTClient per gestione protocollo MQTT

Proprio per dimostrare come sia possibile trasferire variabili tra diversi sistemi utilizzando il protocollo MQTT ho realizzato il programma MQTTExchange. Questo programmasi connette ad un broker gratuito broker.mqttdashboard.com ed esegue la pubblicazione dello stato di un ingresso logico sul topic IOCommand.

Il programma si sottoscrive allo stesso topic così ne riceve dal broker lo stato ad ogni variazione, e lo stato ricevuto comanda una uscita logica. In questo modo lo stato dell’ingresso è riportato sull’uscita passando dal broker. E’ possibile trasferire lo stesso programma su diversi sistemi e gestendo opportunamente la pubblicazione e la sottoscrizione dei topic sui sistemi è possibile realizzare uno scambio dati.

Eseguendo il programma su di un sistema attivando Di01CPU si comanda la connessione al broker, a connessione avvenuta si attiva Do01CPU. Attivando Di00CPU ne viene pubblicato lo stato che è ricevuto e trasferito su Do00CPU. Quindi lo stato dell’ingresso è copiato sulla uscita passando attraverso la pubblicazione sul broker (Stampa programma, Download programma).

Attenzione, per evitare di andare in conflitto con altri utenti che testano il programma conviene modificare il nome del topic e l’identificativo utente. Ci può solo essere un utente con lo stesso identificativo sullo stesso broker.

Attualmente la comunicazione è solo in chiaro, livelli di crittografia sono in previsione ma non ho date di rilascio.

Si certo è possibile sottoscriversi a tutti i topics che si desidera, ma venendo al tuo problema, se ho ben capito con TopicRxD tu intendi la variabile stringa il cui indirizzo è passato in:

MQTT.VBufferRxD:=ADR(TopicRxD); (* Value buffer (Received) *)

Quindi nella stringa tu vedi la ricezione del valore pubblicato da qualcuno su quel topic (Nel tuo caso la app sullo smartphone). Bene ho provato esattamente la tua situazione (Utilizzando il programma IOOnMQTT scaricabile da questa knowledge) e non noto alcun problema, io uso la app MyMQTT per i test.

Non è che sia l’app ad inviare insieme al dato anche il nome del topic?

Si se la dimensione del messaggio ricevuto da un topic ha lunghezza pari a 0 o superiore alla dimensione del buffer definito per contenerlo (Parametro VBLengthRxD) il messaggio viene scartato segnalando errore 10067288.

Visto il problema, in effetti non veniva inizializzato il buffer che contiene il nome del topic. Ho provveduto a correggere il FB ed a rilasciare la nuova versione di libreria eLLabNetworkLib_B000 scaricabile dal sito.

Il problema capita solo se attivo lo spionaggio, c’è un bug nella gestione dello spionaggio del frame trasmesso. Ho corretto il bug e tra poco sarà disponibile una nuova versione della libreria eLLabNetworkLib_B100 .

Per risponderti mi rifaccio all’esempio riportato sul manuale on-line del FB MQTTClient, in pratica nel ciclo CASE di esecuzione basta aggiungere le varie  sottoscrizioni, ecco un esempio.

    CASE (CaseNr) OF

        // ---------------------------------------------------------------------
        // CONNECTION TO BROKER
        // ---------------------------------------------------------------------
        // Check if connected to broker.

        0:
        MQTT.Enable:=Enable; //Connection enable
        IF NOT(MQTT.Connected) THEN RETURN; END_IF;

        // Client connected to broker, manage the subscription

        MQTT.Topic:=ADR('TopicOne'); //Topic name
        MQTT.Subscribe:=TRUE; //Topic subscribe
        CaseNr:=CaseNr+1; //Program case

        // ---------------------------------------------------------------------
        // Waits for subscription.

        1:
        MQTT.Subscribe:=FALSE; //Topic subscribe
        IF NOT(MQTT.Subscribed) THEN RETURN; END_IF;
        CaseNr:=CaseNr+1; //Program case

        // ---------------------------------------------------------------------
        // Manage the subscription

        2:
        MQTT.Topic:=ADR('TopicTwo'); //Topic name
        MQTT.Subscribe:=TRUE; //Topic subscribe
        CaseNr:=CaseNr+1; //Program case

        // ---------------------------------------------------------------------
        // Waits for subscription.

        3:
        MQTT.Subscribe:=FALSE; //Topic subscribe
        IF NOT(MQTT.Subscribed) THEN RETURN; END_IF;
        CaseNr:=CaseNr+1; //Program case

Puoi continuare con i cases aggiungendo tutte le sottoscrizioni che ti servono.