消息队列模块的定义和实现 更多...
#include "../common/logger.hpp"#include "../common/helper.hpp"#include "../common/msg.pb.h"#include <iostream>#include <unordered_map>#include <mutex>#include <memory>

类 | |
| struct | XuMQ::MsgQueue |
| 消息队列结构体 更多... | |
| class | XuMQ::MsgQueueMapper |
| 消息队列持久化管理类 将数据存储在sqlite数据库中 更多... | |
| class | XuMQ::MsgQueueManager |
| 消息队列数据内存管理类 更多... | |
命名空间 | |
| namespace | XuMQ |
类型定义 | |
| using | XuMQ::QueueMap = std::unordered_map< std::string, MsgQueue::ptr > |
| 消息队列映射表 消息队列名称->消息队列指针 | |
消息队列模块的定义和实现
本文件定义了消息队列的结构体 MsgQueue 及其管理类 MsgQueueMapper 和 MsgQueueManager。
MsgQueue 结构体用于表示一个消息队列,包含其属性和相关操作。 MsgQueueMapper 类负责持久化管理,将消息队列信息存储在 SQLite 数据库中。 MsgQueueManager 类负责在内存中管理消息队列,并提供相应的操作接口。