备案控制台
探索云世界
开发者社区 物联网 文章 正文

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

2022-04-29 615
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 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命令
阿里云物联网
阿里云物联网平台
阿里云试用
相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台，通过云产品流转到函数计算FC，调用钉钉群机器人API，实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品，7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前，请先开通下方两个云产品，让学习更流畅： IoT物联网平台：https://iot.console.aliyun.com/ LinkWAN物联网络管理平台：https://linkwan.console.aliyun.com/service-open
FutureDeveloper
目录
相关文章
SarPro
|
2月前
|
传感器 存储 监控
【物联网】液滴即信息：雨滴探测传感器实验解析降雨的密码
【物联网】液滴即信息：雨滴探测传感器实验解析降雨的密码
SarPro
55 0
cuicuicuic
|
2月前
|
消息中间件 DataWorks 物联网
MQTT问题之接入阿里云物联网平台如何解决
MQTT接入是指将设备或应用通过MQTT协议接入到消息服务器，以实现数据的发布和订阅；本合集着眼于MQTT接入的流程、配置指导以及常见接入问题的解决方法，帮助用户实现稳定可靠的消息交换。
cuicuicuic
177 1
bbpp
|
11天前
|
消息中间件 存储 JavaScript
阿里云IOC物联网异步处理基础概念
该内容介绍了异步处理基础和消息队列的相关概念。首先，同步处理指任务完成后才能执行其他操作，而异步则允许任务并行执行，不阻塞程序。异步能提高系统并发性和响应性，但也增加复杂性和资源消耗。接着，提到了消息队列，包括生产者、消费者、队列、broker和topic等概念，并指出在IoT中，设备作为生产者发送消息到特定topic，消费者从队列获取数据。最后，简要介绍了AMQP协议，它是用于应用程序间消息传递的开放标准，常用于分布式系统和物联网，如RabbitMQ和Apache Qpid。课程将以Apache Qpid为例接收IoT数据。
bbpp
125 6
阿里云IOC物联网异步处理基础概念
云计算小子258号
|
1月前
|
弹性计算 负载均衡 数据库
2024阿里云服务器试用规则及云产品试用常见问题解答
2024年阿里云服务器可以试用吗？不仅是云服务器产品，包括无影云电脑、云数据库 RDS、统型负载均衡 CLB、对象存储 OSS、文件存储 NAS等云产品都是可以试用的，只是需要注意的是，我们在试用云服务器产品之后，免费试用权益无法与新用户优惠购买活动同享，也就是说，领取了云服务器ECS免费试用权益的用户，将不能参产品新用户的相关活动。本文为大家介绍2024年阿里云服务器和其他云产品的试用规则及试用常见问题解答。
云计算小子258号
189 1
2024阿里云服务器试用规则及云产品试用常见问题解答
cuicuicuic
|
2月前
|
消息中间件 网络协议 物联网
MQTT协议问题之阿里云物联网服务器断开如何解决
MQTT协议是一个轻量级的消息传输协议，设计用于物联网（IoT）环境中设备间的通信；本合集将详细阐述MQTT协议的基本原理、特性以及各种实际应用场景，供用户学习和参考。
cuicuicuic
130 1
q7s2kces74wvy
|
7月前
|
存储 机器学习/深度学习 监控
物联网平台常见类别及对应平台（二）
物联网平台常见类别及对应平台（二）
q7s2kces74wvy
253 0
聚优云惠
|
3月前
|
存储 安全 物联网
安防摄像头IPC如何快速接入阿里云Link Visual视频服务(阿里云生活物联网)
Link Visual是生活物联网平台针对视频产品推出的增值服务，提供视频数据上云、存储、转发、AI计算等能力。 大白话就是：通过阿里云的Link Visual视频服务，可以让你的IPC摄像头设备完成上云功能，并快速实现如下功能介绍中的功能。其中可以享受阿里云P2P协议支持，帮助企业节省流量服务器流量带宽。
聚优云惠
298 7
云小弟指导上云
|
4月前
|
云安全 存储 弹性计算
阿里云产品试用图文教程及注意事项
阿里云产品可以免费试用，阿里云企业和个人用户都能申请，本文以个人用户申请试用云服务器ECS产品为例为大家展示阿里云产品试用图文教程及注意事项，来看看怎么申请免费试用到阿里云产品吧。
云小弟指导上云
705 1
阿里云产品试用图文教程及注意事项
流子
|
5月前
|
移动开发 安全 JavaScript
阿里云的数据风控试用总结
阿里云的数据风控试用总结
流子
88 0
二进制怪兽
|
6月前
|
消息中间件 Java 物联网
[笔记]阿里云物联网之业务服务端（java、php）接入阿里云平台（二）
[笔记]阿里云物联网之业务服务端（java、php）接入阿里云平台（二）
二进制怪兽
328 0

物联网

热门文章

最新文章

  • 1
    使用MQTT客户端连接阿里云MQTT服务器
  • 2
    物联网发展的三大编程语言
  • 3
    PostgreSQL "物联网"应用 - 1 实时流式数据处理案例(万亿每天)
  • 4
    物联网平台实用技巧：调用API获取设备状态
  • 5
    一个简单算法可以帮助物联网,金融 用户 节约98%的数据存储成本 (PostgreSQL,Greenplum帮你做到)
  • 6
    【阿里云IoT+YF3300】1.时代大背景下的阿里云IoT物联网的现状和未来
  • 7
    NB-IOT物联网平台是如何工作的
  • 8
    ALink协议是最简单的通信协议
  • 9
    阿里云物联网平台体验(树莓派+Python篇)
  • 10
    PostgreSQL 物联网黑科技 - 瘦身500倍的索引(范围索引)
  • 1
    墨水屏电子纸标签/电子纸价签领域如何选择无线通信方案？
    8
  • 2
    基于Vulnhub靶场之DC-3渗透测试过程
    20
  • 3
    “大厂”角力移动办公系统市场，钉钉和企微向左、WorkPlus向右
    14
  • 4
    瑞典全国核心数据被一锅端，企业数字安全还能好吗？
    21
  • 5
    MQTT微消息队列服务器连接报错：Error: Connection refused: Not authorized
    41
  • 6
    性能工具之emqtt-bench BenchMark 测试示例
    62
  • 7
    如何入门做物联网系统压测？
    77
  • 8
    低功耗广域网的代表主要有LORA和NB-IOT和TPUNB
    31
  • 9
    嵌入式开发常用的接口和通信协议
    31
  • 10
    hibernate二级缓存
    15

    • 相关产品

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

    • 相关课程

    更多
  • 跟阿里云技术专家学习智能推荐系统
  • 阿里云负载均衡SLB实战演练
  • 云原生基础概念及阿里云云原生产品介绍
  • 阿里云图数据库GDB入门与应用
  • 企业上云攻略-阿里云网络产品应用系列教程
  • 阿里云物联网平台专题介绍

    • 相关电子书

    更多
  • 阿里云云原生 Serverless 技术实践营 PPT 演讲
  • 阿里云产品十月刊
  • 基于阿里云构建博学谷平台实时湖仓

    • 相关实验场景

    更多
  • 使用阿里云ECS监控您的特斯拉
  • 使用阿里云ECS安装家用内网穿透服务
  • 在阿里云百炼大模型中快速创建企业知识应用
  • 使用阿里云ECS搭建一套网页IDE
  • 使用阿里云ECS搭建自己的持续集成服务
  • 阿里云百炼xAnalyticDB PostgreSQL构建AIGC应用
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）