鸿蒙OpenHarmony【轻量系统内核通信机制（消息队列）】子系统开发

消息队列

基本概念

消息队列又称队列，是一种任务间通信的机制。消息队列接收来自任务或中断的不固定长度消息，并根据不同的接口确定传递的消息是否存放在队列空间中。

任务能够从队列里面读取消息，当队列中的消息为空时，挂起读取任务；当队列中有新消息时，挂起的读取任务被唤醒并处理新消息。任务也能够往队列里写入消息，当队列已经写满消息时，挂起写入任务；当队列中有空闲消息节点时，挂起的写入任务被唤醒并写入消息。

可以通过调整读队列和写队列的超时时间来调整读写接口的阻塞模式，如果将读队列和写队列的超时时间设置为0，就不会挂起任务，接口会直接返回，这就是非阻塞模式。反之，如果将读队列和写队列的超时时间设置为大于0的时间，就会以阻塞模式运行。

消息队列提供了异步处理机制，允许将一个消息放入队列，但不立即处理。同时队列还有缓冲消息的作用，可以使用队列实现任务异步通信，队列具有如下特性：

  • 消息以先进先出的方式排队，支持异步读写。
  • 读队列和写队列都支持超时机制。
  • 每读取一条消息，就会将该消息节点设置为空闲。
  • 发送消息类型由通信双方约定，可以允许不同长度（不超过队列的消息节点大小）的消息。
  • 一个任务能够从任意一个消息队列接收和发送消息。
  • 多个任务能够从同一个消息队列接收和发送消息。
  • 创建普通队列时所需的队列空间，由系统自行动态申请内存。
  • 创建静态队列时所需的队列空间，由用户传入。这块空间在队列删除之后也由用户去释放。

运行机制

队列控制块

队列会在初始化时给分配一个属于自己的控制块，控制块包含了队列的名称、状态等信息。删除队列时会释放该控制块。

队列控制块数据结构如下：

typedef struct 
{UINT8       *queue;                          		/* 队列消息内存空间的指针 */UINT8 		*queueName								/* 队列名称 */UINT16      queueState;                      		/* 队列状态 */UINT16      queueLen;                        		/* 队列中消息节点个数，即队列长度 */UINT16      queueSize;                       		/* 消息节点大小 */UINT16      queueID;                         		/* 队列ID */UINT16      queueHead;                       		/* 消息头节点位置（数组下标）*/UINT16      queueTail;                       		/* 消息尾节点位置（数组下标）*/UINT16      readWriteableCnt[OS_READWRITE_LEN]; 	/* 数组下标0的元素表示队列中可读消息数，                              数组下标1的元素表示队列中可写消息数 */LOS_DL_LIST readWriteList[OS_READWRITE_LEN];    	/* 读取或写入消息的任务等待链表， 下标0：读取链表，下标1：写入链表 */LOS_DL_LIST memList;                         		/* 内存块链表 */
} LosQueueCB;

每个队列控制块中都含有队列状态，表示该队列的使用情况：

  • OS_QUEUE_UNUSED：队列未被使用。
  • OS_QUEUE_INUSED：队列被使用中。

队列运作原理

  • 创建队列时，创建队列成功会返回队列ID。

  • 在队列控制块中维护着一个消息头节点位置Head和一个消息尾节点位置Tail，用于表示当前队列中消息的存储情况。Head表示队列中被占用的消息节点的起始位置。Tail表示被占用的消息节点的结束位置，也是空闲消息节点的起始位置。队列刚创建时，Head和Tail均指向队列起始位置。

  • 写队列时，根据readWriteableCnt[1]判断队列是否可以写入，不能对已满（readWriteableCnt[1]为0）队列进行写操作。写队列支持两种写入方式：向队列尾节点写入，也可以向队列头节点写入。尾节点写入时，根据Tail找到起始空闲消息节点作为数据写入对象，如果Tail已经指向队列尾部则采用回卷方式。头节点写入时，将Head的前一个节点作为数据写入对象，如果Head指向队列起始位置则采用回卷方式。

  • 读队列时，根据readWriteableCnt[0]判断队列是否有消息需要读取，对全部空闲（readWriteableCnt[0]为0）队列进行读操作会引起任务挂起。如果队列可以读取消息，则根据Head找到最先写入队列的消息节点进行读取。如果Head已经指向队列尾部则采用回卷方式。

  • 删除队列时，根据队列ID找到对应队列，把队列状态置为未使用，把队列控制块置为初始状态，并释放队列所占内存。

    图1 队列读写数据操作示意图

    1

