MQTT ESP01 STM32
Dependencies: LCD_i2c_GSOE ESP8266MQTT
main.cpp@8:6533611e7deb, 2021-08-19 (annotated)
- Committer:
- jack1930
- Date:
- Thu Aug 19 10:52:24 2021 +0000
- Revision:
- 8:6533611e7deb
- Parent:
- 7:bbf6329081a9
QOS2
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
petripakkanen | 0:0046df9d5380 | 1 | #include "mbed.h" |
jack1930 | 2:40091707a95c | 2 | #include "PubSubClient.h" |
jack1930 | 5:fb5a02cfb826 | 3 | #include "LCD.h" |
jack1930 | 5:fb5a02cfb826 | 4 | /* |
jack1930 | 5:fb5a02cfb826 | 5 | "wifi-ssid": { |
jack1930 | 5:fb5a02cfb826 | 6 | "help": "WiFi SSID", |
jack1930 | 5:fb5a02cfb826 | 7 | "value": "\"x-Netz\"" |
jack1930 | 5:fb5a02cfb826 | 8 | }, |
jack1930 | 5:fb5a02cfb826 | 9 | "wifi-password": { |
jack1930 | 5:fb5a02cfb826 | 10 | "help": "WiFi Password", |
jack1930 | 5:fb5a02cfb826 | 11 | "value": "\"aCT3xuSbm9rt\"" |
jack1930 | 5:fb5a02cfb826 | 12 | }, |
jack1930 | 5:fb5a02cfb826 | 13 | */ |
jack1930 | 6:5f6c4afcd8ca | 14 | /* |
jack1930 | 6:5f6c4afcd8ca | 15 | "mqtt-broker-hostname": { |
jack1930 | 6:5f6c4afcd8ca | 16 | "help": "MQTT Broker resolvable hostname.", |
jack1930 | 6:5f6c4afcd8ca | 17 | "value": "\"test.mosquitto.org\"" |
jack1930 | 6:5f6c4afcd8ca | 18 | }, |
jack1930 | 6:5f6c4afcd8ca | 19 | */ |
jack1930 | 2:40091707a95c | 20 | PortOut diag(PortC,0xFF); |
jack1930 | 2:40091707a95c | 21 | AnalogIn poti(PA_0); |
jack1930 | 5:fb5a02cfb826 | 22 | lcd mylcd; |
jack1930 | 2:40091707a95c | 23 | |
jack1930 | 2:40091707a95c | 24 | PubSubClient client; |
petripakkanen | 0:0046df9d5380 | 25 | |
jack1930 | 6:5f6c4afcd8ca | 26 | /* |
jack1930 | 6:5f6c4afcd8ca | 27 | struct Message |
jack1930 | 6:5f6c4afcd8ca | 28 | { |
jack1930 | 6:5f6c4afcd8ca | 29 | enum QoS qos; |
jack1930 | 6:5f6c4afcd8ca | 30 | bool retained; |
jack1930 | 6:5f6c4afcd8ca | 31 | bool dup; |
jack1930 | 6:5f6c4afcd8ca | 32 | unsigned short id; |
jack1930 | 6:5f6c4afcd8ca | 33 | void *payload; |
jack1930 | 6:5f6c4afcd8ca | 34 | size_t payloadlen; |
jack1930 | 6:5f6c4afcd8ca | 35 | }; |
jack1930 | 6:5f6c4afcd8ca | 36 | |
jack1930 | 6:5f6c4afcd8ca | 37 | |
jack1930 | 6:5f6c4afcd8ca | 38 | struct MessageData |
jack1930 | 6:5f6c4afcd8ca | 39 | { |
jack1930 | 6:5f6c4afcd8ca | 40 | MessageData(MQTTString &aTopicName, struct Message &aMessage) : message(aMessage), topicName(aTopicName) |
jack1930 | 6:5f6c4afcd8ca | 41 | { } |
jack1930 | 6:5f6c4afcd8ca | 42 | |
jack1930 | 6:5f6c4afcd8ca | 43 | struct Message &message; |
jack1930 | 6:5f6c4afcd8ca | 44 | MQTTString &topicName; |
jack1930 | 6:5f6c4afcd8ca | 45 | }; |
jack1930 | 6:5f6c4afcd8ca | 46 | */ |
jack1930 | 6:5f6c4afcd8ca | 47 | |
jack1930 | 5:fb5a02cfb826 | 48 | void subscribeCallback(MessageData& mymessage) |
jack1930 | 5:fb5a02cfb826 | 49 | { |
jack1930 | 5:fb5a02cfb826 | 50 | mylcd.cursorpos(0); |
jack1930 | 6:5f6c4afcd8ca | 51 | mylcd.printf("%s ",client.gibPayload(mymessage).c_str()); |
jack1930 | 5:fb5a02cfb826 | 52 | } |
jack1930 | 5:fb5a02cfb826 | 53 | |
jack1930 | 6:5f6c4afcd8ca | 54 | void subscribeCallback2(MessageData& mymessage) |
jack1930 | 5:fb5a02cfb826 | 55 | { |
jack1930 | 6:5f6c4afcd8ca | 56 | |
jack1930 | 6:5f6c4afcd8ca | 57 | mylcd.cursorpos(0x40); |
jack1930 | 6:5f6c4afcd8ca | 58 | mylcd.printf("%s ",client.gibPayload(mymessage).c_str()); |
jack1930 | 5:fb5a02cfb826 | 59 | } |
jack1930 | 5:fb5a02cfb826 | 60 | |
jack1930 | 6:5f6c4afcd8ca | 61 | |
jack1930 | 5:fb5a02cfb826 | 62 | //test.mosquitto.org 5.196.95.208 |
petripakkanen | 0:0046df9d5380 | 63 | int main() |
petripakkanen | 0:0046df9d5380 | 64 | { |
jack1930 | 2:40091707a95c | 65 | diag=1; |
jack1930 | 2:40091707a95c | 66 | int d; |
jack1930 | 2:40091707a95c | 67 | char buffer[64]; |
jack1930 | 5:fb5a02cfb826 | 68 | mylcd.clear(); |
jack1930 | 6:5f6c4afcd8ca | 69 | client.connect((char*)"joerg"); |
jack1930 | 6:5f6c4afcd8ca | 70 | client.subscribe("MBED/joerg/ersteTests", QOS0, subscribeCallback); |
jack1930 | 7:bbf6329081a9 | 71 | client.subscribe("MBED/joerg/zweiteTests", QOS0, subscribeCallback2); |
jack1930 | 2:40091707a95c | 72 | while(true) |
petripakkanen | 1:f6ebd1725aae | 73 | { |
jack1930 | 5:fb5a02cfb826 | 74 | client.loop(); |
jack1930 | 2:40091707a95c | 75 | diag=diag+1; |
jack1930 | 2:40091707a95c | 76 | d=diag; |
jack1930 | 2:40091707a95c | 77 | sprintf(buffer, "poti=%d", (int)(poti*4095)); |
jack1930 | 2:40091707a95c | 78 | client.publish("MBED/joerg/ersteTests", buffer); |
jack1930 | 7:bbf6329081a9 | 79 | //HAL_Delay(200); |
jack1930 | 7:bbf6329081a9 | 80 | sprintf(buffer, "diag=%d", d); |
jack1930 | 7:bbf6329081a9 | 81 | client.publish("MBED/joerg/zweiteTests", buffer); |
jack1930 | 6:5f6c4afcd8ca | 82 | //HAL_Delay(200); |
petripakkanen | 0:0046df9d5380 | 83 | } |
petripakkanen | 0:0046df9d5380 | 84 | } |
petripakkanen | 1:f6ebd1725aae | 85 | |
petripakkanen | 1:f6ebd1725aae | 86 | |
jack1930 | 6:5f6c4afcd8ca | 87 | |
jack1930 | 6:5f6c4afcd8ca | 88 |