Come inviare il ping utilizzando il client Eclipse Paho MQTT?

Question

Abbiamo appena iniziato a creare il nostro sistema di notifica push (per esigenze del cliente) per Android e trovato Eclipse Paho (http://www.eclipse.org/paho/). Inutile dire che questo progetto è davvero eccitante.

Il problema con Android è, se la CPU è in stato di sospensione, il client MQTT potrebbe non avere la possibilità di inviare ping al suo intervallo impostato. La soluzione alternativa è usare AlarmManager per riattivarlo e portare a termine il lavoro. La documentazione Android dice:

Il Gestore allarme contiene un blocco scia CPU finché il metodo OnReceive() del destinatario dell'allarme è in esecuzione. Ciò garantisce che il telefono non si addormenta fino al termine della gestione della trasmissione. Una volta che onReceive() ritorna, Alarm Manager rilascia questo wake lock. Ciò significa che il telefono in alcuni casi verrà interrotto non appena viene completato il metodo onReceive().

http://developer.android.com/reference/android/app/AlarmManager.html

ho bisogno di essere sicuro che ho potuto inviare il comando ping all'interno di tale metodo OnReceive() mentre la CPU ha PARTIAL_WAKE_LOCK, quindi stavo cercando un modo per inviare manualmente ping al server, ma sembra il client non espone alcun metodo di questo tipo. Mi sto perdendo qualcosa? Oppure, qual è la soluzione qui tranne la pubblicazione del mio "messaggio ping"? Voglio evitare che a causa di:

1. ingrandita della testa
2. Ci assicuriamo che i client Android sono abbonati solo, può essere con ACL mosquitto. Non saranno autorizzati a pubblicare messaggi.

Answer 1

Ho lavorato con MQTT su Android e ho riscontrato esattamente lo stesso problema.

Come dice Dale, la vecchia versione del client MQTT utilizzava un metodo ping() esplicito, ma sfortunatamente questo è ora nascosto.

L'approccio più semplice, e quello che uso, è pubblicare esplicitamente un messaggio da 1 byte su un argomento particolare, da utilizzare come keepalive. Non penso che questo dovrebbe aggiungere molto al sovraccarico della vostra applicazione e, anche se non ho familiarità con l'ACL di Mosquitto, presumo che potreste avere ogni cliente che usa lo stesso argomento 'keepalive' e solo fornire accesso in scrittura a tutti. Questo non dovrebbe influire sulla sicurezza finché nessuno può leggere dall'argomento.

Un approccio alternativo sarebbe quello di far inviare al client (s) un messaggio "keepalive" a QoS 1 o 2 (pub/sub attraverso un singolo argomento a tutti per efficienza) poiché, a causa dei flussi QoS, ciò comporterà che il client invii un messaggio al server sotto le copertine; che servirà da keepalive. Questo ha il vantaggio di mantenere i tuoi clienti solo come abbonati; tuttavia è incompatibile con 'clean session = false' (come avresti grandi quantità di messaggi in coda per il recapito ai client che sono offline per un po '- influendo inutilmente sul rendimento della riconnessione).

Sfortunatamente queste sono le uniche due soluzioni alternative che posso attualmente pensare.

---

Inoltre, come una breve parte, ho sperimentato una serie di questioni che utilizzano il MqttDefaultFilePersistence su Android, così si potrebbe desiderare di essere consapevoli di questo. In particolare a che fare con il blocco dei file e problemi durante la nuova istanziazione del client. Per aggirare questo ho creato un'implementazione di MqttClientPersistence costruita su un database SQLite e questo è molto più robusto; potresti voler fare lo stesso.

Answer 2

Mi sono imbattuto in questo problema durante la scrittura di app MQTT per Android un anno fa circa. Ne ho già parlato a lungo a http://dalelane.co.uk/blog/?p=1599 ma in breve, sì, ho visto lo stesso problema in cui descrivi dove se la CPU è addormentata quando il client MQTT deve inviare il suo ping, quindi il ping non viene mai inviato.

La differenza è che stavo usando una libreria client MQTT diversa (questo era prima dei giorni di Paho), e la libreria client che ho usato aveva un metodo ping() che potevo chiamare. (La fonte completa per la mia implementazione è a quel link e risolve questo problema).

Non è possibile estendere l'implementazione della libreria client Paho per includere il comando PING? Presumo che dovrebbe essere una modifica ragionevolmente piccola.

Answer 3

C'è un modo per modificare il codice paho e fare un ping in qualsiasi momento. Se usiamo l'argomento di pubblicazione per restare in vita, dobbiamo inviare almeno 7 o 8 byte al server. Sì, 8 byte non sono ancora grandi dati. Ma il battito cardiaco di MQTT è solo di 2 byte. Abbiamo perso il miglior vantaggio di MQTT.

Guardare a fondo il codice paho, lo modifico e scrivo un metodo pubblico chiamato nnnn() in MQTTClient. Questo metodo potrebbe inviare MqttPingReq al server. l'Implementazione può essere trovato qui ... https://github.com/chinesejie/paho-for-android

Answer 4

la mia soluzione:

(1) modificare: ClientComms comms;protected-public (nella confezione org.eclipse.paho.client.mqttv3)

public class MqttAsyncClient implements IMqttAsyncClient { // DestinationProvider { 
    //... 
    public ClientComms comms; // Add by Ben for pingreq* 
    //... 
} 

(2) definire nuova classe: (derivato da MqttClient)

public class MqttClient2 extends MqttClient { 

    public MqttClient2(String serverURI, String clientId, MqttClientPersistence persistence) throws MqttException { 
     super(serverURI, clientId, persistence); 
    } 

    public void pingreq() throws MqttException { 

     MqttDeliveryToken token = new MqttDeliveryToken(getClientId()); 
     MqttPingReq pingMsg = new MqttPingReq(); 
     aClient.comms.sendNoWait(pingMsg, token); 

    } 
} 

(3) da nessuna parte, yo Potete:

MqttClient2 mClient = new MqttClient2(url, mDeviceId, mDataStore); 
mClient.pingreq(); 

spero che questo possa essere utile per voi.