上图对读写队列做了示意，图中只画了尾节点写入方式，没有画头节点写入，但是两者是类似的。

接口说明

功能分类接口描述
创建/删除消息队列LOS_QueueCreate：创建一个消息队列，由系统动态申请队列空间。 LOS_QueueCreateStatic：创建一个消息队列，由用户传入队列空间。 LOS_QueueDelete：根据队列ID删除一个指定队列，静态消息队列删除后，队列空间需要用例自行处理。
读/写队列（不带拷贝）LOS_QueueRead：读取指定队列头节点中的数据（队列节点中的数据实际上是一个地址）。 LOS_QueueWrite：向指定队列尾节点中写入入参bufferAddr的值（即buffer的地址）。 LOS_QueueWriteHead：向指定队列头节点中写入入参bufferAddr的值（即buffer的地址）。
读/写队列（带拷贝）LOS_QueueReadCopy：读取指定队列头节点中的数据。 LOS_QueueWriteCopy：向指定队列尾节点中写入入参bufferAddr中保存的数据。 LOS_QueueWriteHeadCopy：向指定队列头节点中写入入参bufferAddr中保存的数据。
获取队列信息LOS_QueueInfoGet：获取指定队列的信息，包括队列ID、队列长度、消息节点大小、头节点、尾节点、可读节点数量、可写节点数量、等待读操作的任务、等待写操作的任务。

开发流程

  1. 用LOS_QueueCreate创建队列。创建成功后，可以得到队列ID。
  2. 通过LOS_QueueWrite或者LOS_QueueWriteCopy写队列。
  3. 通过LOS_QueueRead或者LOS_QueueReadCopy读队列。
  4. 通过LOS_QueueInfoGet获取队列信息。
  5. 通过LOS_QueueDelete删除队列。

说明：

  • 系统支持的最大队列数是指：整个系统的队列资源总个数，而非用户能使用的个数。例如：系统软件定时器多占用一个队列资源，那么用户能使用的队列资源就会减少一个。
  • 创建队列时传入的队列名和flags暂时未使用，作为以后的预留参数。
  • 队列接口函数中的入参timeOut是相对时间。
  • LOS_QueueReadCopy和LOS_QueueWriteCopy及LOS_QueueWriteHeadCopy是一组接口，LOS_QueueRead和LOS_QueueWrite及LOS_QueueWriteHead是一组接口，每组接口需要配套使用。
  • 鉴于LOS_QueueWrite和LOS_QueueWriteHead和LOS_QueueRead这组接口实际操作的是数据地址，用户必须保证调用LOS_QueueRead获取到的指针所指向的内存区域在读队列期间没有被异常修改或释放，否则可能导致不可预知的后果。
  • LOS_QueueReadCopy接口的读取长度如果小于消息实际长度，消息将被截断。
  • 鉴于LOS_QueueWrite和LOS_QueueWriteHead和LOS_QueueRead这组接口实际操作的是数据地址，也就意味着实际写和读的消息长度仅仅是一个指针数据，因此用户使用这组接口之前，需确保创建队列时的消息节点大小，为一个指针的长度，避免不必要的浪费和读取失败。

编程实例

实例描述

创建一个队列，两个任务。任务1调用写队列接口发送消息，任务2通过读队列接口接收消息。

  1. 通过LOS_TaskCreate创建任务1和任务2。
  2. 通过LOS_QueueCreate创建一个消息队列。
  3. 在任务1 SendEntry中发送消息。
  4. 在任务2 RecvEntry中接收消息。
  5. 通过LOS_QueueDelete删除队列。

示例代码

示例代码如下：

本演示代码在 ./kernel/liteos_m/testsuites/src/osTest.c 中编译验证，在TestTaskEntry中调用验证入口函数ExampleQueue。

#include "los_task.h"
#include "los_queue.h"STATIC UINT32 g_queue;
#define BUFFER_LEN 50VOID SendEntry(VOID)
{UINT32 ret = 0;CHAR abuf[] = "test message";UINT32 len = sizeof(abuf);ret = LOS_QueueWriteCopy(g_queue, abuf, len, 0);if (ret != LOS_OK) {printf("send message failure, error: %x\n", ret);}
}VOID RecvEntry(VOID)
{UINT32 ret = 0;CHAR readBuf[BUFFER_LEN] = {0};UINT32 readLen = BUFFER_LEN;/* 休眠1s */usleep(1000000);ret = LOS_QueueReadCopy(g_queue, readBuf, &readLen, 0);if (ret != LOS_OK) {printf("recv message failure, error: %x\n", ret);}printf("recv message: %s.\n", readBuf);ret = LOS_QueueDelete(g_queue);if (ret != LOS_OK) {printf("delete the queue failure, error: %x\n", ret);}printf("delete the queue success.\n");
}UINT32 ExampleQueue(VOID)
{printf("start queue example.\n");UINT32 ret = 0;UINT32 task1;UINT32 task2;TSK_INIT_PARAM_S taskParam1 = { 0 };TSK_INIT_PARAM_S taskParam2 = { 0 };LOS_TaskLock();taskParam1.pfnTaskEntry = (TSK_ENTRY_FUNC)SendEntry;taskParam1.usTaskPrio = 9;taskParam1.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE;taskParam1.pcName = "SendQueue";ret = LOS_TaskCreate(&task1, &taskParam1);if(ret != LOS_OK) {printf("create task1 failed, error: %x\n", ret);return ret;}taskParam2.pfnTaskEntry = (TSK_ENTRY_FUNC)RecvEntry;taskParam2.usTaskPrio = 10;taskParam2.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE;taskParam2.pcName = "RecvQueue";ret = LOS_TaskCreate(&task2, &taskParam2);if(ret != LOS_OK) {printf("create task2 failed, error: %x\n", ret);return ret;}ret = LOS_QueueCreate("queue", 5, &g_queue, 0, 50);if(ret != LOS_OK) {printf("create queue failure, error: %x\n", ret);}printf("create the queue success.\n");LOS_TaskUnlock();return ret;
}

结果验证

编译运行得到的结果为：

start queue example.
create the queue success.
recv message: test message.
delete the queue success.

以上就是本篇文章所带来的鸿蒙开发中一小部分技术讲解；想要学习完整的鸿蒙全栈技术。可以在结尾找我可全部拿到！
下面是鸿蒙的完整学习路线，展示如下：
1

除此之外，根据这个学习鸿蒙全栈学习路线，也附带一整套完整的学习【文档+视频】，内容包含如下：

内容包含了：（ArkTS、ArkUI、Stage模型、多端部署、分布式应用开发、音频、视频、WebGL、OpenHarmony多媒体技术、Napi组件、OpenHarmony内核、鸿蒙南向开发、鸿蒙项目实战）等技术知识点。帮助大家在学习鸿蒙路上快速成长！

鸿蒙【北向应用开发+南向系统层开发】文档

鸿蒙【基础+实战项目】视频

鸿蒙面经

2

为了避免大家在学习过程中产生更多的时间成本，对比我把以上内容全部放在了↓↓↓想要的可以自拿喔！谢谢大家观看！
3

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

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

相关文章

Linux--禁止root用户通过ssh直接登录

Linux--禁止root用户通过ssh直接登录

原文网址：Linux--禁止root用户通过ssh直接登录_IT利刃出鞘的博客-CSDN博客 简介 本文介绍Linux服务器怎样禁止root用户通过ssh直接登录。 为什么要禁止？ 因为root用户是每个Linux系统都有的，黑客可以使用root用户名尝试不同的密码来暴力破…
阅读更多...
ClickHouse 与 Quickwit 集成实现高效查询

ClickHouse 与 Quickwit 集成实现高效查询

1. 概述 在当今大数据分析领域，ClickHouse 作为一款高性能的列式数据库，以其出色的查询速度和对大规模数据的处理能力，广泛应用于在线分析处理 (OLAP) 场景。ClickHouse 的列式存储和并行计算能力使得它在处理结构化数据查询时极具优势&…
阅读更多...
【Elasticsearch】-spring boot 依赖包冲突问题

【Elasticsearch】-spring boot 依赖包冲突问题

<dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.17.24</version></dependency> 在pom的配置中&#xff0c;只引入了elasticsearch-7.17.24 &#xff0c;但实际上会同时…
阅读更多...
seq2seq翻译实战-Pytorch复现

seq2seq翻译实战-Pytorch复现

&#x1f368; 本文为&#x1f517;365天深度学习训练营 中的学习记录博客&#x1f356; 原作者&#xff1a;K同学啊 code from __future__ import unicode_literals, print_function, division from io import open import unicodedata import string import re import rando…
阅读更多...
半导体器件制造5G智能工厂数字孪生物联平台，推进制造业数字化转型

半导体器件制造5G智能工厂数字孪生物联平台，推进制造业数字化转型

半导体器件制造行业作为高科技领域的核心驱动力&#xff0c;正积极探索和实践以5G智能工厂数字孪生平台为核心的新型制造模式。这一创新不仅极大地提升了生产效率与质量&#xff0c;更为制造业的未来发展绘制了一幅智能化、网络化的宏伟蓝图。 在半导体器件制造5G智能工厂中&a…
阅读更多...
RabbitMQ 高级特性——发送方确认

RabbitMQ 高级特性——发送方确认

文章目录 前言发送方确认confirm 确认模式return 退回模式 常见面试题 前言 前面我们学习了 RabbitMQ 中交换机、队列和消息的持久化&#xff0c;这样能够保证存储在 RabbitMQ Broker 中的交换机和队列中的消息实现持久化&#xff0c;就算 RabbitMQ 服务发生了重启或者是宕机&…
阅读更多...
中间件知识点-消息中间件（Rabbitmq）一

中间件知识点-消息中间件（Rabbitmq）一

消息中间件介绍 MQ的作用(优点)主要有以下三个方面&#xff1a; a.异步 b.解耦 c.削峰 MQ的作用(缺点)主要有以下三个方面&#xff1a; a.系统可用性降低 b.系统复杂度提高 c.存在消息一致性问题需要解决 备注&#xff1a; 引入MQ后系统的复杂度会大大提高。 以前服务之间可以…
阅读更多...
【软件基础知识】什么是 API，详细解读

【软件基础知识】什么是 API，详细解读

想象一下,你正在使用智能手机上的天气应用。你打开应用,瞬间就能看到实时天气、未来预报,甚至是空气质量指数。但你有没有想过,这些数据是如何神奇地出现在你的屏幕上的?答案就在三个字母中:API。 API,全称Application Programming Interface(应用程序编程接口),是现代软件世…
阅读更多...
计算机网络 --- 初识协议

计算机网络 --- 初识协议

序言 上一篇文章中 &#xff08;&#x1f449;点击查看&#xff09;&#xff0c;我们简单的了解了怎么寻找目标计算机&#xff0c;需要通过交换机&#xff0c;路由器等设备跨越多个网络来不断的转发我们需要传输的数据&#xff0c;直至到达目标计算机。  那我们设备之间数据是…
阅读更多...
重回极简：华为如何走向全面智能化？

重回极简：华为如何走向全面智能化？

“人类发现地球只是宇宙一员的时候&#xff0c;也是我们距离群星最遥远的时候。” 这个来自天文领域的喟叹&#xff0c;今天同样出现在行业与企业的智能化之路上。在这个时代坐标上&#xff0c;AI大模型技术极速成熟&#xff0c;AIGC和AI Agent等应用受到了各个行业的巨大期待。…
阅读更多...
昇腾大模型推理解决方案MindIE部署

昇腾大模型推理解决方案MindIE部署

MindIE大模型推理套件 MindIE&#xff08;Mind Inference Engine&#xff0c;昇腾推理引擎&#xff09;是华为公司针对AI全场景推出的整体解决方案&#xff0c;包含丰富的推理加速套件。通过开放各层次AI能力&#xff0c;支撑客户多样化的AI业务需求&#xff0c;使能百模千态&a…
阅读更多...
存储 NFS

存储 NFS

