网站代做发布需求/成都专业网站推广公司

在前面的文章：

《阿里云IOT-C-SDK系列（1）概述：移植流程、程序框架、代码目录》

《阿里云IOT-C-SDK系列（2）快速体验：移植+示例C代码》

《阿里云IOT-C-SDK系列（2）快速体验：移植+示例C代码》

《阿里云IOT-C-SDK系列（4）SDK配置选项理解》

《阿里云IOT-C-SDK系列（5）：进一步理解SDK的移植使用方式》

        我们是从 移植、应用的角度分析了 阿里云iot c-sdk的移植和使用方式，但是想要深入的理解该SDK的工作原理，最直接有效的方式就是阅读源码。本文及后续的文章将会分析C-SDK的源码脉络，理解其工作原来。

        linkkit SDK是阿里云物联网平台的开发 SDK，简单的说，使用该SDK，可以方便的实现 单设备、网关设备连接到阿里云物联网平台上，在前面的文章也分析过，单设备联网相对比较简单，本文及后续的文章主要还是从网关设备的角度来分析。

        要理解工作原理，首先要了解一下使用该SDK进行开发应用程序的流程 步骤，下面就简单的用伪代码 罗列一下 网关设备应用程序 的 步骤：

/* 子设备四元组 信息*/
#define EXAMPLE_SUBDEV_ADD_NUM          3
#define EXAMPLE_SUBDEV_MAX_NUM          20const iotx_linkkit_dev_meta_info_t subdevArr[EXAMPLE_SUBDEV_MAX_NUM] = {{"a13Npv1vjZ4","PKbZL7baK8pBso94","example_sub1","eglNFNJiRuR0yncB9RP05sSTY4FrUIoe"},{"a1YRfb9bepk","PKbZL7baK8pBso94","test_02","jFsErM3uA7UfbS6J0hm0QaEXsQbmO6Pa"},{"a1YRfb9bepk","PKbZL7baK8pBso94","test_03","MjWMvCLBcuZyqUswryBbgypN8uOgJGVD"}
};static user_example_ctx_t *user_example_get_ctx(void)
{return &g_user_example_ctx;
}/* 用户 连接云服务器成功 回调函数 */
static int user_connected_event_handler(void)
{user_example_ctx_t *user_example_ctx = user_example_get_ctx();EXAMPLE_TRACE("Cloud Connected");user_example_ctx->cloud_connected = 1;return 0;
}/* 用户 云服务器断开连接 回调函数 */
static int user_disconnected_event_handler(void)
{user_example_ctx_t *user_example_ctx = user_example_get_ctx();EXAMPLE_TRACE("Cloud Disconnected");user_example_ctx->cloud_connected = 0;return 0;
}/* 用户 自定义属性设定 回调函数 */
static int user_property_set_event_handler(const int devid, const char *request, const int request_len)
{int res = 0;user_example_ctx_t *user_example_ctx = user_example_get_ctx();EXAMPLE_TRACE("Property Set Received, Devid: %d, Request: %s", devid, request);res = IOT_Linkkit_Report(devid, ITM_MSG_POST_PROPERTY,(unsigned char *)request, request_len);EXAMPLE_TRACE("Post Property Message ID: %d", res);return 0;
}/* 用户自定义 上报回复 回调函数 */
static int user_report_reply_event_handler(const int devid, const int msgid, const int code, const char *reply,const int reply_len){const char *reply_value = (reply == NULL) ? ("NULL") : (reply);const int reply_value_len = (reply_len == 0) ? (strlen("NULL")) : (reply_len);EXAMPLE_TRACE("Message Post Reply Received, Devid: %d, Message ID: %d, Code: %d, Reply: %.*s", devid, msgid, code,reply_value_len,reply_value);return 0;
}/* 网关主设备 联网状态检测函数 */
static int user_master_dev_available(void)
{user_example_ctx_t *user_example_ctx = user_example_get_ctx(); if (user_example_ctx->cloud_connected && user_example_ctx->master_initialized) {return 1;}return 0;
}/* 向网关 添加子设备 信息*/
static int example_add_subdev(iotx_linkkit_dev_meta_info_t *meta_info)
{int res = 0, devid = -1;devid = IOT_Linkkit_Open(IOTX_LINKKIT_DEV_TYPE_SLAVE, meta_info);if (devid == FAIL_RETURN) {EXAMPLE_TRACE("subdev open Failed\n");return FAIL_RETURN;}EXAMPLE_TRACE("subdev open susseed, devid = %d\n", devid);res = IOT_Linkkit_Connect(devid);if (res == FAIL_RETURN) {EXAMPLE_TRACE("subdev connect Failed\n");return res;}EXAMPLE_TRACE("subdev connect success: devid = %d\n", devid);res = IOT_Linkkit_Report(devid, ITM_MSG_LOGIN, NULL, 0);if (res == FAIL_RETURN) {EXAMPLE_TRACE("subdev login Failed\n");return res;}EXAMPLE_TRACE("subdev login success: devid = %d\n", devid);return res;
}/* 用户自定义 Linkkit收到允许子设备入网的请求时, 会触发此事件并调用回调函数 */
int user_permit_join_event_handler(const char *product_key, const int time)
{user_example_ctx_t *user_example_ctx = user_example_get_ctx(); EXAMPLE_TRACE("Product Key: %s, Time: %d", product_key, time); user_example_ctx->permit_join = 1;return 0;
}/* 用户自定义 轮询接收、数据分发 线程 */
void *user_dispatch_yield(void *args)
{user_example_ctx_t *user_example_ctx = user_example_get_ctx();while (user_example_ctx->g_user_dispatch_thread_running) {IOT_Linkkit_Yield(USER_EXAMPLE_YIELD_TIMEOUT_MS);}return NULL;
}int main(void)
{/* 设定SDK的debug 级别 */IOT_SetLogLevel(IOT_LOG_DEBUG); /* 注册用户自定义事件回调函数  */IOT_RegisterCallback(ITE_CONNECT_SUCC, user_connected_event_handler);IOT_RegisterCallback(ITE_DISCONNECTED, user_disconnected_event_handler);IOT_RegisterCallback(ITE_PROPERTY_SET, user_property_set_event_handler);IOT_RegisterCallback(ITE_REPORT_REPLY, user_report_reply_event_handler);IOT_RegisterCallback(ITE_TIMESTAMP_REPLY, user_timestamp_reply_event_handler);IOT_RegisterCallback(ITE_INITIALIZE_COMPLETED, user_initialized);IOT_RegisterCallback(ITE_PERMIT_JOIN, user_permit_join_event_handler);/* Create Master Device Resources 创建网关设备资源 */master_devid = IOT_Linkkit_Open(IOTX_LINKKIT_DEV_TYPE_MASTER, &master_meta_info);/* Choose Login Server 选择登录服务器 */domain_type = IOTX_CLOUD_REGION_SHANGHAI;IOT_Ioctl(IOTX_IOCTL_SET_DOMAIN, (void *)&domain_type);/* Choose Login Method 设定登录方式 */dynamic_register = 0;IOT_Ioctl(IOTX_IOCTL_SET_DYNAMIC_REGISTER, (void *)&dynamic_register);/* Choose Whether You Need Post Property/Event Reply 设定是否 回显 信息*/post_event_reply = 0;IOT_Ioctl(IOTX_IOCTL_RECV_EVENT_REPLY, (void *)&post_event_reply);/* Start Connect Aliyun Server 网关设备开始连接 云服务器*/do {res = IOT_Linkkit_Connect(user_example_ctx->master_devid);if (res < 0) {EXAMPLE_TRACE("IOT_Linkkit_Connect failed, retry after 5s...\n");HAL_SleepMs(5000);}} while (res < 0);/* 创建用户自定义的 yield 、消息调度线程 */user_example_ctx->g_user_dispatch_thread_running = 1;res = HAL_ThreadCreate(&user_example_ctx->g_user_dispatch_thread, user_dispatch_yield, NULL, NULL, NULL);if (res < 0) {EXAMPLE_TRACE("HAL_ThreadCreate Failed\n");IOT_Linkkit_Close(user_example_ctx->master_devid);return -1;}/* Add subdev 注册、添加子设备(创建子设备资源并连接到服务器) */while((subdev_index < EXAMPLE_SUBDEV_ADD_NUM) && (user_example_ctx->permit_join != 0)) {/* Add next subdev */if (example_add_subdev((iotx_linkkit_dev_meta_info_t *)&subdevArr[user_example_ctx->subdev_index]) == SUCCESS_RETURN){EXAMPLE_TRACE("subdev %s add succeed", device_name);} else {EXAMPLE_TRACE("subdev %s add failed", device_name);}user_example_ctx->subdev_index++;}while (1) {HAL_SleepMs(200);time_now_sec = user_update_sec();if (time_prev_sec == time_now_sec) {continue;}/* Post Proprety Example 循环上报 设备属性 */if (time_now_sec % 11 == 0 && user_master_dev_available()) {/* user_post_property(); */}/* Device Info Update Example 循环上报设备信息 */if (time_now_sec % 23 == 0 && user_master_dev_available()) {/* user_deviceinfo_update(); */}time_prev_sec = time_now_sec;}/* 关闭用户 消息调度线程 */user_example_ctx->g_user_dispatch_thread_running = 0;IOT_Linkkit_Close(user_example_ctx->master_devid);HAL_ThreadDelete(user_example_ctx->g_user_dispatch_thread);/* 设定SDK 的debug级别为 NONE*/IOT_SetLogLevel(IOT_LOG_NONE);return 0;
}

