RocketMQ存储中如何实现日志文件创建与映射

1524990177 • 08/17 18:11 • Linux技术 • 阅读 96

这篇文章将为大家详细讲解有关RocketMQ存储中如何实现日志文件创建与映射，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。日志目录(可配置)/data/rocketmq/store/commitlog会有20位长度的日志文件。
1.日志文件什么时候创建的？
2.日志文件创建流程是什么？
3.日志文件和内存映射是怎么样的？在Broker启动时实例化了两个类DefaultMessageStore和AllocateMappedFileService。
AllocateMappedFileService是线程类继承了Runnable接口，该线程类持有DefaultMessageStore的引用（即：可操作管理DefaultMessageStore），并启动该线程类。
调用链既然在Broker启动时该线程类AllocateMappedFileService就启动了，那么在做什么呢？run方法为while循环，即：只要服务不停止并且mmapOperation()返回true则一直运行。mmapOperation方法流程图
小结：mmapOperation方法主要做了两件事：初始化MappedFile和预热MappedFile。只要服务不停止和线程不被中断，这个过程一直重复运行。
4.提交映射文件请求（AllocateRequest）既然AllocateMappedFileService一直从容器（优先级队列和ConcurrentHashMap）中获取AllocateRequest。AllocateRequest是什么时候产生并放到容器中的呢？
RocketMQ消息存储概览【源码笔记】中写入commitLog流程，获取最新的日志文香港云主机件。
调用链流程图小结：MappedFileQueue#getLastMappedFile会向线程类AllocateMappedFileServic提交两个映射文件创建请求：分别为nextFilePath和nextNextFilePath；如果线程类AllocateMappedFileServic为null，则直接new一个MappedFile，此时只会创建一个文件。下面为提交两个映射文件请求流程，即：AllocateMappedFileServic#putRequestAndReturnMappedFile
调用链
流程图
小结：处理提交的映射文件请求指的是:
实例化两个AllocateRequest并把他们提交到requestTable(ConcurrentHashMap)
和requestQueue(PriorityBlockingQueue)中，等待5秒，此段时间线程会从这两个容器中获取请求并创建MappedFile，并将结果返回。5.MappedFile初始化本段梳理下上文中mmapOperation方法流程图第5步初始化MappedFile的流程
调用链流程图
MappedFile主要干了两件事：1.创建日志文件。2.并将文件映射到内存中。
关于“RocketMQ存储中如何实现日志文件创建与映射”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。

相关推荐: shell中管道 | 、xargs和exec怎么用

这篇文章将为大家详细讲解有关shell中管道 | 、xargs和exec怎么用，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。命令行参数：getopt()函数用于解析命令行参数标准输入：scanf()/gets()等函数用于获…