Nenad Jovicic
/
PMK2021_MQTT_ETHERNET_SERVER
Ethernet mqtt server
PMK2021_MQTT_ETHERNET_SERVER
main.cpp@1:276a09a95334, 2020-05-02 (annotated)
- Committer:
- nenad
- Date:
- Sat May 02 17:58:25 2020 +0000
- Revision:
- 1:276a09a95334
- Parent:
- 0:75fa10a22545
- Child:
- 4:5b78021768e2
PMK2020 MQTT ESP8266 client
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
nenad | 0:75fa10a22545 | 1 | /* mbed Microcontroller Library |
nenad | 0:75fa10a22545 | 2 | * Copyright (c) 2019 ARM Limited |
nenad | 0:75fa10a22545 | 3 | * SPDX-License-Identifier: Apache-2.0 |
nenad | 0:75fa10a22545 | 4 | */ |
nenad | 0:75fa10a22545 | 5 | |
nenad | 0:75fa10a22545 | 6 | #include "mbed.h" |
nenad | 1:276a09a95334 | 7 | //#include "EthernetInterface.h" |
nenad | 0:75fa10a22545 | 8 | #include "platform/mbed_thread.h" |
nenad | 0:75fa10a22545 | 9 | #include <MQTTClientMbedOs.h> |
nenad | 0:75fa10a22545 | 10 | // Blinking rate in milliseconds |
nenad | 0:75fa10a22545 | 11 | #define BLINKING_RATE_MS 500 |
nenad | 0:75fa10a22545 | 12 | // Initialise the digital pin LED1 as an output |
nenad | 0:75fa10a22545 | 13 | DigitalOut led(LED1); |
nenad | 1:276a09a95334 | 14 | |
nenad | 0:75fa10a22545 | 15 | |
nenad | 0:75fa10a22545 | 16 | InterruptIn button(USER_BUTTON); |
nenad | 0:75fa10a22545 | 17 | |
nenad | 0:75fa10a22545 | 18 | int arrivedcount = 0; |
nenad | 0:75fa10a22545 | 19 | TCPSocket socket; |
nenad | 0:75fa10a22545 | 20 | MQTTClient client(&socket); |
nenad | 0:75fa10a22545 | 21 | MQTT::Message message; |
nenad | 0:75fa10a22545 | 22 | |
nenad | 0:75fa10a22545 | 23 | int button_pressed=0; |
nenad | 0:75fa10a22545 | 24 | |
nenad | 0:75fa10a22545 | 25 | float version = 0.6; |
nenad | 0:75fa10a22545 | 26 | char* topic = "mbed-sample-pub"; |
nenad | 0:75fa10a22545 | 27 | char* topic_sub = "mbed-sample-sub"; |
nenad | 0:75fa10a22545 | 28 | |
nenad | 0:75fa10a22545 | 29 | |
nenad | 1:276a09a95334 | 30 | |
nenad | 1:276a09a95334 | 31 | |
nenad | 1:276a09a95334 | 32 | WiFiInterface *wifi; |
nenad | 1:276a09a95334 | 33 | |
nenad | 1:276a09a95334 | 34 | const char *sec2str(nsapi_security_t sec) |
nenad | 1:276a09a95334 | 35 | { |
nenad | 1:276a09a95334 | 36 | switch (sec) { |
nenad | 1:276a09a95334 | 37 | case NSAPI_SECURITY_NONE: |
nenad | 1:276a09a95334 | 38 | return "None"; |
nenad | 1:276a09a95334 | 39 | case NSAPI_SECURITY_WEP: |
nenad | 1:276a09a95334 | 40 | return "WEP"; |
nenad | 1:276a09a95334 | 41 | case NSAPI_SECURITY_WPA: |
nenad | 1:276a09a95334 | 42 | return "WPA"; |
nenad | 1:276a09a95334 | 43 | case NSAPI_SECURITY_WPA2: |
nenad | 1:276a09a95334 | 44 | return "WPA2"; |
nenad | 1:276a09a95334 | 45 | case NSAPI_SECURITY_WPA_WPA2: |
nenad | 1:276a09a95334 | 46 | return "WPA/WPA2"; |
nenad | 1:276a09a95334 | 47 | case NSAPI_SECURITY_UNKNOWN: |
nenad | 1:276a09a95334 | 48 | default: |
nenad | 1:276a09a95334 | 49 | return "Unknown"; |
nenad | 1:276a09a95334 | 50 | } |
nenad | 1:276a09a95334 | 51 | } |
nenad | 1:276a09a95334 | 52 | |
nenad | 1:276a09a95334 | 53 | int scan_demo(WiFiInterface *wifi) |
nenad | 1:276a09a95334 | 54 | { |
nenad | 1:276a09a95334 | 55 | WiFiAccessPoint *ap; |
nenad | 1:276a09a95334 | 56 | |
nenad | 1:276a09a95334 | 57 | printf("Scan:\n"); |
nenad | 1:276a09a95334 | 58 | |
nenad | 1:276a09a95334 | 59 | int count = wifi->scan(NULL,0); |
nenad | 1:276a09a95334 | 60 | |
nenad | 1:276a09a95334 | 61 | if (count <= 0) { |
nenad | 1:276a09a95334 | 62 | printf("scan() failed with return value: %d\n", count); |
nenad | 1:276a09a95334 | 63 | return 0; |
nenad | 1:276a09a95334 | 64 | } |
nenad | 1:276a09a95334 | 65 | |
nenad | 1:276a09a95334 | 66 | /* Limit number of network arbitrary to 15 */ |
nenad | 1:276a09a95334 | 67 | count = count < 15 ? count : 15; |
nenad | 1:276a09a95334 | 68 | |
nenad | 1:276a09a95334 | 69 | ap = new WiFiAccessPoint[count]; |
nenad | 1:276a09a95334 | 70 | count = wifi->scan(ap, count); |
nenad | 1:276a09a95334 | 71 | |
nenad | 1:276a09a95334 | 72 | if (count <= 0) { |
nenad | 1:276a09a95334 | 73 | printf("scan() failed with return value: %d\n", count); |
nenad | 1:276a09a95334 | 74 | return 0; |
nenad | 1:276a09a95334 | 75 | } |
nenad | 1:276a09a95334 | 76 | |
nenad | 1:276a09a95334 | 77 | for (int i = 0; i < count; i++) { |
nenad | 1:276a09a95334 | 78 | printf("Network: %s secured: %s BSSID: %hhX:%hhX:%hhX:%hhx:%hhx:%hhx RSSI: %hhd Ch: %hhd\n", ap[i].get_ssid(), |
nenad | 1:276a09a95334 | 79 | sec2str(ap[i].get_security()), ap[i].get_bssid()[0], ap[i].get_bssid()[1], ap[i].get_bssid()[2], |
nenad | 1:276a09a95334 | 80 | 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 | 81 | } |
nenad | 1:276a09a95334 | 82 | printf("%d networks available.\n", count); |
nenad | 1:276a09a95334 | 83 | |
nenad | 1:276a09a95334 | 84 | delete[] ap; |
nenad | 1:276a09a95334 | 85 | return count; |
nenad | 1:276a09a95334 | 86 | } |
nenad | 1:276a09a95334 | 87 | |
nenad | 0:75fa10a22545 | 88 | void messageArrived(MQTT::MessageData& md) |
nenad | 0:75fa10a22545 | 89 | { |
nenad | 0:75fa10a22545 | 90 | MQTT::Message &message = md.message; |
nenad | 1:276a09a95334 | 91 | printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id); |
nenad | 1:276a09a95334 | 92 | printf("Payload %.*s\r\n", message.payloadlen, (char*)message.payload); |
nenad | 0:75fa10a22545 | 93 | ++arrivedcount; |
nenad | 0:75fa10a22545 | 94 | } |
nenad | 0:75fa10a22545 | 95 | |
nenad | 0:75fa10a22545 | 96 | void buttonFunction() { |
nenad | 0:75fa10a22545 | 97 | |
nenad | 0:75fa10a22545 | 98 | button_pressed=1; |
nenad | 0:75fa10a22545 | 99 | |
nenad | 0:75fa10a22545 | 100 | } |
nenad | 0:75fa10a22545 | 101 | |
nenad | 0:75fa10a22545 | 102 | |
nenad | 0:75fa10a22545 | 103 | |
nenad | 0:75fa10a22545 | 104 | |
nenad | 0:75fa10a22545 | 105 | int main() |
nenad | 0:75fa10a22545 | 106 | { |
nenad | 0:75fa10a22545 | 107 | button.rise(&buttonFunction); // attach the address of the flip function to the rising edge |
nenad | 0:75fa10a22545 | 108 | |
nenad | 0:75fa10a22545 | 109 | const char* hostname = "broker.mqttdashboard.com"; |
nenad | 0:75fa10a22545 | 110 | int port = 1883; |
nenad | 0:75fa10a22545 | 111 | // Network interface |
nenad | 1:276a09a95334 | 112 | //EthernetInterface net; |
nenad | 0:75fa10a22545 | 113 | |
nenad | 1:276a09a95334 | 114 | wifi = WiFiInterface::get_default_instance(); |
nenad | 1:276a09a95334 | 115 | if (!wifi) { |
nenad | 1:276a09a95334 | 116 | printf("ERROR: No WiFiInterface found.\n"); |
nenad | 1:276a09a95334 | 117 | return -1; |
nenad | 1:276a09a95334 | 118 | } |
nenad | 1:276a09a95334 | 119 | |
nenad | 1:276a09a95334 | 120 | int count = scan_demo(wifi); |
nenad | 1:276a09a95334 | 121 | if (count == 0) { |
nenad | 1:276a09a95334 | 122 | printf("No WIFI APs found - can't continue further.\n"); |
nenad | 1:276a09a95334 | 123 | return -1; |
nenad | 1:276a09a95334 | 124 | } |
nenad | 0:75fa10a22545 | 125 | |
nenad | 1:276a09a95334 | 126 | printf("\nConnecting to %s...\n", MBED_CONF_APP_WIFI_SSID); |
nenad | 1:276a09a95334 | 127 | int ret = wifi->connect(MBED_CONF_APP_WIFI_SSID, MBED_CONF_APP_WIFI_PASSWORD, NSAPI_SECURITY_WPA_WPA2); |
nenad | 1:276a09a95334 | 128 | if (ret != 0) { |
nenad | 1:276a09a95334 | 129 | printf("\nConnection error: %d\n", ret); |
nenad | 1:276a09a95334 | 130 | return -1; |
nenad | 1:276a09a95334 | 131 | } |
nenad | 1:276a09a95334 | 132 | |
nenad | 1:276a09a95334 | 133 | printf("Success\n\n"); |
nenad | 1:276a09a95334 | 134 | printf("MAC: %s\n", wifi->get_mac_address()); |
nenad | 1:276a09a95334 | 135 | printf("IP: %s\n", wifi->get_ip_address()); |
nenad | 1:276a09a95334 | 136 | printf("Netmask: %s\n", wifi->get_netmask()); |
nenad | 1:276a09a95334 | 137 | printf("Gateway: %s\n", wifi->get_gateway()); |
nenad | 1:276a09a95334 | 138 | printf("RSSI: %d\n\n", wifi->get_rssi()); |
nenad | 1:276a09a95334 | 139 | |
nenad | 1:276a09a95334 | 140 | |
nenad | 1:276a09a95334 | 141 | |
nenad | 0:75fa10a22545 | 142 | |
nenad | 0:75fa10a22545 | 143 | //client = MQTTClient::(&socket); |
nenad | 1:276a09a95334 | 144 | socket.open(wifi); |
nenad | 0:75fa10a22545 | 145 | socket.connect(hostname, port); |
nenad | 0:75fa10a22545 | 146 | |
nenad | 0:75fa10a22545 | 147 | int rc=0; |
nenad | 0:75fa10a22545 | 148 | |
nenad | 0:75fa10a22545 | 149 | MQTTPacket_connectData data = MQTTPacket_connectData_initializer; |
nenad | 0:75fa10a22545 | 150 | data.MQTTVersion = 3; |
nenad | 0:75fa10a22545 | 151 | data.clientID.cstring = "mbed-sample"; |
nenad | 0:75fa10a22545 | 152 | //data.username.cstring = "testuser"; |
nenad | 0:75fa10a22545 | 153 | //data.password.cstring = "testpassword"; |
nenad | 0:75fa10a22545 | 154 | if ((rc = client.connect(data)) != 0) |
nenad | 1:276a09a95334 | 155 | printf("rc from MQTT connect is %d\r\n", rc); |
nenad | 0:75fa10a22545 | 156 | |
nenad | 0:75fa10a22545 | 157 | if ((rc = client.subscribe(topic_sub, MQTT::QOS2, messageArrived)) != 0) |
nenad | 1:276a09a95334 | 158 | printf("rc from MQTT subscribe is %d\r\n", rc); |
nenad | 0:75fa10a22545 | 159 | |
nenad | 0:75fa10a22545 | 160 | |
nenad | 0:75fa10a22545 | 161 | |
nenad | 0:75fa10a22545 | 162 | |
nenad | 0:75fa10a22545 | 163 | |
nenad | 0:75fa10a22545 | 164 | |
nenad | 0:75fa10a22545 | 165 | |
nenad | 0:75fa10a22545 | 166 | while (true) { |
nenad | 0:75fa10a22545 | 167 | led = !led; |
nenad | 0:75fa10a22545 | 168 | thread_sleep_for(BLINKING_RATE_MS); |
nenad | 0:75fa10a22545 | 169 | if (button_pressed==1) { |
nenad | 0:75fa10a22545 | 170 | button_pressed=0; |
nenad | 1:276a09a95334 | 171 | printf("sace publish\r\n"); |
nenad | 0:75fa10a22545 | 172 | // QoS 0 |
nenad | 0:75fa10a22545 | 173 | char buf[100]; |
nenad | 0:75fa10a22545 | 174 | sprintf(buf, "Hello World! QoS 0 message from app version %f\r\n", version); |
nenad | 0:75fa10a22545 | 175 | message.qos = MQTT::QOS0; |
nenad | 0:75fa10a22545 | 176 | message.retained = false; |
nenad | 0:75fa10a22545 | 177 | message.dup = false; |
nenad | 0:75fa10a22545 | 178 | message.payload = (void*)buf; |
nenad | 0:75fa10a22545 | 179 | message.payloadlen = strlen(buf)+1; |
nenad | 0:75fa10a22545 | 180 | client.publish(topic, message); |
nenad | 0:75fa10a22545 | 181 | //pc.printf("sace jild\r\n"); |
nenad | 0:75fa10a22545 | 182 | //client.yield(1000); |
nenad | 0:75fa10a22545 | 183 | //pc.printf("izjildovo\r\n"); |
nenad | 0:75fa10a22545 | 184 | } |
nenad | 1:276a09a95334 | 185 | printf("sace jild\r\n"); |
nenad | 0:75fa10a22545 | 186 | client.yield(1000); |
nenad | 1:276a09a95334 | 187 | printf("izjildovo\r\n"); |
nenad | 0:75fa10a22545 | 188 | |
nenad | 0:75fa10a22545 | 189 | } |
nenad | 0:75fa10a22545 | 190 | } |