目录 1.存储的应用场景 2.存储分类 3.NFS服务组成 4.环境说明 ​编辑 5.服务端部署 6.NFS服务端的配置 7.NFS服务端本地进行测试 1.存储的应用场景 存储一般用于上传网站数据&#xff08;内容&#xff09;&#xff0c;一般用于在网站集群中。使用存储的话用户上传的…
阅读更多...
成型的程序

成型的程序

加一个提示信息 加上python 常用的包 整个程序打包完 250M 安装 960MB matplot numpy pandas scapy pysearial 常用的包 (pyvisa)… … 啥都有 Python 解释器组件构建 要比 lua 容易的多 &#xff08;C/Rust 的组件库)
阅读更多...
JavaSE--集合总览02：单列集合Collection的体系之一：List

JavaSE--集合总览02：单列集合Collection的体系之一：List

Collection体系的特点 分为 list 和set集合&#xff0c;这篇文章主要讲述List&#xff0c;下篇讲述Set。 简单认识单列集合collection集合的特点 : list集合的特点&#xff1a; 有序 可重复 有索引 set集合的特点&#xff1a;无序 不重复 无索引 其中LinkedHashSet有序 TreeS…
阅读更多...
微服务架构陷阱与挑战

微服务架构陷阱与挑战

微服务架构6大陷阱 现在微服务的基础设施还是越来越完善了&#xff0c;现在基础设施缺乏的问题逐渐被解决了。 拆分粒度太细&#xff0c;服务关系复杂 拆分降低了服务的内部复杂度&#xff0c;但是提升了系统的外部复杂度&#xff0c;服务越多&#xff0c;服务和服务之间的连接…
阅读更多...
from tqdm.auto import tqdm用法详细介绍

from tqdm.auto import tqdm用法详细介绍

tqdm 是一个 Python 库&#xff0c;用于在长时间运行的任务中显示进度条。tqdm.auto 是 tqdm 的一个版本&#xff0c;能够自动适配输出环境&#xff08;如 Jupyter Notebook、命令行等&#xff09;&#xff0c;以确保进度条在各种环境下显示正确。下面是 tqdm.auto 的详细用法介…
阅读更多...
每天五分钟计算机视觉：将人脸识别问题转换为二分类问题

每天五分钟计算机视觉：将人脸识别问题转换为二分类问题

本文重点 在前面的课程中，我们学习了两种人脸识别的网络模型，这两种人脸识别网络不能算是基于距离或者Triplet loss等等完成的神经网络参数的学习。我们比较熟悉的是分类任务，那么人脸识别是否可以转变为分类任务呢？ 本节课程我们将介绍一种全新的方法来学习神经网络的参…
阅读更多...
用友U8二次开发工具KK-FULL-*****-EFWeb使用方法

用友U8二次开发工具KK-FULL-*****-EFWeb使用方法

1、安装: 下一步&#xff0c;下一步即可。弹出黑框不要关闭&#xff0c;让其自动执行并关闭。 2、服务配置&#xff1a; 输入服务器IP地址&#xff0c;选择U8数据源&#xff0c;输入U8用户名及账号&#xff0c;U8登录日期勾选系统日期。测试参数有效性&#xff0c;提示测试通过…
阅读更多...
利用 FastAPI 和 Jinja2 模板引擎快速构建 Web 应用

利用 FastAPI 和 Jinja2 模板引擎快速构建 Web 应用

FastAPI 是一个现代、快速&#xff08;高性能&#xff09;的 Web 框架&#xff0c;用于构建 API&#xff0c;它基于标准 Python 类型提示。FastAPI 支持异步编程&#xff0c;使得开发高性能的 Web 应用变得简单快捷。在本文中&#xff0c;我们将探讨如何使用 FastAPI 结合 Jinj…
阅读更多...
VS code 查看 ${workspaceFolder} 目录指代路径

VS code 查看 ${workspaceFolder} 目录指代路径

VS code 查看 ${workspaceFolder} 目录指代路径 引言正文 引言 在 VS code 创建与运行 task.json 文件 一文中我们已经介绍了如何创建属于自己的 .json 文件。在 VS code 中&#xff0c;有时候我们需要添加一些文件路径供我们导入自定义包使用&#xff0c;此时&#xff0c;我们…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023