简介
RocketMQ是一款分布式,队列模型的消息中间件,具有以下特点:
- 能够保证严格的消息顺序
- 提供丰富的消息拉取模式
- 高效的订阅者水平扩展能力
- 实时的消息订阅机制
- 亿级消息堆积能力
选用理由:
- 强调集群无单点,可扩展,任意一点高可用,水平可扩展
- 海量消息堆积能力,消息堆积后,写入低延迟。
- 支持上万个队列
- 消息失败重试机制
- 消息可查询
- 开源社区活跃
- 成熟度(经过双十一考验)
关键概念
主题与标签
主题Topic:第一级消息类型
标签Tags:第二级消息类型,可以基于Tag做消息过滤
例如
主题:
- 订单交易
标签:
- 订单交易-创建
- 订单交易-付款
- 订单交易-完成
发送与订阅群组
生产组:用于消息的发送
消费组:用于消息的订阅处理
生产组和消费组,方便扩缩机器,增减处理能力,集群组的名字,用于标记用途中的一员。每次只会随机的发给每个集群中的一员