ETH应用：使用mbedos自带的mbed-mqtt库与云平台通信（MQTT协议）

/*

 * Copyright (c) 2006-2020 Arm Limited and affiliates.

 * SPDX-License-Identifier: Apache-2.0

 */

#include "mbed.h"



#include "EthernetInterface.h"

#include <MQTTClientMbedOs.h>

#include <cstring>

#include <string>

#include "MQTTNetwork.h"



SocketAddress ipAddress; //ip地址



char* mqtt_server = "mqtt.nlecloud.com"; //mqtt服务器域名

int mqtt_port = 1883;                    //mqtt服务器端口号



char* project_id = "896774";             //项目id

char* device_id = "957380";              //设备id

char* client_id = "apm32f407";           //设备标识符

char* device_key = "228c9236ac99407c92dcd9dacfdce115";//设备密钥



AnalogIn adc_data(PA_0);



int main(void)

{

    nsapi_error_t err;



    printf("ETH MQTT Test!\r\n");



    //使用默认的网络服务，APM32F407IG默认设置的是ETH接口

    NetworkInterface *net = NetworkInterface::get_default_instance();



    //使用DHCP动态分配IP地址

    net->connect();



    //打印测试ip地址是否分配成功

    err = net->get_ip_address(&ipAddress);

    printf("IP address : %s \r\n",ipAddress.get_ip_address());



    //新建一个MQTTNetwork网络接口

    MQTTNetwork mqttNetwork(net);



    //新建一个MQTTClient

    MQTT::Client<MQTTNetwork, Countdown> client(mqttNetwork);

    printf("Connect to %s: %d\r\n",mqtt_server,mqtt_port);



    //连接mqtt服务器

    err = mqttNetwork.connect(mqtt_server, mqtt_port);

    if(err != 0)

    {

        printf("mqtt server connect fail!\r\n");

        return -1;

    }



    //配置连接的项目参数

    MQTTPacket_connectData conn_data = MQTTPacket_connectData_initializer;

    conn_data.MQTTVersion = 3;

    conn_data.clientID.cstring = client_id; //client_id为设备标识符

    conn_data.username.cstring = device_id; //device_id为分配的设备id

    conn_data.password.cstring = device_key;//device_key为生成的密钥



    //客户端连接云平台，并打印相关信息

    if(client.connect(conn_data) != 0)

    {

        printf("mqtt server connect fail!\r\n");

        return -1;

    }

    else

    {

        printf("mqtt server connect success!\r\n");

    }



    //新建一个变量存储adc采集的数据

    unsigned short voltage = adc_data.read_u16();

    char buf[100];



    // buf = "{\"datatype\":1,\"datas\":{\"adc_data\":0.2}";

    sprintf(buf,"{\"datatype\":1,\"datas\":{\"adc_data\":%d}",voltage);



    //message为MQTTpublish的配置信息

    MQTT::Message message;

    message.dup = false;

    message.qos = MQTT::QOS1;

    message.retained = false;



    while(1)

    {

        //获取adc采集的数据

        voltage = adc_data.read_u16();

        sprintf(buf,"{\"datatype\":1,\"datas\":{\"adc_data\":%d},\"msgid\":001}",voltage);//json格式的上报数据信息，用buf缓存，上传的数据格式需要根据开发文档定义

        message.payload = (void*)buf;

        message.payloadlen = strlen(buf);



        //客户端上传数据

        client.publish("/sys/896774/957380/sensor/datas",message);//订阅的topic，topic 格式需要根据开发文档对应



        //每隔1s上传一次

        ThisThread::sleep_for(1s);

    }



    return 0;

}