嵌入式技术william hill官网
直播中

小熊派开源社区

4年用户 123经验值
擅长:嵌入式技术 物联网
私信 关注

LiteOS云端对接教程07-LiteOS基于CoAP对接华为OC平台实战

本帖最后由 小熊派开源社区 于 2020-2-27 08:48 编辑

1. LiteOS OC COAP 抽象组件

概述

为了适应各种各样的使用coap接入华为OC的模式，特采用该层次接口，对上提供应用所需的接口，对下允许接入方式的灵活适配。
OC COAP AL的api接口声明在中，使用相关的接口需要包含该头文件。

配置并连接

对接服务器的所有信息保存在结构体oc_coap_al.h中，如下：
其中boot_mode是对接模式，对应华为平台的两种模式：
  1. typedef enum
  2. {
  3.     en_oc_boot_strap_mode_factory = 0,
  4.     en_oc_boot_strap_mode_client_initialize,
  5.     en_oc_boot_strap_mode_sequence,
  6. }en_oc_boot_strap_mode_t;
app_server参数是服务器信息，定义如下：
  1. typedef struct
  2. {
  3.     char *ep_id;                  ///< endpoint identifier, which could be recognized by the server
  4.     char *address;                ///< server address,maybe domain name
  5.     char *port;                   ///< server port
  6.     char *psk_id;                 ///< server encode by psk, if not set NULL here
  7.     char *psk;
  8.     int   psk_len;
  9. }oc_server_t;
参数说明如下：
  • ep_id：设备标识符
  • address：服务器地址
  • port：服务器端口
  • psk_id：DTLS使用，不使用的话设置为NULL
rcv_func是回调函数的函数指针，当设备接收到coap消息后回调：
  1. typedef int (*fn_oc_coap_msg_deal)(void *msg, int len);
在配置结构体完成之后，调用配置函数进行配置并连接，API如下：
  1. /**
  2. * [url=home.php?mod=space&uid=2666770]@Brief[/url] the application use this function to configure the coap agent
  3. * @param[in] param, refer to tag_oc_coap_config
  4. * [url=home.php?mod=space&uid=1141835]@Return[/url] oc coap handle else NULL failed
  5. */
  6. void *oc_coap_config(oc_config_param_t *param);
函数参数很清楚，将存放对接信息的结构体指针传入即可，API的返回值是oc coap handle指针，后续使用。

数据上报

连接成功之后，因为平台部署了编解码插件，直接向华为云平台上报二进制数据即可，oc_coap提供的API如下：
  1. /**
  2. * @brief the application use this function to send the message to the cdp
  3. * @param[in] hanlde:the coap handle returned by oc_coap_config
  4. * @param[in] report:the message to report
  5. *
  6. * @return 0 success while <0 failed
  7. */
  8. int oc_coap_report(void *handle,char *msg,int len);
命令接收
当OC平台发布该主题数据时，oc_coap组件会拉起接收回调函数将数据保存，进而用户解析接收到的数据即可。
oc_coap组件自动初始化
在SDK目录中的IoT_LINK_1.0.0iot_linklink_main.c中可以看到自动初始化函数：

2. 配置准备

Makefile配置

因为本次实验用到的组件较多：
  • AT框架
  • ESP8266设备驱动
  • 串口驱动框架
  • SAL组件
  • coap组件
  • oc_coap组件
这些实验代码全部编译下来，有350KB，而小熊派开发板所使用的主控芯片STM32L431RCT6的 Flash 仅有256KB，会导致编译器无法链接出可执行文件，所以要在makefile中修改优化选项，修改为-Os参数，即最大限度的优化代码尺寸，并去掉-g参数，即代码只能下载运行，无法调试，如图：

