rokectmq

主要功能

  • 异步解藕
  • 流量削峰
  • 数据分发

应用角色

  • Nameserver
  • Broker
  • Product
  • Consumer

角色

  • 分组
  • 主题
  • 消息队列
  • 偏移量
  • tag

消息发送和接收/消费模式

  • 点对点/广播/批量
  • 同步/异步

消息分类

顺序/延时

消息存储

commitlog(元数据1G)、consumerqueue(逻辑 )、index(messagkey)、config(topic\groop等配置)

文件删除

过期删除 非当前写文件默认42小时
过期判断 最后一次更新到现在
删除时间点 4点、磁盘使用率

rocketmq零拷贝MMP

内存映射

rocketmq半事物

两阶段提交

生产队列选择/消费队列选择策略

  • 默认选择队列+轮训+规避 生产者超过重试选规避/故障延时策略 超过重试次数 规避一段时间
  • consumer默认平均/改为queue轮训

集群高可用

  • 多master 消息分散到2个master
    主挂不可写可以在从节点消费
    同步复制/同步刷盘
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容