RocketMq名词概念

简介: RocketMq名词概念

还有一些名词概念如:主题(Topic),分组(Group),消息队列(Message Queue),偏移量(Offset),标签(Tag)

image-20220620161432043

2.2.1、Topic 主题

我们可以通过topic区标识一类消息,可以将消息分为不同主题。例如Topic A、Tocpic B等。在实际应用中可能会分为家电、衣物、视频等不同主题进行区分。

我们的Topic一般来说会挂载多个queue队列,这样在某种程度上可以提高我们消息队列的并发度。

读/写队列问题:

从物理上来讲,读写队列是同一个队列。

例如:创建Topic时,创建的写队列数量为8,而读队列的数量为4。此时系统会创建8个Queue,分别是0,1,2,3,4,5,6,7。Producer会将消息写入到这8个队列,但Consumer只会消费0,1,2,3这四个队列中的消息,而4,5,6,7中的消息是不会被消费到的。

例如:创建Topic时,创建的写队列数量为4,而读队列的数量为8。此时系统会创建8个Queue,分别是0,1,2,3,4,5,6,7。Producer会将消息写入到这0,1,2,3 这几个队列,但Consumer只会消费0,1,2,3,4,5,6,7中的消息是进行消费,但是4,5,6,7中是没有消息可以消费的。

这两种设计方式都是有问题的,但是这样设计的好处是什么呢?

其实这样设计的目的是为了方便Topic的queue缩容。

Perm: 用于设置当前创建的Topic的操作权限:2表示只读,4表示只写,6表示读写

2.2.2、Group 分组

  • 生产者分组:标识同一类的消息的发送,生产者中的消息分组一般作用于事务消息。
  • 消费者分组:是对一类消息的消费,消费的逻辑大致上是一致的。

    • eg:
      消费者分组:             物流组                                  通知组
                       物流的业务逻辑进行消费                    消息通知的业务逻辑进行消费

2.2.3、Message Queue 消息队列

Message Queue 即是 主题被划分为一个或多个子主题,而一条消息必须有一个主题(Topic),主题可以看做你要邮寄的地址,一条消息也可以拥有一个可选的Tag标签和额外的键值对。我们的生产者发布消息之后,会被Topic会分发到队列之中,而我们的消费者组就是区订阅消费指定的队列中的消息。

image-20220620164047772

2.2.4、Offset 偏移量

一般来说是指MessageQueue中的偏移量,没有特别指出的话就是指我们消费者消费的数量。

2.2.5、Tag 标签

Tag标签相当于是子主题,他是消息的第二级别类型,用于为用户提供额外的灵活性。如果Topic比作是衣服,那么Tag就可以看做是风衣、短袖、短裤等等...

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
2月前
|
消息中间件 存储 JSON
从兔子说起:深入理解RabbitMQ基础概念【RabbitMQ 一】
从兔子说起:深入理解RabbitMQ基础概念【RabbitMQ 一】
32 0
|
4月前
|
消息中间件 缓存 运维
java消息队列基础和RabbitMQ相关概念(二)
java消息队列基础和RabbitMQ相关概念
53 0
|
4月前
|
消息中间件 存储 Java
java消息队列基础和RabbitMQ相关概念(一)
java消息队列基础和RabbitMQ相关概念
46 0
|
4月前
|
消息中间件 存储 负载均衡
RocketMQ基本概念
RocketMQ基本概念
37 0
|
5月前
|
消息中间件 存储 Kafka
三分钟白话RocketMQ系列—— 核心概念
三分钟白话RocketMQ系列—— 核心概念
|
6月前
|
消息中间件 存储 Kafka
3分钟白话RocketMQ系列—— 核心概念
3分钟白话RocketMQ系列—— 核心概念
105 1
|
7月前
|
消息中间件 存储 监控
RocketMQ 的基本概念、架构设计、特点以及适用场景
RocketMQ 的基本概念、架构设计、特点以及适用场景
487 0
RocketMQ 的基本概念、架构设计、特点以及适用场景
|
8月前
|
消息中间件 存储 网络协议
RabbitMQ基础概念
RabbitMQ基础概念
55 0
|
8月前
|
消息中间件 存储 Kafka
RocketMQ基本概念及功能
RocketMQ是阿里巴巴在2012年开发的分布式消息中间件,专为万亿级超大规模的消息处理而设计,具有高吞吐量、低延迟、海量堆积、顺序收发等特点。
180 0
|
8月前
|
消息中间件 RocketMQ
RocketMQ核心概念
RocketMQ核心概念
54 0