rocketmq 概览

发表于 | 更新于 | 分类于 | 阅读次数：

消息队列

FIFO

异步解耦、流量削峰、消息分发

  • 异步解耦

    • 对分布式应用进行异步解耦，增加应用的水平扩展能力。
    • 基于 生产者、消费者 模式

  • 削峰填谷

    • 大促等流量洪流突然来袭时，MQ 可以缓冲突发流量，避免下游订阅系统因突发流量崩溃。
    • 基于 队列 缓冲

  • 消息分发

    • 一对多，多对多 消息分发
    • 基于 发布/订阅 模型

rocketmq 发展历程

2010年，Alibaba 开始大规模使用 ActiveMQ 作为消息内核。

随着阿里业务的快速发展，急需一款支持顺序消息，拥有海量消息堆积能力的消息中间件， MetaQ 1.0 在 2011 年诞生。

2012年，MetaQ已经发展到了3.0版本，并抽象出了通用的消息引擎 RocketMQ。
随后，对 RocketMQ 进行了开源，阿里的消息中间件正式走人了公众视野。

2016年，RocketMQ 进入 Apache 孵化(精细设计、代码 Review、编码规约、分支模型、发布规约)。

最新版本是 4.3.1。
4.0 是过渡版本，和 3.0 相比，架构层面没有较大的改变。

Why RocketMQ?

主流的MQ有很多，比如 ActiveMQ、RabbitMQ、Kafka、ZeroMQ

Why RocketMQ?

RocketMQ 是使用 Java 语言开发的，
比起 Kafka 的 Scala语言 和 RabbitMQ 的 Erlang 语言，更容易找到技术人员进行定制开发。

Architecture & FAQ

Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability.

It offers a variety of features:

  • Pub/Sub messaging model
  • Scheduled message delivery
  • Message retroactivity by time or offset
  • Log hub for streaming
  • Big data integration
  • Reliable FIFO and strict ordered messaging in the same queue
  • Efficient pull&push consumption model
  • Million-level message accumulation capacity in a single queue
  • Multiple messaging protocols like JMS and OpenMessaging
  • Flexible distributed scale-out deployment architecture
  • Lightning-fast batch message exchange system
  • Various message filter mechanics such as SQL and Tag
  • Feature-rich administrative dashboard for configuration, metrics and monitoring

Low Latency
More than 99.6% response latency within 1 millisecond under high pressure.

Finance Oriented
High availability with tracking and auditing features.

Industry Sustainable
Trillion-level message capacity guaranteed.

Vendor Neutral
A new open distributed messaging and streaming standard since latest 4.1 version.

BigData Friendly
Batch transferring with versatile integration for flooding throughput.

Massive Accumulation
Given sufficient disk space, accumulate messages without performance loss.

RocketMQ Architecture

现实生活中的邮政系统，要正常运行，离不开下面四个角色:

  1. 发信者
  2. 收信者
  3. 负责暂存、传输的邮局
  4. 负责协调各个地方邮局的管理机构

对应到 rocketmq 中，这四个角色就是 Producer、Consumer、Broker 和 NameServer。

Core Concept

FAQ

参考

本文参考了互联网上大家的分享，就不一一列举，在此一并谢过。
也希望本文，能对大家有所帮助，若有错误，还请谅解、指正。