当前位置: 首页 > news >正文

RocketMQ 初步了解

RocketMQ 初步了解

前言:

​  近期,因公司使用 RocketMQ 作为消息队列中间件,特此了解。
 RocketMQ 是阿里巴巴在 2012 年开发的分布式消息中间件,专为万亿级超大规模的消息处理而设计,具有高吞吐量、低延迟、海量堆积、顺序收发等特点。



1、基本组成

在这里插入图片描述

  • 主题(Topic)
    • 消息传输和存储的顶层容器(逻辑概念)
    • 含一个或多个队列
  • 队列(MessageQueue)
    • 消息存储和传输的实际容器’
  • 消息(Message)
    • 类型:
      • Normal:普通消息
      • FIFO:顺序消息
      • Delay:定时/延时消息
      • Transaction:事务消息
  • 生产者(Producer)
    • 构建并传输消息到服务端的运行实体
    • 传输行为:
      • 发送方式(同步传输/异步传输)
      • 批量发送
      • 事务行为
  • 消费者(Consumer)
    • 接收并处理消息的运行实体
    • 传输行为:
      • 消费者身份:消费者必须关联一个指定的消费者分组
      • 消费者类型:
        • 消费者身份:消费者必须关联一个指定的消费者分组
        • 消费者类型:
          • PushConsumer
          • SimpleConsumer
          • PullConsumer
        • 消费者本地运行配置
          • 消费者根据不同的消费者类型,控制消费者客户端本地的运行配置
  • 消费者分组(ConsumerGroup)
    • 承载多个消费行为一致的消费者的负载均衡分组(逻辑概念)
    • 消费行为:
      • 订阅关系
      • 投递顺序性
      • 消费重试策略
  • 订阅关系(Subscription)
    • 消费者获取消息、处理消息的规则和状态配置
      • 消费过滤规则:过滤消费者需要的消息集合
      • 消费状态:消费者分组在服务端注册订阅关系后,当消费者离线并再次上线后,可以获取离线前的消费进度并继续消费


2、功能特性

2.1、消息发送重试和流控机制

2.1.1、消息重发

触发条件:

  1. 客户端消息发送请求调用失败或请求超时;
  2. 网络异常造成连接失败或请求超时;
  3. 服务端节点处于重启或下线等状态造成连接失败;
  4. 服务端运行慢造成请求超时;
  5. 服务端返回失败错误码。
    1. 系统逻辑错误:因运行逻辑不正确造成的错误;
    2. 系统流控错误:因容量超限造成的流控错误。

2.1.2、流控机制

​  流控机制:指当系统容量或水位过高,MQ 服务端会通过快速失败返回流控错误来避免底层资源承受过高压力

触发条件:

  1. 存储压力大;
  2. 服务端请求任务排队溢出。

2.2、消息过滤

​  消息过滤:指将符合条件的消息投递给消费者,而不是将匹配到的消息过滤掉。


注:

  1. 消费者订阅了某个主题后,MQ 会将该主题中的所有消息投递给消费者。
  2. 消息过滤功能通过生产者和消费者对消息的属性、标签进行定义。

分类:

  • Tag标签过滤
    • 单Tag匹配:过滤表达式为目标Tag,表示只有消息标签为指定目标Tag的消息符合匹配条件,才会被发送给消费者。
    • 多Tag匹配:多个Tag之间为或的关系,(不同Tag间使用 || 隔开,如,Tag1||Tag2||Tag3),表示标签Tag1或Tag2或Tag3的消息都满足匹配条件,都会被发送给消费者进行消费。
    • 全部匹配:使用星号(*)作为全匹配表达式,表示主题下的所有消息都将被发送给消费者进行消费。
  • SQL属性过滤(SQL92语法)
对比项Tag标签过滤SQL属性过滤
过滤目标消息的Tag标签消息的属性,包括自定义属性以及系统属性(Tag是一种系统属性)
过滤能力精准匹配SQL语法匹配
适用场景简单过滤场景、计算逻辑简单轻量复杂过滤场景、计算逻辑较复杂

2.3、负载均衡

​  负载均衡:MQ 通过消费者负载均衡策略,将主题内的消息分配给指定消费者分组中的多个消费者共同分担,进而提高消费并发能力和消费者的水平扩展能力。

