快速接入

创建产品

为了方便体验，提供了一个烟感的产品模型，烟感会上报烟雾值、温度、湿度、烟雾报警、还支持响铃报警命令。以烟感为例，体验消息上报、属性上报等功能。

1. 访问设备接入服务，单击“管理控制台”进入设备接入控制台，选择您的实例，单击实例卡片进入。
2. 单击左侧导航栏“产品”，单击页面左侧的“创建产品”。
   图1 产品-创建产品
   

3. 根据页面提示填写参数，然后单击“确定”完成产品的创建。

   基本信息
   所属资源空间	平台自动将新创建的产品归属在默认资源空间下。如需归属在其他资源空间下，下拉选择所属的资源空间。如无对应的资源空间，请先创建资源空间。
   产品名称	自定义。支持字母、数字、下划线（_）、连字符（-）的字符组合。
   协议类型	选择“MQTT”。
   数据格式	选择“JSON”。
   设备类型选择	选择”自定义类型”
   设备类型	填写“smokeDetector”
   高级配置
   产品ID	不填写
   产品描述	请根据实际情况填写。

   图2 创建产品-MQTT
   

上传产品模型

1. 单击下载烟感产品模型smokeDetector，获取产品模型文件。
2. 找到创建的产品，单击产品进入产品详情页。
3. 选择“基本信息”页签，单击“上传模型文件”，上传1获取的产品模型文件。
   图3 产品-上传产品模型
   

注册设备

1. 选择左侧导航栏“设备 > 所有设备”，单击“注册设备”。
2. 根据页面提示信息填写参数，然后单击“确定”。

   参数名称	说明
   所属资源空间	确保和创建的产品归属在同一个资源空间。
   所属产品	选择创建的产品。
   设备标识码	即nodeID，设备唯一物理标识。可自定义，由英文字母和数字组成。
   设备名称	即device_name，可自定义。
   设备认证类型	选择“密钥”。
   密钥	设备密钥，可自定义。若不填写密钥，物联网平台会自动生成密钥。

   设备注册成功后保存设备标识码、设备ID、密钥。

设备初始化

1. 获取接入地址。可在控制台的“总览 > 接入信息”中查看。
   图4 接入信息-设备侧MQTT接入地址
   

2. 打开文件demos/device_demo/basic_test.c，将之前获取到的接入地址、设备ID以及设备密钥填入对应位置。

   // 创建一个设备并初始化。在basic_test.c中修改连接参数：
   // You can get the access address from IoT Console "Overview" -> "Access Information"
   char *g_address = "域名"; 
   char *g_port = "8883";
   char *g_deviceId = "设备id"; 
   char *g_secret = "设备密钥";
   
   static void mqttDeviceSecretInit(char *address, char *port, char *deviceId, char *password) {
   
       IOTA_Init("."); // The certificate address is set to: ./conf/rootcert.pem
       IOTA_SetPrintLogCallback(MyPrintLog); // Set log printing method
   
       // MQTT protocol when the connection parameter is 1883; MQTTS protocol when the connection parameter is 8883
       IOTA_ConnectConfigSet(address, port, deviceId, password);
       int ret = IOTA_Connect();
       if (ret != 0) {
           PrintfLog(EN_LOG_LEVEL_ERROR, "basic_test: IOTA_Connect() error, Auth failed, result %d\n", ret);
           return -1;
       }
   }

   

   平台的证书可以从源码中conf/rootcert.pem下载。

3. 编译及运行。在根目录运行以下命令，日志中打印“login success”表示设备鉴权成功。

    export LD_LIBRARY_PATH=./lib/  #加载库文件
    make clean
    make device_demo
    ./basic_test

   图5 连接成功
   

4. 查看设备运行情况。在控制台的设备详情页面查看设备已在线。
   图6 设备列表-设备在线
   

消息上报