如果上面的代码还是难以理解，下面再用文字进行说明：

int main(void)
{/* 设定debug 级别 *//*-- 注册用户自定义的 事件回调函数 ---------------------*//* 注册用户自定义<连接云服务器成功>事件回调函数 		*//* 注册用户自定义<云服务器断开>事件回调函数 			*//* 注册用户自定义<属性上报>事件回调函数 				*//* 注册用户自定义<时间戳上报>事件回调函数 				*//* 注册用户自定义<属性上报>事件回调函数 				*//* 注册用户自定义<连接网络的设备初始化完成>事件回调函数 *//* 注册用户自定义<允许子设备入网>事件回调函数 			*//* 调用 IOT_Linkkit_Open 创建网关主设备资源 */	/* 调用 IOT_Ioctl 设定登录服务器、方式等配置参数 */	/* 调用 IOT_Linkkit_Connect 发起 网关主设备 连接云服务器 *//* 创建用户自定义的 事件调度 线程(user_dispatch_yield)   */	/* 收到 ITE_PERMIT_JOIN 和 ITE_INITIALIZE_COMPLETED 事件后 添加子设备 *//* 添加子设备的流程也是 先 xxx_Open 然后 xxx_Connect */ while(1){		/* 周期调用 IOT_Linkkit_Report(dev_id, ITM_MSG_POST_PROPERTY, property_payload, strlen(property_payload));根据dev_id的不同，实现不同子设备的 属性上报*/}/* 调用 IOT_Linkkit_Close(master_devid); 关闭网关主设备及释放资源 */	/* 调用 HAL_ThreadDelete(g_user_dispatch_thread); 关闭用户自定义 事件调度线程  */ return 0;	}

        所以从上面的应用流程可知，我们还是要从 SDK 给用于提供的 有限的 API 接口入手来分析源码功能，官方提供的API和事件如下：官方链接《Alink协议API详解、Event列表详解》

       IOT_Linkkit_Open
      IOT_Linkkit_Connect
   IOT_Linkkit_Yield
IOT_Linkkit_Close
     IOT_Linkkit_TriggerEvent
IOT_Linkkit_Report
    IOT_Linkkit_Query
    IOT_RegisterCallback
     IOT_Ioctl

    
   Event列表详解
 ITE_CONNECT_SUCC
  ITE_DISCONNECTED
   ITE_RAWDATA_ARRIVED
ITE_SERVICE_REQUEST
 ITE_PROPERTY_SET
ITE_PROPERTY_GET
   ITE_REPORT_REPLY
ITE_TRIGGER_EVENT_REPLY
  ITE_TIMESTAMP_REPLY
ITE_TOPOLIST_REPLY
 ITE_PERMIT_JOIN
  ITE_INITIALIZE_COMPLETED
   ITE_FOTA
   ITE_COTA
    
    后面我们将会根据上面的 应用 程序 移植框架来逐个分析 这些接口函数的 源码逻辑。
 

————————————————
版权声明：本文为CSDN博主「猪哥-嵌入式」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/u012351051/article/details/104214695

https://blog.csdn.net/u012351051/article/details/104214695?utm_medium=distribute.pc_relevant.none-task-blog-baidujs-3