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…...
AI-调查研究-01-正念冥想有用吗？对健康的影响及科学指南
点一下关注吧！！！非常感谢！！持续更新！！！ 🚀 AI篇持续更新中！（长期更新） 目前2025年06月05日更新到： AI炼丹日志-28 - Aud…...
)
Java 语言特性(面试系列2)
一、SQL 基础 1. 复杂查询 （1）连接查询（JOIN） 内连接（INNER JOIN）：返回两表匹配的记录。 SELECT e.name, d.dept_name FROM employees e INNER JOIN departments d ON e.dept_id d.dept_id; 左…...
C++初阶-list的底层
目录 1.std::list实现的所有代码 2.list的简单介绍 2.1实现list的类 2.2_list_iterator的实现 2.2.1_list_iterator实现的原因和好处 2.2.2_list_iterator实现 2.3_list_node的实现 2.3.1. 避免递归的模板依赖 2.3.2. 内存布局一致性 2.3.3. 类型安全的替代方案 2.3.…...
linux 下常用变更-8
1、删除普通用户 查询用户初始UID和GIDls -l /home/ ###家目录中查看UID cat /etc/group ###此文件查看GID删除用户1.编辑文件 /etc/passwd 找到对应的行，YW343:x:0:0::/home/YW343:/bin/bash 2.将标红的位置修改为用户对应初始UID和GID： YW3…...
微服务商城-商品微服务
数据表 CREATE TABLE product (id bigint(20) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT 商品id,cateid smallint(6) UNSIGNED NOT NULL DEFAULT 0 COMMENT 类别Id,name varchar(100) NOT NULL DEFAULT COMMENT 商品名称,subtitle varchar(200) NOT NULL DEFAULT COMMENT 商…...
QT： `long long` 类型转换为 `QString` 2025.6.5
在 Qt 中，将 long long 类型转换为 QString 可以通过以下两种常用方法实现： 方法 1：使用 QString::number() 直接调用 QString 的静态方法 number()，将数值转换为字符串： long long value 1234567890123456789LL; …...
Maven 概述、安装、配置、仓库、私服详解
目录 1、Maven 概述 1.1 Maven 的定义 1.2 Maven 解决的问题 1.3 Maven 的核心特性与优势 2、Maven 安装 2.1 下载 Maven 2.2 安装配置 Maven 2.3 测试安装 2.4 修改 Maven 本地仓库的默认路径 3、Maven 配置 3.1 配置本地仓库 3.2 配置 JDK 3.3 IDEA 配置本地 Ma…...
OCR MLLM Evaluation
为什么需要评测体系？——背景与矛盾 能干的事： 看清楚发票、身份证上的字（准确率>90%），速度飞快（眨眼间完成）。干不了的事： 碰到复杂表格（合并单元…...
【免费数据】2005-2019年我国272个地级市的旅游竞争力多指标数据（33个指标）
旅游业是一个城市的重要产业构成。旅游竞争力是一个城市竞争力的重要构成部分。一个城市的旅游竞争力反映了其在旅游市场竞争中的比较优势。 今日我们分享的是2005-2019年我国272个地级市的旅游竞争力多指标数据！该数据集源自2025年4月发表于《地理学报》的论文成果…...
电脑桌面太单调，用Python写一个桌面小宠物应用。
下面是一个使用Python创建的简单桌面小宠物应用。这个小宠物会在桌面上游荡，可以响应鼠标点击，并且有简单的动画效果。 import tkinter as tk import random import time from PIL import Image, ImageTk import os import sysclass DesktopPet:def __i…...