RabbitMQ 中怎么实现 Fanout 广播模式消息分发

夏伟姑娘_6462

夏伟姑娘_6462

2026-08-09

805人浏览

原创

fanout交换机实现消息广播,将每条消息无差别转发给所有绑定队列,忽略routing key;声明时需指定type='fanout',绑定队列无需routing key,发送消息时routing key亦被忽略。

rabbitmq 中怎么实现 fanout 广播模式消息分发

RabbitMQ 的 Fanout 交换机(Exchange)专为广播模式设计,它会把收到的每条消息无差别地转发给所有绑定到它的队列,不关心路由键(routing key),也不做任何匹配判断。

创建 Fanout 类型的 Exchange

在声明交换机时,必须指定类型为 fanout。这是实现广播的前提,其他类型(如 direct、topic)无法实现纯广播行为。

  • 使用 RabbitMQ 官方客户端(如 Python 的 pika)时,调用 exchange_declare 并传入 exchange_type='fanout'
  • 通过管理界面创建时,在 “Exchanges” 页面点击 “Add a new exchange”,Type 选择 Fanout
  • 命令行工具 rabbitmqadmin 可执行:rabbitmqadmin declare exchange name=my_fanout type=fanout

绑定多个队列到同一个 Fanout Exchange

Fanout 的核心机制是“一对多”广播,因此需将多个队列分别绑定(bind)到该交换机。绑定时无需指定 routing key(即使指定也会被忽略)。

JavaStoryDevelop
JavaStoryDevelop

你接手一个需求时,是不是经常这样:"改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续";这个 Skill 就是专门解决这些问题的。 它会自动探测你的项目环境(JDK、Spring Boot、ORM、数据库、前端框架),记在

下载
  • 每个队列调用 queue_bind,目标 exchange 为 fanout 交换机,routing key 参数可留空或设为任意字符串(例如 '' 或 'ignored')
  • 多个消费者可各自声明专属队列并绑定,实现消息的并行消费与解耦
  • 示例场景:订单服务发一条“订单已创建”通知,用户服务、库存服务、日志服务各自监听对应队列,互不影响

发布消息时不设置 routing key

向 Fanout Exchange 发送消息时,routing key 被完全忽略。只要 exchange 存在且有绑定队列,消息就会被复制并投递到所有绑定队列。

  • 生产者调用 basic_publish 时,routing_key 参数可为空字符串('')或任意值(如 'any'),效果相同
  • 消息体(body)和属性(如 delivery_mode)照常设置,Fanout 不修改这些内容
  • 注意:若没有任何队列绑定到该 Fanout Exchange,消息会被直接丢弃(除非设置了备用交换机)

验证广播是否生效

可通过 RabbitMQ 管理界面或命令行观察实际投递情况,确保逻辑符合预期。

  • 进入管理界面的 “Queues” 页面,查看各队列的 “Ready” 和 “Unacknowledged” 消息数是否同步增长
  • 使用 rabbitmqctl list_bindings 查看该 Fanout Exchange 绑定了哪些队列
  • 启动多个消费者分别监听不同队列,发送一条消息后确认每个消费者都收到了副本

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

java rabbitmq

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.02.23

604

5

Java 消息队列与异步架构实战
Java 消息队列与异步架构实战

本专题系统讲解 Java 在消息队列与异步系统架构中的核心应用,涵盖消息队列基本原理、Kafka 与 RabbitMQ 的使用场景对比、生产者与消费者模型、消息可靠性与顺序性保障、重复消费与幂等处理,以及在高并发系统中的异步解耦设计。通过实战案例,帮助学习者掌握 使用 Java 构建高吞吐、高可靠异步消息系统的完整思路。

2026.01.28

948

20

RabbitMQ使用教程合集
RabbitMQ使用教程合集

RabbitMQ使用教程合集整理 RabbitMQ 基础教程、消息队列开发案例、生产者消费者、交换机与队列实战内容。

2026.05.20

184

15

RabbitMQ集群部署指南
RabbitMQ集群部署指南

RabbitMQ集群部署指南聚合 RabbitMQ 集群部署、高可用架构、镜像队列、故障恢复、监控与运维优化内容。

2026.05.20

137

12

RabbitMQ Docker实战指南
RabbitMQ Docker实战指南

RabbitMQ Docker实战指南提供 RabbitMQ Docker 镜像部署、Docker Compose、Kubernetes Operator 与云原生实践教程。

2026.05.20

142

10

OpenJDK JVM参数怎么调优
OpenJDK JVM参数怎么调优

Java应用运行缓慢,如何调整JVM参数?本专题介绍OpenJDK JVM性能调优的基本流程,涵盖性能指标确认、运行数据采集、内存配置和垃圾回收分析,帮助你先定位瓶颈,再通过对照测试验证效果,避免直接套用参数而影响应用稳定性。

2026.10.16

60

10

OpenJDK怎么配置Java开发环境
OpenJDK怎么配置Java开发环境

怎样用OpenJDK搭建开发环境?本专题介绍版本选择、下载安装、环境变量配置和编译运行验证,帮助你理清JDK的作用及基本配置流程,并通过简单程序检查环境是否可用,为后续项目开发做好准备。

2026.10.16

40

10

OpenJDK怎么部署Java应用
OpenJDK怎么部署Java应用

Java项目开发完成后,怎样部署到目标环境并正常运行?本专题介绍OpenJDK应用部署流程,涵盖运行环境准备、版本兼容检查、应用打包、启动参数配置和日志查看,帮助你理清部署前后的操作顺序,减少环境差异造成的运行问题。

2026.10.16

40

10

Revel框架模板渲染与表单验证
Revel框架模板渲染与表单验证

本专题围绕Revel框架视图层开发,介绍模板语法、变量输出、布局复用、表单提交、参数绑定与验证规则,帮助开发者完成安全规范的页面交互。

2026.10.16

20

15

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
dev.java 官方:Learn Java
dev.java 官方:Learn Java

共0课时 | 0人学习

Java JDBC数据库连接官方教程
Java JDBC数据库连接官方教程

共0课时 | 0人学习