mqtt esp8266
Dependencies: X_NUCLEO_IKS01A3
PMK2021_MQTT_ESP8266_IKS01A3
main.cpp@4:c737f3d85a19, 2021-04-27 (annotated)
- Committer:
- nenad
- Date:
- Tue Apr 27 17:32:05 2021 +0000
- Revision:
- 4:c737f3d85a19
- Parent:
- 1:276a09a95334
mqtt esp8266 test
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
nenad | 0:75fa10a22545 | 1 | |
nenad | 0:75fa10a22545 | 2 | #include "mbed.h" |
nenad | 0:75fa10a22545 | 3 | #include "platform/mbed_thread.h" |
nenad | 0:75fa10a22545 | 4 | #include <MQTTClientMbedOs.h> |
nenad | 4:c737f3d85a19 | 5 | #include "XNucleoIKS01A3.h" |
nenad | 4:c737f3d85a19 | 6 | |
nenad | 0:75fa10a22545 | 7 | // Blinking rate in milliseconds |
nenad | 0:75fa10a22545 | 8 | #define BLINKING_RATE_MS 500 |
nenad | 0:75fa10a22545 | 9 | // Initialise the digital pin LED1 as an output |
nenad | 4:c737f3d85a19 | 10 | DigitalOut led(LED1); |
nenad | 1:276a09a95334 | 11 | |
nenad | 4:c737f3d85a19 | 12 | /* Instantiate the expansion board */ |
nenad | 4:c737f3d85a19 | 13 | static XNucleoIKS01A3 *mems_expansion_board = XNucleoIKS01A3::instance(D14, D15, D4, D5, A3, D6, A4); |
nenad | 4:c737f3d85a19 | 14 | |
nenad | 4:c737f3d85a19 | 15 | /* Retrieve the composing elements of the expansion board */ |
nenad | 4:c737f3d85a19 | 16 | static STTS751Sensor *t_sensor = mems_expansion_board->t_sensor; |
nenad | 4:c737f3d85a19 | 17 | |
nenad | 4:c737f3d85a19 | 18 | |
nenad | 4:c737f3d85a19 | 19 | volatile int mems_event = 0; |
nenad | 4:c737f3d85a19 | 20 | uint32_t previous_tick = 0; |
nenad | 4:c737f3d85a19 | 21 | uint32_t current_tick = 0; |
nenad | 4:c737f3d85a19 | 22 | uint8_t high = 0, low = 0; |
nenad | 4:c737f3d85a19 | 23 | float temperature = 0.0f; |
nenad | 4:c737f3d85a19 | 24 | char buffer[32]; |
nenad | 4:c737f3d85a19 | 25 | |
nenad | 4:c737f3d85a19 | 26 | void INT_cb(); |
nenad | 4:c737f3d85a19 | 27 | |
nenad | 4:c737f3d85a19 | 28 | /* Helper function for printing floats & doubles */ |
nenad | 4:c737f3d85a19 | 29 | static char *print_double(char *str, double v, int decimalDigits = 2) |
nenad | 4:c737f3d85a19 | 30 | { |
nenad | 4:c737f3d85a19 | 31 | int i = 1; |
nenad | 4:c737f3d85a19 | 32 | int intPart, fractPart; |
nenad | 4:c737f3d85a19 | 33 | int len; |
nenad | 4:c737f3d85a19 | 34 | char *ptr; |
nenad | 4:c737f3d85a19 | 35 | |
nenad | 4:c737f3d85a19 | 36 | /* prepare decimal digits multiplicator */ |
nenad | 4:c737f3d85a19 | 37 | for (; decimalDigits != 0; i *= 10, decimalDigits--); |
nenad | 4:c737f3d85a19 | 38 | |
nenad | 4:c737f3d85a19 | 39 | /* calculate integer & fractinal parts */ |
nenad | 4:c737f3d85a19 | 40 | intPart = (int)v; |
nenad | 4:c737f3d85a19 | 41 | fractPart = (int)((v - (double)(int)v) * i); |
nenad | 4:c737f3d85a19 | 42 | |
nenad | 4:c737f3d85a19 | 43 | /* fill in integer part */ |
nenad | 4:c737f3d85a19 | 44 | sprintf(str, "%i.", intPart); |
nenad | 4:c737f3d85a19 | 45 | |
nenad | 4:c737f3d85a19 | 46 | /* prepare fill in of fractional part */ |
nenad | 4:c737f3d85a19 | 47 | len = strlen(str); |
nenad | 4:c737f3d85a19 | 48 | ptr = &str[len]; |
nenad | 4:c737f3d85a19 | 49 | |
nenad | 4:c737f3d85a19 | 50 | /* fill in leading fractional zeros */ |
nenad | 4:c737f3d85a19 | 51 | for (i /= 10; i > 1; i /= 10, ptr++) { |
nenad | 4:c737f3d85a19 | 52 | if (fractPart >= i) { |
nenad | 4:c737f3d85a19 | 53 | break; |
nenad | 4:c737f3d85a19 | 54 | } |
nenad | 4:c737f3d85a19 | 55 | *ptr = '0'; |
nenad | 4:c737f3d85a19 | 56 | } |
nenad | 4:c737f3d85a19 | 57 | |
nenad | 4:c737f3d85a19 | 58 | /* fill in (rest of) fractional part */ |
nenad | 4:c737f3d85a19 | 59 | sprintf(ptr, "%i", fractPart); |
nenad | 4:c737f3d85a19 | 60 | |
nenad | 4:c737f3d85a19 | 61 | return str; |
nenad | 4:c737f3d85a19 | 62 | } |
nenad | 0:75fa10a22545 | 63 | |
nenad | 0:75fa10a22545 | 64 | InterruptIn button(USER_BUTTON); |
nenad | 0:75fa10a22545 | 65 | int arrivedcount = 0; |
nenad | 0:75fa10a22545 | 66 | TCPSocket socket; |
nenad | 0:75fa10a22545 | 67 | MQTTClient client(&socket); |
nenad | 0:75fa10a22545 | 68 | MQTT::Message message; |
nenad | 0:75fa10a22545 | 69 | int button_pressed=0; |
nenad | 0:75fa10a22545 | 70 | |
nenad | 4:c737f3d85a19 | 71 | char* topic_pub = "PMK-client-temperature"; |
nenad | 4:c737f3d85a19 | 72 | char* topic_sub = "PMK-client-topic_sub"; |
nenad | 1:276a09a95334 | 73 | |
nenad | 1:276a09a95334 | 74 | WiFiInterface *wifi; |
nenad | 1:276a09a95334 | 75 | |
nenad | 1:276a09a95334 | 76 | const char *sec2str(nsapi_security_t sec) |
nenad | 1:276a09a95334 | 77 | { |
nenad | 1:276a09a95334 | 78 | switch (sec) { |
nenad | 1:276a09a95334 | 79 | case NSAPI_SECURITY_NONE: |
nenad | 1:276a09a95334 | 80 | return "None"; |
nenad | 1:276a09a95334 | 81 | case NSAPI_SECURITY_WEP: |
nenad | 1:276a09a95334 | 82 | return "WEP"; |
nenad | 1:276a09a95334 | 83 | case NSAPI_SECURITY_WPA: |
nenad | 1:276a09a95334 | 84 | return "WPA"; |
nenad | 1:276a09a95334 | 85 | case NSAPI_SECURITY_WPA2: |
nenad | 1:276a09a95334 | 86 | return "WPA2"; |
nenad | 1:276a09a95334 | 87 | case NSAPI_SECURITY_WPA_WPA2: |
nenad | 1:276a09a95334 | 88 | return "WPA/WPA2"; |
nenad | 1:276a09a95334 | 89 | case NSAPI_SECURITY_UNKNOWN: |
nenad | 1:276a09a95334 | 90 | default: |
nenad | 1:276a09a95334 | 91 | return "Unknown"; |
nenad | 1:276a09a95334 | 92 | } |
nenad | 1:276a09a95334 | 93 | } |
nenad | 1:276a09a95334 | 94 | |
nenad | 1:276a09a95334 | 95 | int scan_demo(WiFiInterface *wifi) |
nenad | 1:276a09a95334 | 96 | { |
nenad | 1:276a09a95334 | 97 | WiFiAccessPoint *ap; |
nenad | 1:276a09a95334 | 98 | printf("Scan:\n"); |
nenad | 1:276a09a95334 | 99 | int count = wifi->scan(NULL,0); |
nenad | 1:276a09a95334 | 100 | if (count <= 0) { |
nenad | 1:276a09a95334 | 101 | printf("scan() failed with return value: %d\n", count); |
nenad | 1:276a09a95334 | 102 | return 0; |
nenad | 1:276a09a95334 | 103 | } |
nenad | 1:276a09a95334 | 104 | /* Limit number of network arbitrary to 15 */ |
nenad | 1:276a09a95334 | 105 | count = count < 15 ? count : 15; |
nenad | 1:276a09a95334 | 106 | ap = new WiFiAccessPoint[count]; |
nenad | 1:276a09a95334 | 107 | count = wifi->scan(ap, count); |
nenad | 1:276a09a95334 | 108 | if (count <= 0) { |
nenad | 1:276a09a95334 | 109 | printf("scan() failed with return value: %d\n", count); |
nenad | 1:276a09a95334 | 110 | return 0; |
nenad | 1:276a09a95334 | 111 | } |
nenad | 1:276a09a95334 | 112 | for (int i = 0; i < count; i++) { |
nenad | 1:276a09a95334 | 113 | printf("Network: %s secured: %s BSSID: %hhX:%hhX:%hhX:%hhx:%hhx:%hhx RSSI: %hhd Ch: %hhd\n", ap[i].get_ssid(), |
nenad | 1:276a09a95334 | 114 | sec2str(ap[i].get_security()), ap[i].get_bssid()[0], ap[i].get_bssid()[1], ap[i].get_bssid()[2], |
nenad | 1:276a09a95334 | 115 | ap[i].get_bssid()[3], ap[i].get_bssid()[4], ap[i].get_bssid()[5], ap[i].get_rssi(), ap[i].get_channel()); |
nenad | 1:276a09a95334 | 116 | } |
nenad | 1:276a09a95334 | 117 | printf("%d networks available.\n", count); |
nenad | 1:276a09a95334 | 118 | delete[] ap; |
nenad | 1:276a09a95334 | 119 | return count; |
nenad | 1:276a09a95334 | 120 | } |
nenad | 1:276a09a95334 | 121 | |
nenad | 0:75fa10a22545 | 122 | void messageArrived(MQTT::MessageData& md) |
nenad | 0:75fa10a22545 | 123 | { |
nenad | 0:75fa10a22545 | 124 | MQTT::Message &message = md.message; |
nenad | 1:276a09a95334 | 125 | printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id); |
nenad | 1:276a09a95334 | 126 | printf("Payload %.*s\r\n", message.payloadlen, (char*)message.payload); |
nenad | 0:75fa10a22545 | 127 | ++arrivedcount; |
nenad | 0:75fa10a22545 | 128 | } |
nenad | 0:75fa10a22545 | 129 | |
nenad | 4:c737f3d85a19 | 130 | void buttonFunction() { |
nenad | 4:c737f3d85a19 | 131 | button_pressed=1; |
nenad | 0:75fa10a22545 | 132 | } |
nenad | 0:75fa10a22545 | 133 | |
nenad | 0:75fa10a22545 | 134 | |
nenad | 0:75fa10a22545 | 135 | |
nenad | 0:75fa10a22545 | 136 | |
nenad | 0:75fa10a22545 | 137 | int main() |
nenad | 0:75fa10a22545 | 138 | { |
nenad | 4:c737f3d85a19 | 139 | /* Attach callback to STTS751 INT */ |
nenad | 4:c737f3d85a19 | 140 | t_sensor->attach_int_irq(&INT_cb); |
nenad | 4:c737f3d85a19 | 141 | /* Enable STTS751 temperature sensor */ |
nenad | 4:c737f3d85a19 | 142 | t_sensor->enable(); |
nenad | 4:c737f3d85a19 | 143 | /* Set ODR to 4Hz */ |
nenad | 4:c737f3d85a19 | 144 | t_sensor->set_odr(4.0f); |
nenad | 4:c737f3d85a19 | 145 | /* Set Low Temperature Threshold */ |
nenad | 4:c737f3d85a19 | 146 | t_sensor->set_low_temp_thr(22.0f); |
nenad | 4:c737f3d85a19 | 147 | /* Set High Temperature Threshold */ |
nenad | 4:c737f3d85a19 | 148 | t_sensor->set_high_temp_thr(28.0f); |
nenad | 4:c737f3d85a19 | 149 | /* Enable Event pin */ |
nenad | 4:c737f3d85a19 | 150 | t_sensor->set_event_pin(1); |
nenad | 4:c737f3d85a19 | 151 | /* Get beginning status */ |
nenad | 4:c737f3d85a19 | 152 | t_sensor->get_temp_limit_status(NULL, NULL, NULL); |
nenad | 4:c737f3d85a19 | 153 | |
nenad | 0:75fa10a22545 | 154 | button.rise(&buttonFunction); // attach the address of the flip function to the rising edge |
nenad | 0:75fa10a22545 | 155 | |
nenad | 0:75fa10a22545 | 156 | const char* hostname = "broker.mqttdashboard.com"; |
nenad | 0:75fa10a22545 | 157 | int port = 1883; |
nenad | 0:75fa10a22545 | 158 | |
nenad | 1:276a09a95334 | 159 | wifi = WiFiInterface::get_default_instance(); |
nenad | 1:276a09a95334 | 160 | if (!wifi) { |
nenad | 1:276a09a95334 | 161 | printf("ERROR: No WiFiInterface found.\n"); |
nenad | 1:276a09a95334 | 162 | return -1; |
nenad | 1:276a09a95334 | 163 | } |
nenad | 1:276a09a95334 | 164 | |
nenad | 1:276a09a95334 | 165 | int count = scan_demo(wifi); |
nenad | 1:276a09a95334 | 166 | if (count == 0) { |
nenad | 1:276a09a95334 | 167 | printf("No WIFI APs found - can't continue further.\n"); |
nenad | 1:276a09a95334 | 168 | return -1; |
nenad | 1:276a09a95334 | 169 | } |
nenad | 0:75fa10a22545 | 170 | |
nenad | 1:276a09a95334 | 171 | printf("\nConnecting to %s...\n", MBED_CONF_APP_WIFI_SSID); |
nenad | 1:276a09a95334 | 172 | int ret = wifi->connect(MBED_CONF_APP_WIFI_SSID, MBED_CONF_APP_WIFI_PASSWORD, NSAPI_SECURITY_WPA_WPA2); |
nenad | 1:276a09a95334 | 173 | if (ret != 0) { |
nenad | 1:276a09a95334 | 174 | printf("\nConnection error: %d\n", ret); |
nenad | 1:276a09a95334 | 175 | return -1; |
nenad | 1:276a09a95334 | 176 | } |
nenad | 1:276a09a95334 | 177 | |
nenad | 1:276a09a95334 | 178 | printf("Success\n\n"); |
nenad | 1:276a09a95334 | 179 | printf("MAC: %s\n", wifi->get_mac_address()); |
nenad | 1:276a09a95334 | 180 | printf("IP: %s\n", wifi->get_ip_address()); |
nenad | 1:276a09a95334 | 181 | printf("Netmask: %s\n", wifi->get_netmask()); |
nenad | 1:276a09a95334 | 182 | printf("Gateway: %s\n", wifi->get_gateway()); |
nenad | 4:c737f3d85a19 | 183 | printf("RSSI: %d\n\n", wifi->get_rssi()); |
nenad | 4:c737f3d85a19 | 184 | |
nenad | 1:276a09a95334 | 185 | socket.open(wifi); |
nenad | 0:75fa10a22545 | 186 | socket.connect(hostname, port); |
nenad | 0:75fa10a22545 | 187 | |
nenad | 0:75fa10a22545 | 188 | int rc=0; |
nenad | 0:75fa10a22545 | 189 | |
nenad | 0:75fa10a22545 | 190 | MQTTPacket_connectData data = MQTTPacket_connectData_initializer; |
nenad | 0:75fa10a22545 | 191 | data.MQTTVersion = 3; |
nenad | 4:c737f3d85a19 | 192 | data.clientID.cstring = "PMK-client"; |
nenad | 0:75fa10a22545 | 193 | //data.username.cstring = "testuser"; |
nenad | 0:75fa10a22545 | 194 | //data.password.cstring = "testpassword"; |
nenad | 0:75fa10a22545 | 195 | if ((rc = client.connect(data)) != 0) |
nenad | 1:276a09a95334 | 196 | printf("rc from MQTT connect is %d\r\n", rc); |
nenad | 0:75fa10a22545 | 197 | |
nenad | 0:75fa10a22545 | 198 | if ((rc = client.subscribe(topic_sub, MQTT::QOS2, messageArrived)) != 0) |
nenad | 1:276a09a95334 | 199 | printf("rc from MQTT subscribe is %d\r\n", rc); |
nenad | 0:75fa10a22545 | 200 | |
nenad | 0:75fa10a22545 | 201 | while (true) { |
nenad | 4:c737f3d85a19 | 202 | t_sensor->get_temperature(&temperature); |
nenad | 4:c737f3d85a19 | 203 | printf("Temp[C]: %7s C\r\n", print_double(buffer, temperature)); |
nenad | 0:75fa10a22545 | 204 | led = !led; |
nenad | 0:75fa10a22545 | 205 | thread_sleep_for(BLINKING_RATE_MS); |
nenad | 0:75fa10a22545 | 206 | if (button_pressed==1) { |
nenad | 0:75fa10a22545 | 207 | button_pressed=0; |
nenad | 4:c737f3d85a19 | 208 | printf("Publishing data\r\n"); |
nenad | 0:75fa10a22545 | 209 | // QoS 0 |
nenad | 0:75fa10a22545 | 210 | char buf[100]; |
nenad | 4:c737f3d85a19 | 211 | sprintf(buf, "Temp[C]: %7s C\r\n", print_double(buffer, temperature)); |
nenad | 0:75fa10a22545 | 212 | message.qos = MQTT::QOS0; |
nenad | 0:75fa10a22545 | 213 | message.retained = false; |
nenad | 0:75fa10a22545 | 214 | message.dup = false; |
nenad | 0:75fa10a22545 | 215 | message.payload = (void*)buf; |
nenad | 0:75fa10a22545 | 216 | message.payloadlen = strlen(buf)+1; |
nenad | 4:c737f3d85a19 | 217 | client.publish(topic_pub, message); |
nenad | 0:75fa10a22545 | 218 | } |
nenad | 4:c737f3d85a19 | 219 | printf("Yielding"); |
nenad | 0:75fa10a22545 | 220 | client.yield(1000); |
nenad | 4:c737f3d85a19 | 221 | printf(" -> Yielded\r\n"); |
nenad | 0:75fa10a22545 | 222 | |
nenad | 0:75fa10a22545 | 223 | } |
nenad | 0:75fa10a22545 | 224 | } |
nenad | 4:c737f3d85a19 | 225 | |
nenad | 4:c737f3d85a19 | 226 | void INT_cb() |
nenad | 4:c737f3d85a19 | 227 | { |
nenad | 4:c737f3d85a19 | 228 | mems_event = 1; |
nenad | 4:c737f3d85a19 | 229 | } |