目录

喷淋实验--嵌入式实训

1.MQTT通信原理

2.MQTT库的移植

3.代码流程

运行视频如下:

---

喷淋实验--嵌入式实训

---

---

打开MQTT
订阅主题（元宇宙的发布主题）

while(1)
{
获取数据
if(数据   >   最大值)
{
		发送消息（给元宇宙的订阅主题发消息，喷淋关）；
}
else if(数据   <   最小值)
{
发送消息（给元宇宙的订阅主题发消息，喷淋开）；
}
打印数据；
sleep(1);
}
关闭MQTT；

打开MQTT
mqtt_init();


订阅函数和发布函数
int mqtt_subscribe(const char *topic)
功能：订阅主题
参数：元宇宙发布主题

int mqtt_publish(const char *topic, char *msg)
功能：发布消息
参数：元宇宙的订阅主题	消息

获取数据
float get_virtual_env()
功能：获取土壤湿度数据
参数：空

关闭MQTT；
exit_mqtt();

---

#include<stdio.h>
#include"mqtt.h"
#include<unistd.h>

int main(int argc, char *argv[]){
    //1-连接服务器
    mqtt_init();

    //2-订阅元宇宙平台主题，获得数据串
        //通过目标节点的发布主题，才能的得到发布的内容
    mqtt_subscribe("1703406852492/AIOTSIM2APP");

    //3.定义变量接收到存储解析的数据
    float soilHum=0;

    //4.循环获取数据，下发控制指令
    while (1){
        sleep(1);
        soilHum= get_virtual_env();
        if (soilHum>80){
            mqtt_publish("1703406852492/APP2AIOTSIM", "{\"irrigated\":false}");
            mqtt_publish("1703406852492/APP2AIOTSIM", "{\"alarm\":true}");
            printf("关闭喷淋，警报响起。。。。\n");
        }
        else if (soilHum<10){
            mqtt_publish("1703406852492/APP2AIOTSIM", "{\"irrigated\":true}");
            mqtt_publish("1703406852492/APP2AIOTSIM", "{\"alarm\":false}");
            printf("打开喷淋，警报关闭。。。。\n");
        }
        sleep(1);
        printf("当前湿度：%.2f\n", soilHum);
    }
    exit_mqtt();
    return 0;
}

        上述程序使用MQTT协议进行物联网通信的示例程序。根据代码的逻辑，大致可以分为以下几个步骤：

1. 导入必要的头文件，包括"stdio.h"、"mqtt.h"和"unistd.h"。

2. 在主函数中，首先调用mqtt_init()函数来初始化MQTT连接。

3. 调用mqtt_subscribe()函数订阅指定的主题，该主题用于接收元宇宙平台发布的数据。

4. 定义一个float类型的变量soilHum，用于存储解析得到的数据。

5. 进入一个无限循环，在循环中通过get_virtual_env()函数获取虚拟环境的湿度数据，并将其赋值给soilHum变量。

6. 根据湿度数据的不同情况，使用mqtt_publish()函数向指定主题发送控制指令，控制喷淋器的状态和警报器的状态。

7. 在每次循环中，使用printf()函数打印当前湿度数据。

8. 最后，调用exit_mqtt()函数关闭MQTT连接，并返回0表示程序正常结束。

        总的来说，这段代码是一个简单的智能灌溉系统的控制程序，通过接收来自元宇宙平台的湿度数据，根据设定的阈值进行判断，并控制喷淋器和警报器的状态

运行结果：

运行视频如下: