基于Openharmony轻量级操作系统的分布式数据管理开发案例

实验内容

本例程演示如何在小凌派-RK2206开发板上使用OpenHarmony轻量级操作系统进行KvStore（即分布式数据管理）数据读写。

例程：

（1）创建两个线程，一个负责写入KvStore存储，一个负责读取KvStore存储；

（2）每1秒进行1次读写操作；

程序设计

在本章节中，我们将了解OpenHarmony KvStore存储接口，如文件如何获取数据、设置数据、删除数据和清除缓存。

API分析

头文件

//utils/native/lite/include/kv_store.h

UtilsGetValue()

intUtilsGetValue(constchar*key,char*value,unsignedintlen);

描述：

从文件系统或缓存中获取与指定键匹配的值。

参数：

返回值：

UtilsSetValue()

intUtilsSetValue(constchar*key,constchar*value);

描述：

添加或更新与文件系统或缓存中的指定键匹配的值。

参数：

返回值：

UtilsDeleteValue()

intUtilsDeleteValue(constchar*key);

描述：

从文件系统或缓存中删除与指定键匹配的值。

参数：

返回值：

ClearKVCache()

int ClearKVCache(void);

描述：

从缓存中清除所有键值对。

返回值：

软件设计

主要代码分析

在kv_store_example函数中通过LOS_TaskCreate函数创建两个线程：kv_store_write_thread、kv_store_read_thread。

void kv_store_example(){ unsigned int thread_id1; unsigned int thread_id2; TSK_INIT_PARAM_S task1 = {0}; TSK_INIT_PARAM_S task2 = {0}; unsigned int ret = LOS_OK;

task1.pfnTaskEntry = (TSK_ENTRY_FUNC)kv_store_write_thread; task1.uwStackSize = 1024 * 10; task1.pcName = "kv_store_write_thread"; task1.usTaskPrio = 25; ret = LOS_TaskCreate(&thread_id1, &task1); if (ret != LOS_OK) { printf("Falied to create kv_store_write_thread ret:0x%x\n", ret); return; }

task2.pfnTaskEntry = (TSK_ENTRY_FUNC)kv_store_read_thread; task2.uwStackSize = 1024 * 10; task2.pcName = "kv_store_read_thread"; task2.usTaskPrio = 25; ret = LOS_TaskCreate(&thread_id2, &task2); if (ret != LOS_OK) { printf("Falied to create kv_store_read_thread ret:0x%x\n", ret); return; }}

APP_FEATURE_INIT(kv_store_example);

kv_store_write_thread线程负责创建/更新KV存储，每1秒写入一段内容，重复以上流程。

void kv_store_write_thread(){ int ret = 0; char defValue[50] = {0}; int current = 0;

while (1) { snprintf(defValue, sizeof(defValue), "test value %d.", current); int ret = UtilsSetValue(key, defValue); if (ret < 0) { printf("[error] %d\r\n", ret); } else { printf("[write] write success\r\n"); }

current++; LOS_Msleep(1000); }}

kv_store_read_thread线程负责读取KV存储，每1秒读取一段内容，重复以上流程。

void kv_store_read_thread(){ int ret = 0; char value1[50] = {0};

while (1) { ret = UtilsGetValue(key, value1, sizeof(value1)); if (ret < 0) { printf("[error] %d\r\n", ret); } else { printf("[read] key: %s value:%s\r\n", key, value1); }

LOS_Msleep(1000); }}

编译调试

修改 BUILD.gn 文件

修改 vendor/lockzhiner/rk2206/sample 路径下 BUILD.gn 文件，指定 a10_kv_store 参与编译。

"./a10_kv_store:kv_store_example",

修改 device/rockchip/rk2206/sdk_liteos路径下 Makefile 文件，添加 `-lkv_store_example` 参与编译。

app_LIBS = -lkv_store_example

运行结果

示例代码编译烧录代码后，按下开发板的RESET按键，通过串口助手查看日志。

HalFileInit: Flash Init Successful![write] write success[read] key: key_sample value:test value 0.[write] write success[read] key: key_sample value:test value 1.[write] write success[read] key: key_sample value:test value 2.[write] write success[read]key:key_samplevalue:testvalue3.