Khakimov Rishat
/
Kurs_copyed
ADFWQEF
main.cpp
- Committer:
- rishat
- Date:
- 23 months ago
- Revision:
- 100:7c75f1700889
- Parent:
- 91:dab9882e2b49
File content as of revision 100:7c75f1700889:
#include "MQTTmbed.h" #include <MQTTClientMbedOs.h> #include <cstdio> #include "mbed.h" AnalogIn my_adc(PA_7); //D11 on board AnalogIn my_abc(PA_6); //DigitalOut led(LED1); DigitalOut dat(D15); int main(int argc, char *argv[]) { //long distance = sensor.distance(); //long distanza = distance; //printf("distanza %d \n",distanza); printf("Starting IBM MQTT demo:\n"); TCPSocket socket; NetworkInterface *net = NetworkInterface::get_default_instance(); if (!net) { printf("Error! No 11network inteface11 found.\n"); return 0; } printf("Connecting to the network...\r\n"); nsapi_size_or_error_t rc = net->connect(); if (rc != 0) { printf("Error! _net->connect() returned: %d\r\n", rc); return -1; } rc = socket.open(net); if (rc != 0) { printf("Error! _socket.open() returned: %d\r\n", rc); return -1; } SocketAddress address; net->gethostbyname("dev.rightech.io", &address); address.set_port(1883); printf("Opening connection to remote %s port %d\r\n", address.get_ip_address(), address.get_port()); rc = socket.connect(address); if (rc != 0) { printf("Error! _socket.connect() returned: %d\r\n", rc); return -1; } printf("Connected socket\n"); MQTTClient client(&socket); MQTTPacket_connectData data = MQTTPacket_connectData_initializer; data.MQTTVersion = 3; data.clientID.cstring = "XXXXX"; data.username.cstring = "ZZZ"; data.password.cstring = "ZZZ"; if ((rc = client.connect(data)) != 0) printf("rc from MQTT connect is %d\r\n", rc); MQTT::Message message; while(1) { char *topic = "post"; char buf[100]; int distanza = round(my_adc*100); //sprintf(buf, // "{\"d\":{\"ST\":\"Nucleo-IoT-mbed\",\"Temp\":%d,\"Pressure\":" // "%d,\"Humidity\":%d}}", temp, press, hum); sprintf(buf, "{\"distanse\": %d}", distanza); wait_ns(1000000); printf("Sending message: \n%s\n", buf); message.qos = MQTT::QOS0; message.retained = false; message.dup = false; message.payload = (void *)buf; message.payloadlen = strlen(buf); rc = client.publish(topic, message); printf("Message sent\n"); printf("Demo concluded successfully \r\n"); wait_ns(9000000000); char buf2[10]; int ogon = round(my_abc*100); sprintf(buf2, "{\"ogon\": %d}", ogon); wait_ns(9000000000); printf("Sending message: \n%s\n", buf2); message.qos = MQTT::QOS0; message.retained = false; message.dup = false; message.payload = (void *)buf2; message.payloadlen = strlen(buf2); rc = client.publish(topic, message); printf("Message sent\n"); printf("Demo concluded successfully \r\n"); wait_ns(10000000000); } return 0; }