【尚硅谷】RocketMQ 消息队列学习笔记
RocketMQ 和 Kafka 消息队列概念比较？
好的！RocketMQ 和 Kafka 都是分布式消息队列系统，它们的核心概念有很多相似之处，但在具体实现和命名上有所不同。下面我通过一个表格来对比 RocketMQ 和 Kafka 中的五个概念：消息、主题（Topic）、标签（Tag）、队列（Queue）、消息标识（Message ID）。
| RocketMQ 概念 | Kafka 对应概念 | 解释 |
|---|---|---|
| 消息（Message） | 消息（Message） | 消息是生产者发送的内容，Kafka 和 RocketMQ 都使用“消息”这个术语。消息可以是任何数据，比如订单信息、日志数据等。 |
| 主题（Topic） | 主题（Topic） | 在两者中，Topic 都是消息的分类方式。生产者将消息发送到某个 Topic，消费者订阅该 Topic 来接收消息。 |
| 标签（Tag） | 无直接对应概念 | RocketMQ 中的 Tag 是对 Topic 下的消息进行进一步分类的机制，Kafka 没有直接的 Tag 概念。Kafka 可以通过消息的 Key 或者 Headers 来实现类似的功能，但没有内置的 Tag 机制。 |
| 队列（Queue） | 分区（Partition） | RocketMQ 中的 Queue 和 Kafka 中的 Partition 类似，都是用于分散存储消息的单元。一个 Topic 通常会有多个 Queue（RocketMQ）或 Partition（Kafka），以支持并行消费。 |
| 消息标识（Message ID） | 偏移量（Offset） | RocketMQ 中的 Message ID 是每条消息的唯一标识符，Kafka 中没有全局唯一的 Message ID，但每条消息在其分区中有一个唯一的 Offset（偏移量），可以用来定位和追踪消息。 |
什么是分片？
Topic -> Queue -> 消息
Queue 太多不好管理，将Queue划分成不同的分片，Broker 存储分片
Broker 是按照分片存储的
相关文章：
【尚硅谷】RocketMQ 消息队列学习笔记
RocketMQ 和 Kafka 消息队列概念比较？ 好的！RocketMQ 和 Kafka 都是分布式消息队列系统，它们的核心概念有很多相似之处，但在具体实现和命名上有所不同。下面我通过一个表格来对比 RocketMQ 和 Kafka 中的五个概念：消息…...
C题（三）芝麻开门 --- strcmp函数应用
场景一：“芝麻开门 ”是通往C语言的大门的暗号，现在你需要说对暗号，大门才会打开。 【分解目标1】字符串的输入 char arr[20] { 0 }; //字符的集合---字符串（数组表示）//20为预定的数组的大小scanf("%s", a…...
C++函数模板、选择排序实现（从大到小）
template <class T> void mysw (T &a , T &b) {T temp b;b a;a temp; }template <class T> void muSort( T &arr ,int len) {//该实现为选择排序(高到低)for (int i 0; i < len; i) {int max i ; //首先默认本次循环首位元素为最大for (int j …...
EasyExcel使用介绍
EasyExcel使用 1、EasyExcel介绍 1.1 官网介绍 传统操作Excel大多都是利用Apach POI进行操作的，但是POI框架并不完善，使用过程非常繁琐且有较多的缺陷： 动态操作Excel非常繁琐,对于新手来说，很难在短时间内上手;读写时需要占用…...
字段临时缓存包装器
前言 在实际开发中，我们有时候存在一种需求，例如对于某个字段，我们希望在某个明确的保存节点前对字段的修改都仅作为缓存保留，最终是否应用这些修改取决于某些条件，比如玩家对游戏设置的修改可能需要玩家明确确认应用修…...
Python（三）——列表
文章目录 创建列表访问下标遍历列表元素新增元素查找元素删除元素连接列表切片操作 创建列表 创建列表主要有两种方式 [ ]表示一个空的列表 a [] print(type(a)) # <class list> print(a) # []通过list()的方式来创建一个空列表 a list() print(type(a)) # …...
MySQL--三大范式（超详解）
目录 一、前言二、三大范式2.1概念2.2第一范式（1NF）2.3第二范式（2NF）2.3第三范式（3NF） 一、前言 欢迎大家来到权权的博客~欢迎大家对我的博客进行指导，有什么不对的地方，我会及时改进…...
追梦无Bug的软件世界
追梦无Bug的软件世界：测试人员的视角与探索 我有一个梦想，今天我们共同承载着一个愿景：创造一个没有Bug的软件世界。 我梦想有一天，用户将享受到完全无Bug的软件体验，用户不再因为软件中的Bug而感到困扰和沮丧。 我梦…...
在C#中使用Redis实现高效消息队列
使用Redis实现C#中的消息队列 Redis是一种开源的内存数据结构存储系统，因其高性能和灵活性被广泛用于缓存、数据库和消息队列等场景。本文将详细介绍如何在C#中使用Redis实现一个简单的消息队列，涵盖环境准备、代码实现和使用示例。 1. 环境准备 1.1 安装Redis 首先，确保…...
微服务JMeter解析部署使用全流程
目录 1、介绍 2、下载 3、运行 4、设置简体中文版 5、开始测试 1、添加线程组 2、添加监听器 3、添加请求 先.测试userController里的查询方法 6、查看结果 1、查看结果树 2、汇总报告 3、聚合报告 7、JMeter报错 1、介绍 Apache JMeter 是 Apache 组织基于 Java…...
Python 从入门到实战32（数据库MySQL）
我们的目标是：通过这一套资料学习下来，通过熟练掌握python基础，然后结合经典实例、实践相结合，使我们完全掌握python，并做到独立完成项目开发的能力。 上篇文章我们讨论了数据库编程接口操作的相关知识。今天我们将学习…...
hrnet训练的pt模型结合目标检测进行关键点识别的更准确前向推理
本篇在将图像输入hrnet识别之前先进行目标检测来确定识别的位置，让识别更加精准。 本段代码设置了一个区域框BOX，让人走入区域内才开始检测，适用于考核等场景，也可以直接去掉BOX也是一样的效果。若画面背景中有多个行人࿰…...
Leetcode 3306. Count of Substrings Containing Every Vowel and K Consonants II
Leetcode 3306. Count of Substrings Containing Every Vowel and K Consonants II 1. 解题思路2. 代码实现 题目链接：3306. Count of Substrings Containing Every Vowel and K Consonants II 1. 解题思路 这一题的话思路上就是一个滑动窗口，考察没一…...
算法笔记（五）——分治
文章目录 算法笔记（五）——分治快排颜色分类排序数组数组中的第K个最大元素库存管理 III 归并排序数组交易逆序对的总数计算右侧小于当前元素的个数翻转对 算法笔记（五）——分治 分治算法字面上的解释是“分而治之”，就…...
多级侧边菜单（递归）
需要编写两个文件 aside-menu.vue 和 menu-item.vue menu-item.vue <script setup> defineOptions({name: MenuItem}) defineProps({menuList: Array}) </script><template><template v-for"menu of menuList"><!-- 如果当前有子菜单&a…...
JavaScript break与continue语句
break语句和continue语句都具有跳转作用，可以让代码不按既有的顺序执行。 break break语句用于跳出代码块或循环 for(i0;i<100;i){if(i5){break;}console.log(i);} continue continue语句用于应即终止本轮循环,返回循环结构的头部，开始下一轮循环。…...
算法【从递归入手一维动态规划】
动态规划：用空间代替重复计算，包含一整套原理和技巧的总和。后面会有非常多的文章介绍动态规划。 有些递归在展开计算时，总是重复调用同一个子问题的解，这种重复调用的递归变成动态规划很有收益。如果每次展开都是不同的解&#…...
Linux中的进程间通信之共享内存
共享内存 共享内存示意图 共享内存数据结构 struct shmid_ds {struct ipc_perm shm_perm; /* operation perms */int shm_segsz; /* size of segment (bytes) */__kernel_time_t shm_atime; /* last attach time */__kernel_time_t shm_dtime; /* last detach time */__kerne…...
第18周 3-过滤器
过滤器（Filter）概念总结 什么是过滤器 过滤器（Filter）是Java Web应用中用于统一拦截和处理请求的组件，类似于现实生活中的空气净化器或安检。它通过对请求进行前置处理，确保请求符合特定要求。 过滤器的…...
Linux之进程概念
作者主页： 作者主页 本篇博客专栏：Linux专栏 创作时间 ：2024年9月28日 基本概念： 进程说白了其实就是一个程序的执行实例，正在执行的程序。 在内核层面来说，就是一个担当分配资源（CPU时间…...
cf2117E
原题链接：https://codeforces.com/contest/2117/problem/E 题目背景： 给定两个数组a,b，可以执行多次以下操作：选择 i (1 < i < n - 1)，并设置 或，也可以在执行上述操作前执行一次删除任意 和 。求…...
高危文件识别的常用算法：原理、应用与企业场景
高危文件识别的常用算法：原理、应用与企业场景 高危文件识别旨在检测可能导致安全威胁的文件，如包含恶意代码、敏感数据或欺诈内容的文档，在企业协同办公环境中（如Teams、Google Workspace）尤为重要。结合大模型技术&…...
Python爬虫（一）：爬虫伪装
一、网站防爬机制概述 在当今互联网环境中，具有一定规模或盈利性质的网站几乎都实施了各种防爬措施。这些措施主要分为两大类： 身份验证机制：直接将未经授权的爬虫阻挡在外反爬技术体系：通过各种技术手段增加爬虫获取数据的难度…...
什么是Ansible Jinja2
理解 Ansible Jinja2 模板 Ansible 是一款功能强大的开源自动化工具，可让您无缝地管理和配置系统。Ansible 的一大亮点是它使用 Jinja2 模板，允许您根据变量数据动态生成文件、配置设置和脚本。本文将向您介绍 Ansible 中的 Jinja2 模板，并通…...
AspectJ 在 Android 中的完整使用指南
一、环境配置（Gradle 7.0 适配） 1. 项目级 build.gradle // 注意：沪江插件已停更，推荐官方兼容方案 buildscript {dependencies {classpath org.aspectj:aspectjtools:1.9.9.1 // AspectJ 工具} } 2. 模块级 build.gradle plu…...
AI病理诊断七剑下天山，医疗未来触手可及
一、病理诊断困局：刀尖上的医学艺术 1.1 金标准背后的隐痛 病理诊断被誉为"诊断的诊断"，医生需通过显微镜观察组织切片，在细胞迷宫中捕捉癌变信号。某省病理质控报告显示，基层医院误诊率达12%-15%，专家会诊…...
在Ubuntu24上采用Wine打开SourceInsight
1. 安装wine sudo apt install wine 2. 安装32位库支持，SourceInsight是32位程序 sudo dpkg --add-architecture i386 sudo apt update sudo apt install wine32:i386 3. 验证安装 wine --version 4. 安装必要的字体和库（解决显示问题） sudo apt install fonts-wqy…...
JVM虚拟机：内存结构、垃圾回收、性能优化
1、JVM虚拟机的简介 Java 虚拟机（Java Virtual Machine 简称：JVM）是运行所有 Java 程序的抽象计算机，是 Java 语言的运行环境，实现了 Java 程序的跨平台特性。JVM 屏蔽了与具体操作系统平台相关的信息，使得 Java 程序只需生成在 JVM 上运行的目标代码（字节码），就可以…...
保姆级教程：在无网络无显卡的Windows电脑的vscode本地部署deepseek
文章目录 1 前言2 部署流程2.1 准备工作2.2 Ollama2.2.1 使用有网络的电脑下载Ollama2.2.2 安装Ollama（有网络的电脑）2.2.3 安装Ollama（无网络的电脑）2.2.4 安装验证2.2.5 修改大模型安装位置2.2.6 下载Deepseek模型 2.3 将deepse…...
无人机侦测与反制技术的进展与应用
国家电网无人机侦测与反制技术的进展与应用 引言 随着无人机（无人驾驶飞行器，UAV）技术的快速发展，其在商业、娱乐和军事领域的广泛应用带来了新的安全挑战。特别是对于关键基础设施如电力系统，无人机的“黑飞”&…...