一种基于文件系统的消息中间件持久消息的存储方法

摘要

本发明是一种基于文件系统的消息中间件持久消息的存储方法，包括如下步骤：第一步：以消息为参数创建AddMessageCommand；第二步：把AddMessageCommand对象序列化为字节流；第三步：将字节流写入日志文件，如果设置为异步模式，则将多个写入操作合并，将每个写入操作需写入的字节流合并，一次性写入到日志文件中；第四步：更新内存中的索引页，将消息标识符和消息对应于日志文件中的位置插入到索引树中的节点；第五步：写回索引文件。本发明提供了一种在保证消息存储的可靠性的同时，还提高了持久消息的读写性能的基于文件系统的消息中间件持久消息的存储方法。

主权项

一种基于文件系统的消息中间件持久消息的存储方法，其特征在于包括如下步骤：第一步：以消息为参数创建AddMessageCommand，即将AddMessageCommand的message字段设为需要存储的消息；将RemoveMessageCommand中的messageId设为需要从存储中删除的消息标识符；第二步：把AddMessageCommand对象序列化为字节流；第三步：将字节流写入日志文件，如果设置为异步模式，则将多个写入操作合并，将每个写入操作需写入的字节流合并，一次性写入到日志文件中；第四步：更新内存中的索引页，将消息标识符和消息对应于日志文件中的位置插入到索引树中的节点；第五步：写回索引文件，将更新的索引树节点所对应的文件页以双写的方式写回到索引文件。