我建立了一个smarthome的物模型，包括温度、湿度和LED状态3个属性，其中LED状态属性是平台可以修改的，另外两个都是设备上报的。

连接华为云平台

先建立IoTDA.ets，内容如下：

import { MqttAsync, MqttClient, MqttPublishOptions, MqttResponse, MqttSubscribeOptions } from '@ohos/mqtt'

export class MQTT{
  private serverUrl: string = 'tcp://bde4cbe7aa.st1.iotda-device.cn-north-4.myhuaweicloud.com:1883'
  private clientId: string = 'xxxxx_test_0_0_2025020502'
  private userName: string = 'xxxxx_test'
  private password: string = 'xxxxxxxxxxxxxx'
  public mqttAsyncClient: MqttClient = MqttAsync.createMqtt({
    url: this.serverUrl,
    clientId: this.clientId,
    persistenceType: 1,
  })

  private topic: string = "light002"

  connectMqtt() {
    this.mqttAsyncClient.connect({
      userName: this.userName,
      password: this.password,
    }).then(() => {
      this.mqttAsyncClient.isConnected()
        .then((data: boolean) => {
          console.log("连接状态: " + data)
        });
    }).catch(() => {
      console.warn('连接失败')
    })
  }

  subscribeMqtt(topic: string) {
    let subscribeOption: MqttSubscribeOptions = {
      topic: topic,//主题名称
      qos: 0            //消息的服务质量设置
    }
    this.mqttAsyncClient.subscribe(subscribeOption)
      .then((data: MqttResponse) => {
        console.log("订阅成功 " + JSON.stringify(data));
      }).catch((err: MqttResponse) => {
      console.log("订阅失败" + JSON.stringify(err));
    })
  }

  messageArrived() {
    this.mqttAsyncClient.messageArrived((err, data) => {
      if (err) {
        console.error("接收消息时发生错误:", err);
      } else {
        console.log("接收到的消息:",JSON.stringify(data));
      }
    });
  }

  publish(topic:string, message:string) {
    let publishOption: MqttPublishOptions = {
      topic: topic,               //主题名称
      qos: 0,                     //消息的服务质量设置
      payload: message,//发布的消息
    };

    this.mqttAsyncClient.publish(publishOption)
      .then((data: MqttResponse) => {
        console.log("推送成功" + JSON.stringify(data));
      })
      .catch((err: Error) => {
        console.log("推送失败" + JSON.stringify(err));
      });
  }

  disconnect() {
    this.mqttAsyncClient.disconnect()
      .then((data: MqttResponse) => {
        console.log("断开成功:" + JSON.stringify(data));
      })
      .catch((err: MqttResponse) => {
        console.log("断开失败:" + JSON.stringify(err));
      })
  }
}
export const mqtt = new MQTT();

在index.ets开头加上下面的语句：

import {mqtt} from './IoTDA'

 在SmartHomeControlPanel部分加上：

  deviceId: string = "XXXX_test";

  aboutToAppear() {
    // 创建MQTT客户端
    mqtt.connectMqtt()
  }

这样就可以在程序一启动时先连接上华为云的服务器。 

发布LED灯状态

代码重构

我们将原来的LED灯控制逻辑进行一下重构，添加如下函数：

  // 控制LED灯的状态并发布消息
  private setLedStatusAndPublish() {
    if (this.lightStatus) {
      console.info("this toggle is On.");
      let res: string = testNapi.gpio_on(this.ledPath);
      console.info(res);
    } else {
      console.info("this.toggle is Off.");
      let res: string = testNapi.gpio_off(this.ledPath);
      console.info(res);
    }
    let ledstatus: string = this.lightStatus ? 'ON' : 'OFF';
    const topic = `$oc/devices/${this.deviceId}/sys/properties/report`;
    const message = `{"services": [{"serviceId": "smarthome", "properties": {"LED状态": "${ledstatus}"}}]}`;
    mqtt.publish(topic, message);
  }

然后将灯光控制按钮修改为：

      // 灯光控制按钮
      Button({
        type: ButtonType.Capsule,
        stateEffect: true,
      }) {
        Row() {
          Image(this.lightStatus ? $r('app.media.light_off_icon') : $r('app.media.light_on_icon'))
            .width(48)
            .height(48)
            .margin({ right: 10 })
          Text(this.lightStatus ? '关闭灯光' : '打开灯光')
            .fontSize(20)
            .fontColor('#FFFFFF')
        }
      }
      .width('80%')
      .height(80)
      .margin({ top: 20 })
      .onClick(() => {
        this.lightStatus = !this.lightStatus;
        this.setLedStatusAndPublish();
      })

 这样我们每按下灯光控制按钮，就会自动向云平台发送一下最新的状态。

