名词

Topic：消息主题，一级消息类型，通过 Topic 对消息进行分类。详情请见Topic 与 Tag 最佳实践。
Tag：消息标签，二级消息类型，用来进一步区分某个 Topic 下的消息分类。详情请见Topic 与 Tag 最佳实践。
Message：消息，消息队列中信息传递的载体。
Message ID：消息的全局唯一标识，由消息队列 RocketMQ 系统自动生成，唯一标识某条消息。
Message Key：消息的业务标识，由消息生产者（Producer）设置，唯一标识某个业务逻辑。
Group：一类 Producer 或 Consumer，这类 Producer 或 Consumer 通常生产或消费同一类消息，且消息发布或订阅的逻辑一致。

一个完整的消息过程

发送 -- 存储 -- 消费

Provider 通过NameServer获取到Broker信息和路由信息，和一个Broker建立长连接
Provider 根据设定的Topic，轮询的在Topic的Queue下发送消息
默认同步消息，如果发送失败会重试2次或者超时，如果发送成功，会返回一个sendStatus为SEND_OK
Broker把消息持久化的保存下来，并且对Consumer可见
Consumer会定时的从Consumer Queue里面拉取消息到本地的线程池
消息成功的被消费之后，会response给Broker，消费成功，MQ会标记已经被成功消费过的消息，保证不会被重复消费

特点

灵活可扩展性:RocketMQ 天然支持集群，其核心四组件（Name Server、Broker、Producer、Consumer）每一个都可以在没有单点故障的情况下进行水平扩展。
海量消息堆积能力:RocketMQ 采用零拷贝原理实现超大的消息的堆积能力，据说单机已可以支持亿级消息堆积，而且在堆积了这么多消息后依然保持写入低延迟。
支持顺序消息:可以保证消息消费者按照消息发送的顺序对消息进行消费。顺序消息分为全局有序和局部有序，一般推荐使用局部有序，即生产者通过将某一类消息按顺序发送至同一个队列来实现。
多种消息过滤方式:消息过滤分为在服务器端过滤和在消费端过滤。服务器端过滤时可以按照消息消费者的要求做过滤，优点是减少不必要消息传输，缺点是增加了消息服务器的负担，实现相对复杂。消费端过滤则完全由具体应用自定义实现，这种方式更加灵活，缺点是很多无用的消息会传输给消息消费者。
支持事务消息:RocketMQ 除了支持普通消息，顺序消息之外还支持事务消息，这个特性对于分布式事务来说提供了又一种解决思路。
回溯消费：回溯消费是指消费者已经消费成功的消息，由于业务上需求需要重新消费，RocketMQ 支持按照时间回溯消费，时间维度精确到毫秒，可以向前回溯，也可以向后回溯。

消息的类型

http://rocketmq.apache.org/docs/simple-example/

按照发送的特点分：

同步消息
异步消息
单向消息

按照使用功能特点分：

普通消息（）
顺序消息
广播消息
延时消息
批量消息
事务消息

按照Broker和Consumer的关系：

订阅模式
广播模式

支持的功能

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
Docker images for isolated testing and cloud isolated clusters
Feature-rich administrative dashboard for configuration, metrics and monitoring

默认参数

4.3.0版本的源码

发送消息超时时间默认3s
发送消息失败重试的次数2次，一共就是3次（正常一次，重试2次）
默认QueueNums：4
事务消息MQ的重试次数默认是15次，可以通过设置transactionCheckMax设置

    private int sendMsgTimeout = 3000;
    private int retryTimesWhenSendFailed = 2;
    private int retryTimesWhenSendAsyncFailed = 2;
    private volatile int defaultTopicQueueNums = 4;
    private int compressMsgBodyOverHowmuch = 1024 * 4;
    private int maxMessageSize = 1024 * 1024 * 4; // 4M

消息堆积

https://blog.csdn.net/yinni11/article/details/80531970

消息在MQ里面堆积(官方文档说是具有万亿级别的堆积容量)
Consumer有专门的线程从Broker拉取Message，并且丢到自己的线程池里面做堆积，拉取过程中如果发现消息数据条数超过1000条，或者消息量超过100M，那么我们就暂停消息拉取，延迟50ms后再次发起任务拉取

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