【Java 开发日记】RabbitMQ 里面的交换机是什么，你用过哪种？-rabbitmq-CSS教程网

交换机是什么？

我用过的交换机类型（及详细介绍）

① 直连交换机

② 扇出交换机

③ 主题交换机

④ 头交换机

总结与对比

在 RabbitMQ 中，交换机 是消息路由机制的核心。你可以把它想象成一个邮局分拣员。

简单流程：
生产者 -> 交换机 -> (根据绑定规则) -> 一个或多个队列 -> 消费者

如果没有交换机，生产者需要直接知道所有队列的存在，这在复杂的、需要灵活路由的系统里是几乎不可行的。交换机解耦了生产者和队列，使得消息的路由策略变得非常灵活和强大。

RabbitMQ 主要提供了四种类型的交换机，每种都有不同的路由行为。最常用的是前三种。

类型：direct
行为：一个消息的路由键如果 完全匹配 某个队列的绑定键，那么这条消息就会被路由到该队列。
类比：就像公司里的邮件系统，你写对了工号（路由键），邮件就会被准确地投递到那个人的邮箱（队列）。
使用场景：
- 有明确一对一或一对多任务分发的场景。例如，将错误日志（routing_key: 'error'）只发送给记录错误的队列，将订单消息（routing_key: 'order.paid'）只发送给处理已支付订单的队列。
我的使用经验：这是最常用、最简单的交换机类型。我们在处理不同优先级的任务时经常使用，比如 task.high 和 task.low 分别绑定到不同的队列，由不同性能的消费者来处理。

类型：fanout
行为：它会把发送到该交换机的所有消息广播到所有与它绑定的队列中。它完全忽略路由键。
类比：就像公司里的群发邮件或公告板，一条消息发出，所有订阅了的人都收到一份。
使用场景：
- 发布/订阅模式。例如，用户成功注册后，需要同时执行多个操作：发送欢迎邮件、初始化用户画像、发放新手优惠券。你可以让这三个任务对应的队列都绑定到同一个 fanout 交换机上，这样一条“用户注册成功”的消息会被这三个队列同时接收并处理。
我的使用经验：在需要做事件驱动架构，一个事件触发多个下游服务的场景下非常好用。我们用它来同步不同服务间的缓存数据失效通知。

类型：topic
行为：功能最强大的交换机。它使用路由键和一种模式进行匹配。绑定键（Binding Key）可以包含两种特殊的通配符：
- * (星号)：匹配一个单词。
- # (井号)：匹配零个或多个单词。
- 单词之间用点号 . 分隔，例如 usa.news， europe.weather.serious。
类比：就像新闻订阅系统，你可以订阅“所有美国地区的新闻”（usa.#），或者“所有地区的严重天气”（*.weather.serious）。
使用场景：
- 根据消息的多个属性进行灵活路由。例如，一个日志处理系统，你可以根据日志的严重程度（info, error）和来源（auth, order, payment）来路由。绑定键 *.error 会接收所有服务的错误日志，而 order.* 会接收订单服务的所有日志。
我的使用经验：在构建复杂的消息路由规则时，topic 交换机是首选。我们用它来构建日志收集和业务通知系统，可以根据不同的标签组合将消息精准地投递给感兴趣的消费者。

类型：headers
行为：它不依赖于路由键的匹配规则，而是根据消息的 headers 属性 来路由。在绑定时，你需要指定一组键值对。当发送来的消息的 headers 属性与绑定时指定的键值对完全匹配时，消息就会被路由到该队列。
使用场景：
- 用于需要基于多个消息属性（而不仅仅是一个路由键）进行路由的复杂场景。但因为性能比 topic 交换机差，且使用起来更复杂，所以在实际开发中非常少见。
我的使用经验：我个人在实际项目中几乎没有使用过头交换机，topic 交换机已经能满足绝大多数复杂路由的需求，而且更直观高效。

回答“你用过哪种？”：

在实际工作中，我最常用的是 直连交换机、扇出交换机 和 主题交换机。

如果小假的内容对你有帮助，请点赞，评论，收藏。创作不易，大家的支持就是我坚持下去的动力！

分享到：