RabbitMQ的交换机
一、三种交换机模式
核心区别对比
| 特性 | 广播模式（Fanout） | 路由模式（Direct） | 主题模式（Topic） |
|---|---|---|---|
| 路由规则 | 无条件复制到所有绑定队列 | 精确匹配 Routing Key | 通配符匹配 Routing Key（*/#） |
| 消息分发 | 1:N（所有消费者收到相同消息） | 1:1 或 1:N（相同 Key 的队列） | M:N（灵活匹配多个队列） |
| 典型应用场景 | 系统通知、多服务数据同步 | 任务分发、精确路由（如支付处理） | 分类事件（如日志分级、新闻订阅） |
| Exchange 类型 | Fanout Exchange（RabbitMQ） | Direct Exchange | Topic Exchange |
| Routing Key | 忽略 | 必须完全匹配 | 支持通配符（如 news.*） |
2. 详细说明
(1) 广播模式（Fanout）
- 核心逻辑：
消息发送到Fanout Exchange后，会无条件复制到所有绑定的队列，消费者订阅不同队列时会收到相同消息。 - 示例场景：
- 系统公告：一条消息需同时触发邮件、短信、日志服务。
- 数据同步：订单创建后广播给库存、物流、分析服务。
- 特点：
- 简单粗暴，无过滤逻辑。
- 性能开销较大（消息全量复制）。
(2) 路由模式（Direct）
- 核心逻辑：
消息通过精确的Routing Key匹配到指定队列，只有绑定相同 Key 的消费者能收到消息。 - 示例场景：
- 支付处理：
routing_key=payment.success仅路由到支付服务队列。 - 任务分发：多个 worker 竞争消费同一队列（工作队列模式）。
- 支付处理：
- 特点：
- 精准控制消息接收方。
- 灵活性较低（需提前定义 Key）。
(3) 主题模式（Topic）
- 核心逻辑：
通过通配符（*匹配一个单词，#匹配多级）动态匹配Routing Key，实现灵活的路由。 - 示例场景：
- 日志分级：
log.error路由到告警服务，log.info路由到存储服务。 - 新闻订阅：用户订阅
news.sports或news.weather。
- 日志分级：
- 特点：
- 兼顾广播的覆盖范围和路由的精确性。
- 适合多维度、分层级的消息分类。
3. 不同消息队列的实现
| MQ 类型 | 广播模式 | 路由模式 | 主题模式 |
|---|---|---|---|
| RabbitMQ | Fanout Exchange | Direct Exchange | Topic Exchange |
| Kafka | 多个 Consumer Group 独立消费 | 单 Partition 或 Key 路由 | Topic + 通配符订阅 |
| RocketMQ | 广播消费（Broadcasting） | Tag 过滤（精确匹配） | Tag 过滤（通配符支持） |
4. 如何选择？
- 需要无条件广播？ → Fanout（如全量数据同步）。
- 需要精确路由？ → Direct（如支付结果处理）。
- 需要动态分类？ → Topic（如日志分级、多维度事件）。
5.java代码实现（生产者）
总结
- 广播模式：简单粗暴，适合全覆盖场景。
- 路由模式：精准控制，适合点对点或任务分发。
- 主题模式：灵活匹配，适合复杂分类和订阅需求。
二、RabbitMQ对应的工作模式
1. 简单模式（Simple）
- 对应机制：
- 默认直连队列（无Exchange），生产者直接发消息到指定队列，单个消费者消费。
- 本质：最基础的点对点通信。
2. 工作队列模式（Work Queue）
- 对应机制：
- Direct Exchange的简化版：多个消费者共享同一队列，消息轮询或竞争消费（仍属于路由模式，但隐式使用队列名作为Routing Key）。
- 特点：无显式Routing Key，负载均衡分发。
3. 发布/订阅模式（Pub/Sub）
- 对应机制：
- Fanout Exchange：消息广播到所有绑定队列，忽略Routing Key。
- 特点：1:N广播，所有订阅者收到相同消息。
4. 路由模式（Routing）
- 对应机制：
- Direct Exchange：消息通过精确匹配Routing Key路由到指定队列。
- 特点：1:1或1:N（相同Key的队列），精确控制接收方。
5. 通配符模式（Topics）
- 对应机制：
- Topic Exchange：通过通配符（
*匹配一个词，#匹配多级）动态匹配Routing Key。 - 特点：灵活分类，如
news.sports或weather.*。
- Topic Exchange：通过通配符（
三、总结对应关系
| 模式名称 | 对应Exchange类型 | Routing Key规则 | 分发逻辑 |
|---|---|---|---|
| 简单模式 | (无，直连队列) | 队列名作为隐式Key | 1:1点对点 |
| 工作队列模式 | Direct（隐式） | 队列名作为隐式Key | 1:N竞争消费 |
| 发布/订阅模式 | Fanout | 忽略 | 1:N广播 |
| 路由模式 | Direct | 精确匹配 | 1:1或1:N（相同Key） |
| 通配符模式 | Topic | *或#通配符 | M:N动态匹配 |
相关文章：
RabbitMQ的交换机
一、三种交换机模式 核心区别对比 特性广播模式（Fanout）路由模式（Direct）主题模式（Topic）路由规则无条件复制到所有绑定队列精确匹配 Routing Key通配符匹配…...
多模态大语言模型arxiv论文略读（五十五）
MoMA: Multimodal LLM Adapter for Fast Personalized Image Generation ➡️ 论文标题：MoMA: Multimodal LLM Adapter for Fast Personalized Image Generation ➡️ 论文作者：Kunpeng Song, Yizhe Zhu, Bingchen Liu, Qing Yan, Ahmed Elgammal, Xiao…...
：投稿相关网址)
TMI投稿指南(四)：投稿相关网址
TMI官网：https://ieeetmi.org/ 模版选择器：选择合适的latex模版 IEEE-Template Selector 评审过程状态查看：ScholarOne Manuscripts AE assigns reviewers：副编辑已经开始选择和邀请审稿人，但同意审稿…...
Oracle无法正常OPEN(三）
在Oracle数据库中，如果几个数据文件丢失，导致数据库无法启动，报错“ORA-01157: cannot identify/lock data file 2 - see DBWR trace file”，如果没有物理备份的情况下，位于丢失数据文件的数据是无法找回的，…...
SQL语句练习 自学SQL网 在查询中使用表达式 统计
目录 Day 9 在查询中使用表达式 Day 10 在查询中进行统计 聚合函数 Day 11 在查询中进行统计 HAVING关键字 Day12 查询执行顺序 Day 9 在查询中使用表达式 SELECT id , Title , (International_salesDomestic_sales)/1000000 AS International_sales FROM moviesLEFT JOIN …...
当LLM遇上Agent：AI三大流派的“复仇者联盟”
你一定听说过ChatGPT和DeepSeek，也知道它们背后的LLM（大语言模型）有多牛——能写诗、写代码、甚至假装人类。但如果你以为这就是AI的极限，那你就too young too simple了！ 最近，**Agent（智能体&a…...
模拟开发授权平台
这次只是实现应用的curd和公私钥的校验以及第三方的通知dmeo项目，大家可以拓开视野来编写 进入主题 项目链接：桌角的眼镜/develop_auth_platform 直接下拉并运行就行 回调应用代码在test包中 回调应用测试代码 package mainimport ("encoding/…...
python数据分析（八）：Pandas 文本数据处理
Pandas 文本数据处理全面指南 1. 引言 在数据分析中，文本数据是常见的数据类型之一。Pandas 提供了强大的字符串处理方法，可以方便地对文本数据进行各种操作。本文将详细介绍 Pandas 中的文本处理功能，包括字符串连接(cat)、分割(split)、替…...
Spring AI：简化人工智能功能应用程序开发
Spring AI：简化人工智能功能应用程序开发 一、项目简介 Spring AI 项目致力于简化包含人工智能功能的应用程序的开发工作，并且不会引入不必要的复杂性。该项目从著名的 Python 项目（如 LangChain 和 LlamaIndex）中获取灵感&#…...
【算法基础】三指针排序算法 - JAVA
一、基础概念 1.1 什么是三指针排序 三指针排序是一种特殊的分区排序算法，通过使用三个指针同时操作数组，将元素按照特定规则进行分类和排序。这种算法在处理包含有限种类值的数组时表现出色，最经典的应用是荷兰国旗问题（Dutch …...
从实列中学习linux shell9 如何确认 服务器反应迟钝是因为cpu还是 硬盘io 到底是那个程序引起的。cpu负载多高算高
在 Linux 系统中，Load Average（平均负载） 是衡量系统整体压力的关键指标，但它本身没有绝对的“高/低”阈值，需要结合 CPU 核心数 和 其他性能指标 综合分析。以下是具体判断方法： 一、Load Average 的基本含义 定义：Load Average 表示 单位时间内处于可运行状态（R）和不…...
[面试]SoC验证工程师面试常见问题（三）
SoC验证工程师面试常见问题（三） 在 SoC 验证工程师的面试中，面试官可能会要求候选人现场编写 SystemVerilog、UVM (Universal Verification Methodology) 或 SystemC 代码，以评估其编程能力、语言掌握程度以及解决实际验证问题的能力。这种随机抽题写代码的环节通常…...
架构进阶：深入学习企业总体架构规划（Oracle 战略专家培训课件）【附全文阅读】
本文主要讨论了企业总体技术架构规划的重要性与实施建议。针对Oracle战略专家培训课件中的内容，文章强调了行业面临的挑战及现状分析、总体技术架构探讨、SOA集成解决方案讨论与问题解答等方面。文章指出，为了消除信息孤岛、强化应用系统，需要…...
stm32教程：软件I2C通信协议 代码模板提供
早上好啊大伙，这一期也是stm32的基础教学，这一期说的是 —— I2C通信协议。 文章目录 一、I2C协议概述二、物理层特性硬件结构速率模式 三、协议层机制起始与停止信号数据帧结构应答机制时钟同步与仲裁 四、通信协议1. 起始信号（START Condit…...
Java零基础入门Day4：数组与二维数组详解
一、为什么需要数组？ 当程序需要处理批量同类型数据时，使用多个变量存储会非常繁琐。例如存储70个学生姓名时，需定义70个变量，而数组可以简化这一过程，提高代码可维护性。 示例：变量存储的弊端 String n…...
一条 SQL 查询语句是如何执行的（MySQL）
第一讲：一条 SQL 查询语句是如何执行的 总览图示 MySQL 查询的执行流程可以大致分为以下步骤（如图所示）： 连接器（Connection）查询缓存（Query Cache，MySQL 8.0 已废弃）…...
IntelliJ IDEA
文章目录 一、集成开发环境(IDE, Integrated Development Environment)二、IntelliJ IDEAIDEA 安装 三、IDEA 管理 Java 程序的结构四、IDEA 开发 HelloWorld 程序 一、集成开发环境(IDE, Integrated Development Environment) 把代码编写，编译，执行等多…...
详细说明StandardCopyOption.REPLACE_EXISTING参数的作用和使用方法
StandardCopyOption.REPLACE_EXISTING 是 Java java.nio.file.StandardCopyOption 枚举类中的一个常量，它主要用于在文件复制或移动操作中处理目标文件已存在的情况。下面详细介绍其作用和使用方法。 作用 在使用 java.nio.file.Files 类的 copy() 或 move() 方法时…...
Linux 下使用tcpdump进行网络分析原
简介 tcpdump 是一个命令行数据包分析器，可实时捕获和检查网络流量。它通常用于网络故障排除、性能分析和安全监控。 安装 Debian/Ubuntu sudo apt update && sudo apt install tcpdump -yCentOS/RHEL sudo yum install tcpdump -ymacOS brew install…...
人车交叉作业防撞系统介绍
一、技术原理与核心功能 UWB脉冲测距技术 系统基于UWB技术，通过纳秒级非正弦窄脉冲（脉冲宽度0.21.5ns）实现实时测距，精度可达1030厘米。 工作原理：人员佩戴防撞标签（A）与车载基站（B&…...
移动端开发中设备、分辨率、浏览器兼容性问题
以下是针对移动端开发中设备、分辨率、浏览器兼容性问题的 系统化解决方案，按开发流程和技术维度拆解，形成可落地的执行步骤： 一、基础环境适配：从「起点」杜绝兼容性隐患 1. Viewport 元标签标准化 <meta name"viewpor…...
Git 基本操作（二）
目录 撤销修改操作 情况一 情况二 情况三 删除文件 升级git 撤销修改操作 在日常编码过程中，有些时候，我们可能写着写着发现目前的版本的代码越写越挫，越不符合标准，想让我们当前的文件去恢复到上一次提交的版本…...
多模态大模型轻量化探索-开源SmolVLM模型架构、数据策略及其衍生物PDF解析模型SmolDocling
在《多模态大模型轻量化探索-视觉大模型SAM的视觉编码器》介绍到，缩小视觉编码器的尺寸，能够有效的降低多模态大模型的参数量。再来看一个整体的工作，从视觉侧和语言模型侧综合考量模型参数量的平衡模式，进一步降低参数量…...
gRPC学习笔记记录以及整合gin开发
gprc基础 前置环境准备 grpc下载 项目目录下执行 go get google.golang.org/grpclatestProtocol Buffers v3 https://github.com/protocolbuffers/protobuf/releases/download/v3.20.1/protoc-3.20.1-linux-x86_64.zip go语言插件： go install google.golang.…...
Linux diff 命令使用详解
简介 Linux 中的 diff 命令用于逐行比较文件。它以各种格式报告差异，广泛应用于脚本编写、开发和补丁生成。 基础语法 diff [OPTION]... FILES常用选项 -i：忽略大小写 -u：打印输出时不包含任何多余的上下文行 -c：输出不同行周…...
非对称加密算法（RSA、ECC、SM2）——密码学基础
对称加密算法（AES、ChaCha20和SM4）Python实现——密码学基础(Python出现No module named “Crypto” 解决方案) 这篇的续篇，因此实践部分少些； 文章目录 一、非对称加密算法基础二、RSA算法2.1 RSA原理与数学基础2.2 RSA密钥长度…...
【安装指南】Chat2DB-集成了AI功能的数据库管理工具
一、Chat2DB 的介绍 Chat2DB 是一款开源的、AI 驱动的数据库工具和 SQL 客户端，提供现代化的图形界面，支持 MySQL、Oracle、PostgreSQL、DB2、SQL Server、SQLite、H2、ClickHouse、BigQuery 等多种数据库。它旨在简化数据库管理、SQL 查询编写、报表生…...
【C++】认识map和set
目录 前言： 一：认识map和set 二：map和set的使用 1.set的使用 2.map的使用 三：map的insert方法返回值 四：map的[ ]的使用 五：multiset和multimap 六：map和set的底层数据结构 七&#x…...
LWIP带freeRTOS系统移植笔记
以正点原子学习视频为基础的文章 LWIP带freeRTOS系统移植 准备资料/工程 1、lwIP例程1 lwIP裸机移植 工程 ， 作为基础工程 改名为LWIP_freeRTOS_yizhi工程 2、lwIP例程6 lwIP_FreeRTOS移植 工程 3、freeRTO源码 打开https://www.freertos.org/网址下载…...
【MinerU技术原理深度解析】大模型时代的文档解析革命
目录 一、MinerU概述 获取MinerU 二、核心功能与技术亮点 1. 多模态解析能力 2. 高效预处理能力 3. 多场景适配性 4. API服务 三、技术架构解析 3.1 概述 1. 模块化处理流程 2. 关键模型与技术 3.2 核心组件技术原理 3.2.1 布局检测(Layout Detection) 3.2.2 公式…...
rabbitMQ如何确保消息不会丢失
rabbitmq消息丢失的三种情况 生产者将消息发送到RabbitMQ的过程中时，消息丢失。消息发送到RabbitMQ，还未被持久化就丢失了数据。消费者接收到消息，还未处理，比如服务宕机导致消息丢失。 解决方案 生产者发送过程中，…...
数字智慧方案5970丨智慧农业大数据服务建设方案（69页PPT）（文末有下载方式）
详细资料请看本解读文章的最后内容。 资料解读：智慧农业大数据服务建设方案 在当今数字化时代，农业领域也正经历着深刻变革，智慧农业大数据服务建设方案应运而生。这一方案对推动农业现代化进程意义非凡，下面让我们深入剖析其核心…...
英一真题阅读单词笔记 22-23年
2022年真题阅读单词 2022 年 Text 1 第一段 1 complain [kəmˈpleɪn] v. 抱怨，投诉；诉说（病痛） 2 plastic [ˈplstɪk] n. 塑料；信用卡 a. 造型的，塑造的；塑料制的 3 durable [ˈd…...
Java大师成长计划之第10天：锁与原子操作
📢 友情提示： 本文由银河易创AI（https://ai.eaigx.com）平台gpt-4o-mini模型辅助创作完成，旨在提供灵感参考与技术分享，文中关键数据、代码与结论建议通过官方渠道验证。 在多线程编程中，锁与原子…...
2025大模型安全研究十大框架合集（10份）
2025大模型安全研究十大框架合集的详细介绍： Anthropic AI信任研究框架 Anthropic于2024年10月更新的《安全责任扩展政策》(RSP)，提出了一个灵活的动态AI风险治理框架。该框架规定当AI模型达到特定能力时，将自动升级安全措施，如…...
溯因推理思维——AI与思维模型【92】
一、定义 溯因推理思维模型是一种从结果出发，通过分析、推测和验证，寻找导致该结果的可能原因的思维方式。它试图在已知的现象或结果基础上，逆向追溯可能的原因，构建合理的解释框架，以理解事物的本质和内在机制。 二、由来 溯因推理的思想可以追溯到古希腊哲学家亚里士…...
系统架构设计师：设计模式——结构型设计模式
一、结构型设计模式 结构型设计模式涉及如何组合类和对象以获得更大的结构。结构型类模式采用继承机制来组合接口或实现。一个简单的例子是采用多重继承方法将两个以上的类组合成一个类，结果这个类包含了所有父类的性质。 这一模式尤其有助于多个独立开发的类库协…...
接口测试实战指南：从入门到精通的质量保障之道
为什么接口测试如此重要？ 在当今快速迭代的软件开发环境中，接口测试已成为质量保障体系中不可或缺的一环。据统计，有效的接口测试可以发现约70%的系统缺陷，同时能将测试效率提升3-5倍。本指南将从实战角度出发，系统性…...
对第三方软件开展安全测评，如何保障其安全使用？
对第三方软件开展安全测评，能够精准找出软件存在的各类安全隐患，进而为软件的安全使用给予保障。此次会从漏洞发现、风险评估、测试环境等多个方面进行具体说明。 漏洞发现情况 在测评过程中，我们借助专业技术与工具，对第三方软…...
计算方法实验四 解线性方程组的间接方法
【实验性质】 综合性实验。 【实验目的】 掌握迭代法求解线性方程组。 【实验内容】 应用雅可比迭代法和Gauss-Sediel迭代法求解下方程组： 【理论基础】 线性方程组的数值解法分直接算法和迭代算法。迭代法将方程组的求解转化为构造一个向量序列&…...
Qt 中基于 QTableView + QSqlTableModel 的分页搜索与数据管理实现
Qt 中基于 QTableView QSqlTableModel 的分页搜索与数据管理实现 一、组件说明 QTableView：一个基于模型的表格视图控件，支持排序、选择、委托自定义。QSqlTableModel：与数据库表直接绑定的模型类，可用于展示和编辑数据库表数据…...
云计算-容器云-服务网格Bookinfo
服务网格：创建 Ingress Gateway 将 Bookinfo 应用部署到 default 命名空间下，请为 Bookinfo 应用创建一个网 关，使外部可以访问 Bookinfo 应用。 上传ServiceMesh.tar.gz包 [rootk8s-master-node1 ~]# tar -zxvf ServiceMesh.tar.gz [rootk…...
PostgreSQL自定义函数
自定义函数 基本语法 //建一个名字为function_name的自定义函数create or replace function function_name() returns data_type as //returns 返回一个data_type数据类型的结果；data_type 是返回的字段的类型；$$ //固定写法......//方法体$$ LANGUAGE …...
学习记录：DAY22
我的重生开发之旅：优化DI容器，git提交规范，AOP处理器，锁与并发安全 前言 我重生了，重生到了五一开始的一天。上一世，我天天摆烂，最后惨遭实习生优化。这一世，我要好好内卷… 今天的…...
HarmonyOS NEXT第一课——HarmonyOS介绍
一、什么是HarmonyOS 万物互联时代应用开发的机遇、挑战和趋势 随着万物互联时代的开启，应用的设备底座将从几十亿手机扩展到数百亿IoT设备。全新的全场景设备体验，正深入改变消费者的使用习惯。 同时应用开发者也面临设备底座从手机单设备到全场景多设…...
数据库系统概论|第五章：数据库完整性—课程笔记1
前言 在前文介绍完数据库标准语言SQL之后，大家已经基本上掌握了关于数据库编程的基本操作，那我们今天将顺承介绍关于数据库完整性的介绍，数据库的完整性是指数据的正确性和相容性。数据的完整性是为了防止数据库中存在不符合语义的数据&…...
开源无人机地面站QGroundControl安卓界面美化与逻辑优化实战
QGroundControl作为开源无人机地面站软件，其安卓客户端界面美化与逻辑优化是提升用户体验的重要工程。 通过Qt框架的界面重构和代码逻辑优化，可以实现视觉升级与性能提升的双重目标。本文将系统讲解QGC安卓客户端的二次开发全流程，包括开发环境搭建、界面视觉升级、多分辨率…...
工作记录 2017-12-12 + 在IIS下发布wordpress
工作记录 2017-12-12 序号 工作 相关人员 1 修改邮件上的问题。 更新RD服务器。 在IIS下发布wordpress。 郝 服务器更新 RD服务器更新了，更新的文件放在190的D:\Temp\CHTeam\fnehr_update_20171212\下了。 数据库更新: 数据库没有更新 更新的文件…...
BBR 之 ProbeRTT 新改
早在 1981 年，Jaffe 在 Flow Control Power is Nondecentralizable 中就给出过论证，测量 maxbw 必然引入队列，而获得 minrtt 时带宽必然欠载，这确定了后面 30 年的拥塞控制算法基调，但 BBR 在 35 年后非常聪明地在两者…...
[创业之路-354]：农业文明到智能纪元：四次工业革命下的人类迁徙与价值重构
农业文明到智能纪元：四次工业革命下的人类迁徙与价值重构 从游牧到定居，从蒸汽轰鸣到算法洪流，人类文明的每一次跨越都伴随着生产关系的剧烈震荡。四次工业革命的浪潮不仅重塑了物质世界的生产方式，更将人类推向了身份认同与存在…...