模式:

  • 消息粒度负载均衡(PushConsumer、SimpleConsumer 默认使用)
    • 消息随机分配;
    • 基于内部的单条消息确认语义实现(消息被消费时加锁)。

在这里插入图片描述

  • 队列粒度负载均衡(PullConsumer 默认使用)
    • 一个消费者对应一个队列

在这里插入图片描述


2.4、消费进度管理

​  消费进度管理:定义消费者客户端启动后从哪里开始消费,如何标记已消费的消息。

术语:

  • 消息位点(Offset,0 ~ Long.Max):消息在队列中的坐标位置。
  • 最小消息位点(MinOffset):队列中最早一条消息的位点。
  • 最大消息位点(MaxOffset):队列中最新一条消息的位点。
  • 消费位点(ConsumerOffset):消费者消费过的最新一条消息的位点。
  • 消费位点初始值:消费者首次获取消息时,该时刻队列中的最大消息位点。
  • 重置消费位点(功能)
    • 重置到队列中的指定位点;
    • 重置到某一时刻对应的消费位点,匹配位点时,服务端会根据自动匹配到该时刻最接近的消费位点。

在这里插入图片描述


2.5、消息存储和清理机制

  • 消息存储

    • 管理粒度:按存储节点管理消息的存储时长。
    • 判断依据:以存储时间为判断依据。
    • 消息存储与消息是否被消费的状态无关。
  • 消息过期清理机制

    • 消息保存时长并不能完整控制消息的实际保存时间,因为消息存储仍然使用本地磁盘,本地磁盘空间不足时,为保证服务稳定性消息仍然会被强制清理,导致消息的实际保存时长小于设置的保存时长


以上内容总结于 RocketMQ 官方文档

RocketMQ 官方文档链接 https://rocketmq.apache.org/zh/docs/

相关文章:

RocketMQ 初步了解

RocketMQ 初步了解 前言: ​  近期,因公司使用 RocketMQ 作为消息队列中间件,特此了解。  RocketMQ 是阿里巴巴在 2012 年开发的分布式消息中间件,专为万亿级超大规模的消息处理而设计,具有高吞吐量、低延迟、海量…...

Mac下PyCharm快捷键

Mac键盘符号和修饰键说明 ⌘ Command⇧ Shift⌥ Option⌃ Control↩︎ Return/Enter⌫ Delete⌦ 向前删除键(FnDelete)↑ 上箭头↓ 下箭头← 左箭头→ 右箭头⇞ Page Up(Fn↑)⇟ Page Down(Fn↓)Home Fn …...

城市管网监测系统,保障城市血管生命线!

各种不同的管网线路组成了城市的供血管道,管网对于维持正常的社会生活、生产秩序和公共安全至关重要。我国城市平均漏损率达到38%,部分城市甚至超过50%,远超发达国家的平均水平(10%)。对于管道状态的监测,是…...

Web3中文|1月数据显示复苏迹象,涉及NFT、DeFi、Dapp、链游……

本期看点 1、Dapp行业概述 2、DeFi的TVL增长26.8%,有回暖迹象 3、NFT市场数据飙升,交易额达9.46亿美元 4、链游使用量占行业48% 5、与去年相比,1月份区块链漏洞损失最低 区块链领域正在多元化发展,2023年1月,从各…...

MySQL索引的介绍以及优缺点

1.索引简介 索引是一种用于快速查询和检索数据的数据结构,其本质可以看成是一种排序好的数据结构。 使用索引可以快速找出在某个或多个列中有一特定值的行,所有MySQL列类型都可以被索引,对相关列使用索引是提高查询操作速度的最佳途径。 索…...

Java_小项目书城

1.概述 书城的基本功能: 展示书籍上新书籍下架书籍退出应用 书城项目所涉及到的知识点: 用户交互–键盘录入分支结构,循环结构面向对象的思维,封装对象集合的使用 2.菜单的编写 这部分代码就是读取用户键盘的录入&#xff0…...

Unreal Engine08:Pawn的实现

