网站首页 站内搜索

搜索结果

查询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 人评论 次浏览
扫一扫关注最新编程教程