Dongho Kim
/
HelloMQTT
HW4
Fork of HelloMQTT by
Revision 23:e2ab0669caeb, committed 2018-01-05
- Comitter:
- Dongho
- Date:
- Fri Jan 05 06:36:32 2018 +0000
- Parent:
- 22:f5f6c9059eed
- Commit message:
- HW4;
Changed in this revision
diff -r f5f6c9059eed -r e2ab0669caeb Linux-example/LinuxIPStack.h --- a/Linux-example/LinuxIPStack.h Mon Sep 11 16:43:49 2017 +0200 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,119 +0,0 @@ -#if !defined(LINUX_IPSTACK_H) -#define LINUX_IPSTACK_H - -class IPStack -{ -public: - IPStack() - { - - } - - int Socket_error(const char* aString) - { - - if (errno != EINTR && errno != EAGAIN && errno != EINPROGRESS && errno != EWOULDBLOCK) - { - if (strcmp(aString, "shutdown") != 0 || (errno != ENOTCONN && errno != ECONNRESET)) - printf("Socket error %s in %s for socket %d\n", strerror(errno), aString, mysock); - } - return errno; - } - - int connect(const char* hostname, int port) - { - int type = SOCK_STREAM; - struct sockaddr_in address; - int rc = -1; - sa_family_t family = AF_INET; - struct addrinfo *result = NULL; - struct addrinfo hints = {0, AF_UNSPEC, SOCK_STREAM, IPPROTO_TCP, 0, NULL, NULL, NULL}; - - if ((rc = getaddrinfo(hostname, NULL, &hints, &result)) == 0) - { - struct addrinfo* res = result; - - /* prefer ip4 addresses */ - while (res) - { - if (res->ai_family == AF_INET) - { - result = res; - break; - } - res = res->ai_next; - } - - if (result->ai_family == AF_INET) - { - address.sin_port = htons(port); - address.sin_family = family = AF_INET; - address.sin_addr = ((struct sockaddr_in*)(result->ai_addr))->sin_addr; - } - else - rc = -1; - - freeaddrinfo(result); - } - - if (rc == 0) - { - mysock = socket(family, type, 0); - if (mysock != -1) - { - int opt = 1; - - //if (setsockopt(mysock, SOL_SOCKET, SO_NOSIGPIPE, (void*)&opt, sizeof(opt)) != 0) - // printf("Could not set SO_NOSIGPIPE for socket %d", mysock); - - rc = ::connect(mysock, (struct sockaddr*)&address, sizeof(address)); - } - } - - return rc; - } - - int read(char* buffer, int len, int timeout_ms) - { - struct timeval interval = {timeout_ms / 1000, (timeout_ms % 1000) * 1000}; - if (interval.tv_sec < 0 || (interval.tv_sec == 0 && interval.tv_usec <= 0)) - { - interval.tv_sec = 0; - interval.tv_usec = 100; - } - - setsockopt(mysock, SOL_SOCKET, SO_RCVTIMEO, (char *)&interval, sizeof(struct timeval)); - - //printf("reading %d bytes\n", len); - int rc = ::recv(mysock, buffer, (size_t)len, 0); - if (rc == -1) - Socket_error("read"); - //printf("read %d bytes\n", rc); - return rc; - } - - int write(char* buffer, int len, int timeout) - { - struct timeval tv; - - tv.tv_sec = 0; /* 30 Secs Timeout */ - tv.tv_usec = timeout * 1000; // Not init'ing this can cause strange errors - - setsockopt(mysock, SOL_SOCKET, SO_RCVTIMEO, (char *)&tv,sizeof(struct timeval)); - int rc = ::write(mysock, buffer, len); - //printf("write rc %d\n", rc); - return rc; - } - - int disconnect() - { - return ::close(mysock); - } - -private: - - int mysock; - -}; - -#endif \ No newline at end of file
diff -r f5f6c9059eed -r e2ab0669caeb Linux-example/LinuxMQTT.h --- a/Linux-example/LinuxMQTT.h Mon Sep 11 16:43:49 2017 +0200 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,64 +0,0 @@ -#if !defined(LINUXMQTT_H) -#define LINUXMQTT_H - -class Countdown -{ -public: - Countdown() - { - - } - - Countdown(int ms) - { - countdown_ms(ms); - } - - - bool expired() - { - struct timeval now, res; - gettimeofday(&now, NULL); - timersub(&end_time, &now, &res); - //printf("left %d ms\n", (res.tv_sec < 0) ? 0 : res.tv_sec * 1000 + res.tv_usec / 1000); - //if (res.tv_sec > 0 || res.tv_usec > 0) - // printf("expired %d %d\n", res.tv_sec, res.tv_usec); - return res.tv_sec < 0 || (res.tv_sec == 0 && res.tv_usec <= 0); - } - - - void countdown_ms(int ms) - { - struct timeval now; - gettimeofday(&now, NULL); - struct timeval interval = {ms / 1000, (ms % 1000) * 1000}; - //printf("interval %d %d\n", interval.tv_sec, interval.tv_usec); - timeradd(&now, &interval, &end_time); - } - - - void countdown(int seconds) - { - struct timeval now; - gettimeofday(&now, NULL); - struct timeval interval = {seconds, 0}; - timeradd(&now, &interval, &end_time); - } - - - int left_ms() - { - struct timeval now, res; - gettimeofday(&now, NULL); - timersub(&end_time, &now, &res); - //printf("left %d ms\n", (res.tv_sec < 0) ? 0 : res.tv_sec * 1000 + res.tv_usec / 1000); - return (res.tv_sec < 0) ? 0 : res.tv_sec * 1000 + res.tv_usec / 1000; - } - -private: - - struct timeval end_time; -}; - - -#endif \ No newline at end of file
diff -r f5f6c9059eed -r e2ab0669caeb Linux-example/linux-main.cpp --- a/Linux-example/linux-main.cpp Mon Sep 11 16:43:49 2017 +0200 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,149 +0,0 @@ -/******************************************************************************* - * Copyright (c) 2014 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 - *******************************************************************************/ - - /** - This is a sample program to illustrate the use of the MQTT Client library - on Linux. 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 Linux - system libraries. - - */ - -#if defined(LINUX) - -#include "LinuxMQTT.h" -#include "LinuxIPStack.h" -#include "MQTTClient.h" - -#include <sys/types.h> -#include <sys/socket.h> -#include <sys/param.h> -#include <sys/time.h> -#include <sys/select.h> -#include <netinet/in.h> -#include <netinet/tcp.h> -#include <arpa/inet.h> -#include <netdb.h> -#include <stdio.h> -#include <unistd.h> -#include <errno.h> -#include <fcntl.h> - -#include <stdlib.h> -#include <string.h> -#include <signal.h> - -#define DEFAULT_STACK_SIZE -1 - - -int arrivedcount = 0; - -void messageArrived(MQTT::Message* message) -{ - printf("Message %d arrived: qos %d, retained %d, dup %d, packetid %d\n", - ++arrivedcount, message->qos, message->retained, message->dup, message->id); - printf("Payload %.*s\n", message->payloadlen, (char*)message->payload); -} - - -int connect(MQTT::Client<IPStack, Countdown>::connectionLostInfo* info) -{ - const char* hostname = "localhost"; //"m2m.eclipse.org"; - int port = 1883; - printf("Connecting to %s:%d\n", hostname, port); - int rc = info->network->connect(hostname, port); - if (rc != 0) - printf("rc from TCP connect is %d\n", rc); - - MQTTPacket_connectData data = MQTTPacket_connectData_initializer; - data.MQTTVersion = 3; - data.clientID.cstring = (char*)"mbed-icraggs"; - rc = info->client->connect(&data); - if (rc != 0) - printf("rc from MQTT connect is %d\n", rc); - - return rc; -} - - -int main(int argc, char* argv[]) -{ - IPStack ipstack = IPStack(); - float version = 0.3; - const char* topic = "mbed-sample"; - - printf("Version is %f\n", version); - - MQTT::Client<IPStack, Countdown> client = MQTT::Client<IPStack, Countdown>(ipstack); - - client.setConnectionLostHandler(connect); - - MQTT::Client<IPStack, Countdown>::connectionLostInfo info = {&client, &ipstack}; - int rc = connect(&info); - - rc = client.subscribe(topic, MQTT::QOS2, messageArrived); - if (rc != 0) - printf("rc from MQTT subscribe is %d\n", rc); - - MQTT::Message message; - - // QoS 0 - char buf[100]; - sprintf(buf, "Hello World! QoS 0 message from app version %f", 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 == 0) - client.yield(100); - - // QoS 1 - printf("Now QoS 1\n"); - sprintf(buf, "Hello World! QoS 1 message from app version %f", version); - message.qos = MQTT::QOS1; - message.payloadlen = strlen(buf)+1; - rc = client.publish(topic, &message); - while (arrivedcount == 1) - client.yield(100); - - // QoS 2 - sprintf(buf, "Hello World! QoS 2 message from app version %f", version); - message.qos = MQTT::QOS2; - message.payloadlen = strlen(buf)+1; - rc = client.publish(topic, &message); - while (arrivedcount == 2) - client.yield(100); - - rc = client.unsubscribe(topic); - if (rc != 0) - printf("rc from unsubscribe was %d\n", rc); - - rc = client.disconnect(); - if (rc != 0) - printf("rc from disconnect was %d\n", rc); - - ipstack.disconnect(); - - printf("Finishing with %d messages received\n", arrivedcount); - - return 0; -} - -#endif
diff -r f5f6c9059eed -r e2ab0669caeb MQTTNetwork.h --- a/MQTTNetwork.h Mon Sep 11 16:43:49 2017 +0200 +++ b/MQTTNetwork.h Fri Jan 05 06:36:32 2018 +0000 @@ -7,6 +7,7 @@ public: MQTTNetwork(NetworkInterface* aNetwork) : network(aNetwork) { socket = new TCPSocket(); + socket -> set_blocking(false); } ~MQTTNetwork() {
diff -r f5f6c9059eed -r e2ab0669caeb easy-connect.lib --- a/easy-connect.lib Mon Sep 11 16:43:49 2017 +0200 +++ b/easy-connect.lib Fri Jan 05 06:36:32 2018 +0000 @@ -1,1 +1,1 @@ -https://github.com/ARMmbed/easy-connect/#cb933fb19cda0a733a64d6b71d271fb6bdaf9e6d +https://github.com/ARMmbed/easy-connect/#a913964341394430cd3997c6f2950f93ba1d75c8
diff -r f5f6c9059eed -r e2ab0669caeb main.cpp --- a/main.cpp Mon Sep 11 16:43:49 2017 +0200 +++ b/main.cpp Fri Jan 05 06:36:32 2018 +0000 @@ -1,139 +1,183 @@ -/******************************************************************************* - * 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 - #define logMessage printf - -#endif - #define MQTTCLIENT_QOS2 1 +#include "mbed.h" #include "easy-connect.h" #include "MQTTNetwork.h" #include "MQTTmbed.h" #include "MQTTClient.h" -int arrivedcount = 0; +#define ADT7420_TEMP_REG (0x00) // Temperature Register +#define ADT7420_CONF_REG (0x03) // Configuration Register +#define EVAL_ADT7420_ADDR (0x48) // EVAL_ADT7420 i2c address + + +/* 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.14" +#define MQTT_BROKER_PORT 1883 + +DigitalOut wifiHwResetPin(WIFI_HW_RESET_PIN); +DigitalOut led2(LED2); +Serial pc(USBTX, USBRX); // computer to mbed boardSerial esp(D1, D0); +I2C i2c(I2C_SDA, I2C_SCL); + +volatile bool flag = false; +Mutex mqttMtx; + +char* topic1 = "LED"; +char* topic2 = "TEMP"; 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 fwd to */ + 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; + + default: + pc.printf("Unknown MQTT message\n"); + break; + } } - int main(int argc, char* argv[]) { - float version = 0.6; - char* topic = "mbed-sample"; + 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"); - logMessage("HelloMQTT: version is %.2f\r\n", version); + wifiHwResetPin = 0; + wait_ms(500); + wifiHwResetPin = 1; + pc.printf("Starting MQTT example with an ESP8266 wifi device using Mbed OS.\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); MQTTPacket_connectData data = MQTTPacket_connectData_initializer; data.MQTTVersion = 3; - data.clientID.cstring = "mbed-sample"; - data.username.cstring = "testuser"; - data.password.cstring = "testpassword"; + data.clientID.cstring = "mbed-kdh"; + data.username.cstring = "kdh"; + data.password.cstring = "2ehd2gh4"; + if ((rc = client.connect(data)) != 0) logMessage("rc from MQTT connect is %d\r\n", rc); - if ((rc = client.subscribe(topic, MQTT::QOS2, messageArrived)) != 0) + if ((rc = client.subscribe(topic1, MQTT::QOS0, messageArrived)) != 0) logMessage("rc from MQTT subscribe is %d\r\n", rc); - MQTT::Message message; + int count = 0; + + int status; + float temp; + char data_write[2]; + char data_read[2]; + + i2c.frequency(100000); // 100 k + + // 13-bit resolution and 1 SPS mode + data_write[0] = ADT7420_CONF_REG; + data_write[1] = 0x40; + status = i2c.write((EVAL_ADT7420_ADDR << 1), data_write, 2); - // 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); + if (status != 0) { // error + char buf[100]; + MQTT::Message message; + + pc.printf("I2C configuration error!!\r\n"); + sprintf(buf, "{ \"actions\": [ { \"name\": 'error' , \"parameter\": \"NaN\" } ] }"); + pc.printf("%s\r\n", buf); + + 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(); + + while(1) { + } + } + + while(1) { + Thread::wait(1000); + char buf[100]; + MQTT::Message message; - // 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 (count == 5) { + + // Read temperature register + data_write[0] = ADT7420_TEMP_REG; + i2c.write((EVAL_ADT7420_ADDR << 1), data_write, 1, 0); + i2c.read(((EVAL_ADT7420_ADDR << 1) | 0x01), data_read, 2, 0); + + // Calculate temperature value in Celcius + int tempval = ((int)data_read[0] << 8) | data_read[1]; + tempval >>= 3; - // 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); + // tempval = 0x1e70; //test value for a negative temperature (-25.0) + if ((tempval & 0x1000) > 0) { //negative value + temp = (tempval - 8192)/16.0; + } else { + temp = tempval/16.0; + } + + pc.printf("Publish: TEMP\r\n"); + sprintf(buf, "%4.2f", temp); + pc.printf("%s\r\n", buf); + + 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 ((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); + if(!client.isConnected()) + NVIC_SystemReset(); // soft reset - mqttNetwork.disconnect(); - - logMessage("Version %.2f: finish %d msgs\r\n", version, arrivedcount); - + /* yield() needs to be called at least once per keepAliveInterval */ + client.yield(10); + count++; + } return 0; -} +} \ No newline at end of file
diff -r f5f6c9059eed -r e2ab0669caeb mbed_app.json --- a/mbed_app.json Mon Sep 11 16:43:49 2017 +0200 +++ b/mbed_app.json Fri Jan 05 06:36:32 2018 +0000 @@ -1,8 +1,8 @@ { "config": { "network-interface":{ - "help": "options are ETHERNET, WIFI_ESP8266, WIFI_ODIN, WIFI_RTW, MESH_LOWPAN_ND, MESH_THREAD, CELLULAR_ONBOARD", - "value": "ETHERNET" + "help": "options are ETHERNET, WIFI_ESP8266, WIFI_ODIN, MESH_LOWPAN_ND, MESH_THREAD", + "value": "WIFI_ESP8266" }, "mesh_radio_type": { "help": "options are ATMEL, MCR20", @@ -10,60 +10,69 @@ }, "esp8266-tx": { "help": "Pin used as TX (connects to ESP8266 RX)", - "value": "D1" + "value": "D8" }, "esp8266-rx": { "help": "Pin used as RX (connects to ESP8266 TX)", - "value": "D0" - }, - "esp8266-ssid": { - "value": "\"SSID\"" - }, - "esp8266-password": { - "value": "\"Password\"" + "value": "D2" }, "esp8266-debug": { - "value": true + "value": false }, - "lcd-mosi": { - "value": "D11", - "macro_name": "LCD_MOSI" + "wifi-ssid": { + "value": "\"netlab1\"" }, - "lcd-sck": { - "value": "D13", - "macro_name": "LCD_SCK" + "wifi-password": { + "value": "\"netlab1@414\"" }, - "lcd-miso": { - "value": "D12", - "macro_name": "LCD_MISO" + "button": { + "help": "Pin which you'll use as button (can be overriden per target below)", + "value": "BUTTON1" }, - "lcd-a0": { - "value": "D7", - "macro_name": "LCD_A0" + "builtin_led_on": { + "help": "Value to write to built-in LEDs to turn them on", + "value": 1, + "macro_name": "BUILTIN_LED_ON" }, - "lcd-ncs": { - "value": "D10", - "macro_name": "LCD_NCS" + "builtin_led_off": { + "help": "Value to write to built-in LEDs to turn them off", + "value": 0, + "macro_name": "BUILTIN_LED_OFF" } }, "target_overrides": { "*": { "target.features_add": ["NANOSTACK", "LOWPAN_ROUTER", "COMMON_PAL"], + "platform.stdio-baud-rate": 115200, + "platform.stdio-convert-newlines": true, "mbed-mesh-api.6lowpan-nd-channel-page": 0, "mbed-mesh-api.6lowpan-nd-channel": 12, "mbed-trace.enable": 0 }, + "K64F": { + "button": "SW2", + "builtin_led_on": 0, + "builtin_led_off": 1 + }, "HEXIWEAR": { + "button": "PTA12", "esp8266-tx": "PTD3", "esp8266-rx": "PTD2" }, "NUCLEO_F401RE": { + "button": "USER_BUTTON", "esp8266-tx": "D8", "esp8266-rx": "D2" }, "NUCLEO_F411RE": { + "button": "USER_BUTTON", "esp8266-tx": "D8", "esp8266-rx": "D2" + }, + "NUMAKER_PFM_NUC472": { + "button": "SW1", + "builtin_led_on": 0, + "builtin_led_off": 1 } } }