RocketMQ 消息队列 架构与 特性

消息队列RocketMQ

• RocketMQ体系架构
• Rocketmq特性
• （此处为新增行）
• 生产者模块
  顺序 msg

• 消息延迟处理

• 批处理机制

• 条件筛选

• 事务处理

  • Consumer端
  • • 消费模型
    • 消费点位
    • 消息重复幂等

RocketMQ 架构

RocketMQ分为四个角色：任何一项都可以实现横向扩展，并且不会存在单一故障点。

NameServer Cluster 注册中心负责实现服务发现与路由查询功能。每个NameServer都完整地包含其对应的Broker Cluster相关信息，并且由于NameServer本身没有存储状态信息

Broker Cluster：信息路由角色，在处理信息存储与传递方面发挥着关键作用。
Broker定期向NameServer发送心跳信息，并完成注册操作

Consumer Cluster 无状态的

Pull consumers typically obtain data from bro