On Node-Red and MQTT
Dependencies: mbed ESP8266Interface MbedJSONValue MQTT JSON
Diff: main.cpp
- Revision:
- 20:568d04eb3d63
- Parent:
- 19:9dfb938f07eb
- Child:
- 21:f08f17225c7c
diff -r 9dfb938f07eb -r 568d04eb3d63 main.cpp --- a/main.cpp Thu Mar 07 08:55:54 2019 +0000 +++ b/main.cpp Fri Mar 08 04:51:18 2019 +0000 @@ -4,17 +4,20 @@ #include "MbedJSONValue.h" char buf[100]; -MQTTESP8266 ipstack(D1, D0, D10, "BHNTG1682GFFE2","220960b5"); // change to match your wifi access point +MQTTESP8266 ipstack(D1, D0, D10, "Sidsap10","Arduino111"); // change to match your wifi access point float version = 0.47; char* topic = "k64"; char* topic2 = "k64rec"; char* topic3 = "bulb"; char* key2 = "key"; -char* hostname = "192.168.0.6"; // Ip +char* hostname = "192.168.43.87"; // Ip int port = 1883; int rc = ipstack.connect(hostname, port); +unsigned long previousTime = 0; // will store last time LED was updated +// constants won't change: +const long interval = 20; MQTT::Client<MQTTESP8266, Countdown> client = MQTT::Client<MQTTESP8266, Countdown>(ipstack); MbedJSONValue demo; int arrivedcount = 0; @@ -32,7 +35,7 @@ void subscribeCallback(MQTT::MessageData& md) { MQTT::Message &message = md.message; - printf("Message received: qos %d, retained %d, dup %d, packetid %d\n", message.qos, message.retained, message.dup, message.id); + printf("Message received: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id); printf("%s",(char*)message.payload); printf("\r\n"); @@ -54,27 +57,27 @@ message.payload = (void*)buf; message.payloadlen = strlen(buf)+1; rc = client.publish(topic3, message); - printf("if condition checked, its cloudy\n"); + printf("if condition checked, its cloudy\r\n"); } else if ( !(someString.find(clearsky)) ) { - sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d,clearsky %s\n", key2); + sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d,clearsky %s\r\n", key2); message.payload = (void*)buf; message.payloadlen = strlen(buf)+1; rc = client.publish(topic3, message); - printf("if condition checked, its clear\n"); + printf("if condition checked, its clear\r\n"); } else if ( !(someString.find(snow)) ) { - sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d,snow %s\n",key2); + sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d,snow %s\r\n",key2); message.payload = (void*)buf; message.payloadlen = strlen(buf)+1; rc = client.publish(topic3, message); - printf("if condition checked, its snowy\n"); + printf("if condition checked, its snowy\r\n"); } else { - printf("went into else\n"); + printf("went into else\r\n"); } } @@ -82,14 +85,14 @@ int main(int argc, char* argv[]) { wait (1); - printf("Starting\n"); + printf("Starting\r\n"); - printf("Version is %f\n", version); + printf("Version is %f\r\n", version); if (rc != 0) - printf("rc from TCP connect is %d\n", rc); + printf("rc from TCP connect is %d\r\n", rc); MQTTPacket_connectData data = MQTTPacket_connectData_initializer; //data.MQTTVersion = 3; @@ -98,33 +101,39 @@ //data.password.cstring = "testpassword"; if ((rc = client.connect(data)) != 0) - printf("rc from MQTT connect is %d\n", rc); + printf("rc from MQTT connect is %d\r\n", rc); if ((rc = client.subscribe(topic2, MQTT::QOS1, subscribeCallback)) != 0) - printf("Recv'd from MQTT subscribe is %d\n", rc); + printf("Recv'd from MQTT subscribe is %d\r\n", rc); MQTT::Message message; // QoS 0 - - sprintf(buf, "fa02d31610ce9ea0de15b22bb2fe279d, %s\n", key2); + time_t seconds = time(NULL); + + sprintf(buf, "fa02d31610ce9ea0de15b22bb2fe279d, %s\r\n", key2); message.qos = MQTT::QOS0; message.retained = false; message.dup = false; message.payload = (void*)buf; message.payloadlen = strlen(buf)+1; + + rc = client.publish(topic, message); wait(5); /* - sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d, %s\n", key2); + sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d, %s\r\n", key2); message.payload = (void*)buf; message.payloadlen = strlen(buf)+1; rc = client.publish(topic2, message); */ + while (arrivedcount < 10) client.yield(100); + + /* // QoS 1 - sprintf(buf, "Hello World! QoS 1 message from app version %f\n", version); + sprintf(buf, "Hello World! QoS 1 message from app version %f\r\n", version); message.qos = MQTT::QOS1; message.payloadlen = strlen(buf)+1; rc = client.publish(topic, message); @@ -132,7 +141,7 @@ client.yield(100); // QoS 2 - sprintf(buf, "Hello World! QoS 2 message from app version %f\n", version); + sprintf(buf, "Hello World! QoS 2 message from app version %f\r\n", version); message.qos = MQTT::QOS2; message.payloadlen = strlen(buf)+1; rc = client.publish(topic, message); @@ -142,7 +151,7 @@ // n * QoS 2 for (int i = 1; i <= 10; ++i) { - sprintf(buf, "Hello World! QoS 2 message number %d from app version %f\n", i, version); + sprintf(buf, "Hello World! QoS 2 message number %d from app version %f\r\n", i, version); message.qos = MQTT::QOS2; message.payloadlen = strlen(buf)+1; rc = client.publish(topic, message); @@ -152,13 +161,13 @@ */ if ((rc = client.unsubscribe(topic)) != 0) - printf("rc from unsubscribe was %d\n", rc); + printf("rc from unsubscribe was %d\r\n", rc); if ((rc = client.disconnect()) != 0) - printf("rc from disconnect was %d\n", rc); + printf("rc from disconnect was %d\r\n", rc); //ipstack.disconnect(); - //printf("Finishing with %d messages received\n", arrivedcount); + //printf("Finishing with %d messages received\r\n", arrivedcount); return 0; }