Nenad Jovicic
/
PMK2021_MQTT_ESP8266_test
MQTT ESP8266 basic test
Diff: main.cpp
- Revision:
- 1:276a09a95334
- Parent:
- 0:75fa10a22545
--- a/main.cpp Thu Apr 30 23:31:41 2020 +0000 +++ b/main.cpp Sat May 02 17:58:25 2020 +0000 @@ -4,14 +4,14 @@ */ #include "mbed.h" -#include "EthernetInterface.h" +//#include "EthernetInterface.h" #include "platform/mbed_thread.h" #include <MQTTClientMbedOs.h> // Blinking rate in milliseconds #define BLINKING_RATE_MS 500 // Initialise the digital pin LED1 as an output DigitalOut led(LED1); -Serial pc(USBTX,USBRX); + InterruptIn button(USER_BUTTON); @@ -27,11 +27,69 @@ char* topic_sub = "mbed-sample-sub"; + + +WiFiInterface *wifi; + +const char *sec2str(nsapi_security_t sec) +{ + switch (sec) { + case NSAPI_SECURITY_NONE: + return "None"; + case NSAPI_SECURITY_WEP: + return "WEP"; + case NSAPI_SECURITY_WPA: + return "WPA"; + case NSAPI_SECURITY_WPA2: + return "WPA2"; + case NSAPI_SECURITY_WPA_WPA2: + return "WPA/WPA2"; + case NSAPI_SECURITY_UNKNOWN: + default: + return "Unknown"; + } +} + +int scan_demo(WiFiInterface *wifi) +{ + WiFiAccessPoint *ap; + + printf("Scan:\n"); + + int count = wifi->scan(NULL,0); + + if (count <= 0) { + printf("scan() failed with return value: %d\n", count); + return 0; + } + + /* Limit number of network arbitrary to 15 */ + count = count < 15 ? count : 15; + + ap = new WiFiAccessPoint[count]; + count = wifi->scan(ap, count); + + if (count <= 0) { + printf("scan() failed with return value: %d\n", count); + return 0; + } + + for (int i = 0; i < count; i++) { + printf("Network: %s secured: %s BSSID: %hhX:%hhX:%hhX:%hhx:%hhx:%hhx RSSI: %hhd Ch: %hhd\n", ap[i].get_ssid(), + sec2str(ap[i].get_security()), ap[i].get_bssid()[0], ap[i].get_bssid()[1], ap[i].get_bssid()[2], + ap[i].get_bssid()[3], ap[i].get_bssid()[4], ap[i].get_bssid()[5], ap[i].get_rssi(), ap[i].get_channel()); + } + printf("%d networks available.\n", count); + + delete[] ap; + return count; +} + void messageArrived(MQTT::MessageData& md) { MQTT::Message &message = md.message; - pc.printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id); - pc.printf("Payload %.*s\r\n", message.payloadlen, (char*)message.payload); + printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id); + printf("Payload %.*s\r\n", message.payloadlen, (char*)message.payload); ++arrivedcount; } @@ -51,19 +109,39 @@ const char* hostname = "broker.mqttdashboard.com"; int port = 1883; // Network interface - EthernetInterface net; + //EthernetInterface net; - // Bring up the ethernet interface - printf("Ethernet socket example\n"); - net.connect(); + wifi = WiFiInterface::get_default_instance(); + if (!wifi) { + printf("ERROR: No WiFiInterface found.\n"); + return -1; + } + + int count = scan_demo(wifi); + if (count == 0) { + printf("No WIFI APs found - can't continue further.\n"); + return -1; + } - // Show the network address - const char *ip = net.get_ip_address(); - pc.printf("IP address is: %s\n", ip ? ip : "No IP"); - + printf("\nConnecting to %s...\n", MBED_CONF_APP_WIFI_SSID); + int ret = wifi->connect(MBED_CONF_APP_WIFI_SSID, MBED_CONF_APP_WIFI_PASSWORD, NSAPI_SECURITY_WPA_WPA2); + if (ret != 0) { + printf("\nConnection error: %d\n", ret); + return -1; + } + + printf("Success\n\n"); + printf("MAC: %s\n", wifi->get_mac_address()); + printf("IP: %s\n", wifi->get_ip_address()); + printf("Netmask: %s\n", wifi->get_netmask()); + printf("Gateway: %s\n", wifi->get_gateway()); + printf("RSSI: %d\n\n", wifi->get_rssi()); + + + //client = MQTTClient::(&socket); - socket.open(&net); + socket.open(wifi); socket.connect(hostname, port); int rc=0; @@ -74,10 +152,10 @@ //data.username.cstring = "testuser"; //data.password.cstring = "testpassword"; if ((rc = client.connect(data)) != 0) - pc.printf("rc from MQTT connect is %d\r\n", rc); + printf("rc from MQTT connect is %d\r\n", rc); if ((rc = client.subscribe(topic_sub, MQTT::QOS2, messageArrived)) != 0) - pc.printf("rc from MQTT subscribe is %d\r\n", rc); + printf("rc from MQTT subscribe is %d\r\n", rc); @@ -90,7 +168,7 @@ thread_sleep_for(BLINKING_RATE_MS); if (button_pressed==1) { button_pressed=0; - pc.printf("sace publish\r\n"); + printf("sace publish\r\n"); // QoS 0 char buf[100]; sprintf(buf, "Hello World! QoS 0 message from app version %f\r\n", version); @@ -104,9 +182,9 @@ //client.yield(1000); //pc.printf("izjildovo\r\n"); } - pc.printf("sace jild\r\n"); + printf("sace jild\r\n"); client.yield(1000); - pc.printf("izjildovo\r\n"); + printf("izjildovo\r\n"); } }