AI 助理
备案控制台
开发者社区 物联网 文章 正文

【平头哥RVB2601开发板试用体验】AT 解析器和通过w800 AT命令接入阿里云生活物联网平台

2022-04-29 919
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： RISC-V RVB2601 Yoc 实现和测试验证阿里云平台接入的等相关功能，同时去了解YoC中网络设备和AT解析器框架。

作者 | niu


在RVB2601开发板上，CH2601主芯片通过SPI接口和W800 WIFi/BLE模块通信，W800芯片在此接口上提供AT命令的方式供主芯片使用W800的功能1.png

根据《W800模组AT指令集》中的描述，W800芯片中实现了WiFi配网、WiFi连接、TCP连接、阿里云飞燕生活物联网平台接入等功能。


2.png

接口详细说明

初始化一个AT指令解析器

atparser_uservice_t *atparser_init(utask_t *task, const char *name, uart_config_t *config)


根据指定的微服务任务,串口名以及串口配置信息创建一个AT 指令解析器，成功则返回atparser_uservice_t指针，失败返回NULL


参数：

  • task：微服务任务
  • name: 串口名
  • config: 串口配置信息


返回值：

成功则返回atparser_uservice_t指针，失败返回NULL


初始化一个用户自定义的AT指令解析器

atparser_uservice_t *atparser_channel_init(utask_t *task, const char *name, void *config, at_channel_t *channel);


根据指定的微服务任务,串口名以及串口配置信息创建一个AT 指令解析器，成功则返回atparser_uservice_t指针，失败返回NULL


参数：

  • task：微服务任务
  • name: 设备名
  • config: 设备配置信息
  • channel：at指令解析器的channel


返回值：

成功则返回atparser_uservice_t指针，失败返回NULL


at_channel是具体执行AT命令内容收发的通道，比如串口、SPI接口等，RVB2601开发板上使用SPI接口；atparse负责对命令内容的解析和格式化拼装。


带外数据处理函数的格式

typedef int (*oob_callback)(atparser_uservice_t *at, void *pive, oob_data_t *oob_data);


用户根据传入的数据，做相关的处理，若处理完成则返回0；若处理未完成则返回-1


参数:

  • at: AT 指令解析器
  • pive：用户自定义数据
  • oob_data: 带外数据结构体


返回值:

  • 0表示处理完成并退出本次OOB,-1表示处理未完成,需要继续执行OOB


创建一个带外数据服务

int atparser_oob_create(atparser_uservice_t *at, const char *prefix, oob_callback cb, void *context);


根据指定的AT 指令解析器，带外数据匹配字符串，带外数据处理函数，以及用户自定义的上下文创建一个带外数据处理服务，成功则返回0，失败则返回负值


代码实现

cli中注册一个命令去触发连接云等动作，在获取到IP后去给w800发AT命令，开始连接云。

//应用层，添加cli命令
extern int set_aliyun_key( );
extern int set_aliyun_smartconf( );
extern int cloud_connect();
static void do_yun_cmd(char *wbuf, int wbuf_len, int argc, char **argv)
{
    if (argc > 1) {
        if (0 == strcmp(argv[1], "config")) {
            printf("do smart confg\r\n");
            set_aliyun_smartconf( );
            return;
        } else if (0 == strcmp(argv[1], "conn")) {
            printf("do cloud_connect\r\n");
            cloud_connect();
            return;
        } else if (0 == strcmp(argv[1], "set")) {
            printf("do set_aliyun_key\r\n");
            set_aliyun_key( );
            return;
        }
    }
}
void cli_reg_cmd_user(void)
{
    static const struct cli_command cmd_yun = {
        "yun",
        "yun comand",
        do_yun_cmd,
    };
    aos_cli_register_command(&cmd_yun);
}


W800的AT解析器实现中增加对云连接状态和属性设置下发的处理

