Osamu Koizumi / Mbed OS HelloMQTT

HelloMQTT over TLS.

Dependencies:   MQTT

Fork of HelloMQTT by Osamu Koizumi

HelloMQTT over TLS

This program is a fork of HelloMQTT. Added TLS capability by using TLSSocket library. Tested on K64F.

This sample program connects to iot.eclipse.org:8883 by default. Verifies server identification. Subscribes a certain topic. Then publishes three messages with different QoSs, i.e. QoS0, QoS1, and QoS2.

Warning

Some brokers do not accept QoS2 and/or QoS1 message. For example, AWS IoT Message Broker doesn't accept QoS2. In such broker, this program doesn't work as is. Change QoS level.

Output from console

HelloMQTT: version is 0.70

Opening network interface...
Network interface opened successfully.

Connecting to host iot.eclipse.org:8883 ...
Connection established.

MQTT client is trying to connect the server ...
Client connected.

Client is trying to subscribe a topic "mbed-test".
Client has subscribed a topic "mbed-test".

Client publishes messages ...
Publishing message QoS 0.
QoS 0 message published.
! Message arrived: qos 0, retained 0, dup 0, packetid 6257
! Payload Hello World!  QoS 0 message from app version 0.700000

Publishing message QoS 1.
QoS 1 message published.
! Message arrived: qos 1, retained 0, dup 0, packetid 1
! Payload Hello World!  QoS 1 message from app version 0.700000

Publishing message QoS 2.
QoS 2 message published.
! Message arrived: qos 2, retained 0, dup 0, packetid 2
! Payload Hello World!  QoS 2 message from app version 0.700000

Version 0.70: finish 3 msgs

Known Issues

On K64F, when serial baud rate is changed from 9600 to 115200, program fails.

MQTTNetwork.h@43:4dfeeaa9713e, 2018-06-15 (annotated)

Committer:
Osamu Koizumi
Date:
Fri Jun 15 00:34:21 2018 +0900
Revision:
43:4dfeeaa9713e
Parent:
42:c88d777f2e00 
Updated TLSSocket library.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Jan Jongboom 20:49c9daf2b0ff 1 #ifndef _MQTTNETWORK_H_
Jan Jongboom 20:49c9daf2b0ff 2 #define _MQTTNETWORK_H_
Jan Jongboom 20:49c9daf2b0ff 3
Jan Jongboom 20:49c9daf2b0ff 4 #include "NetworkInterface.h"
Jan Jongboom 20:49c9daf2b0ff 5
Osamu Koizumi 24:e7cf8b02e012 6 #undef USE_TLS
Osamu Koizumi 24:e7cf8b02e012 7 #if defined(MBED_CONF_APP_USE_TLS) && (MBED_CONF_APP_USE_TLS == 1)
Osamu Koizumi 24:e7cf8b02e012 8 #define USE_TLS
Osamu Koizumi 24:e7cf8b02e012 9 #endif
Osamu Koizumi 24:e7cf8b02e012 10
Osamu Koizumi 24:e7cf8b02e012 11 #ifdef USE_TLS
Osamu Koizumi 24:e7cf8b02e012 12 #include "TLSSocket.h"
Osamu Koizumi 24:e7cf8b02e012 13 #endif /* USE_TLS */
Osamu Koizumi 24:e7cf8b02e012 14
Jan Jongboom 20:49c9daf2b0ff 15 class MQTTNetwork {
Jan Jongboom 20:49c9daf2b0ff 16 public:
Jan Jongboom 20:49c9daf2b0ff 17 MQTTNetwork(NetworkInterface* aNetwork) : network(aNetwork) {
Osamu Koizumi 24:e7cf8b02e012 18 #ifdef USE_TLS
Osamu Koizumi 24:e7cf8b02e012 19 socket = new TLSSocket();
Osamu Koizumi 24:e7cf8b02e012 20 #else
Jan Jongboom 20:49c9daf2b0ff 21 socket = new TCPSocket();
Osamu Koizumi 24:e7cf8b02e012 22 #endif /* USE_TLS */
Jan Jongboom 20:49c9daf2b0ff 23 }
Jan Jongboom 20:49c9daf2b0ff 24
Jan Jongboom 20:49c9daf2b0ff 25 ~MQTTNetwork() {
Jan Jongboom 20:49c9daf2b0ff 26 delete socket;
Jan Jongboom 20:49c9daf2b0ff 27 }
Jan Jongboom 20:49c9daf2b0ff 28
Jan Jongboom 20:49c9daf2b0ff 29 int read(unsigned char* buffer, int len, int timeout) {
Jan Jongboom 20:49c9daf2b0ff 30 return socket->recv(buffer, len);
Jan Jongboom 20:49c9daf2b0ff 31 }
Jan Jongboom 20:49c9daf2b0ff 32
Jan Jongboom 20:49c9daf2b0ff 33 int write(unsigned char* buffer, int len, int timeout) {
Jan Jongboom 20:49c9daf2b0ff 34 return socket->send(buffer, len);
Jan Jongboom 20:49c9daf2b0ff 35 }
Jan Jongboom 20:49c9daf2b0ff 36
Osamu Koizumi 34:8f7a465c2192 37 int connect(const char* hostname, int port, const char *ssl_ca_pem = NULL,
Osamu Koizumi 34:8f7a465c2192 38 const char *ssl_cli_pem = NULL, const char *ssl_pk_pem = NULL) {
Osamu Koizumi 24:e7cf8b02e012 39 nsapi_error_t ret = 0;
Osamu Koizumi 24:e7cf8b02e012 40 if((ret = socket->open(network)) != 0) {
Osamu Koizumi 24:e7cf8b02e012 41 return ret;
Osamu Koizumi 24:e7cf8b02e012 42 }
Osamu Koizumi 24:e7cf8b02e012 43 #ifdef USE_TLS
Osamu Koizumi 42:c88d777f2e00 44 socket->set_root_ca_cert(ssl_ca_pem);
Osamu Koizumi 42:c88d777f2e00 45 socket->set_client_cert_key(ssl_cli_pem, ssl_pk_pem);
Osamu Koizumi 24:e7cf8b02e012 46 #endif /* USE_TLS */
Jan Jongboom 20:49c9daf2b0ff 47 return socket->connect(hostname, port);
Jan Jongboom 20:49c9daf2b0ff 48 }
Jan Jongboom 20:49c9daf2b0ff 49
Jan Jongboom 21:a68bd76740f9 50 int disconnect() {
Jan Jongboom 21:a68bd76740f9 51 return socket->close();
Jan Jongboom 20:49c9daf2b0ff 52 }
Jan Jongboom 20:49c9daf2b0ff 53
Jan Jongboom 20:49c9daf2b0ff 54 private:
Jan Jongboom 20:49c9daf2b0ff 55 NetworkInterface* network;
Osamu Koizumi 24:e7cf8b02e012 56 #ifdef USE_TLS
Osamu Koizumi 24:e7cf8b02e012 57 TLSSocket* socket;
Osamu Koizumi 24:e7cf8b02e012 58 #else
Jan Jongboom 20:49c9daf2b0ff 59 TCPSocket* socket;
Osamu Koizumi 24:e7cf8b02e012 60 #endif /* USE_TLS */
Jan Jongboom 20:49c9daf2b0ff 61 };
Jan Jongboom 20:49c9daf2b0ff 62
Jan Jongboom 20:49c9daf2b0ff 63 #endif // _MQTTNETWORK_H_