本示例将演示如何在BearPi-HM_Nano开发板上使用MQTT协议连接华为IoT平台,使用各路传感器件与 BearPi-HM_Nano 开发板实现智能电饭煲的案例。
int oc_mqtt_profile_msgup(char *deviceid,oc_mqtt_profile_msgup_t *payload);
是指设备无法按照产品模型中定义的属性格式进行数据上报时,可调用此接口将设备的自定义数据上报给平台,平台将设备上报的消息转发给应用服务器或华为云其他云服务上进行存储和处理。
参数 | 描述 |
---|---|
deviceid | 设备id |
payload | 要上传的消息 |
返回 | 描述 |
0 | 上传成功 |
1 | 上传失败 |
int oc_mqtt_profile_propertyreport(char *deviceid,oc_mqtt_profile_service_t *payload);
用于设备按产品模型中定义的格式将属性数据上报给平台。
参数 | 描述 |
---|---|
deviceid | 设备id |
payload | 要上传的消息 |
返回 | 描述 |
0 | 上传成功 |
1 | 上传失败 |
属性上报和消息上报的区别,请查看消息通信说明
int oc_mqtt_profile_gwpropertyreport(char *deviceid,oc_mqtt_profile_device_t *payload);
用于批量设备上报属性数据给平台。网关设备可以用此接口同时上报多个子设备的属性数据。
参数 | 描述 |
---|---|
deviceid | 设备id |
payload | 要上传的消息 |
返回 | 描述 |
0 | 上传成功 |
1 | 上传失败 |
int oc_mqtt_profile_propertysetresp(char *deviceid,oc_mqtt_profile_propertysetresp_t *payload);
参数 | 描述 |
---|---|
deviceid | 设备id |
payload | 消息 |
返回 | 描述 |
0 | 上传成功 |
1 | 上传失败 |
int oc_mqtt_profile_propertygetresp(char *deviceid,oc_mqtt_profile_propertygetresp_t *payload);
参数 | 描述 |
---|---|
deviceid | 设备id |
payload | 消息 |
返回 | 描述 |
0 | 上传成功 |
1 | 上传失败 |
int oc_mqtt_profile_cmdresp(char *deviceid,oc_mqtt_profile_cmdresp_t *payload); 平台下发命令后,需要设备及时将命令的执行结果返回给平台,如果设备没回响应,平台会认为命令执行超时。
参数 | 描述 |
---|---|
deviceid | 设备id |
payload | 要上传的消息 |
返回 | 描述 |
0 | 上传成功 |
1 | 上传失败 |
在连接平台前需要设置获取CONFIG_APP_DEVICEID、CONFIG_APP_DEVICEPWD、CONFIG_APP_SERVERIP、CONFIG_APP_SERVERPORT,通过oc_mqtt_profile_connect()函数连接平台。
WifiConnect(CONFIG_WIFI_SSID, CONFIG_WIFI_PWD);
dtls_al_init();
mqtt_al_init();
oc_mqtt_init();
g_app_cb.app_msg = queue_create("queue_rcvmsg",10,1);
if(NULL == g_app_cb.app_msg){
printf("Create receive msg queue faimotor");
}
oc_mqtt_profile_connect_t connect_para;
(void) memset( &connect_para, 0, sizeof(connect_para));
connect_para.boostrap = 0;
connect_para.device_id = CONFIG_APP_DEVICEID;
connect_para.device_passwd = CONFIG_APP_DEVICEPWD;
connect_para.server_addr = CONFIG_APP_SERVERIP;
connect_para.server_port = CONFIG_APP_SERVERPORT;
connect_para.life_time = CONFIG_APP_LIFETIME;
connect_para.rcvfunc = msg_rcv_callback;
connect_para.security.type = EN_DTLS_AL_SECURITY_TYPE_NONE;
ret = oc_mqtt_profile_connect(&connect_para);
if((ret == (int)en_oc_mqtt_err_ok)){
g_app_cb.connected = 1;
printf("oc_mqtt_profile_connect succed!\r\n");
}
else
{
printf("oc_mqtt_profile_connect faild!\r\n");
}
当需要上传数据时,需要先拼装数据,让后通过oc_mqtt_profile_propertyreport上报数据。代码示例如下:
static void deal_report_msg(report_t *report)
{
oc_mqtt_profile_service_t service;
oc_mqtt_profile_kv_t luminance;
oc_mqtt_profile_kv_t motor;
service.event_time = NULL;
service.service_id = "rice";
service.service_property = &luminance;
service.nxt = NULL;
luminance.key = "Luminance";
luminance.value = &report->lum;
luminance.type = EN_OC_MQTT_PROFILE_VALUE_INT;
luminance.nxt = &motor;
motor.key = "riceStatus";
motor.value = g_app_cb.motor ? "ON" : "OFF";
motor.type = EN_OC_MQTT_PROFILE_VALUE_STRING;
motor.nxt = NULL;
oc_mqtt_profile_propertyreport(USERNAME, &service);
return;
}
华为IoT平台支持下发命令,命令是用户自定义的。接收到命令后会将命令数据发送到队列中,task_main_entry函数中读取队列数据并调用deal_cmd_msg函数进行处理,代码示例如下:
void oc_cmd_rsp_cb(uint8_t *recv_data, size_t recv_size, uint8_t **resp_data, size_t *resp_size)
{
app_msg_t *app_msg;
int ret = 0;
app_msg = malloc(sizeof(app_msg_t));
app_msg->msg_type = en_msg_cmd;
app_msg->msg.cmd.payload = (char *)recv_data;
printf("recv data is %.*s\n", recv_size, recv_data);
ret = osMessageQueuePut(mid_MsgQueue,&app_msg,0U, 0U);
if(ret != 0){
free(recv_data);
}
*resp_data = NULL;
*resp_size = 0;
}
static int task_main_entry( void )
{
app_msg_t *app_msg;
WifiConnect("TP-LINK_65A8","0987654321");
device_info_init(CLIENT_ID,USERNAME,PASSWORD);
oc_mqtt_init();
oc_set_cmd_rsp_cb(oc_cmd_rsp_cb);
while(1){
app_msg = NULL;
(void)osMessageQueueGet(mid_MsgQueue,(void **)&app_msg,NULL, 0U);
if(NULL != app_msg){
switch(app_msg->msg_type){
case en_msg_cmd:
deal_cmd_msg(&app_msg->msg.cmd);
break;
case en_msg_report:
deal_report_msg(&app_msg->msg.report);
break;
default:
break;
}
free(app_msg);
}
}
return 0;
}
static void deal_cmd_msg(cmd_t *cmd)
{
cJSON *obj_root;
cJSON *obj_cmdname;
cJSON *obj_paras;
cJSON *obj_para;
int cmdret = 1;
oc_mqtt_profile_cmdresp_t cmdresp;
obj_root = cJSON_Parse(cmd->payload);
if (NULL == obj_root)
{
goto EXIT_JSONPARSE;
}
obj_cmdname = cJSON_GetObjectItem(obj_root, "command_name");
if (NULL == obj_cmdname)
{
goto EXIT_CMDOBJ;
}
if (0 == strcmp(cJSON_GetStringValue(obj_cmdname), "rice_Control_motor"))
{
obj_paras = cJSON_GetObjectItem(obj_root, "paras");
if (NULL == obj_paras)
{
goto EXIT_OBJPARAS;
}
obj_para = cJSON_GetObjectItem(obj_paras, "motor");
if (NULL == obj_para)
{
goto EXIT_OBJPARA;
}
///< operate the motor here
if (0 == strcmp(cJSON_GetStringValue(obj_para), "ON"))
{
g_app_cb.motor = 1;
rice_StatusSet(ON);
printf("motor On!");
goto EXIT_JSONPARSE;
}
else
{
g_app_cb.motor = 0;
rice_StatusSet(OFF);
printf("motor Off!");
goto EXIT_JSONPARSE;
}
cmdret = 0;
}
EXIT_OBJPARA:
EXIT_OBJPARAS:
EXIT_CMDOBJ:
cJSON_Delete(obj_root);
EXIT_JSONPARSE:
///< do the response
cmdresp.paras = NULL;
cmdresp.request_id = cmd->request_id;
cmdresp.ret_code = cmdret;
cmdresp.ret_name = NULL;
(void)oc_mqtt_profile_cmdresp(NULL, &cmdresp);
return;
}
//水泵直流电机启动
GpioSetOutputVal(WIFI_IOT_IO_NAME_GPIO_6, 1);
hi_udelay(5000000);
GpioSetOutputVal(WIFI_IOT_IO_NAME_GPIO_6, 0);
hi_udelay(5000000);
//放米舵机(MG90)转到90°:打开仓门
for (int i = 1; i <=20 ; i++)
{
GpioSetOutputVal(WIFI_IOT_IO_NAME_GPIO_2, 1);
hi_udelay(1500);
GpioSetOutputVal(WIFI_IOT_IO_NAME_GPIO_2, 0);
hi_udelay(THE_CYCLES_OF_PWM_CONTROL-1500);
}
hi_udelay(10000);
设备接入华为云平台之前,需要在平台注册用户账号,华为云地址:https://www.huaweicloud.com/
在华为云首页单击产品,找到IoT物联网,单击设备接入IoTDA 并单击立即使用。
在设备接入页面可看到总览界面,展示了华为云平台接入的协议与域名信息,根据需要选取MQTT通讯必要的信息备用。
接入协议(端口号):MQTT 1883
域名:iot-mqtts.cn-north-4.myhuaweicloud.com
选中侧边栏产品页,单击右上角“创建产品”,在页面中选中所属资源空间,并且按要求填写产品名称,选中MQTT协议,数据格式为JSON,并填写厂商名称,在下方模型定义栏中选择所属行业以及添加设备类型,并单击右下角“确定”如图:
创建完成后,在产品页会自动生成刚刚创建的产品,单击“查看”可查看创建的具体信息。
单击产品详情页的自定义模型,在弹出页面中新增服务
服务ID:rice
(必须一致)
在“rice”的下拉菜单下点击“添加属性”填写相关信息“Luminance”,“riceStatus”。
在“rice”的下拉菜单下点击“添加命令”填写相关信息。
命令名称:rice_Control_motor
参数名称:motor
数据类型:string
长度:3
枚举值:ON,OFF
在侧边栏中单击“设备”,进入设备页面,单击右上角“注册设备”,勾选对应所属资源空间并选中刚刚创建的产品,注意设备认证类型选择“秘钥”,按要求填写秘钥。
注册完成后,在设备页面单击“所有设备”,即可看到新建的设备,同时设备处于未激活状态
修改iot_cloud_oc_sample.c
中第31行附近的wifi的ssid和pwd,以及设备的DEVICEID和DEVICEPWD(这两个参数是在平台注册设备时产生的),
修改 applications\sample\BearPi\BearPi-HM_Nano
路径下 BUILD.gn 文件,指定 cloud_oc_rice
参与编译。
#"D8_iot_cloud_oc_smoke:cloud_oc_smoke"
"iot_cloud_oc_rice:cloud_oc_rice"
#"D10_iot_cloud_oc_manhole_cover:cloud_oc_manhole_cover"
#"D11_iot_cloud_oc_infrared:cloud_oc_infrared"
#"D12_iot_cloud_oc_agriculture:cloud_oc_agriculture"
示例代码编译烧录代码后,按下开发板的RESET按键,通过串口助手查看日志,平台上的设备显示为在线状态。
点击设备右侧的“查看”,进入设备详情页面,可看到上报的数据
在华为云平台设备详情页,单击“命令”,选择同步命令下发,选中创建的命令属性,单击“确定”,即可发送下发命令控制设备