ping jin
MQTT-STM32
Dependencies: MbedJSONValue wifi-ism43362 LSM6DSL HTS221 MQTT
Revision 0:775536f6b40b, committed 2020-09-23
- Comitter:
- jingege
- Date:
- Wed Sep 23 09:12:20 2020 +0000
- Commit message:
- stm32-MQTT
Changed in this revision
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/HTS221.lib Wed Sep 23 09:12:20 2020 +0000 @@ -0,0 +1,1 @@ +https://os.mbed.com/teams/ST/code/HTS221/#ccf7f36492ae
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/LSM6DSL.lib Wed Sep 23 09:12:20 2020 +0000 @@ -0,0 +1,1 @@ +https://os.mbed.com/teams/ST/code/LSM6DSL/#77ec4781b110
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/MQTT.lib Wed Sep 23 09:12:20 2020 +0000 @@ -0,0 +1,1 @@ +https://os.mbed.com/teams/mqtt/code/MQTT/#9cff7b6bbd01
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/MQTTNetwork.h Wed Sep 23 09:12:20 2020 +0000
@@ -0,0 +1,42 @@
+#ifndef _MQTTNETWORK_H_
+#define _MQTTNETWORK_H_
+
+#include "NetworkInterface.h"
+
+class MQTTNetwork {
+public:
+ MQTTNetwork(NetworkStack* aNetwork) : network(aNetwork) {
+ socket = new TCPSocket();
+ }
+
+ ~MQTTNetwork()
+ {
+ delete socket;
+ }
+
+ int read(unsigned char* buffer, int len, int timeout) {
+ return socket->recv(buffer, len);
+ }
+
+ int write(unsigned char* buffer, int len, int timeout) {
+ return socket->send(buffer, len);
+ }
+
+ int connect(const char* hostname, int port) {
+ int ret = socket->open(network);
+ printf("ret ===%d\n\n\n",ret);
+ ret = socket->connect(hostname, port);
+ printf("ret ======== %d\n\n\n", ret);
+ return ret;
+ }
+
+ int disconnect() {
+ return socket->close();
+ }
+
+private:
+ NetworkStack* network;
+ TCPSocket* socket;
+};
+
+#endif // _MQTTNETWORK_H_
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/MbedJSONValue.lib Wed Sep 23 09:12:20 2020 +0000 @@ -0,0 +1,1 @@ +https://os.mbed.com/users/samux/code/MbedJSONValue/#10a99cdf7846
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp Wed Sep 23 09:12:20 2020 +0000
@@ -0,0 +1,167 @@
+#include "mbed.h"
+#include <string>
+#include "ISM43362Interface.h"
+#include "LSM6DSLSensor.h"
+#include "HTS221Sensor.h"
+#include "MQTTNetwork.h"
+#include "MQTTClient.h"
+#include "MQTTmbed.h"
+#include "MbedJSONValue.h"
+char* hostname = "192.168.22.165";
+int port = 1883;
+#define QOS MQTT::QOS0
+DigitalOut led(LED3);
+int main()
+{
+ Serial pc(SERIAL_TX, SERIAL_RX);
+ char exchangebuf[50];
+ ThisThread::sleep_for(10000);
+ printf("start!");
+ DevI2C I2C(PB_11, PB_10);
+ LSM6DSLSensor Lsm(&I2C, 0xD4);
+ HTS221Sensor Hts(&I2C, 0xBE);
+ void* init;
+ int ret;
+ ret = Hts.init(init);
+ if (0 == ret)
+ {
+ printf("init_hts succeed!!\n ");
+ }
+ else
+ {
+ printf("init_hts failed!!\n");
+ return -1;
+ }
+ ret = Hts.enable();
+ if (0 == ret)
+ {
+ printf("enable_hts succeed!!\n ");
+ }
+ else
+ {
+ printf("enable_hts failed!!\n");
+ return -1;
+ }
+ ret = Lsm.init(init);
+ if(0 == ret)
+ {
+ printf("init succeed!!\n");
+ }
+ else
+ {
+ printf("init failed!!\n");
+ return -1;
+ }
+ ret = Lsm.enable_x();
+ if(0 == ret)
+ {
+ printf("enable succeed!!\n");
+ }
+ else
+ {
+ printf("enable failed!!\n");
+ return -1;
+ }
+ ret = Lsm.set_x_odr(400.0);
+ if(0 == ret)
+ {
+ printf("set_x_odr succeed!!\n");
+ }
+ else
+ {
+ printf("set_x_odr failed!!\n");
+ return -1;
+ }
+ ret = Lsm.set_x_fs(8.0);
+ if(0 == ret)
+ {
+ printf("set_x_fs succeed!!\n");
+ }
+ else
+ {
+ printf("set_x_fs failed!!\n");
+ return -1;
+ }
+ ISM43362Interface net(PC_12,PC_11,PC_10,PE_0,PE_8,PE_1,PB_13);
+ ret = net.connect("Google_2.4G","abcd1234",NSAPI_SECURITY_NONE);
+ if(0 == ret)
+ {
+ printf("connect wifi succeed ip = %s\n",net.get_ip_address());
+ }
+ else
+ {
+ printf("connect wifi failed!!!");
+ return -1;
+ }
+ NetworkStack* network = &net;
+ MQTTNetwork mqttNetwork(network);
+ MQTT::Client<MQTTNetwork, Countdown> client(mqttNetwork);
+ ret = mqttNetwork.connect(hostname, port);
+ client.connect();
+ if (0 == ret)
+ {
+ printf("connect succeed!!\n");
+ }
+ else
+ {
+ printf("connect failed!!\n");
+ }
+ MQTT::Message message;
+ message.qos = QOS;
+ message.retained = false;
+ message.dup = false;
+ string str;
+ while(1)
+ {
+ memset(exchangebuf, 0, sizeof(exchangebuf));
+ float hum,temp;
+ ret = Hts.get_temperature(&temp);
+ if(ret != 0)
+ {
+ printf("get_temperature failed!\n");
+ }
+ MbedJSONValue value;
+ value["temp"] = (int)temp;
+ str = value.serialize();
+ message.payload = (void*)str.c_str();
+ message.payloadlen = str.size();
+ int rc = client.publish("temp", message);
+ printf("rc ==== %d",rc);
+ ret = Hts.get_humidity(&hum);
+ if(ret != 0)
+ {
+ printf("get_humidity failed!\n");
+ }
+ printf("hum = %.2f temp = %.2f\n", hum, temp);
+ str.clear();
+ MbedJSONValue value_hum;
+ value_hum["hum"] = (int)hum;
+ str = value_hum.serialize();
+ message.payload = (void*)str.c_str();
+ message.payloadlen = str.size();
+ rc = client.publish("hum", message);
+ printf("rc ==== %d",rc);
+ str.clear();
+ int32_t buf[3];
+ ret = Lsm.get_x_axes(buf);
+ if(0 == ret)
+ {
+ printf("get_x_axes succeed!!\n");
+ }
+ else
+ {
+ printf("get_x_axes failed!!\n");
+ return -1;
+ }
+ printf("x = %d y = %d z = %d\n",buf[0]/1000,buf[1]/1000,buf[2]/1000);
+ MbedJSONValue value_xyz;
+ value_xyz["x"] = buf[0]/1000;
+ value_xyz["y"] = buf[1]/1000;
+ value_xyz["z"] = buf[2]/1000;
+ str = value_xyz.serialize();
+ message.payload = (void*)str.c_str();
+ message.payloadlen = str.size();
+ rc = client.publish("xyz", message);
+ ThisThread::sleep_for(10);
+ }
+}
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/mbed-os.lib Wed Sep 23 09:12:20 2020 +0000 @@ -0,0 +1,1 @@ +https://github.com/ARMmbed/mbed-os/#b81aeff1a3e171c6421984faa2cc18d0e35746c0
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/wifi-ism43362.lib Wed Sep 23 09:12:20 2020 +0000 @@ -0,0 +1,1 @@ +https://os.mbed.com/teams/Farnell24-IOT-Team/code/wifi-ism43362/#766454e296c3