热门标签
更多>
搜索结果
查询Tags标签: commitlog,共有 3条记录-
rocketMq和kafka消息推拉模式
https://segmentfault.com/a/1190000023854950 rocketMq的推模式,默认每5s检查是否有新消息,另外在处理commitLog消息分发到Message Queue的时候,会唤醒消息请求处理操作,所以对于消息的响应是比较及时的。
2022/2/25 23:22:27 人评论 次浏览 -
RocketMQ源码分析(三)消息存储
1.4 消息存储 1.4.1 消息存储核心类private final MessageStoreConfig messageStoreConfig; //消息配置属性 private final CommitLog commitLog; //CommitLog文件存储的实现类 private final ConcurrentMap<String/* topic */, ConcurrentMap<Integer/* queueId *…
2021/5/25 1:25:00 人评论 次浏览 -
RocketMQ入门到入土(五)消息持久化存储源码解析
精彩推荐一百期Java面试题汇总SpringBoot内容聚合IntelliJ IDEA内容聚合Mybatis内容聚合 接上一篇:RocketMQ入门到入土(四)producer生产消息源码剖析 一、原理 1、消息存在哪了? 消息持久化的地方其实是磁盘上,在如下目录里的commitlog文件夹里。 /root/store/commi…
2021/5/4 22:55:16 人评论 次浏览