Khakimov Rishat / Mbed OS Kurs

87ty78ot7iyu

Dependencies:   HCSR04

main.cpp@100:818629f882ab, 17 months ago (annotated)

Committer:
rishat
Date:
Thu Nov 17 10:40:53 2022 +0000
Revision:
100:818629f882ab
Parent:
91:dab9882e2b49 
112

Who changed what in which revision?

UserRevisionLine numberNew contents of line
rishat 100:818629f882ab 1 #include "MQTTmbed.h"
rishat 100:818629f882ab 2 #include <MQTTClientMbedOs.h>
rishat 100:818629f882ab 3 #include <cstdio>
mbed_official 0:857719181846 4 #include "mbed.h"
rishat 100:818629f882ab 5 #include "hcsr04.h"
mbed_official 0:857719181846 6
rishat 100:818629f882ab 7 int main(int argc, char *argv[]) {
rishat 100:818629f882ab 8 long distance = sensor.distance();
rishat 100:818629f882ab 9 long distanza = distance;
rishat 100:818629f882ab 10 printf("distanza %d \n",distanza);
rishat 100:818629f882ab 11 printf("Starting IBM MQTT demo:\n");
rishat 100:818629f882ab 12 TCPSocket socket;
rishat 100:818629f882ab 13 NetworkInterface *net = NetworkInterface::get_default_instance();
rishat 100:818629f882ab 14 if (!net) {
rishat 100:818629f882ab 15 printf("Error! No 11network inteface11 found.\n");
rishat 100:818629f882ab 16 return 0; }
rishat 100:818629f882ab 17 printf("Connecting to the network...\r\n");
rishat 100:818629f882ab 18 nsapi_size_or_error_t rc = net->connect();
rishat 100:818629f882ab 19 if (rc != 0) {
rishat 100:818629f882ab 20 printf("Error! _net->connect() returned: %d\r\n", rc);
rishat 100:818629f882ab 21 return -1; }
rishat 100:818629f882ab 22 rc = socket.open(net);
rishat 100:818629f882ab 23 if (rc != 0) {
rishat 100:818629f882ab 24 printf("Error! _socket.open() returned: %d\r\n", rc);
rishat 100:818629f882ab 25 return -1; }
rishat 100:818629f882ab 26 SocketAddress address;
rishat 100:818629f882ab 27 net->gethostbyname("dev.rightech.io",
rishat 100:818629f882ab 28 &address);
rishat 100:818629f882ab 29 address.set_port(1883);
rishat 100:818629f882ab 30 printf("Opening connection to remote %s port %d\r\n",
rishat 100:818629f882ab 31 address.get_ip_address(), address.get_port());
rishat 100:818629f882ab 32 rc = socket.connect(address);
rishat 100:818629f882ab 33 if (rc != 0) {
rishat 100:818629f882ab 34 printf("Error! _socket.connect() returned: %d\r\n", rc);
rishat 100:818629f882ab 35 return -1; }
rishat 100:818629f882ab 36 printf("Connected socket\n");
rishat 100:818629f882ab 37 MQTTClient client(&socket);
rishat 100:818629f882ab 38 MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
rishat 100:818629f882ab 39 data.MQTTVersion = 3;
rishat 100:818629f882ab 40 data.clientID.cstring = "distanza1";
rishat 100:818629f882ab 41 data.username.cstring = "AFAC";
rishat 100:818629f882ab 42 data.password.cstring = "As123456";
rishat 100:818629f882ab 43 if ((rc = client.connect(data)) != 0)
rishat 100:818629f882ab 44 printf("rc from MQTT connect is %d\r\n", rc);
rishat 100:818629f882ab 45 MQTT::Message message;
rishat 100:818629f882ab 46 char *topic = "ss";
rishat 100:818629f882ab 47 char buf[100];
rishat 100:818629f882ab 48 int temp = 1;
rishat 100:818629f882ab 49 int press = 2;
rishat 100:818629f882ab 50 int hum = 3;
rishat 100:818629f882ab 51 //sprintf(buf,
rishat 100:818629f882ab 52 // "{\"d\":{\"ST\":\"Nucleo-IoT-mbed\",\"Temp\":%d,\"Pressure\":"
rishat 100:818629f882ab 53 // "%d,\"Humidity\":%d}}", temp, press, hum);
rishat 100:818629f882ab 54 sprintf(buf,
rishat 100:818629f882ab 55 "{\"distanza\": %d}", distanza);
rishat 100:818629f882ab 56 printf("Sending message: \n%s\n", buf);
rishat 100:818629f882ab 57 message.qos = MQTT::QOS0;
rishat 100:818629f882ab 58 message.retained = false;
rishat 100:818629f882ab 59 message.dup = false;
rishat 100:818629f882ab 60 message.payload = (void *)buf;
rishat 100:818629f882ab 61 message.payloadlen = strlen(buf);
rishat 100:818629f882ab 62 rc = client.publish(topic, message);
rishat 100:818629f882ab 63 printf("Message sent\n");
rishat 100:818629f882ab 64 printf("Demo concluded successfully \r\n");
rishat 100:818629f882ab 65 return 0; }