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

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

2022-04-29 664
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 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命令
云解析DNS物联网
阿里云生活物联网平台（飞燕平台）
相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台，通过云产品流转到函数计算FC，调用钉钉群机器人API，实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品，7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前，请先开通下方两个云产品，让学习更流畅： IoT物联网平台：https://iot.console.aliyun.com/ LinkWAN物联网络管理平台：https://linkwan.console.aliyun.com/service-open
FutureDeveloper
目录
相关文章
听风的鱼鱼儿
|
1月前
|
安全 数据挖掘 Linux
Linux命令rpm深度解析
`rpm`是Linux下的软件包管理器，用于安装、升级、卸载和查询`.rpm`包，常见于Red Hat系Linux。它管理依赖、维护软件信息数据库，支持版本控制和安全验证。常用命令如`-i`安装，`-U`升级，`-e`卸载，`-q`查询。安装时用`-v`和`-h`可查看详细信息和进度。注意依赖关系、权限和签名验证，最佳实践包括使用仓库、定期更新和备份数据。
听风的鱼鱼儿
34 3
听风的鱼鱼儿
|
1月前
|
安全 Linux 应用服务中间件
Linux命令show-installed的深入解析
`show-installed`是Linux中一个假设的命令，模拟显示已安装软件包的功能。它结合了`apt`、`yum`等包管理器的特性，提供跨发行版的兼容性，展示包的名称、版本、安装时间和来源。可用参数如`-n`过滤名称，`-v`显示版本，`-s`显示来源，`-t`显示时间。注意需root权限运行，大系统中可能影响性能。最佳实践包括定期审查、使用过滤、结合其他命令和备份数据。
听风的鱼鱼儿
35 1
jcLee95
|
11天前
|
数据采集 运维 监控
运维笔记：流编辑器sed命令用法解析
运维笔记：流编辑器sed命令用法解析
jcLee95
30 5
李木子2024
|
15天前
|
Linux 数据安全/隐私保护 Perl
解锁Linux高手秘籍：文件操作+命令解析大揭秘，面试场上让你光芒万丈，技术实力惊艳四座！
【8月更文挑战第5天】Linux作为服务器与嵌入式系统的基石，其文件管理和命令行操作是技术人员必备技能。本文从文件操作和基础命令两大方面，深入浅出地解析Linux核心要义，助你在面试中脱颖而出。首先探索文件系统的树状结构及操作，包括使用`ls -la`浏览文件详情、`touch`创建文件、`rm -r`慎删目录、`cp`与`mv`复制移动文件、以及利用`find`搜索文件。接着掌握命令行技巧，如用`cat`、`more`和`less`查看文件内容；借助`grep`、`sed`与`awk`处理文本；运用`ps`、`top`和`kill`管理进程；并通过`chmod`和`chown`管理文件权限。
李木子2024
53 8
李木子2024
|
17天前
|
运维 Ubuntu Shell
Docker命令宝典：解锁容器化技术的无限可能，从镜像管理到容器操作，全面解析与实战指南！
【8月更文挑战第3天】Docker简化了应用的部署与运行，掌握其基本命令对开发者和运维人员至关重要。通过`docker images`可查看本地镜像；使用`docker pull`拉取如最新版Ubuntu镜像；`docker rmi`用于删除不再需要的镜像。运行容器可通过`docker run`命令，结合`-it`等选项提供交互式环境。`docker ps`显示运行中的容器，加上`-a`则列出所有容器。`docker stop`和`docker start`分别用于停止和重启容器，而`docker rm`则删除容器。
李木子2024
44 5
香吧香
|
22天前
|
Linux Docker 容器
ip addr命令解析
ip addr命令解析
香吧香
19 1
1941623231718325
|
23天前
|
边缘计算 安全 物联网
边缘计算在物联网中的作用：技术深度解析
【7月更文挑战第28天】边缘计算在物联网中发挥着至关重要的作用。通过降低延迟、减少网络负载、提高隐私和安全性以及增强离线功能等优势，边缘计算为物联网带来了更加高效、智能和安全的解决方案。未来随着技术的不断进步和应用场景的拓展，边缘计算将在物联网领域发挥更加重要的作用
1941623231718325
45 1
听风的鱼鱼儿
|
28天前
|
Linux
《解析 Linux 命令：systemd-delta》
`systemd-delta`: 解析Linux服务配置差异。概览: 显示服务单元文件与默认配置的对比，助于配置问题排查与系统审计。特点: 清晰展示修改点，涵盖启动选项等。示例: `systemd-delta [--plain] &lt;service&gt;`. 注意: 理解默认配置，谨慎修改，定期检查。掌握此命令，深化系统服务配置洞察，优化Linux管理。#Linux #systemd-delta
听风的鱼鱼儿
35 2
听风的鱼鱼儿
|
1月前
|
存储 监控 Linux
stdbuf命令在Linux中的深度解析
`stdbuf`是Linux工具，用于控制命令的stdin、stdout和stderr的缓冲模式。它可以设置为无缓冲、行缓冲或块缓冲，以优化数据处理和实时性。例如，`stdbuf -o0 cmd`禁用cmd的输出缓冲，`-oL`则按行缓冲。在需要实时监控或高效处理大量数据时，选择合适的缓冲模式至关重要。注意，过度使用无缓冲可能影响性能，并非所有系统都支持`stdbuf`。
听风的鱼鱼儿
48 8
听风的鱼鱼儿
|
1月前
|
监控 安全 Linux
Linux命令ssltap的深入解析与应用实践
`ssltap`是一个假想的Linux命令，用于模拟SSL/TLS流量分析。它捕获、解密（如果有密钥）并分析加密流量，提供实时监控、协议解析和安全审计。特点包括实时性、灵活性、可扩展性和安全性。示例用法包括捕获特定端口流量和实时监控会话状态。在实际操作中应注意私钥安全、性能影响及合规性，建议定期审计和自动化监控。
听风的鱼鱼儿
50 6

