Vergil Cola / Mbed OS HelloMQTT Featured

A Threaded Secure MQTT Client example. Uses MBED TLS for SSL/TLS connection. QoS0 only for now. Example has been tested with K64F connected via Ethernet.

Dependencies:   FP MQTTPacket

Fork of HelloMQTT by MQTT

main.cpp@31:d34f6adb7a53, 2017-04-01 (annotated)

Committer:
vpcola
Date:
Sat Apr 01 12:41:29 2017 +0000
Revision:
31:d34f6adb7a53
Parent:
28:01d5cc81af31 
Testing on NUCLEO L476RG

Who changed what in which revision?

UserRevisionLine numberNew contents of line
icraggs 1:a1d5c7a6acbc 1 /*******************************************************************************
icraggs 17:0811bdbdd78a 2 * Copyright (c) 2014, 2015 IBM Corp.
icraggs 1:a1d5c7a6acbc 3 *
icraggs 1:a1d5c7a6acbc 4 * All rights reserved. This program and the accompanying materials
icraggs 1:a1d5c7a6acbc 5 * are made available under the terms of the Eclipse Public License v1.0
icraggs 1:a1d5c7a6acbc 6 * and Eclipse Distribution License v1.0 which accompany this distribution.
icraggs 1:a1d5c7a6acbc 7 *
icraggs 1:a1d5c7a6acbc 8 * The Eclipse Public License is available at
icraggs 1:a1d5c7a6acbc 9 * http://www.eclipse.org/legal/epl-v10.html
icraggs 1:a1d5c7a6acbc 10 * and the Eclipse Distribution License is available at
icraggs 1:a1d5c7a6acbc 11 * http://www.eclipse.org/org/documents/edl-v10.php.
icraggs 1:a1d5c7a6acbc 12 *
icraggs 1:a1d5c7a6acbc 13 * Contributors:
icraggs 1:a1d5c7a6acbc 14 * Ian Craggs - initial API and implementation and/or initial documentation
icraggs 17:0811bdbdd78a 15 * Ian Craggs - make sure QoS2 processing works, and add device headers
icraggs 1:a1d5c7a6acbc 16 *******************************************************************************/
Jan Jongboom 20:49c9daf2b0ff 17
icraggs 2:638c854c0695 18 /**
icraggs 2:638c854c0695 19 This is a sample program to illustrate the use of the MQTT Client library
icraggs 2:638c854c0695 20 on the mbed platform. The Client class requires two classes which mediate
icraggs 2:638c854c0695 21 access to system interfaces for networking and timing. As long as these two
icraggs 2:638c854c0695 22 classes provide the required public programming interfaces, it does not matter
icraggs 2:638c854c0695 23 what facilities they use underneath. In this program, they use the mbed
icraggs 2:638c854c0695 24 system libraries.
Jan Jongboom 20:49c9daf2b0ff 25
icraggs 2:638c854c0695 26 */
Jan Jongboom 20:49c9daf2b0ff 27
vpcola 21:a7506c90aa84 28 #include "mbed.h"
vpcola 21:a7506c90aa84 29 #include "rtos.h"
vpcola 31:d34f6adb7a53 30
vpcola 31:d34f6adb7a53 31 #undef MBED_CONF_APP_ESP8266_DEBUG
Jan Jongboom 20:49c9daf2b0ff 32 #include "easy-connect.h"
vpcola 23:06fac173529e 33 #include "MQTTThreadedClient.h"
vpcola 23:06fac173529e 34
vpcola 31:d34f6adb7a53 35 using namespace MQTT;
icraggs 2:638c854c0695 36
vpcola 21:a7506c90aa84 37 Serial pc(USBTX, USBRX, 115200);
vpcola 26:4b21de8043a5 38 Thread msgSender(osPriorityNormal, DEFAULT_STACK_SIZE * 2);
vpcola 26:4b21de8043a5 39
vpcola 26:4b21de8043a5 40 #define MQTT_USE_TLS
vpcola 26:4b21de8043a5 41
vpcola 26:4b21de8043a5 42 #ifdef MQTT_USE_TLS
vpcola 26:4b21de8043a5 43 /* List of trusted root CA certificates
vpcola 26:4b21de8043a5 44 * currently only "letsencrypt", the CA for mbedhacks.com
vpcola 26:4b21de8043a5 45 *
vpcola 26:4b21de8043a5 46 * To add more than one root, just concatenate them.
vpcola 26:4b21de8043a5 47 *
vpcola 26:4b21de8043a5 48 * TODO: Move this certificate file onto the SD card.
vpcola 26:4b21de8043a5 49 */
vpcola 26:4b21de8043a5 50 static const char SSL_CA_PEM[] = "-----BEGIN CERTIFICATE-----\n"
vpcola 26:4b21de8043a5 51 "MIIFETCCA/mgAwIBAgISA2ktlb1Y6ap4GCH7dg3wS37XMA0GCSqGSIb3DQEBCwUA\n"
vpcola 26:4b21de8043a5 52 "MEoxCzAJBgNVBAYTAlVTMRYwFAYDVQQKEw1MZXQncyBFbmNyeXB0MSMwIQYDVQQD\n"
vpcola 26:4b21de8043a5 53 "ExpMZXQncyBFbmNyeXB0IEF1dGhvcml0eSBYMzAeFw0xNzAzMDkwMTQ4MDBaFw0x\n"
vpcola 26:4b21de8043a5 54 "NzA2MDcwMTQ4MDBaMBgxFjAUBgNVBAMTDW1iZWRoYWNrcy5jb20wggEiMA0GCSqG\n"
vpcola 26:4b21de8043a5 55 "SIb3DQEBAQUAA4IBDwAwggEKAoIBAQC4ppYHlH8lfB7lkWOjMSnOJGaLtCBfz57I\n"
vpcola 26:4b21de8043a5 56 "VVOd1Rngsz7nE5fg3joa7lkazRY1ZqtuC2UloS+4LYoQZX4Z887dhdug/TPA4J1A\n"
vpcola 26:4b21de8043a5 57 "GppA4xVCb2kUFODMjZ2r4pMLp+MjFFMBaHrL4cgx/n4aJUB+N9Z+HW0p2Yr5TsOQ\n"
vpcola 26:4b21de8043a5 58 "ghIOPkNxFr2q6klm49+BMUbO98hAwFwsIISLf6IbHM93gx1ltqkvb55N87ZM1hYH\n"
vpcola 26:4b21de8043a5 59 "fkq+J+YqjleiLaqRN2MVlNMNfy9MDbqM5uCyGiWGtq8eiQLaWpZkxnA2MC5zPsO/\n"
vpcola 26:4b21de8043a5 60 "fzEWiVjn2uazlXZ5xZwiK22KMxVasqWMitvETtmPOl9mocRbLQdxAgMBAAGjggIh\n"
vpcola 26:4b21de8043a5 61 "MIICHTAOBgNVHQ8BAf8EBAMCBaAwHQYDVR0lBBYwFAYIKwYBBQUHAwEGCCsGAQUF\n"
vpcola 26:4b21de8043a5 62 "BwMCMAwGA1UdEwEB/wQCMAAwHQYDVR0OBBYEFCsgG+z1BTjrN3K+/tF0C4k818Yv\n"
vpcola 26:4b21de8043a5 63 "MB8GA1UdIwQYMBaAFKhKamMEfd265tE5t6ZFZe/zqOyhMHAGCCsGAQUFBwEBBGQw\n"
vpcola 26:4b21de8043a5 64 "YjAvBggrBgEFBQcwAYYjaHR0cDovL29jc3AuaW50LXgzLmxldHNlbmNyeXB0Lm9y\n"
vpcola 26:4b21de8043a5 65 "Zy8wLwYIKwYBBQUHMAKGI2h0dHA6Ly9jZXJ0LmludC14My5sZXRzZW5jcnlwdC5v\n"
vpcola 26:4b21de8043a5 66 "cmcvMCsGA1UdEQQkMCKCDW1iZWRoYWNrcy5jb22CEXd3dy5tYmVkaGFja3MuY29t\n"
vpcola 26:4b21de8043a5 67 "MIH+BgNVHSAEgfYwgfMwCAYGZ4EMAQIBMIHmBgsrBgEEAYLfEwEBATCB1jAmBggr\n"
vpcola 26:4b21de8043a5 68 "BgEFBQcCARYaaHR0cDovL2Nwcy5sZXRzZW5jcnlwdC5vcmcwgasGCCsGAQUFBwIC\n"
vpcola 26:4b21de8043a5 69 "MIGeDIGbVGhpcyBDZXJ0aWZpY2F0ZSBtYXkgb25seSBiZSByZWxpZWQgdXBvbiBi\n"
vpcola 26:4b21de8043a5 70 "eSBSZWx5aW5nIFBhcnRpZXMgYW5kIG9ubHkgaW4gYWNjb3JkYW5jZSB3aXRoIHRo\n"
vpcola 26:4b21de8043a5 71 "ZSBDZXJ0aWZpY2F0ZSBQb2xpY3kgZm91bmQgYXQgaHR0cHM6Ly9sZXRzZW5jcnlw\n"
vpcola 26:4b21de8043a5 72 "dC5vcmcvcmVwb3NpdG9yeS8wDQYJKoZIhvcNAQELBQADggEBABFH6YcvHh8foHeg\n"
vpcola 26:4b21de8043a5 73 "NM7iR9HnYRqa5gSERcCtq6jm8PcTsAbsdQ/BNpIHK7AZSg2kk17kj+JFeyMuNJWq\n"
vpcola 26:4b21de8043a5 74 "lmabV0dtzdC8ejp1d7hGb/HjuQ400th/QRayvyrDVzQPfCNyJ0C82Q2DFjeUgnqv\n"
vpcola 26:4b21de8043a5 75 "oJMcV6i4ICW0boI7GUf7oeHCmrUEHKffAbeFvx3c85c39IHJEFa59UWj1linU/Tr\n"
vpcola 26:4b21de8043a5 76 "g9i5AaSKB95d706u1XRA7WLV/Hu7yunhxEjlj33bfdifBb/ZLBd0LtrXPwtXi6E8\n"
vpcola 26:4b21de8043a5 77 "r6obp+B+Ce89G7WEhdT9BX0ck1KTK+yP7uAC7tvvsiejxXOoCtVyBAumBJS7mRuv\n"
vpcola 26:4b21de8043a5 78 "I5hmKgE=\n"
vpcola 26:4b21de8043a5 79 "-----END CERTIFICATE-----\n"
vpcola 26:4b21de8043a5 80 "-----BEGIN CERTIFICATE-----\n"
vpcola 26:4b21de8043a5 81 "MIIEkjCCA3qgAwIBAgIQCgFBQgAAAVOFc2oLheynCDANBgkqhkiG9w0BAQsFADA/\n"
vpcola 26:4b21de8043a5 82 "MSQwIgYDVQQKExtEaWdpdGFsIFNpZ25hdHVyZSBUcnVzdCBDby4xFzAVBgNVBAMT\n"
vpcola 26:4b21de8043a5 83 "DkRTVCBSb290IENBIFgzMB4XDTE2MDMxNzE2NDA0NloXDTIxMDMxNzE2NDA0Nlow\n"
vpcola 26:4b21de8043a5 84 "SjELMAkGA1UEBhMCVVMxFjAUBgNVBAoTDUxldCdzIEVuY3J5cHQxIzAhBgNVBAMT\n"
vpcola 26:4b21de8043a5 85 "GkxldCdzIEVuY3J5cHQgQXV0aG9yaXR5IFgzMIIBIjANBgkqhkiG9w0BAQEFAAOC\n"
vpcola 26:4b21de8043a5 86 "AQ8AMIIBCgKCAQEAnNMM8FrlLke3cl03g7NoYzDq1zUmGSXhvb418XCSL7e4S0EF\n"
vpcola 26:4b21de8043a5 87 "q6meNQhY7LEqxGiHC6PjdeTm86dicbp5gWAf15Gan/PQeGdxyGkOlZHP/uaZ6WA8\n"
vpcola 26:4b21de8043a5 88 "SMx+yk13EiSdRxta67nsHjcAHJyse6cF6s5K671B5TaYucv9bTyWaN8jKkKQDIZ0\n"
vpcola 26:4b21de8043a5 89 "Z8h/pZq4UmEUEz9l6YKHy9v6Dlb2honzhT+Xhq+w3Brvaw2VFn3EK6BlspkENnWA\n"
vpcola 26:4b21de8043a5 90 "a6xK8xuQSXgvopZPKiAlKQTGdMDQMc2PMTiVFrqoM7hD8bEfwzB/onkxEz0tNvjj\n"
vpcola 26:4b21de8043a5 91 "/PIzark5McWvxI0NHWQWM6r6hCm21AvA2H3DkwIDAQABo4IBfTCCAXkwEgYDVR0T\n"
vpcola 26:4b21de8043a5 92 "AQH/BAgwBgEB/wIBADAOBgNVHQ8BAf8EBAMCAYYwfwYIKwYBBQUHAQEEczBxMDIG\n"
vpcola 26:4b21de8043a5 93 "CCsGAQUFBzABhiZodHRwOi8vaXNyZy50cnVzdGlkLm9jc3AuaWRlbnRydXN0LmNv\n"
vpcola 26:4b21de8043a5 94 "bTA7BggrBgEFBQcwAoYvaHR0cDovL2FwcHMuaWRlbnRydXN0LmNvbS9yb290cy9k\n"
vpcola 26:4b21de8043a5 95 "c3Ryb290Y2F4My5wN2MwHwYDVR0jBBgwFoAUxKexpHsscfrb4UuQdf/EFWCFiRAw\n"
vpcola 26:4b21de8043a5 96 "VAYDVR0gBE0wSzAIBgZngQwBAgEwPwYLKwYBBAGC3xMBAQEwMDAuBggrBgEFBQcC\n"
vpcola 26:4b21de8043a5 97 "ARYiaHR0cDovL2Nwcy5yb290LXgxLmxldHNlbmNyeXB0Lm9yZzA8BgNVHR8ENTAz\n"
vpcola 26:4b21de8043a5 98 "MDGgL6AthitodHRwOi8vY3JsLmlkZW50cnVzdC5jb20vRFNUUk9PVENBWDNDUkwu\n"
vpcola 26:4b21de8043a5 99 "Y3JsMB0GA1UdDgQWBBSoSmpjBH3duubRObemRWXv86jsoTANBgkqhkiG9w0BAQsF\n"
vpcola 26:4b21de8043a5 100 "AAOCAQEA3TPXEfNjWDjdGBX7CVW+dla5cEilaUcne8IkCJLxWh9KEik3JHRRHGJo\n"
vpcola 26:4b21de8043a5 101 "uM2VcGfl96S8TihRzZvoroed6ti6WqEBmtzw3Wodatg+VyOeph4EYpr/1wXKtx8/\n"
vpcola 26:4b21de8043a5 102 "wApIvJSwtmVi4MFU5aMqrSDE6ea73Mj2tcMyo5jMd6jmeWUHK8so/joWUoHOUgwu\n"
vpcola 26:4b21de8043a5 103 "X4Po1QYz+3dszkDqMp4fklxBwXRsW10KXzPMTZ+sOPAveyxindmjkW8lGy+QsRlG\n"
vpcola 26:4b21de8043a5 104 "PfZ+G6Z6h7mjem0Y+iWlkYcV4PIWL1iwBi8saCbGS5jN2p8M+X+Q7UNKEkROb3N6\n"
vpcola 26:4b21de8043a5 105 "KOqkqm57TH2H3eDJAkSnh6/DNFu0Qg==\n"
vpcola 26:4b21de8043a5 106 "-----END CERTIFICATE-----";
vpcola 26:4b21de8043a5 107 #endif
vpcola 23:06fac173529e 108
vpcola 23:06fac173529e 109 static const char * clientID = "mbed-sample";
vpcola 23:06fac173529e 110 static const char * userID = "mbedhacks";
vpcola 23:06fac173529e 111 static const char * password = "qwer123";
vpcola 23:06fac173529e 112 static const char * topic_1 = "mbed-sample";
vpcola 23:06fac173529e 113 static const char * topic_2 = "test";
vpcola 23:06fac173529e 114
icraggs 2:638c854c0695 115 int arrivedcount = 0;
icraggs 2:638c854c0695 116
vpcola 23:06fac173529e 117 void messageArrived(MessageData& md)
icraggs 2:638c854c0695 118 {
vpcola 23:06fac173529e 119 Message &message = md.message;
vpcola 23:06fac173529e 120 printf("Arrived Callback 1 : qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id);
vpcola 22:826657a00c44 121 printf("Payload [%.*s]\r\n", message.payloadlen, (char*)message.payload);
icraggs 2:638c854c0695 122 ++arrivedcount;
icraggs 2:638c854c0695 123 }
icraggs 0:0cae29831d01 124
vpcola 23:06fac173529e 125 class CallbackTest
vpcola 21:a7506c90aa84 126 {
vpcola 23:06fac173529e 127 public:
vpcola 23:06fac173529e 128
vpcola 23:06fac173529e 129 CallbackTest()
vpcola 23:06fac173529e 130 : arrivedcount(0)
vpcola 23:06fac173529e 131 {}
vpcola 23:06fac173529e 132
vpcola 23:06fac173529e 133 void messageArrived(MessageData& md)
vpcola 21:a7506c90aa84 134 {
vpcola 23:06fac173529e 135 Message &message = md.message;
vpcola 25:326f00faa092 136 printf("Arrived Callback 2 : qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id);
vpcola 23:06fac173529e 137 printf("Payload [%.*s]\r\n", message.payloadlen, (char*)message.payload);
vpcola 23:06fac173529e 138 ++arrivedcount;
vpcola 23:06fac173529e 139 }
vpcola 23:06fac173529e 140
vpcola 23:06fac173529e 141 private:
vpcola 23:06fac173529e 142
vpcola 23:06fac173529e 143 int arrivedcount;
vpcola 23:06fac173529e 144 };
icraggs 2:638c854c0695 145
icraggs 2:638c854c0695 146 int main(int argc, char* argv[])
Jan Jongboom 20:49c9daf2b0ff 147 {
Jan Jongboom 20:49c9daf2b0ff 148 float version = 0.6;
vpcola 23:06fac173529e 149 CallbackTest testcb;
Jan Jongboom 20:49c9daf2b0ff 150
vpcola 21:a7506c90aa84 151 printf("HelloMQTT: version is %.2f\r\n", version);
Jan Jongboom 20:49c9daf2b0ff 152
vpcola 31:d34f6adb7a53 153 NetworkInterface* network = easy_connect(false);
Jan Jongboom 20:49c9daf2b0ff 154 if (!network) {
Jan Jongboom 20:49c9daf2b0ff 155 return -1;
Jan Jongboom 20:49c9daf2b0ff 156 }
Jan Jongboom 20:49c9daf2b0ff 157
vpcola 26:4b21de8043a5 158 #ifdef MQTT_USE_TLS
vpcola 26:4b21de8043a5 159 MQTTThreadedClient mqtt(network, SSL_CA_PEM);
vpcola 26:4b21de8043a5 160 #else
vpcola 23:06fac173529e 161 MQTTThreadedClient mqtt(network);
vpcola 26:4b21de8043a5 162 #endif
vpcola 26:4b21de8043a5 163
Jan Jongboom 20:49c9daf2b0ff 164
vpcola 23:06fac173529e 165 const char* hostname = "mqtt.mbedhacks.com";
vpcola 23:06fac173529e 166 // const char* hostname = "192.168.0.7";
vpcola 26:4b21de8043a5 167 #ifdef MQTT_USE_TLS
vpcola 26:4b21de8043a5 168 int port = 8883;
vpcola 26:4b21de8043a5 169 #else
icraggs 6:e4c690c45021 170 int port = 1883;
vpcola 26:4b21de8043a5 171 #endif
Jan Jongboom 20:49c9daf2b0ff 172
vpcola 26:4b21de8043a5 173 MQTTPacket_connectData logindata = MQTTPacket_connectData_initializer;
vpcola 26:4b21de8043a5 174 logindata.MQTTVersion = 3;
vpcola 26:4b21de8043a5 175 logindata.clientID.cstring = (char *) clientID;
vpcola 26:4b21de8043a5 176 logindata.username.cstring = (char *) userID;
vpcola 26:4b21de8043a5 177 logindata.password.cstring = (char *) password;
vpcola 26:4b21de8043a5 178
vpcola 26:4b21de8043a5 179 mqtt.setConnectionParameters(hostname, port, logindata);
vpcola 26:4b21de8043a5 180 mqtt.addTopicHandler(topic_1, messageArrived);
vpcola 26:4b21de8043a5 181 mqtt.addTopicHandler(topic_2, &testcb, &CallbackTest::messageArrived);
Jan Jongboom 20:49c9daf2b0ff 182
vpcola 22:826657a00c44 183 // Start the data producer
vpcola 23:06fac173529e 184 msgSender.start(mbed::callback(&mqtt, &MQTTThreadedClient::startListener));
vpcola 21:a7506c90aa84 185
vpcola 23:06fac173529e 186 int i = 0;
vpcola 21:a7506c90aa84 187 while(true)
vpcola 21:a7506c90aa84 188 {
vpcola 23:06fac173529e 189 PubMessage message;
vpcola 23:06fac173529e 190 message.qos = QOS0;
vpcola 23:06fac173529e 191 message.id = 123;
vpcola 21:a7506c90aa84 192
vpcola 23:06fac173529e 193 strcpy(&message.topic[0], topic_1);
vpcola 23:06fac173529e 194 sprintf(&message.payload[0], "Testing %d", i);
vpcola 23:06fac173529e 195 message.payloadlen = strlen((const char *) &message.payload[0]);
vpcola 23:06fac173529e 196 mqtt.publish(message);
vpcola 23:06fac173529e 197
vpcola 23:06fac173529e 198 i++;
vpcola 23:06fac173529e 199 //TODO: Nothing here yet ...
vpcola 25:326f00faa092 200 Thread::wait(6000);
vpcola 21:a7506c90aa84 201 }
Jan Jongboom 20:49c9daf2b0ff 202
icraggs 0:0cae29831d01 203 }