失效链接处理 |
RocketMQ使用指南 PDF 下载
本站整理下载:
提取码:phi0
相关截图:
主要内容:
核心概念
消息队列 RocketMQ 版是阿里云基于 Apache RocketMQ 构建的低延迟、高
并发、高可用、高可靠的分布式消息中间件。消息队列 RocketMQ 版既可为分布式
应用系统提供异步解耦和削峰填谷的能力,同时也具备互联网应用所需的海量消息堆
积、高吞吐、可靠重试等特性。
产品功能与特性
消息队列 RocketMQ 版在阿里云多个地域(Region)提供了高可用消息云服务。
单个地域内采用多机房部署,可用性极高,即使整个机房都不可用,仍然可以为应用
提供消息发布服务。
消息队列 RocketMQ 版提供 TCP 和 HTTP 协议的多语言接入方式,方便不
同编程语言开发的应用快速接入消息队列 RocketMQ 版消息云服务。您可以将应
用部署在阿里云 ECS、企业自建云,或者嵌入到移动端、物联网设备中与消息队列
RocketMQ 版建立连接进行消息收发;同时,本地开发者也可以通过公网接入消息队
列 RocketMQ 版服务进行消息收发。
什么是消息队列 RocketMQ < 5
系统部署架构
系统部署架构如下图所示。
图中所涉及到的概念如下所述:
6 > 什么是消息队列 RocketMQ
● Name Server:是一个几乎无状态节点,可集群部署,在消息队列 RocketMQ 版中提供命名服务,更新和发现 Broker 服务。
● Broker:消息中转角色,负责存储消息,转发消息。分为 Master Broker 和
Slave Broker,一个 Master Broker 可以对应多个 Slave Broker,但是一个
Slave Broker 只能对应一个 Master Broker。Broker 启动后需要完成一次将
自己注册至 Name Server 的操作;随后每隔 30s 定期向 Name Server 上报
Topic 路由信息。
● 生产者:与 Name Server 集群中的其中一个节点(随机)建立长链接(Keepalive),定期从 Name Server 读取 Topic 路由信息,并向提供 Topic 服务的
Master Broker 建立长链接,且定时向 Master Broker 发送心跳。
● 消费者:与 Name Server 集群中的其中一个节点(随机)建立长连接,定期从
Name Server 拉取 Topic 路由信息,并向提供 Topic 服务的 Master Broker、
Slave Broker 建立长连接,且定时向 Master Broker、Slave Broker 发送心
跳。Consumer 既可以从 Master Broker 订阅消息,也可以从 Slave Broker
订阅消息,订阅规则由 Broker 配置决定。
应用场景
削峰填谷
流量削峰也是消息队列 RocketMQ 版的常用场景,一般在秒杀或团队抢购活动
中使用广泛。
在秒杀或团队抢购活动中,由于用户请求量较大,导致流量暴增,秒杀的应用在
处理如此大量的访问流量后,下游的通知系统无法承载海量的调用量,甚至会导致系
统崩溃等问题而发生漏通知的情况。为解决这些问题,可在应用和下游通知系统之间
加入消息队列 RocketMQ 版。
|