写在前面 Pawn继承于Actor,增加了一些用于控制和提供玩家视角的功能,这里主要是介绍一下Pawn类的实现。 一、创建一个Pawn的C类 创建的C类也是放在Source文件夹中的Public和Private文件夹中;选择Pawn作为继承的父类;头文件中除…...

408强化(二)线性表纯享版

目录 一、顺序表(数组)和链表总览 二、考情分析 2.1 从历年考情可以看出,如果一个方法出现了第2次,一般是以下情况: 2.2 没有考过的地方 三、 共同操作或考法 3.1 多指针后移 3.2 逆置 3.3 空间换时间的操作 3.…...

ubuntu下如何使用wireshark抓包,保姆级教程

Wireshark(前称Ethereal)是一个网络封包分析软件。网络封包分析软件的功能是截取网络封包,并尽可能显示出最为详细的网络封包资料。Wireshark使用WinPCAP作为接口,直接与网卡进行数据报文交换。 一、安装wireshark 打开终端&…...

世界上最健康的程序员作息表!「值得一看」

昨晚看了一篇“传说中”的“世界上最健康的作息时间表”,开始纠结自己还要不要5点半起床。 都说程序员这一行,猝死概率极高,究其原因还是加班太狠、作息不规律、缺乏运动… 今天和大家分享一下这篇文章,还是非常值得参考的&#…...

Java中多继承的实现

1 问题Java是一种面向对象的只允许单继承的语言,那么怎样在Java中实现多继承呢?2 方法多层继承如果要直接继承类,子类是不可以直接多继承的,但是可以通过多层继承来实现多继承,但多层继承一般不建议超过三次。接口接口…...

蓝桥杯 stm32 USART 串口发送数据

