RocketMQ教程(三)：RocketMQ的核心组件
四个核心组件
RocketMQ 的架构采用了典型的分布式系统设计理念，以确保高性能、高可用和可扩展性。RocketMQ 主要由四个核心组件构成：NameServer、Broker、Producer 和 Consumer。下面是对这些组件以及它们在 RocketMQ 中的角色和功能的概述：
1. NameServer
- 角色和功能：NameServer 负责维护整个消息队列系统中 Broker 的路由信息，提供轻量级的服务发现和路由功能。每个 Broker 启动时会向所有 NameServer 注册自己的路由信息，Producer 和 Consumer 通过查询 NameServer 来获取 Broker 的地址信息。
- 设计理念：通过提供一个几乎无状态的轻量级服务，RocketMQ 的 NameServer 能够轻松实现集群和负载均衡，同时避免成为系统瓶颈。
2. Broker
- 角色和功能：Broker 是消息处理的核心，负责消息的存储、传输、和检索。它支持长期存储、高性能和高并发的消息处理。Broker 可以按主题对消息进行分类存储，并支持顺序和非顺序消息。
- 设计理念：为了保证高性能和数据的可靠性，Broker 设计了多层消息存储结构，支持快速的消息写入和消费。同时，它支持主从复制机制，确保高可用。
3. Producer
- 角色和功能：Producer 负责生产发布消息到 Broker。它首先从 NameServer 查询 Broker 的路由信息，然后根据负载均衡算法选择一个或多个 Broker 发送消息。
- 设计理念：通过高效的网络通讯和负载均衡策略，Producer 能够实现快速和可靠地消息发送。
4. Consumer
- 角色和功能：Consumer 负责从 Broker 订阅和消费消息。它支持拉（Pull）和推（Push）两种模式来获取消息，提供灵活的消费处理方式。
- 设计理念：Consumer 的设计支持高效的消息拉取和自动消费偏移管理，确保消息的准确处理。同时，支持集群消费和广播消费两种模式，以满足不同的应用需求。
架构图
由此可见 NameServer、Broker、Producer、Consumer 都可以搭建成集群部署，并且 Broker 还能搭建主从集群！
消息（Message）
相关文章：
RocketMQ教程(三)：RocketMQ的核心组件
四个核心组件 RocketMQ 的架构采用了典型的分布式系统设计理念，以确保高性能、高可用和可扩展性。RocketMQ 主要由四个核心组件构成：NameServer、Broker、Producer 和 Consumer。下面是对这些组件以及它们在 RocketMQ 中的角色和功能的概述： 1. NameServer 角色和功能：Name…...
46.SQLserver中按照多条件分组：查询每个地方的各种水果的种植数量，新增时，一个地方同时有几种水果，只插入一条记录，同时多种水果之间使用|隔开
1.SQLserver中按照多条件分组 ，分组条件包括（一个字段使用|进行分割，如：apple|orange,查询时，apple和orange分别对应一条数据） 例如：SQL如下： SELECT FROM ( SELECT CDFBM 地方编码…...
C盘满了怎么办，Windows11的C盘没有磁盘清理选项怎么办，一次搞定
问题： 太久没清电脑了，满的跟垃圾堆一样。。。C盘红色看上去很不妙。 一. C盘满了怎么办： 1. 删除临时文件 找到 C:\Windows\Temp，进入Temp资料夹，选中所有文件夹和文件，按下ShiftDelete键，彻…...
「动态规划」当小偷改行去当按摩师，会发生什么？
一个有名的按摩师会收到源源不断的预约请求，每个预约都可以选择接或不接。在每次预约服务之间要有休息时间，因此她不能接受相邻的预约。给定一个预约请求序列，替按摩师找到最优的预约集合（总预约时间最长），…...
Python | 排队取奶茶
队列的基本概念（队头、队尾）和特点（先入先出） 在 Python 语言中，标准库中的queue模块提供了多种队列的实现，比如普通队列和优先级队列，因此你可以使用queue.Queue类来创建队列，不过…...
mysql当前状态分析（show status）
文章目录 查看当前线程数据查询连接情况查询缓存相关查询锁相关查询增删改查执行次数查询DDL创建相关 SHOW STATUS 是一个在 MySQL 中用来查看服务器运行状态的命令。它可以帮助你了解服务器的当前性能，包括连接数、表锁定、缓冲区使用情况等信息。 查看当前线程数据…...
Google Earth Engine（GEE）——使用机器学习进行金三角大米分布图
第 1 步：转到https://code.earthengine.google.com/打开代码编辑器 第 2 步：使用以下代码从 Google Earth Engine Asset 导入数据 // 导入影像集合 var composites = ee.ImageCollection("projects/servir-mekong/yearlyComposites"); // 导入训练数据 var data …...
MyBatis一级和二级缓存介绍
MyBatis是一个持久层框架，它提供了一级缓存和二级缓存来提高数据库操作的性能。下面是一级缓存和二级缓存的区别理解、画图和知识点总结： 一级缓存： 一级缓存是MyBatis默认开启的缓存层，它是SqlSession级别的缓存，也…...
PowerDesigner遍历导出所有表结构到Excel
PowerDesigner遍历导出所有表到Excel 1.打开需要导出表结构到Excel的pdm文件 2.点击Tools|Execute Commands|Edit/Run Script菜单或按下快捷键Ctrl Shift X打开脚本窗口，输入示例VBScript脚本，修改其中的Excel模板路径及工作薄页签，点Run…...
JavaSE——抽象类和接口
目录 一 .抽象类 1.抽象类概念 2.抽象类语法 3.抽象类特性 4.抽象类的作用 二. 接口 1.接口的概念 2.语法规则 3.接口的使用 4.接口特性 5.实现多个接口 6.接口间的继承 三.抽象类和接口的区别 一 .抽象类 1.抽象类概念 在面向对象的概念中，所有的对…...
生成式人工智能 - stable diffusion web-ui安装教程
一、Stable Diffusion WEB UI 屌丝劲发作了，所以本地调试了Stable Diffusion之后，就去看了一下Stable Diffusion WEB UI，网络上各种打包套件什么的好像很火。国内的也就这个层次了，老外搞创新，国内跟着屁股后面搞搞应用层，就叫大神了。 不扯闲篇了，我们这里从git源码直接…...
11-Linux文件系统与日志分析
11.1深入理解Linux文件系统 在处理Liunx系统出现故障时，故障的症状是最易发现。数学LInux系统中常见的日志文件，可以帮助管理员快速定位故障点，并及时解决各种系统问题。 11.1.1 inode与block详解 文件系统通常会将这两部分内容分别存放在…...
mac M1下安装PySide2
在M1下装不了PySide2, 是因为PySide2没有arm架构的包 1 先在M1上装qt5 安装qt主要是为了能用里面的Desinger, uic, rcc brew install qt5 我装完的路径在/opt/homebrew/opt/qt5 其中Designer就是用来设计界面的 rcc用resource compiler, 编绎rc资源文件的, 生成对应的py文件…...
超详解——识别None——小白篇
目录 1. 内建类型的布尔值 2. 对象身份的比较 3. 对象类型比较 4. 类型工厂函数 5. Python不支持的类型 总结： 1. 内建类型的布尔值 在Python中，布尔值的计算遵循如下规则： None、False、空序列（如空列表 []，空…...
C++的MQTT开发：使用Paho的C++接口实现消息发布、订阅、连接RabbitMQ
C Paho实现MQTT消息发布功能 要使用paho的cpp接口实现发布MQTT消息的功能，需要进行以下步骤： 安装paho库：首先从paho官方网站下载并安装paho的C库。可以从https://www.eclipse.org/paho/clients/cpp/ 下载适合操作系统的版本。 创建MQTT客户…...
深度网络学习笔记（二）——Transformer架构详解（包括多头自注意力机制）
Transformer架构详解 前言Transformer的整体架构多头注意力机制（Multi-Head Attention）具体步骤1. 步骤12. 步骤23. 步骤34. 步骤4 Self-Attention应用与比较Self-Attention用于图像处理Self-Attention vs. CNNSelf-Attention vs. RNN Transformer架构详…...
Python 快速查找并替换Excel中的数据
Excel中的查找替换是一个非常实用的功能，能够帮助用户快速完成大量数据的整理和处理工作，避免手动逐一修改数据的麻烦，提高工作效率。要使用Python实现这一功能， 我们可以借助Spire.XLS for Python 库，具体操作如下&am…...
KafkaStream Local Store和Global Store区别和用法
前言 使用kafkaStream进行流式计算时，如果需要对数据进行状态处理，那么常用的会遇到kafkaStream的store，而store也有Local Store以及Global Store，当然也可以使用其他方案的来进行状态保存，文本主要理清楚kafkaStream…...
PowerDesigner导入Excel模板生成数据表
PowerDesigner导入Excel模板生成数据表 1.准备好需要导入的Excel表结构数据,模板内容如下图所示 2.打开PowerDesigner,新建一个physical data model文件,填入文件名称,选择数据库类型 3.点击Tools|Execute Commands|Edit/Run Script菜单或按下快捷键Ctrl Shift X打开脚本窗口…...
STM32 HAL库开发——入门篇（3）：OLED、LCD
源自正点原子视频教程： 【正点原子】手把手教你学STM32 HAL库开发全集【真人出镜】STM32入门教学视频教程 单片机 嵌入式_哔哩哔哩_bilibili 一、OLED 二、内存保护（MPU）实验 2.1 内存保护单元 三、LCD 3.1 显示屏分类 3.2 LCD简介 3.3 LCD…...
UE5 学习系列（二）用户操作界面及介绍
这篇博客是 UE5 学习系列博客的第二篇，在第一篇的基础上展开这篇内容。博客参考的 B 站视频资料和第一篇的链接如下： 【Note】：如果你已经完成安装等操作，可以只执行第一篇博客中 2. 新建一个空白游戏项目 章节操作，重…...
华为云AI开发平台ModelArts
华为云ModelArts：重塑AI开发流程的“智能引擎”与“创新加速器”！ 在人工智能浪潮席卷全球的2025年，企业拥抱AI的意愿空前高涨，但技术门槛高、流程复杂、资源投入巨大的现实，却让许多创新构想止步于实验室。数据科学家…...
C++实现分布式网络通信框架RPC(3)--rpc调用端
目录 一、前言 二、UserServiceRpc_Stub 三、 CallMethod方法的重写 头文件 实现 四、rpc调用端的调用 实现 五、 google::protobuf::RpcController *controller 头文件 实现 六、总结 一、前言 在前边的文章中，我们已经大致实现了rpc服务端的各项功能代…...
关于iview组件中使用 table , 绑定序号分页后序号从1开始的解决方案
问题描述：iview使用table 中type: "index",分页之后 ，索引还是从1开始，试过绑定后台返回数据的id, 这种方法可行，就是后台返回数据的每个页面id都不完全是按照从1开始的升序，因此百度了下，找到了…...
在 Nginx Stream 层“改写”MQTT ngx_stream_mqtt_filter_module
1、为什么要修改 CONNECT 报文？ 多租户隔离：自动为接入设备追加租户前缀，后端按 ClientID 拆分队列。零代码鉴权：将入站用户名替换为 OAuth Access-Token，后端 Broker 统一校验。灰度发布：根据 IP/地理位写…...
渲染学进阶内容——模型
最近在写模组的时候发现渲染器里面离不开模型的定义，在渲染的第二篇文章中简单的讲解了一下关于模型部分的内容，其实不管是方块还是方块实体，都离不开模型的内容 🧱 一、CubeListBuilder 功能解析 CubeListBuilder 是 Minecraft Java 版模型系统的核心构建器，用于动态创…...
【项目实战】通过多模态+LangGraph实现PPT生成助手
PPT自动生成系统 基于LangGraph的PPT自动生成系统，可以将Markdown文档自动转换为PPT演示文稿。 功能特点 Markdown解析：自动解析Markdown文档结构PPT模板分析：分析PPT模板的布局和风格智能布局决策：匹配内容与合适的PPT布局自动…...
HBuilderX安装（uni-app和小程序开发）
下载HBuilderX 访问官方网站：https://www.dcloud.io/hbuilderx.html 根据您的操作系统选择合适版本： Windows版（推荐下载标准版） Windows系统安装步骤 运行安装程序： 双击下载的.exe安装文件 如果出现安全提示&…...
css的定位（position）详解：相对定位 绝对定位 固定定位
在 CSS 中，元素的定位通过 position 属性控制，共有 5 种定位模式：static（静态定位）、relative（相对定位）、absolute（绝对定位）、fixed（固定定位）和…...
鱼香ros docker配置镜像报错：https://registry-1.docker.io/v2/
使用鱼香ros一件安装docker时的https://registry-1.docker.io/v2/问题 一键安装指令 wget http://fishros.com/install -O fishros && . fishros出现问题：docker pull 失败 网络不同，需要使用镜像源 按照如下步骤操作 sudo vi /etc/docker/dae…...