RocketMq 消息（Message）

比眉伴天荒 2024-02-17 11:05 58阅读 0赞

RocketMq是阿里出品（基于MetaQ）的开源中间件，已捐赠给Apache基金会并成为Apache的顶级项目。基于[java语言][java]实现，十万级数据[吞吐量][Link 1]，ms级处理速度，分布式架构，功能强大，扩展性强。

[官网][Link 2]

[Linux 安装 RocketMq-CSDN博客][Linux _ RocketMq-CSDN]

[Springboot 集成 RocketMq（入门）-CSDN博客][Springboot _ RocketMq_-CSDN]

## 1. 定义 ##

消息是 RocketMQ 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到服务端，服务端按照相关语义将消息投递到消费端进行消费。

消息模型具备如下特点：

> **消息不可变性**
> 
> 消息本质上是已经产生并确定的事件，一旦产生后，消息的内容不会发生改变。即使经过传输链路的控制也不会发生变化，消费端获取的消息都是只读消息视图。
> 
> **消息持久化**
> 
> RocketMQ 会默认对消息进行持久化，即将接收到的消息存储到 RocketMQ 服务端的存储文件中，保证消息的可回溯性和系统故障场景下的可恢复性。

##  ##

## 2.模型关系 ##

![24e6c6fa8fe643eeae116ca4b05acf44.png][]

消息由生产者初始化并发送到服务端。

消息按照到达服务端的顺序存储到队列中。

消费者按照指定的订阅关系从服务端中获取消息并消费。

## 3.内部属性 ##

![df3bc1d96f0041c7bb7347683f081c6f.png][]

### 3.1 主题名称 ###

消息所属的主题的名称。集群内全局唯一。【**生产者指定**】

### 3.2 消息类型 ###

消息的类型。【**生产者指定**】

> Normal：普通消息，消息本身无特殊语义，消息之间也没有任何关联。
> 
>   
> FIFO：顺序消息，RocketMQ 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格按照消息发送时的顺序。
> 
>   
> Delay：定时/延时消息，通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后才对消费者可见。
> 
>   
> Transaction：事务消息，RocketMQ 支持分布式事务消息，支持应用数据库更新和消息调用的事务一致性保障。

### 3.3 消息队列 ###

存储当前消息的队列。【**服务端填充**】

### 3.4 消息位点 ###

消息存储在队列中的位置。【**服务端填充**】

### 3.5 消息ID ###

消息的唯一标识，集群内每条消息的ID全局唯一。【**生产者指定**】

### 3.6 索引Key列表（可选） ###

消息的索引键，可通过设置不同的Key区分消息和快速查找消息。【**生产者指定**】

### 3.7 过滤标签Tag（可选） ###

消息的过滤标签。消费者可通过Tag对消息进行过滤，仅接收指定标签的消息。【**生产者指定，一条消息仅支持设置一个标签**】

### 3.8 定时时间（可选） ###

定时场景下，消息触发延时投递的毫秒级时间戳。【**生产者指定，最大可设置定时时长为40天**】

### 3.9 消息发送时间 ###

消息发送时，生产者客户端系统的本地毫秒级时间戳。【**生产者指定**】

### 3.10 消息保存时间戳 ###

消息在服务端完成存储时，服务端系统的本地毫秒级时间戳。 对于定时消息和事务消息，消息保存时间指的是消息生效对消费方可见的服务端系统时间。【**服务端填充**】

### 3.11 消费重试次数 ###

消息消费失败后，服务端重新投递的次数。每次重试后，重试次数加1。【**服务端标记**】

### 3.12 业务自定义属性 ###

生产者自定义设置的扩展信息。【**生产者指定**】

### 3.13 消息负载 ###

业务消息的实际报文数据。【**生产者指定**】

## 4.消息大小约束 ##

消息大小不得超过其类型所对应的限制，否则消息会发送失败。

默认的消息最大限制如下：

> 普通消息和顺序消息：4 MB
> 
> 事务消息和定时或延时消息：64 KB

##  ##

## 5.使用建议 ##

### 5.1 消息负载大小限制 ###

消息过大容易造成网络传输层压力，不利于异常重试和流量控制。  
如果需要传输超大负载，建议按照固定大小做报文拆分，或者结合文件存储等方法进行传输。

### 5.2 消息不可变设计 ###

RocketMQ 服务端5.x版本中，消息本身不可编辑，消费端获取的消息都是只读消息视图。但在历史版本3.x和4.x版本中消息不可变性没有强约束，因此如果您需要在使用过程中对消息进行中转操作，务必将消息重新初始化。

[java]: https://so.csdn.net/so/search?q=java%E8%AF%AD%E8%A8%80&spm=1001.2101.3001.7020
[Link 1]: https://so.csdn.net/so/search?q=%E5%90%9E%E5%90%90%E9%87%8F&spm=1001.2101.3001.7020
[Link 2]: https://rocketmq.apache.org/zh/docs/
[Linux _ RocketMq-CSDN]: https://blog.csdn.net/qq_34253002/article/details/125119483
[Springboot _ RocketMq_-CSDN]: https://blog.csdn.net/qq_34253002/article/details/134201558
[24e6c6fa8fe643eeae116ca4b05acf44.png]: https://img-blog.csdnimg.cn/24e6c6fa8fe643eeae116ca4b05acf44.png
[df3bc1d96f0041c7bb7347683f081c6f.png]: https://img-blog.csdnimg.cn/df3bc1d96f0041c7bb7347683f081c6f.png