消息队列模块的定义和实现 更多...
#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
类负责在内存中管理消息队列,并提供相应的操作接口。