【XR806开发板试用】基于WEBSOCKET实现人机交互（控制开关灯）以及开发问题记录

一、开发板编译、功能介绍

根据官方文档编译烧录成功后，我们修改下官方例子，进行开发来实现websocket。
整体流程：开发板先自动寻找指定的wifi并且连接，连接成功后，通过websocket来与服务端连接，连接成功后，服务端就可以控制开发板开关灯。

二、代码编写以及功能实现

进入目录 device/xradio/xr806/ohosdemo/
修改BUILD.gn文件新增demo:app_demo
group(“ohosdemo”) {
deps = [
#“hello_demo:app_hello”,
#“iot_peripheral:app_peripheral”,
#“wlan_demo:app_WlanTest”,
#“LED:app_led”,
“demo:app_demo”,
]
}
创建demo目录 tree -L 1
├── BUILD.gn
└── main.c
BUILD.gn内容：

import("//device/xradio/xr806/liteos_m/config.gni")static_library("app_demo") {configs = []sources = ["main.c",]cflags = board_cflagsinclude_dirs = board_include_dirsinclude_dirs += ["//kernel/liteos_m/kernel/arch/include","//kernel/liteos_m/kernel/arch/include","//base/iot_hardware/peripheral/interfaces/kits","//utils/native/lite/include","//foundation/communication/wifi_lite/interfaces/wifiservice","//device/xradio/xr806/xr_skylark/project",]
}

main.c

