Kim jihyeon
/
HelloMQTT_jh
,ss
Fork of HelloMQTT by
Diff: main.cpp
- Revision:
- 23:e3422d0d3cc2
- Parent:
- 21:a68bd76740f9
- Child:
- 24:9269143e00f4
diff -r f5f6c9059eed -r e3422d0d3cc2 main.cpp --- a/main.cpp Mon Sep 11 16:43:49 2017 +0200 +++ b/main.cpp Fri Jan 05 12:20:31 2018 +0000 @@ -1,139 +1,165 @@ -/******************************************************************************* - * Copyright (c) 2014, 2015 IBM Corp. - * - * All rights reserved. This program and the accompanying materials - * are made available under the terms of the Eclipse Public License v1.0 - * and Eclipse Distribution License v1.0 which accompany this distribution. - * - * The Eclipse Public License is available at - * http://www.eclipse.org/legal/epl-v10.html - * and the Eclipse Distribution License is available at - * http://www.eclipse.org/org/documents/edl-v10.php. - * - * Contributors: - * Ian Craggs - initial API and implementation and/or initial documentation - * Ian Craggs - make sure QoS2 processing works, and add device headers - *******************************************************************************/ - - /** - This is a sample program to illustrate the use of the MQTT Client library - on the mbed platform. The Client class requires two classes which mediate - access to system interfaces for networking and timing. As long as these two - classes provide the required public programming interfaces, it does not matter - what facilities they use underneath. In this program, they use the mbed - system libraries. - - */ - - // change this to 1 to output messages to LCD instead of serial -#define USE_LCD 0 - -#if USE_LCD +/* #include "C12832.h" - -// the actual pins are defined in mbed_app.json and can be overridden per target -C12832 lcd(LCD_MOSI, LCD_SCK, LCD_MISO, LCD_A0, LCD_NCS); - -#define logMessage lcd.cls();lcd.printf - -#else +#include "easy-connect.h" +#include "MQTTNetwork.h" +#include "MQTTmbed.h" +#include "MQTTClient.h" +*/ #define logMessage printf - -#endif - -#define MQTTCLIENT_QOS2 1 - +//#define MQTTCLIENT_QOS2 1 +#include "mbed.h" #include "easy-connect.h" #include "MQTTNetwork.h" #include "MQTTmbed.h" #include "MQTTClient.h" - -int arrivedcount = 0; +#include "DHT.h" +/* connect this pin to both the CH_PD (aka EN) & RST pins on the ESP8266 just in case */ +#define WIFI_HW_RESET_PIN D4 +/* See if you can try using a hostname here */ +#define MQTT_BROKER_ADDR "192.168.0.9" +#define MQTT_BROKER_PORT 1883 +DHT sensor(D7,DHT22); +DigitalOut wifiHwResetPin(WIFI_HW_RESET_PIN); +DigitalOut led2(LED2); +Serial pc(USBTX, USBRX); // computer to mbedboardSerialesp(D1, D0); + + +volatile bool flag = false; + +Mutex mqttMtx; + + +float t = 0; + +char* topic1 = "LED"; +char* topic2 = "TEMP"; +char* topic3 = "LEDS"; void messageArrived(MQTT::MessageData& md) { + MQTT::Message &message = md.message; - logMessage("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id); + /* our messaging standard says the first byte denotes which thread to fwdto */ + logMessage("Message arrived: qos%d, retained %d, dup %d, packetid%d\r\n", message.qos, message.retained, message.dup, message.id); logMessage("Payload %.*s\r\n", message.payloadlen, (char*)message.payload); - ++arrivedcount; -} + + char fwdTarget= ((char *)message.payload)[0]; + switch(fwdTarget) + { + case '0': // turn off + led2 = 0; + break; + case '1': //turn on + led2 = 1; + break; + + case '2': //LED status + flag = true; + break; + + default: + pc.printf("Unknown MQTT message\n"); + break; + } + } int main(int argc, char* argv[]) { - float version = 0.6; - char* topic = "mbed-sample"; - - logMessage("HelloMQTT: version is %.2f\r\n", version); + float version = 0.5; + pc.baud(115200); + logMessage("MQTT example: version is %.2f\r\n", version); + wait(0.2); //delay startup + pc.printf("Resetting ESP8266 Hardware...\r\n"); + wifiHwResetPin= 0; + wait_ms(500); + wifiHwResetPin= 1; + pc.printf("Starting MQTT example with an ESP8266 wifidevice using MbedOS.\r\n"); + pc.printf("Attempting to connect to access point...\r\n"); NetworkInterface* network = easy_connect(true); if (!network) { + pc.printf("Error in east connection\r\n"); return -1; } MQTTNetwork mqttNetwork(network); - MQTT::Client<MQTTNetwork, Countdown> client(mqttNetwork); + + logMessage("Connecting to %s:%d\r\n", MQTT_BROKER_ADDR, MQTT_BROKER_PORT); + int rc= mqttNetwork.connect(MQTT_BROKER_ADDR, MQTT_BROKER_PORT); - const char* hostname = "m2m.eclipse.org"; - int port = 1883; - logMessage("Connecting to %s:%d\r\n", hostname, port); - int rc = mqttNetwork.connect(hostname, port); - if (rc != 0) - logMessage("rc from TCP connect is %d\r\n", rc); + if (rc!= 0) + logMessage("rcfrom TCP connect is %d\r\n", rc); + + MQTTPacket_connectData data= MQTTPacket_connectData_initializer; + data.MQTTVersion= 3; + data.clientID.cstring= "mbed-ljw"; + data.username.cstring= "user-ljw"; + data.password.cstring= "testpassword"; - MQTTPacket_connectData data = MQTTPacket_connectData_initializer; - data.MQTTVersion = 3; - data.clientID.cstring = "mbed-sample"; - data.username.cstring = "testuser"; - data.password.cstring = "testpassword"; - if ((rc = client.connect(data)) != 0) - logMessage("rc from MQTT connect is %d\r\n", rc); + if ((rc= client.connect(data)) != 0) + logMessage("rcfrom MQTT connect is %d\r\n", rc); + if ((rc= client.subscribe(topic1, MQTT::QOS0, messageArrived)) != 0) + logMessage("rcfrom MQTT subscribe is %d\r\n", rc); + + int count = 0; + + while(1) { + Thread::wait(1000); - if ((rc = client.subscribe(topic, MQTT::QOS2, messageArrived)) != 0) - logMessage("rc from MQTT subscribe is %d\r\n", rc); + char buf[64]; + MQTT::Message message; + + + t = sensor.ReadTemperature(CELCIUS); - MQTT::Message message; + + + if (count == 30) { + pc.printf("Publish: TEMP\r\n"); + + sprintf(buf, "{ \"temp\": \"%.1f\"}\r\n", t); - // QoS 0 - char buf[100]; - sprintf(buf, "Hello World! QoS 0 message from app version %f\r\n", version); - message.qos = MQTT::QOS0; - message.retained = false; - message.dup = false; - message.payload = (void*)buf; - message.payloadlen = strlen(buf)+1; - rc = client.publish(topic, message); - while (arrivedcount < 1) - client.yield(100); + message.qos= MQTT::QOS2; + message.retained= false; + message.dup= false; + message.payload= (void*)buf; + message.payloadlen= strlen(buf)+1; + mqttMtx.lock(); + rc= client.publish(topic2, message); + mqttMtx.unlock(); + count = 0; + + } + + if (flag) { + pc.printf("Publish: LEDS\r\n"); - // QoS 1 - 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); - while (arrivedcount < 2) - client.yield(100); + if (led2 == 0) + sprintf(buf, "LED OFF"); + else + sprintf(buf, "LED ON"); + + message.qos= MQTT::QOS1; + message.retained= false; + message.dup= false; + message.payload= (void*)buf; + message.payloadlen= strlen(buf)+1; - // QoS 2 - 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); - while (arrivedcount < 3) - client.yield(100); + mqttMtx.lock(); + rc= client.publish(topic3, message); + mqttMtx.unlock(); + flag = false; + } - if ((rc = client.unsubscribe(topic)) != 0) - logMessage("rc from unsubscribe was %d\r\n", rc); - - if ((rc = client.disconnect()) != 0) - logMessage("rc from disconnect was %d\r\n", rc); - - mqttNetwork.disconnect(); - - logMessage("Version %.2f: finish %d msgs\r\n", version, arrivedcount); - + if(!client.isConnected()) + NVIC_SystemReset();// soft reset + /* yield() needs to be called at least once per keepAliveInterval*/ + client.yield(10); + count++; + } return 0; }