RocketMq简介以及名词概念

举报
木字楠 发表于 2022/12/16 09:33:03 2022/12/16
【摘要】 highlight: ascetictheme: condensed-night-purple开启掘金成长之旅!这是我参与「掘金日新计划 · 12 月更文挑战」的第23天,点击查看活动详情 </p🎶 文章简介:RocketMq简介以及名词概念💡 创作目的:简单介绍RocketMq的信息以及名词概念☀️ 今日天气:天气阴沉📝 每日一言:小酌一杯炉火前,白色人间又一年 😺 1...

highlight: ascetic
theme: condensed-night-purple

开启掘金成长之旅!这是我参与「掘金日新计划 · 12 月更文挑战」的第23天,点击查看活动详情

木字楠-header.gif </p

🎶 文章简介:RocketMq简介以及名词概念

💡 创作目的:简单介绍RocketMq的信息以及名词概念

☀️ 今日天气:天气阴沉

📝 每日一言:小酌一杯炉火前,白色人间又一年


😺 1、RocketMq介绍

RocketMq作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。

😸 1.1、RocketMq的特点

  • 支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型。

  • 在一个队列中可靠的先进先出(FIFO)和严格的顺序传递。(RocketMq可以严格的保证消息的顺序)

  • 支持推(Push) 和 拉(pull)两种消息模式。

    • 拉(pull)就是消费者拉去MQ中拉取消息,而push是MQ给消费者推送消息。
      
  • 单一队列百万消息的堆积能力(RocketMq提供亿级消息的堆积能力,而重点是在亿级消息堆积之后,依然保持写入低延迟)

  • 支持多种消息队列,如JMS、MQTT等等…

  • 分布式高可用架构,满足至少一次消息传递语句。

  • 提供Docker镜像用于隔离测试和云集群部署。

  • 提供配制、指标和监控等丰富的控制。

😹 1.2、RocketMq的优势所在

目前主流的 MQ 主要是 RocketMQ、ActiveMq、kafka、RabbitMQ,其主要优势有:

  • 支持事务型消息(消息发送和 DB 操作保持两方的最终一致性,RabbitMQ 和 Kafka 不支持)
  • 支持结合 RocketMQ 的多个系统之间数据最终一致性(多方事务,二方事务是前提)
  • 支持 18 个级别的延迟消息(Kafka 不支持)
  • 支持指定次数和时间间隔的失败消息重发(Kafka 不支持,RabbitMQ 需要手动确认)
  • 支持 Consumer 端 Tag 过滤,减少不必要的网络传输(即过滤由MQ完成,而不是由消费者完成。RabbitMQ 和 Kafka 不支持)
  • 支持重复消费(RabbitMQ 不支持,Kafka 支持)

😼 2、Rocket名词概念

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

image-20220620161432043

😽 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、Group 分组

  • 生产者分组:标识同一类的消息的发送,生产者中的消息分组一般作用于事务消息。

  • 消费者分组:是对一类消息的消费,消费的逻辑大致上是一致的。

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

😾 2.3、Message Queue消息队列

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

image-20220620164047772

😿 2.4、Offset 偏移量

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

🙀 2.5、Tag 标签

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


【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。