1. ./demos/device_demo/message_test.c是一个上报消息例子，可以通过IOTA_MessageDataReport函数将消息上报给平台。

   void basicMassage() 
   {
       // 订阅系统topic
       SubscribeAll(); 
       // 向连接设备上报一个id为123的消息，消息内容为"hello!"
       ST_IOTA_MESS_REP_INFO mass = {NULL, "name", "id", "hello!", "test"};
       int messageId = IOTA_MessageDataReport(mass, NULL);
       if (messageId != 0) {
           PrintfLog(EN_LOG_LEVEL_ERROR, "basicMassage() failed, messageId %d\n", messageId);
       }
       TimeSleep(3000);
   }

2. 在设备接入控制台，选择“设备 > 所有设备”-查看设备是否在线。
   图7 设备列表-设备在线
   
3. 选择对应设备，单击“详情”，在设备详情页面启动设备消息跟踪。
   图8 消息跟踪-启动消息跟踪
   
4. 查看消息跟踪，确认平台是否收到设备消息。
   

   消息跟踪会有一定的延时，如果没有看到数据，请等待后刷新。

   图9 消息跟踪-查看device_sdk_java消息跟踪
   

属性上报

1. 源代码中demos/device_demo/properties_test.c是一个属性上报的例子，可以通过IOTA_PropertiesReport函数将属性上报给平台。

   void Test_propertiesReport() {
     int serviceNum = 1;//上报的service个数
     ST_IOTA_SERVICE_DATA_INFO services[serviceNum];
   
     //---------------the data of service-------------------------------
     char *service = "{\"temperature\": 28}";
     services[0].event_time = NULL;
     services[0].service_id = "smokeDetector";
     services[0].properties = service;
   
     int messageId = IOTA_PropertiesReport(services, serviceNum, 0, NULL);
     if(messageId != 0) {
   	PrintfLog(EN_LOG_LEVEL_ERROR, "device_demo: Test_batchPropertiesReport() failed, messageId %d\n", messageId);
     }
   }

2. 在左侧导航栏中选择“设备 > 所有设备”，选择对应设备单击“详情”，在“设备影子”处可以看到上报的属性值。
   图10 设备影子-temperature
   

若是没有查看到属性上报值，确认是否已上传产品模型：上传产品模型。

命令下发

设置命令监听器用来接收平台下发的命令，在回调接口里，将对命令进行处理，并上报响应。./demos/device_demo/command_test.c是一个处理平台命令下发的例子。下面代码的HandleCommandRequest函数作为命令监听器，即：

• 注册回调函数，设备接收命令下发（profile中定义的命令）。HW_API_FUNC HW_VOID IOTA_SetCmdCallback(PFN_CMD_CALLBACK_HANDLER callbackHandler) 通过该接口设置命令回调函数

  IOTA_SetCmdCallback(HandleCommandRequest);

• 当云端下发命令或端侧规则触发执行命令时，定义的函数会被调用。

  int beepState = 0; // 物模型，蜂鸣器状态
  // 响应命令下发
  static void Test_CommandResponse(char *requestId)
  {
    /* 请客户自行实现命令下发响应参数，以下为示例 */
    char pcCommandRespense[100] = {0}; // in service accumulator
    (void)sprintf_s(pcCommandRespense, sizeof(pcCommandRespense), "{\"Beep_State\": %d}", beepState); 
  
    int result_code = 0;
    char *response_name = "Smoke_Control_Beep";
  
    int messageId = IOTA_CommandResponse(requestId, result_code, response_name, pcCommandRespense, NULL);
    if (messageId != 0) {
        PrintfLog(EN_LOG_LEVEL_ERROR, "Test_CommandResponse() failed, messageId %d\n", messageId);
    }
  } 
  
  void HandleCommandRequest(EN_IOTA_COMMAND *command)
  {
      if (command == NULL) {
          return;
      }
      PrintfLog(EN_LOG_LEVEL_INFO, "command_test: HandleCommandRequest(), messageId %d, service_id %s, command_name %s, request_id %s\n", 
          command->mqtt_msg_info->messageId, command->service_id, command->command_name, command->request_id);
      PrintfLog(EN_LOG_LEVEL_INFO, "command_test: HandleCommandRequest(), request_id %s\n", command->request_id);
  
      /* 请客户自行实现命令下发处理逻辑 */
     
        Test_CommandResponse(command->request_id); //response command
  }