extern at_channel_t spi_channel;
int w800_module_init(utask_t *task, w800_wifi_param_t *param)
{
    if (w800_module_inited) {
        return 0;
    }
    if (task == NULL) {
        task = utask_new("w800", 7 * 1024, QUEUE_MSG_COUNT, AOS_DEFAULT_APP_PRI + 4);
    }
    if (task == NULL) {
        return -1;
    }
    if (param->reset_pin) {
        csi_gpio_pin_init(&g_reset_pin, param->reset_pin);
        csi_gpio_pin_mode(&g_reset_pin,GPIO_MODE_PULLUP);
        csi_gpio_pin_dir(&g_reset_pin,GPIO_DIRECTION_OUTPUT);
        csi_gpio_pin_write(&g_reset_pin, GPIO_PIN_LOW);
        aos_msleep(200);
        csi_gpio_pin_write(&g_reset_pin, GPIO_PIN_HIGH);
        aos_msleep(1000);
        LOGD(TAG, "hard reset");
    }
    g_atparser_uservice_t = atparser_channel_init(task, NULL, param, &spi_channel);
    aos_mutex_new(&g_cmd_mutex);
    atparser_debug_control(g_atparser_uservice_t, 1);
    atparser_oob_create(g_atparser_uservice_t, "2,CLOSED", _closed2_handler, NULL);
    atparser_oob_create(g_atparser_uservice_t, "1,CLOSED", _closed1_handler, NULL);
    atparser_oob_create(g_atparser_uservice_t, "0,CLOSED", _closed0_handler, NULL);
    atparser_oob_create(g_atparser_uservice_t, "+EVENT=NET,LINK_UP", _gotip_handler, NULL);
    atparser_oob_create(g_atparser_uservice_t, "+EVENT=NET,LINK_DOWN", _disconnect_handler, NULL);
    atparser_oob_create(g_atparser_uservice_t, "+EVENT=RECV,", _recv_data_handler, NULL);
    atparser_oob_create(g_atparser_uservice_t, "+EVENT=DISCONNECT,0", _closed0_handler, NULL);
    atparser_oob_create(g_atparser_uservice_t, "+EVENT=DISCONNECT,1", _closed1_handler, NULL);
    atparser_oob_create(g_atparser_uservice_t, "+EVENT=DISCONNECT,2", _closed2_handler, NULL);
    atparser_oob_create(g_atparser_uservice_t, "+IDMSTA:", cloud_connsta_handler, NULL);   //连接状态OOB注册
    atparser_oob_create(g_atparser_uservice_t, "+IDMPS:", cloud_recv_handler, NULL);       //属性设置OOB注册
    w800_module_inited = 1;
    return 0;
}
/* 接收到云端下发的属性设置 */
/* oob_data->buf和oob_data->len为AT通道上接收到的"+IDMPS:"之后的内容和长度 */
static int cloud_recv_handler(atparser_uservice_t *at, void *priv, oob_data_t *oob_data)
{
    //+IDMPS:<device_id>,<msg_len>,<message>  OK
    int id = 0;
    int len = 0;
    char data[128] = {0};
    LOGI(TAG,"%s(%d)",oob_data->buf,oob_data->len);
     char *str = strchr(oob_data->buf, ':');
        if (str  != NULL) {
            sscanf(oob_data->buf, "%d,%d,%s\r\n", &id, &len, data);
            LOGI(TAG,"==>cloud_recv %d(%d):%s\r\n",id, len, data);
            oob_data->used_len += (str - oob_data->buf+1);
        }
    /* recv data is not enough need recv more */
    return 0;
}
/*云连接状态上报OOB处理*/
static int cloud_connsta_handler(atparser_uservice_t *at, void *priv, oob_data_t *oob_data)
{
    LOGI(TAG,"==>cloud_conn: %s(%d)",oob_data->buf,oob_data->len);
    /* recv data is not enough need recv more */
    return 0;
}


3.png

4.png


实现云连接等功能的AT命令收发