#include <stdio.h>
#include <string.h>#include "ohos_init.h"
#include "kernel/os/os.h"
#include "iot_gpio.h"#include "wifi_device.h"
#include "wifi_hotspot.h"#include "net/libwebsockets/libwebsockets.h"#define WIFI_DEVICE_CONNECT_AP_SSID "um"  //wifi名称
#define WIFI_DEVICE_CONNECT_AP_PSK "12345678" //wifi密码#define WEBSOCKET_HOST      "192.168.10.21"    //服务器IP
#define WEBSOCKET_PORT      9999                //服务器端口
#define WEBSOCKET_PATH      "/ws"               //websocket路径#define LIGHT_OPEN          "/light/open"       //开灯指令
#define LIGHT_CLOSE         "/light/close"               //关灯指令static OS_Thread_t g_main_thread;#define GPIO_ID_PA21 21#define MAX_PAYLOAD_SIZE  10 * 1024/*** 会话上下文对象，结构根据需要自定义*/
struct session_data {int msg_count;unsigned char buf[LWS_PRE + MAX_PAYLOAD_SIZE];int len;
};/*** 某个协议下的连接发生事件时，执行的回调函数** wsi：指向WebSocket实例的指针* reason：导致回调的事件* user 库为每个WebSocket会话分配的内存空间* in 某些事件使用此参数，作为传入数据的指针* len 某些事件使用此参数，说明传入数据的长度*/
int callback( struct lws *wsi, enum lws_callback_reasons reason, void *user, void *in, size_t len ) {struct session_data *data = (struct session_data *) user;switch ( reason ) {case LWS_CALLBACK_CLIENT_ESTABLISHED:   // 连接到服务器后的回调lwsl_notice( "Connected to server ok!\n" );break;case LWS_CALLBACK_CLIENT_RECEIVE:       // 接收到服务器数据后的回调，数据为in，其长度为lenlwsl_notice( "Rx: %s\n", (char *) in );if (strncmp(in, LIGHT_CLOSE, len)){//开灯操作IoTGpioSetOutputVal(GPIO_ID_PA21, 1);}else if (strncmp(in, LIGHT_OPEN, len)){//关灯操作IoTGpioSetOutputVal(GPIO_ID_PA21, 0);}break;case LWS_CALLBACK_CLIENT_WRITEABLE:     // 当此客户端可以发送数据时的回调if ( data->msg_count < 3 ) {// 前面LWS_PRE个字节必须留给LWSmemset( data->buf, 0, sizeof( data->buf ));char *msg = (char *) &data->buf[ LWS_PRE ];data->len = sprintf( msg, "你好 %d", ++data->msg_count );lwsl_notice( "Tx: %s\n", msg );// 通过WebSocket发送文本消息lws_write( wsi, &data->buf[ LWS_PRE ], data->len, LWS_WRITE_TEXT );}break;}return 0;
}/*** 支持的WebSocket子协议数组* 子协议即JavaScript客户端WebSocket(url, protocols)第2参数数组的元素* 你需要为每种协议提供回调函数*/
struct lws_protocols protocols[] = {{//协议名称，协议回调，接收缓冲区大小"ws", callback, sizeof( struct session_data ), MAX_PAYLOAD_SIZE,},{NULL, NULL,   0 // 最后一个元素固定为此格式}
};//连接wifi，并且打印ip
static int wifiConnect()
{const char ssid_want_connect[] = WIFI_DEVICE_CONNECT_AP_SSID;const char psk[] = WIFI_DEVICE_CONNECT_AP_PSK;if (WIFI_SUCCESS != EnableWifi()) {printf("Error: EnableWifi fail.\n");return -1;}OS_Sleep(1);if (WIFI_STA_ACTIVE == IsWifiActive())printf("Wifi is active.\n");OS_Sleep(1);if (WIFI_SUCCESS != Scan()) {printf("Error: Scan fail.\n");return -1;}OS_Sleep(3);WifiScanInfo scan_results[30];unsigned int scan_num = 30;if (WIFI_SUCCESS != GetScanInfoList(scan_results, &scan_num)) {printf("Error: GetScanInfoList fail.\n");return -1;}WifiDeviceConfig config = { 0 };int netId = 0;int i;for (i = 0; i < scan_num; i++) {if (0 == strcmp(scan_results[i].ssid, ssid_want_connect)) {memcpy(config.ssid, scan_results[i].ssid,WIFI_MAX_SSID_LEN);memcpy(config.bssid, scan_results[i].bssid,WIFI_MAC_LEN);strcpy(config.preSharedKey, psk);config.securityType = scan_results[i].securityType;config.wapiPskType = WIFI_PSK_TYPE_ASCII;config.freq = scan_results[i].frequency;break;}}if (i >= scan_num) {printf("Error: No found ssid in scan_results\n");return -1;}if (WIFI_SUCCESS != AddDeviceConfig(&config, &netId)) {printf("Error: AddDeviceConfig Fail\n");return -1;}if (WIFI_SUCCESS != ConnectTo(netId)) {printf("Error: ConnectTo Fail\n");return -1;}printf("ConnectTo Success\n");OS_Sleep(15);return 0;
}void wifiDisconnect()
{printf("\n=========== DisConnect Test Start ===========\n");if (WIFI_SUCCESS != Disconnect()) {printf("Error: Disconnect Fail\n");return;}printf("Disconnect Success\n");if (WIFI_SUCCESS != DisableWifi()) {printf("Error: DisableWifi fail.\n");return;}printf("DisableWifi Success\n");printf("\n=========== DisConnect Test End ===========\n");
}static void MainThread(void *arg)                                               
{int s32Ret = 0;s32Ret = wifiConnect();if (0 != s32Ret){printf("wifiConnect failed\n");return;}IoTGpioInit(GPIO_ID_PA21);IoTGpioSetDir(GPIO_ID_PA21, IOT_GPIO_DIR_OUT);// 用于创建vhost或者context的参数struct lws_context_creation_info ctx_info = { 0 };ctx_info.port = CONTEXT_PORT_NO_LISTEN;
//    ctx_info.iface = NULL;ctx_info.protocols = protocols;ctx_info.gid = -1;ctx_info.uid = -1;// 创建一个WebSocket处理器struct lws_context *context = lws_create_context( &ctx_info );char address[] = WEBSOCKET_HOST;int port = WEBSOCKET_PORT;char addr_port[256] = { 0 };sprintf(addr_port, "%s:%u", address, port & 65535 );// 客户端连接参数struct lws_client_connect_info conn_info = { 0 };conn_info.context = context;conn_info.address = address;conn_info.port = port;conn_info.path = WEBSOCKET_PATH;conn_info.host = addr_port;conn_info.origin = addr_port;conn_info.protocol = protocols[ 0 ].name;// 下面的调用触发LWS_CALLBACK_PROTOCOL_INIT事件// 创建一个客户端连接struct lws *wsi = lws_client_connect_via_info( &conn_info );while (1) {// 执行一次事件循环（Poll），最长等待1000毫秒lws_service( context, 1000 );/*** 下面的调用的意义是：当连接可以接受新数据时，触发一次WRITEABLE事件回调* 当连接正在后台发送数据时，它不能接受新的数据写入请求，所有WRITEABLE事件回调不会执行*/lws_callback_on_writable( wsi );}// 销毁上下文对象lws_context_destroy( context );wifiDisconnect();
}
//连接websocket 进行开灯，关灯操作//wifi 连接
void demoMain(void)                                                              //(2)
{printf("websocket Test Start\n");if (OS_ThreadCreate(&g_main_thread, "MainThread", MainThread, NULL,OS_THREAD_PRIO_APP, 4 * 1024) != OS_OK){printf("[ERR] Create MainThread Failed\n");}
}SYS_RUN(demoMain);

三、效果演示

服务器用了网上下载的个WebssocketMan工具来模拟，网盘链接
链接：https://pan.baidu.com/s/1t82q_1evB5Zla-Hc1m4SYA
提取码：4pxu
在这里插入图片描述

登陆成功后打印显示：
在这里插入图片描述

登录后平台收到“/light/open”消息为点灯，“/light/close”为关灯
演示截图：
在这里插入图片描述
在这里插入图片描述

四、问题记录

在打开wifi例子，编译过程中遇到了分区叠加的错误，具体如图（感谢群里的朋友、社区以及论坛的帮助）
在这里插入图片描述

因为内存分配不够，官方文档描述
device\xradio\xr806\xr_skylark\project\image_cfg\readme.md
在这里插入图片描述

按照网上说的修改：
device\xradio\xr806\xr_skylark\project\demo\wlan_ble_demo\image\xr806\image_wlan_ble.cfg 分配不能够生效
最终解决：xr806\device\xradio\xr806\xr_skylark\project\demo\audio_demo\image\xr806\目录中将 image_auto_cal.cfg替换image.cfg

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/541872.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

贪心算法（算法竞赛、蓝桥杯）--均分纸牌

贪心算法（算法竞赛、蓝桥杯）--均分纸牌

1、B站视频链接&#xff1a;A30 贪心算法 P1031 [NOIP2002 提高组] 均分纸牌_哔哩哔哩_bilibili 题目链接&#xff1a;[NOIP2002 提高组] 均分纸牌 - 洛谷 #include <bits/stdc.h> using namespace std; int n,a[101],av,cnt;int main(){scanf("%d",&n);…
阅读更多...
鸿蒙实战开发：【分布式软总线组件】

鸿蒙实战开发：【分布式软总线组件】

简介 现实中多设备间通信方式多种多样(WIFI、蓝牙等)&#xff0c;不同的通信方式使用差异大&#xff0c;导致通信问题多&#xff1b;同时还面临设备间通信链路的融合共享和冲突无法处理等挑战。分布式软总线实现近场设备间统一的分布式通信管理能力&#xff0c;提供不区分链路…
阅读更多...
【IC设计】Verilog线性序列机点灯案例(二)（小梅哥课程）

【IC设计】Verilog线性序列机点灯案例(二)（小梅哥课程）

文章目录 该系列目录&#xff1a;设计目标设计思路RTL 及 Testbench仿真结果存在的问题&#xff1f;改善后的代码RTL代码testbench代码 仿真结果 案例和代码来自小梅哥课程&#xff0c;本人仅对知识点做做笔记&#xff0c;如有学习需要请支持官方正版。 该系列目录&#xff1a;…
阅读更多...
考研复习C语言进阶（4）

考研复习C语言进阶（4）

1. 为什么存在动态内存分配 我们已经掌握的内存开辟方式有&#xff1a; int val 20;//在栈空间上开辟四个字节 char arr[10] {0};//在栈空间上开辟10个字节的连续空间 但是上述的开辟空间的方式有两个特点&#xff1a; 1. 空间开辟大小是固定的。 2. 数组在申明的时候&#…
阅读更多...
OpenOFDM接收端信号处理流程

OpenOFDM接收端信号处理流程

Overview — OpenOFDM 1.0 documentation 本篇文章为学习OpenOFDM之后的产出PPT&#xff0c;仅供学习参考。 ​​​​​​​
阅读更多...
Gitlab部署及使用

Gitlab部署及使用

1. 简介 GitLab 是一个用于仓库管理系统的开源项目&#xff0c;使用 Git 作为代码管理工具&#xff0c;并在此基础上搭建起来的Web服务。Gitlab是目前被广泛使用的基于 git 的开源代码管理平台&#xff0c;基于Ruby on Rails构建&#xff0c;主要针对软件开发过程中产生的代码…
阅读更多...
华为配置中心AP内漫游实验

华为配置中心AP内漫游实验

华为配置中心AP内漫游示例 组网图形 图1 配置中心AP内漫游组网图 配置流程组网需求配置思路数据规划配置注意事项操作步骤配置文件 配置流程 WLAN不同的特性和功能需要在不同类型的模板下进行配置和维护&#xff0c;这些模板统称为WLAN模板&#xff0c;如域管理模板、射频模…
阅读更多...
基于单片机的自动售货机的设计

基于单片机的自动售货机的设计

摘 要 自动售货机是近些年来兴起的一种通过FPGA或者单片机等硬件支持的智能设备。它广泛的应用于商场&#xff0c;公寓&#xff0c;火车汽车站等人流较密集且购物需求大的地方。自动售货机通过硬件支持&#xff0c;通过以编写好的程序自动出货自动找零&#xff0c;但货物一旦售…
阅读更多...
docker 安装minio,详细图解

docker 安装minio,详细图解

废话不多说&#xff0c;直接上干货 docker 安装minio 拉取镜像 docker pull minio/minio创建数据目录、配置目录 mkdir /opt/minio/data mkdir /opt/minio/config启动容器 docker run -p 9000:9000 -p 9090:9090 \--name minio \-d --restartalways \-e "MINIO_ACCESS_KE…
阅读更多...
Flutter：构建美观应用的跨平台方案

Flutter：构建美观应用的跨平台方案

&#x1f90d; 前端开发工程师、技术日更博主、已过CET6 &#x1f368; 阿珊和她的猫_CSDN博客专家、23年度博客之星前端领域TOP1 &#x1f560; 牛客高级专题作者、打造专栏《前端面试必备》 、《2024面试高频手撕题》 &#x1f35a; 蓝桥云课签约作者、上架课程《Vue.js 和 E…
阅读更多...
笔记本电脑数据恢复：如何轻松地从笔记本电脑恢复文件

笔记本电脑数据恢复：如何轻松地从笔记本电脑恢复文件

不小心从笔记本电脑中删除了一些重要文件&#xff1f;或者恶意软件和其他不可控因素是否导致您的文件消失&#xff1f;人们很容易认为这些文件已经永远消失&#xff0c;并且无法恢复。但这与事实相差甚远。通过遵循正确的数据恢复礼仪并使用良好的数据恢复工具&#xff0c;您可…
阅读更多...
老电脑装什么系统流畅

老电脑装什么系统流畅

对于一些老旧电脑来说&#xff0c;重装系统是提升电脑性能的最佳选择。那么&#xff0c;老电脑装什么系统流畅呢&#xff1f;推荐Windows 7系统&#xff0c;它对硬件的需求相对较低。配置较低的电脑运行Windows 7可以更好地利用系统资源&#xff0c;提高电脑的运行速度和响应能…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023