ESP8266设备配置
在工程目录中的OS_CONFIG/iot_link_config.h文件中，配置ESP8266设备的波特率和设备名称:
SDK：C:UsersAdministrator.icodesdkIoT_LINK_1.0.0（其中Administrator是实验电脑的用户名）。
在SDK目录中的<iot_linknetworktcpipesp8266_socketesp8266_socket_imp.c文件中，配置连接信息：
在 Demo 文件夹下创建cloud_test_demo文件夹，在其中创建oc_coap_demo.c文件。
编写以下代码：
  1. #include
  2. #include
  3. #include
  4. #include

  6. #define cn_endpoint_id        "654654654"
  7. #define cn_app_server         "49.4.85.232"
  8. #define cn_app_port           "5683"

  10. #define cn_app_light           0
  11. #define cn_app_ledcmd          1

  13. #pragma pack(1)

  15. typedef struct
  16. {
  17.     int8_t msgid;
  18.     uint16_t intensity;
  19. }app_light_intensity_t;


  22. typedef struct
  23. {
  24.     int8_t msgid;
  25.     char led[3];
  26. }app_led_cmd_t;

  28. #pragma pack()

  30. #define cn_app_rcv_buf_len 128
  31. static int8_t          s_rcv_buffer[cn_app_rcv_buf_len];
  32. static int             s_rcv_datalen;
  33. static osal_semp_t     s_rcv_sync;

  35. static void           *s_coap_handle = NULL;

  37. static int app_msg_deal(void *msg, int len)
  38. {
  39.     int ret = -1;

  41.     if(len <= cn_app_rcv_buf_len)
  42.     {
  43.         memcpy(s_rcv_buffer,msg,len);
  44.         s_rcv_datalen = len;

  46.         osal_semp_post(s_rcv_sync);

  48.         ret = 0;

  50.     }
  51.     return ret;
  52. }


  55. static int app_cmd_task_entry()
  56. {
  57.     int ret = -1;
  58.     app_led_cmd_t *led_cmd;
  59.     int8_t msgid;

  61.     while(1)
  62.     {
  63.         if(osal_semp_pend(s_rcv_sync,cn_osal_timeout_forever))
  64.         {
  65.             msgid = s_rcv_buffer[0];
  66.             switch (msgid)
  67.             {
  68.                 case cn_app_ledcmd:
  69.                     led_cmd = (app_led_cmd_t *)s_rcv_buffer;
  70.                     printf("LEDCMD:msgid:%d msg:%s nr",led_cmd->msgid, led_cmd->led);
  71.                     if (led_cmd->led[0] == 'o' && led_cmd->led[1] == 'n')
  72.                     {
  73.                         printf("--------------- LED ON! --------------------rn");
  74.                     }

  76.                     else if (led_cmd->led[0] == 'o' && led_cmd->led[1] == 'f' && led_cmd->led[2] == 'f')
  77.                     {
  78.                         printf("--------------- LED OFF! --------------------rn");
  79.                     }
  80.                     else
  81.                     {

  83.                     }
  84.                     break;
  85.                 default:
  86.                     break;
  87.             }
  88.         }
  89.     }

  91.     return ret;
  92. }

  94. static int app_report_task_entry()
  95. {
  96.     int ret = -1;
  97.     int lux = 0;

  99.     oc_config_param_t      oc_param;
  100.     app_light_intensity_t  light;

  102.     memset(&oc_param,0,sizeof(oc_param));

  104.     oc_param.app_server.address = cn_app_server;
  105.     oc_param.app_server.port = cn_app_port;
  106.     oc_param.app_server.ep_id = cn_endpoint_id;
  107.     oc_param.boot_mode = en_oc_boot_strap_mode_factory;
  108.     oc_param.rcv_func = app_msg_deal;

  110.     s_coap_handle = oc_coap_config(&oc_param);

  112.     if(NULL != s_coap_handle)   
  113.     {
  114.         while(1)
  115.         {
  116.             lux++;
  117.             lux= lux%10000;
  118.             printf("lux is %d!rn",lux);

  120.             light.msgid = cn_app_light;
  121.             light.intensity = htons(lux);
  122.             oc_coap_report(s_coap_handle,(char *)&light,sizeof(light));
  123.             osal_task_sleep(5*1000);
  124.         }
  125.     }

  127.     return ret;
  128. }

  130. int standard_app_demo_main()
  131. {
  132.     osal_semp_create(&s_rcv_sync,1,0);

  134.     osal_task_create("app_report",app_report_task_entry,NULL,0x1000,NULL,2);
  135.     osal_task_create("app_command",app_cmd_task_entry,NULL,0x1000,NULL,3);

  137.     return 0;
  138. }
添加路径
在user_demo.mk中添加如下：
  1.         #example for oc_coap_demo
  2.         ifeq ($(CONFIG_USER_DEMO), "oc_coap_demo")        
  3.                 user_demo_src  = ${wildcard $(TOP_DIR)/targets/STM32L431_BearPi/Demos/cloud_test_demo/oc_coap_demo.c}
  4.         endif
添加位置如下：

配置.sdkconfig

上报数据实验结果
编译，下载，在云端的实验现象如下：

在本地的实验现象如下：

命令下发实验结果

在云端下发“on”命令：

在串口助手中可以看到：

下发“off”命令：

在串口助手中可以看到：




更多回帖

0 0 0

相关帖子

单片机 华为云 Liteos 嵌入式
发帖
电子发烧友APP
|投诉反馈|电子发烧友网
© 2021 bbs.elecfans.com
湘ICP备2023018690号
×
20
完善资料，
赚取积分