首页 > 其他 > 详细

mq内存映射

时间:2020-01-18 15:34:09      阅读:111      评论:0      收藏:0      [点我收藏+]

MappedFileQueue的封装

MappedFileQueue是MappedFile的管理容器,MappedFileQueue是对存储目录的封装。

技术分享图片

 

查找MappedFile:

1.根据时间戳来查找MappedFile:

技术分享图片

 

2.根据消息偏移量offset查找MappedFile

 

 

技术分享图片

 

mq采用定时删除策略,不定时的将已消费的消息从存储文件中删除,会造成极大的内存压力与资源浪费,也就是说在存储文件中,第一个文件不一定是0000...因为该文件在某一时刻会被删除。

参考下面3个方法理解:

 

技术分享图片

 

 

 

技术分享图片

 技术分享图片

 内存映射文件MappedFile

 

 

 

技术分享图片

 

wirteBuffer:堆内存ByteBuffer,如果不为空,数据首先将存储在该Buffer中,然后提交到MappedFile对应的内存映射文件Buffer。transientStorePoolEnable为true时不为空

transientStorePool:堆内存池,transientStorePoolEnable为true时启用。

fileFromOffset:该文件的初始偏移量

mappedByteBuffer:物理文件对应的内存映射Buffer。

MappedFile初始化:

1.transientStorePoolEnable为true表示内容先存储在堆外内存,然后通过commit线程将数据提交到内存映射Buffer中,再通过Flush线程将内存映射Buffer中的数据持久化到磁盘。

技术分享图片

 

 

技术分享图片

 

 

 

技术分享图片

 

 

 

技术分享图片

 

 

 

技术分享图片

 

 

刷盘:

是不是少了FileChannel怎么到内存映射Buffer的???

 

 

技术分享图片

mq内存映射

原文:https://www.cnblogs.com/lccsblog/p/12209043.html

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