测试结果

我们可以测试一下，看到云平台显示的状态信息如下：

接收平台发送的属性修改命令

设备侧API

当平台向设备设置属性信息时，首先设备必须在线。

设备侧会自动收到特定Topic的查询请求（无需订阅），设备收到属性查询请求后，需要将设备的属性数据返回给平台，如果设备没回响应平台会认为属性查询请求执行超时。

有关文档可以参考：平台设置设备属性_设备接入 IoTDA_华为云

Topic

下行: $oc/devices/{device_id}/sys/properties/set/request_id={request_id}

上行: $oc/devices/{device_id}/sys/properties/set/response/request_id={request_id}

下行请求参数说明

ServiceProperty结构定义：

上行响应参数说明

程序修改

我们需要在aboutToAppear中加上接收云端消息的函数，同时在其中进行JSON解析。ArkTS的JSON解析有点特殊，参见我写的博文。下面就是修改好的代码：

// 定义设备属性类
class DeviceProperties {
  温度: number;
  湿度: number;
  LED状态: string;

  constructor(温度: number, 湿度: number, LED状态: string) {
    this.温度 = 温度;
    this.湿度 = 湿度;
    this.LED状态 = LED状态;
  }
}

// 定义服务类
class Service {
  serviceId: string;
  properties: DeviceProperties;

  constructor(serviceId: string, properties: DeviceProperties) {
    this.serviceId = serviceId;
    this.properties = properties;
  }
}

// 定义整个数据结构类
class ServiceData {
  services: Service[];

  constructor(services: Service[]) {
    this.services = services;
  }
}

@Entry
@Component
struct SmartHomeControlPanel {
……

  aboutToAppear() {
    // 创建MQTT客户端
    mqtt.connectMqtt()
    mqtt.mqttAsyncClient.messageArrived((err, data) => {
      if (err) {
        console.error("接收消息时发生错误:", err);
      } else {
        console.log("接收到的消息:",JSON.stringify(data));

        // 处理接收到的消息
        if(data.topic.indexOf('sys/properties/set')) {
          let upTopic = this.getUpstreamTopic(data.topic)
          let resultString = '{"result_code": 0, "result_desc": "success" }'
          mqtt.publish(upTopic, resultString);
        }

        // 解析 JSON 字符串
        const parsedData = JSON.parse(data.payload) as ServiceData;

        const ledStatus = parsedData.services[0].properties.LED状态;

        // 打印结果
        console.log(`Service ID: ${parsedData.services[0].serviceId}`);
        console.log(`LED状态: ${parsedData.services[0].properties.LED状态}`);
        if(ledStatus === 'ON'){
          this.lightStatus = true;
        }else {
          this.lightStatus = false;
        }
        this.setLedStatusAndPublish();
      }
    });
  }

应用侧API

华为的物联网平台提供了应用侧API，实现设备数据采集、命令下发、设备管理等业务场景。

有关应用侧API参见：应用侧API参考_设备接入 IoTDA_华为云。

为了简化应用侧程序的开发，华为提供了各种语言的SDK：SDK概述_设备接入 IoTDA_华为云。不过，今天不介绍SDK，只介绍如何用API Explorer进行API测试和学习。

华为云API Explorer为开发者提供一站式API 解决方案 统一平台，集成华为 云服务 所有开放API，支持全量快速检索、可视化调试、帮助文档、代码示例等能力，帮助开发者快速查找、学习API和使用API开发代码。API Explorer致力于帮助您更快地查找华为云Open API，您可以使用API Explorer来检索华为云开放的API并查看相应的文档，同时应用于API调试、 故障排查 等场景。

API Explorer的网站：https://console.huaweicloud.com/apiexplorer/#/openapi/overview

测试设备属性设置功能

我在API Explorer中对test设备的“LED状态”属性进行了修改。

程序可以正常收到下发的指令，并根据指令进行开灯和关灯操作。

结语

至此，我们完成了智能中控屏接入物联网的操作。我们的测试仍然将继续。