物联网

热门文章

最新文章

  • 1
    阿里云物联网无线连接服务：做好菜鸟无人车黑科技的幕后英雄
  • 2
    使用MQTT客户端连接阿里云MQTT服务器
  • 3
    IoT SaaS加速器——助力阿尔茨海默病人护理
  • 4
    物联网发展的三大编程语言
  • 5
    PostgreSQL "物联网"应用 - 1 实时流式数据处理案例(万亿每天)
  • 6
    物联网平台实用技巧：调用API获取设备状态
  • 7
    吃『派』那些事儿——阿里云物联网平台树莓派实战集锦
  • 8
    手机秒变IoT设备?——巧妙利用阿里云物联网平台
  • 9
    【直播回顾】小眯眼摄像头产品培训 - 物联网爆品推荐 - 88大促预告
  • 10
    阿里云物联网消息透传设备端payLoad设置问题
  • 1
    物联卡安全问题
    8
  • 2
    临时
    22
  • 3
    物联卡是什么
    14
  • 4
    物联卡如何选择
    11
  • 5
    物联卡选择指南
    14
  • 6
    本地部署马斯克开源Grok-1大模型，贝锐花生壳3步实现远程访问
    17
  • 7
    LInux下 python混淆代码打包产出exe
    23
  • 8
    python打包pyinstaller如何使用
    19
  • 9
    HarmonyOS 3.1/4.0应用升级到HarmonyOS NEXT改动点
    21
  • 10
    遇到注单异常审核无法提现怎么办？
    65

    • 相关产品

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

    • 相关课程

    更多
  • 走进阿里云物联网
  • 阿里云物联网平台专题介绍
  • 物联网平台云上开发
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计

    • 相关电子书

    更多
  • 神龙云服务器产品及技术深度解析
  • 弹性创造价值：基于ECS的最佳性价比实践解析
  • 又快又稳：阿里云下一代虚拟交换机解析

    • 相关实验场景

    更多
  • 基于阿里云E-HPC平台的WRF气象预报实验
  • 使用计算巢企业应用，一键获取专属的Linux服务器管理软件
  • 温控器设备接入IoT物联网平台与数据管理实践
  • 使用物联网平台远程管理运维设备
  • 通过云拨测对指定服务器进行Ping/DNS监测
  • 阿里云IoT小程序应用开发和组件实践

    • 推荐镜像

    更多
  • DNS
  • NTP
  • termux
    • 下一篇
    通义千问API入门教程