文章代码使用 HAL 库。 文章目录 前言一、串口原理图二、CubeMX 创建工程。三、串口发送函数:四、串口助手 配置:五、详细代码:注意:连续发送数据六、printf 重定向问题代码示例:实验效果:总结前言 USART : ( Universal Synchronous/Asynchronous Receiver/Transmitter…...

Spring之AOP底层源码解析

Spring之AOP底层源码解析 1、动态代理 代理模式的解释:为其他对象提供一种代理以控制对这个对象的访问,增强一个类中的某个方法,对程序进行扩展。 举个例子 public class UserService {public void test() {System.out.println("test.…...

人脸识别——景联文科技提供3D头模数据采集业务!

“拿起手机刷脸解锁、上下班考勤、支付订单,刷脸已极大地便利了我们的生活。清华大学新闻学院教授沈阳表示,中国人平均每天要暴露在各种摄像头下超过500次。人脸识别已成了我们生活中重要的一部分。由于2D人脸识别容易受到姿态、表情、光照等因素影响&am…...

SpringBoot集成Flink-CDC 采集PostgreSQL变更数据发布到Kafka

最近做的一个项目,使用的是pg数据库,公司没有成熟的DCD组件,为了实现数据变更消息发布的功能,我使用SpringBoot集成Flink-CDC 采集PostgreSQL变更数据发布到Kafka。 一、业务价值 监听数据变化,进行异步通知&#xf…...

酷开系统壁纸模式,将氛围感死死拿捏!

古希腊哲学家柏拉图曾经说过:“美感是起于视觉、听觉产生的快感,以人的感官所能达到的范围为极限。”而电视则恰恰就是视觉听觉的完美融合体,当一台开启的电视可以给我们带来视听享受的时候,一台待机状态下的电视又如何取悦于我们…...

第0章 一些你可能正感到迷惑的问题

操作系统是什么 操作系统是控制管理计算机系统的硬软件,分配调度资源的系统软件。 由操作系统把资源获取到后台给用户进程,但为了保护计算机系统不被损坏,不允许用户进程直接访问硬件资源。 操作系统相当于是一个分配资源的机构,…...

MYSQL实战

SQL的处理 缓存解析查询优化(查询优化器) 重写查询;表的读取顺序;选择索引1.不要在索引上做任何操作 表达式函数 2.尽量全值匹配 联合索引中搜素条件后会根据最优条件排序进行查询,联合索引尽量都使用起来。搜索条…...

少儿户外拓展北斗定位解决方案

一、项目背景户外拓展训练是指通过专业的机构,对久居城市的人进行的一种野外生存训练。拓展训练通常利用崇山峻岭、翰海大川等自然环境,通过精心设计的活动达到“磨练意志、陶冶情操、完善人格、熔炼团队”的培训目的。针对户外拓展人员安全管理存在的实…...

更换ssl证书

更换ssl证书常用证书查看以及转换网址阿里云判断流量以及配置证书判断接入点阿里云控制台配置证书WAFAzure判断流量以及配置证书:判断接入点Azure配置证书CDNAPP GateWay常用证书查看以及转换网址 https://www.chinassl.net/ssltools/convert-ssl.htmlhttps://myss…...

后进先出(LIFO)详解

LIFO 是 Last In, First Out 的缩写,中文译为后进先出。这是一种数据结构的工作原则,类似于一摞盘子或一叠书本: 最后放进去的元素最先出来 -想象往筒状容器里放盘子: (1)你放进的最后一个盘子&#xff08…...

React 第五十五节 Router 中 useAsyncError的使用详解

前言 useAsyncError 是 React Router v6.4 引入的一个钩子,用于处理异步操作(如数据加载)中的错误。下面我将详细解释其用途并提供代码示例。 一、useAsyncError 用途 处理异步错误:捕获在 loader 或 action 中发生的异步错误替…...

2025年能源电力系统与流体力学国际会议 (EPSFD 2025)

2025年能源电力系统与流体力学国际会议(EPSFD 2025)将于本年度在美丽的杭州盛大召开。作为全球能源、电力系统以及流体力学领域的顶级盛会,EPSFD 2025旨在为来自世界各地的科学家、工程师和研究人员提供一个展示最新研究成果、分享实践经验及…...

如何在看板中有效管理突发紧急任务

在看板中有效管理突发紧急任务需要:设立专门的紧急任务通道、重新调整任务优先级、保持适度的WIP(Work-in-Progress)弹性、优化任务处理流程、提高团队应对突发情况的敏捷性。其中,设立专门的紧急任务通道尤为重要,这能…...

如何将联系人从 iPhone 转移到 Android

从 iPhone 换到 Android 手机时,你可能需要保留重要的数据,例如通讯录。好在,将通讯录从 iPhone 转移到 Android 手机非常简单,你可以从本文中学习 6 种可靠的方法,确保随时保持连接,不错过任何信息。 第 1…...

论文浅尝 | 基于判别指令微调生成式大语言模型的知识图谱补全方法(ISWC2024)

笔记整理:刘治强,浙江大学硕士生,研究方向为知识图谱表示学习,大语言模型 论文链接:http://arxiv.org/abs/2407.16127 发表会议:ISWC 2024 1. 动机 传统的知识图谱补全(KGC)模型通过…...

Spring Boot面试题精选汇总

🤟致敬读者 🟩感谢阅读🟦笑口常开🟪生日快乐⬛早点睡觉 📘博主相关 🟧博主信息🟨博客首页🟫专栏推荐🟥活动信息 文章目录 Spring Boot面试题精选汇总⚙️ **一、核心概…...

vue3+vite项目中使用.env文件环境变量方法

vue3vite项目中使用.env文件环境变量方法 .env文件作用命名规则常用的配置项示例使用方法注意事项在vite.config.js文件中读取环境变量方法 .env文件作用 .env 文件用于定义环境变量,这些变量可以在项目中通过 import.meta.env 进行访问。Vite 会自动加载这些环境变…...

rnn判断string中第一次出现a的下标

# coding:utf8 import torch import torch.nn as nn import numpy as np import random import json""" 基于pytorch的网络编写 实现一个RNN网络完成多分类任务 判断字符 a 第一次出现在字符串中的位置 """class TorchModel(nn.Module):def __in…...

iOS性能调优实战:借助克魔(KeyMob)与常用工具深度洞察App瓶颈

在日常iOS开发过程中,性能问题往往是最令人头疼的一类Bug。尤其是在App上线前的压测阶段或是处理用户反馈的高发期,开发者往往需要面对卡顿、崩溃、能耗异常、日志混乱等一系列问题。这些问题表面上看似偶发,但背后往往隐藏着系统资源调度不当…...