首页 > 其他 > 详细

DefaultMessageStore-CommitLog-MapedFileQueue.allocateMapedFileService初始化链

时间:2017-05-14 09:54:35      阅读:466      评论:0      收藏:0      [点我收藏+]

刚刚在研究rocketmq生成文件的源码。零时记录一下MapedFileQueue中属性AllocateMapedFileService allocateMapedFileService的初始化链。

首先这个服务实在DefaultMessageStore中初始化完成并启动的,然后DefaultMessageStore把AllocateMapedFileService对象传给了CommitLog(绿色箭头)

技术分享

然后CommitLog初始化MapedFileQueue的时候又穿给了它。

技术分享

最终MapedFileQueue有了两种创建文件的方式,一种就是这个服务线程:AllocateMapedFileService

技术分享

 

使用起来也很方便:

技术分享

 

只要调用它的这个方法就可以了:

allocateMapedFileService.putRequestAndReturnMapedFile(nextFilePath,
                                nextNextFilePath, this.mapedFileSize);

这个方法会把这三个参数分装,然后放入它的优先级队列中PriorityBlockingQueue,这个服务线程就会不断的从这个优先级队列中拿需要创建文件的参数来创建文件来。

 

DefaultMessageStore-CommitLog-MapedFileQueue.allocateMapedFileService初始化链

原文:http://www.cnblogs.com/guazi/p/6850988.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!