文章目录1. 需求文档1.1 需求概要1.2 需求分析1.2.1 多任务间消息通讯1.2.1.1 Eg日志管理任务1.2.1.2 Eg实时数据处理和监控任务1.2.1.3 Eg上位机通信1.2.2 模块状态/异常报警/事件处理1.2.3 消息驱动架构的扩展2. 概要设计2.1 消息类型2.2 消息结构2.3 线程安全的消息队列2.4 消息分发机制2.5 轮询机制2.6 处理不同数据类型的消息负载3. 详细设计3.1 架构设计3.2 异常和类型检查3.3 扩展性设计3.4 安全性和健壮性设计1. 需求文档1.1 需求概要本模块旨在开发一个多任务消息处理系统以确保在多任务环境中安全、及时地发送和处理消息。支持处理多种类型的消息负载。各任务能处理该任务下以注册的消息。允许将同一消息分发至多个任务。适用于操作系统如FreeRTOS…和无操作系统的嵌入式软件应用程序中用于多任务/模拟任务间的消息通信。1.2 需求分析1.2.1 多任务间消息通讯允许各任务按需将消息发送到共享队列由相应的任务处理1.2.1.1 Eg日志管理任务为了保持任务执行的流畅性所有日志消息将被发送到专用的日志队列并由日志管理任务进行处理。1.2.1.2 Eg实时数据处理和监控任务数据处理任务可以接收实时数据更新消息并进行处理而不会干扰数据收集的主流程。1.2.1.3 Eg上位机通信上位机命令或请求可以被封装为消息并分发至相应的任务队列中提高响应速度。1.2.2 模块状态/异常报警/事件处理不同类型的状态更新、异常报警和事件可通过注册的处理函数进行响应。1.2.3 消息驱动架构的扩展通过消息驱动架构可方便地添加新事件和处理逻辑以支持系统的扩展性。2. 概要设计设计中心节点负责将消息分发至对应的任务队列确保命令正确路由和执行。2.1 消息类型定义消息枚举类包括但不限于日志消息、数据更新和网络请求等消息类型。2.2 消息结构消息ID。消息负载作为泛型以存储不同类型的数据。2.3 线程安全的消息队列实现为线程安全。提供消息的入队和出队功能。2.4 消息分发机制允许对消息队列进行注册。允许注册消息处理函数至消息处理器。消息分发器根据消息ID将消息推送至对应的队列。2.5 轮询机制任务通过轮询检查消息队列来处理待处理消息。2.6 处理不同数据类型的消息负载利用模板函数处理特定类型的消息负载。3. 详细设计3.1 架构设计利用多线程实现任务并行处理。用互斥锁和队列实现消息队列的线程安全性。通过映射和函数对象关联消息ID与处理逻辑。采用定时机制管理线程活动。使用智能指针和类型信息处理动态分配和类型安全。Message 结构体定义了消息的基本结构。MessageQueue 类提供了线程安全的消息队列。MessageHandler 类负责处理消息可以注册多个处理函数。MessageDispatcher 类负责将消息分发到对应的队列。具体的消息处理逻辑handleLogMessage、handleDataUpdate 和 handleNetworkRequest 函数测试线程logThreadFunction、dataThreadFunction 和 networkThreadFunction在此架构中main函数负责启动所有线程。每个线程拥有其专用的MessageQueue和MessageHandler。MessageDispatcher负责消息的适当分发。消息处理器可以处理注册的消息类型。线程以轮询机制运行检查并处理队列中的消息。处理函数可以进一步利用MessageDispatcher发送新消息。3.2 异常和类型检查确保在处理消息负载时负载的类型符合预期以防止类型错误。3.3 扩展性设计新消息类型的添加。消息处理函数的可扩展性。3.4 安全性和健壮性设计线程安全保证共享资源的线程安全访问。错误处理妥善处理函数执行中的异常情况。