int cloud_connect()
{
    int ret = -1;
    g_net_status = NET_STATUS_READY;
    aos_mutex_lock(&g_cmd_mutex, AOS_WAIT_FOREVER);
    atparser_set_timeout(g_atparser_uservice_t, 30 * 1000);
    atparser_clr_buf(g_atparser_uservice_t);
    if (atparser_send(g_atparser_uservice_t, "AT+IDMCON") == 0) {
        if (atparser_recv(g_atparser_uservice_t, "OK") == 0) {
            ret = 0;
            LOGI(TAG,"===>IDMCON OK");
        }
    }
    atparser_set_timeout(g_atparser_uservice_t, 8 * 1000);
    atparser_cmd_exit(g_atparser_uservice_t);
    aos_mutex_unlock(&g_cmd_mutex);
    return ret;
}
int set_aliyun_key( )
{
     int ret = -1;
    g_net_status = NET_STATUS_READY;
    aos_mutex_lock(&g_cmd_mutex, AOS_WAIT_FOREVER);
    atparser_set_timeout(g_atparser_uservice_t, 30 * 1000);
    atparser_clr_buf(g_atparser_uservice_t);
    if (atparser_send(g_atparser_uservice_t, "AT+IDMAU=\"%s\",\"%s\",\"%s\",\"%s\"", PRODUCT_KEY, DEVICE_NAME, DEVICE_SECRET, PRODUCT_SECRET) == 0) {
        if (atparser_recv(g_atparser_uservice_t, "OK") == 0) {
            ret = 0;
            LOGI(TAG,"===>IDMAU OK");
        }
    }
    atparser_set_timeout(g_atparser_uservice_t, 30 * 1000);
    atparser_clr_buf(g_atparser_uservice_t);
    if (atparser_send(g_atparser_uservice_t, "AT+IDMPID=%ld", PRODUCT_ID) == 0) {
        if (atparser_recv(g_atparser_uservice_t, "OK") == 0) {
            ret = 0;
            LOGI(TAG,"===>IDMPID OK");
        }
    }
    atparser_set_timeout(g_atparser_uservice_t, 8 * 1000);
    atparser_cmd_exit(g_atparser_uservice_t);
    aos_mutex_unlock(&g_cmd_mutex);
    return ret;
}
int set_aliyun_smartconf( )
{
    int ret = -1;
    g_net_status = NET_STATUS_READY;
    aos_mutex_lock(&g_cmd_mutex, AOS_WAIT_FOREVER);
    atparser_set_timeout(g_atparser_uservice_t, 30 * 1000);
    atparser_clr_buf(g_atparser_uservice_t);
    if (atparser_send(g_atparser_uservice_t, "AT+IDMCLS") == 0) {
        if (atparser_recv(g_atparser_uservice_t, "OK") == 0) {
            ret = 0;
            LOGI(TAG,"===>IDMCLS OK");
        }
    }
    atparser_set_timeout(g_atparser_uservice_t, 30 * 1000);
    atparser_clr_buf(g_atparser_uservice_t);
    if (atparser_send(g_atparser_uservice_t, "AT+IWSSTART=0") == 0) {
        if (atparser_recv(g_atparser_uservice_t, "OK") == 0) {
            ret = 0;
            LOGI(TAG,"===>IWSSTART OK");
        }
    }
    atparser_set_timeout(g_atparser_uservice_t, 8 * 1000);
    atparser_cmd_exit(g_atparser_uservice_t);
    aos_mutex_unlock(&g_cmd_mutex);
    return ret;
}


在阿里云物联网平台创建产品并定义功能

5.png


为w800模块配网和配置五元组

  • 手机app配网没有调通，后续再调，先用手动配网；
  • 调用set_aliyun_key( )配置五元组后，重启，w800将会自动连接路由器；
  • 在连上路由器获取到IP后，调用cloud_connect()，待手动连接状态OOB回调时，“+IDMSTA:2“”说明已经连上阿里云了，在阿里云后台可以看到设备已在线；

6.png


通过在阿里云后台的设备调试页面，可进行在线调试，对设备属性进行设置，开发板上将收到对应的属性值，如下图：

7.png


到此，阿里云接入和属性设置功能验证通过了，后续将继续完善功能，基于在阿里云上定义的产品功能，做进一步的开发实现更多的应用功能。


本文源自：平头哥芯片开放社区

欢迎关注公众号：芯片开放社区（ID：OCC_THEAD），查看更多应用实战文章。

