消息队列文件存储的实现更多...

#include "../common/logger.hpp"
#include "../common/helper.hpp"
#include "../common/msg.pb.h"
#include <iostream>
#include <unordered_map>
#include <mutex>
#include <memory>
#include <list>

message.hpp 的引用(Include)关系图:

此图展示该文件直接或间接的被哪些文件引用了:

浏览源代码.

类
class	XuMQ::MessageMapper
	处理消息队列的文件存储和管理类更多...

class	XuMQ::QueueMessage
	推送消息队列管理更多...

class	XuMQ::MessageManager
	消息管理类更多...

命名空间
namespace	XuMQ

变量
const char *	XuMQ::DATAFILE_SUBFIX = ".mqd"
	数据文件后缀名

const char *	XuMQ::TMPFILE_SUBFIX = ".mqd.tmp"
	临时文件后缀名

const char *	XuMQ::MSG_VALID = "1"
	消息有效标志

const char *	XuMQ::MSG_INVALID = "0"
	消息无效标志

详细描述

消息队列文件存储的实现

该文件定义了 XuMQ 命名空间中的 MessageMapper 类，用于处理消息队列的文件管理。它提供了消息的插入、删除、垃圾回收等功能，并管理与消息队列相关的数据文件。

主要功能包括：

创建、移除消息文件
插入、删除消息
对无效消息进行垃圾回收

使用文件存储消息队列数据，通过指定的目录和文件名进行管理。

类

命名空间

变量

详细描述