任务2：

在所给的 irrigate-1 文件夹中创建一个main.c 完成以下内容：

（1）根据土壤湿度自动控制喷淋开关

（2）根据光照强度控制风扇以及灯的开关

参考：

#include <stdio.h>
#include <unistd.h>
#include "mqtt.h"
#include "parse_config.h"#define SUB_TOPIC  "1703161172612/AIOTSIM2APP"   //定阅的主题
#define PUB_TOPIC  "1703161172612/APP2AIOTSIM"  //发布主题#define IRRIGATED_ON "{\"irrigated\":true}"
#define IRRIGATED_OFF "{\"irrigated\":false}"#define FAN_ON		"{\"fan\":true}"
#define FAN_OFF		"{\"fan\":false}"#define LAMP_ON		"{\"lamp\":true}"
#define LAMP_OFF		"{\"lamp\":false}"#define ALARM_ON		"{\"alarm\":true}"
#define ALARM_OFF		"{\"alarm\":false}"int main(int argc, const char *argv[])
{ENV msg_env={};//1.初始化mqtt协议if(mqtt_init()!=0){printf("mqtt init err.\n");return -1;}//订阅别人发布的消息if(mqtt_subscribe(SUB_TOPIC) < 0){printf("sub err.\n");return -1;}//循环获取温湿度//当大于阈值关闭灌溉，小于就打开while(1){sleep(1);//获取值msg_env=get_virtual_env();if(msg_env.ill < 20000){mqtt_publish(PUB_TOPIC,FAN_OFF);mqtt_publish(PUB_TOPIC,LAMP_ON);}else if(msg_env.ill > 50000){mqtt_publish(PUB_TOPIC,FAN_ON);mqtt_publish(PUB_TOPIC,LAMP_OFF);}printf("ill:%f\n",msg_env.ill);if(msg_env.soil < 30){mqtt_publish(PUB_TOPIC,IRRIGATED_ON);}else if(msg_env.soil > 50){mqtt_publish(PUB_TOPIC,IRRIGATED_OFF);}printf("soilhum:%f\n",msg_env.soil);// if(msg_env.infrared == 1)// {// 	mqtt_publish(PUB_TOPIC,ALARM_ON);// }else {// 	mqtt_publish(PUB_TOPIC,ALARM_OFF);// }// printf("infrared:%d\n",msg_env.infrared);}exit_mqtt();return 0;
}

具体过程：

所用的头文件：

data_global.h

#ifndef __DATA_GLOBAL__H__
#define __DATA_GLOBAL__H__#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <time.h>
#include <termios.h>
#include <signal.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <pthread.h>
#include <stdbool.h>
struct env_info
{float soil;  //土壤湿度float light; //光照强度float temp;   //空气温度uint8_t gas;    //有害气体
};extern struct env_info env_msg;//设备编号
#define FAN  0x00
#define BEEP 0x10
#define LED  0x20
#define PUMP 0X30#define DATA_ARRIVE SIGUSR1 //数据到达信号//订阅、发布主题
#define ENV_PUB_TOPIC "FS_VRJJ/control"//虚拟仿真硬件协议
#define LAMP_ON    "{\"lamp\":true}"
#define LAMP_OFF   "{\"lamp\":false}"#define ALARM_ON   "{\"alarm\":true}"
#define ALARM_OFF  "{\"alarm\":false}"#define SUNSHADE_FOR "{\"sunshade\":\"forward\"}"
#define SUNSHADE_REV	"{\"sunshade\":\"reverse\"}"
#define SUNSHADE_STOP	"{\"sunshade\":\"stop\"}"#define VIR_FAN_ON	"{\"fan\":true}"
#define VIR_FAN_OFF "{\"fan\":false}"#define IRRIGATED_OFF "{\"irrigated\":false}"
#define IRRIGATED_ON "{\"irrigated\":true}"
#endif

mqtt.h

#ifndef __MQTT_SMART_H_
#define __MQTT_SMART_H_typedef struct env
{float soil;//土壤湿度float ill;//光照int smog;//烟雾int infrared;//人体红外
}ENV;
int mqtt_init();
void exit_mqtt();
int mqtt_subscribe(const char*topic);
int mqtt_publish(const char *topic, char *msg);
ENV get_virtual_env();#endif

主程序：mian.c

#include<stdio.h>
#include"mqtt.h"
#include<unistd.h>
#include"data_global.h"#define subscribe "1703503856299/AIOTSIM2APP"
#define publish "1703503856299/APP2AIOTSIM"
int main(int argc, char *argv[]){//1-连接服务器mqtt_init();//2-订阅元宇宙平台主题，获得数据串//通过目标节点的发布主题，才能的得到发布的内容mqtt_subscribe(subscribe);//4.循环获取数据，下发控制指令while (1){sleep(1);ENV env= get_virtual_env();if (env.soil>60){mqtt_publish(publish, IRRIGATED_OFF);printf("关闭喷淋。。。。\n");}else if (env.soil<30){mqtt_publish(publish, IRRIGATED_ON);printf("打开喷淋\n");}printf("当前土壤湿度：%.2f\n", env.soil);if (env.ill>27000){mqtt_publish(publish, VIR_FAN_ON);mqtt_publish(publish,  LAMP_OFF);printf("打开风扇，关闭灯。。。。\n");}else if (env.ill<25000){mqtt_publish(publish,  VIR_FAN_OFF);mqtt_publish(publish,  LAMP_ON);printf("关闭风扇,打开灯。。。。。。\n");}sleep(1);printf("当前光照强度：%.2f\n", env.ill);printf("++++++++++++++++++++++++++++\n");}exit_mqtt();return 0;
}

运行结果：

元宇宙未运行时：

元宇宙运行后：

运行过程视频：

上述程序存在问题：

初步破局：

在元宇宙实验平台还没开始运行时，各种数据都是0，就会导致程序通过if、else if判断语句来控制各种机器运作，这是不正确的。为了避免这种情况，可以添加一些额外的判断来解决这个问题。