文章标签：
物联网平台
微服务
数据处理
网络协议
网络架构
物联网
芯片
关键词：
阿里云物联网平台
解析物联网平台
云解析DNS命令
云解析DNS阿里云
at阿里云物联网平台
相关实践学习
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品，7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前，请先开通下方两个云产品，让学习更流畅： IoT物联网平台：https://iot.console.aliyun.com/ LinkWAN物联网络管理平台：https://linkwan.console.aliyun.com/service-open
FutureDeveloper
目录
相关文章
morixinguan
|
传感器 物联网 调度
天啊！鹅厂都开始做开发板了？网红腾讯物联网开发板终极开箱评测,让我们一睹为快!
天啊！鹅厂都开始做开发板了？网红腾讯物联网开发板终极开箱评测,让我们一睹为快!
morixinguan
337 2
带你读小助手
|
物联网 开发工具 网络架构
基于AT模组连接阿里云物联网平台
本实验主要介绍基于AT模组，通过AT指令将端侧设备快速连接到阿里云物联网平台，助力设备智能化改造。
带你读小助手
809 0
AIoT_qiao
|
监控 物联网
ESP8266通过AT指令连接阿里云物联网
ESP8266通过AT指令连接阿里云物联网
AIoT_qiao
1530 0
ESP8266通过AT指令连接阿里云物联网
FutureDeveloper
|
网络协议 数据安全/隐私保护 芯片
【平头哥RVB2601开发板试用体验】基于NTP的网络校时及WIFI驱动Bug调试
基于NTP实现网络校时，并完成Wi-Fi驱动Bug调试
FutureDeveloper
737 1
【平头哥RVB2601开发板试用体验】基于NTP的网络校时及WIFI驱动Bug调试
FutureDeveloper
|
芯片
【平头哥RVB2601开发板试用体验】关于如何从上位机读入键盘数据的探索
关于如何从上位机读入键盘数据的探索
FutureDeveloper
463 0
【平头哥RVB2601开发板试用体验】关于如何从上位机读入键盘数据的探索
喜欢猪猪
|
12月前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性，极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理，并通过Java代码手写模拟Spring Boot的启动过程，特别是spring.factories文件的解析源码API机制。
喜欢猪猪
325 2
蓝易云
|
8月前
|
算法 测试技术 C语言
深入理解HTTP/2：nghttp2库源码解析及客户端实现示例
通过解析nghttp2库的源码和实现一个简单的HTTP/2客户端示例，本文详细介绍了HTTP/2的关键特性和nghttp2的核心实现。了解这些内容可以帮助开发者更好地理解HTTP/2协议，提高Web应用的性能和用户体验。对于实际开发中的应用，可以根据需要进一步优化和扩展代码，以满足具体需求。
蓝易云
783 29
疯狂的猿
|
8月前
|
前端开发 数据安全/隐私保护 CDN
二次元聚合短视频解析去水印系统源码
二次元聚合短视频解析去水印系统源码
疯狂的猿
273 4
游客lijmi4663rgsa
|
8月前
|
JavaScript 算法 前端开发
JS数组操作方法全景图，全网最全构建完整知识网络！js数组操作方法全集（实现筛选转换、随机排序洗牌算法、复杂数据处理统计等情景详解，附大量源码和易错点解析）
这些方法提供了对数组的全面操作，包括搜索、遍历、转换和聚合等。通过分为原地操作方法、非原地操作方法和其他方法便于您理解和记忆，并熟悉他们各自的使用方法与使用范围。详细的案例与进阶使用，方便您理解数组操作的底层原理。链式调用的几个案例，让您玩转数组操作。 只有锻炼思维才能可持续地解决问题，只有思维才是真正值得学习和分享的核心要素。如果这篇博客能给您带来一点帮助，麻烦您点个赞支持一下，还可以收藏起来以备不时之需，有疑问和错误欢迎在评论区指出~
游客lijmi4663rgsa
278 2
山东布谷科技_sun
|
8月前
|
移动开发 前端开发 JavaScript
从入门到精通:H5游戏源码开发技术全解析与未来趋势洞察
H5游戏凭借其跨平台、易传播和开发成本低的优势，近年来发展迅猛。接下来，让我们深入了解 H5 游戏源码开发的技术教程以及未来的发展趋势。
山东布谷科技_sun
333 5

物联网

热门文章

最新文章

  • 1
    阿里云物联网无线连接服务：做好菜鸟无人车黑科技的幕后英雄
  • 2
    使用MQTT客户端连接阿里云MQTT服务器
  • 3
    物联网+智慧城建，智慧城市建设的新动能
  • 4
    IoT SaaS加速器——助力阿尔茨海默病人护理
  • 5
    物联网发展的三大编程语言
  • 6
    阿里云的物联网之路
  • 7
    PostgreSQL "物联网"应用 - 1 实时流式数据处理案例(万亿每天)
  • 8
    阿里云新推出 HiTSDB + IoT套件 物联网设备上云步入快车道
  • 9
    物联网平台实用技巧：调用API获取设备状态
  • 10
    AIoT设备上云最佳实践集锦【持续更新，建议收藏】
  • 1
    1688商家必看：如何高效转化精准流量？四大核心策略深度解析
    107
  • 2
    1688运营实战指南：1688系统化学习与进阶技巧
    59
  • 3
    百宝箱 IoT 如何定制动画
    45
  • 4
    百宝箱 IoT 如何控制智能灯具
    43
  • 5
    百宝箱 IoT 如何定制设备 UI
    97
  • 6
    中小容量电力设备选型指南：计量型免维护呼吸器的核心价值
    45
  • 7
    干货推荐：分钟级定位 IO 瓶颈，多租户云环境下的智能诊断
    55
  • 8
    转转客服IM聊天系统背后的技术挑战和实践分享
    81
  • 9
    RFID传送带智能采集带来意想不到效果
    71
  • 10
    可编程逻辑器件学习(day1)：技术演进与应用解析
    153

    • 相关产品

  • 物联网平台
    文档详情 产品详情

    • 相关课程

    更多
  • 大咖带你聊物联网
  • 基于STM32的端到端物联网全栈开发
  • 走进阿里云物联网
  • 阿里云物联网平台专题介绍
  • 物联网平台开发全栈教程
  • 物联网平台云上开发

    • 相关电子书

    更多
  • 《平头哥剑池CDK快速上手指南》
  • 无需从0开发 1天上手只能语音离在线方案
  • 无需从0开发 平头哥教你1天上手蓝牙Mesh应用解决方案
    • 下一篇
    阿里云对象存储OSS收费标准：500G存储118元1年、