交换机是RabbitMQ路由消息的核心不同类型的交换机对应不同的路由逻辑交换机和路由规则是多对多绑定适配不同的业务场景。RabbitMQ提供4种默认交换机类型其中前3种最常用。1、Direct Exchange直连交换机精准匹配一对一/多路由Direct交换机是最基础的类型核心逻辑是“路由键Routing Key与绑定键Binding Key完全匹配”仅当两者字符完全一致时消息才会被路由到对应队列。核心特性路由规则简单直接精准度高。一个队列可绑定多个Binding Key一个Binding Key也可绑定多个队列此时消息会被路由到所有匹配队列类似“多播”。适用场景需要精准路由的场景例如业务模块拆分“订单支付”消息仅路由到“支付处理队列”“订单退款”消息仅路由到“退款处理队列”。任务分发特定类型的任务分配给指定的工作队列如视频转码任务分配给转码 worker 队列。工作流程示例1. 声明Direct交换机名称direct_exchange2. 队列A绑定Binding Key order.pay队列B绑定Binding Key order.refund队列C绑定Binding Key order.pay3. 生产者发送消息指定Routing Key order.pay4. 交换机匹配后将消息路由到队列A和队列C队列B无消息。交换机绑定队列的代码如下// 声明一个直连交换机channel.exchangeDeclare(direct_exchange, direct, true);// 声明一个队列channel.queueDeclare(order_queue, true, false, false, null);// 将队列绑定到交换机绑定键为 order.createchannel.queueBind(order_queue, direct_exchange, order.create);2、Fanout Exchange扇出交换机无差别广播一对多路由Fanout交换机是“广播型”交换机核心逻辑是“忽略Routing Key将消息路由到所有与该交换机绑定的队列”无需匹配规则只要队列绑定了交换机就能收到消息。核心特性路由逻辑最简单效率最高无需匹配计算。消息会被复制到所有绑定队列每个队列都能收到完整消息。适用场景需要广播消息的场景例如系统通知服务启动/下线通知、全局配置更新所有相关服务都需接收。日志收集应用日志同时发送到“实时分析队列”和“归档存储队列”。事件同步用户注册成功后同步触发“发送欢迎短信”“创建用户档案”“添加积分”等多个任务。工作流程示例1. 声明Fanout交换机名称fanout_exchange2. 队列1、队列2绑定该交换机队列3未绑定3. 生产者发送消息即使指定Routing Key也会被忽略4. 交换机将消息路由到队列1和队列2队列3无消息。3、Topic Exchange主题交换机模糊匹配按“主题”路由Topic交换机是最灵活的类型核心逻辑是“通过通配符匹配Routing Key与Binding Key”支持按“主题”批量路由消息兼顾精准性和灵活性。核心特性Routing Key和Binding Key需为“多段字符串”段之间用“.”分隔如“user.create.wechat”每段代表一个业务维度如业务类型、操作、渠道。支持两种通配符*星号匹配1个任意段如“user.*”可匹配“user.create”“user.delete”但不匹配“user.create.wechat”#井号匹配0个或多个任意段如“user.#”可匹配“user”“user.create”“user.create.wechat”。适用场景需要按“主题”分类路由的场景例如多维度业务消息通过“user.#”接收所有用户相关消息通过“user.create.*”仅接收用户创建的细分消息。跨模块消息分发订单消息按地区拆分Binding Key order.#.beijing仅接收北京地区的订单消息。工作流程示例1. 声明Topic交换机名称topic_exchange2. 队列A绑定Binding Key user.create.*队列B绑定Binding Key user.#队列C绑定Binding Key user.*.alipay3. 生产者发送消息指定Routing Key user.create.wechat4. 交换机匹配后将消息路由到队列A*匹配“wechat”和队列B#匹配“create.wechat”队列C不匹配无消息。4、Headers Exchange头部交换机按消息头匹配忽略Routing KeyHeaders交换机通过消息的头部属性而非Routing Key进行匹配灵活性较高但路由逻辑复杂性能略差实际应用中较少使用。核心逻辑是生产者发送消息时设置消息头如“typeorder”“priorityhigh”交换机根据绑定队列时指定的头部规则如“匹配所有头”“匹配任意头”路由消息。适用场景需根据多维度属性路由消息且不希望依赖Routing Key的特殊场景如复杂的权限控制消息。
交换机是RabbitMQ路由消息的核心不同类型的交换机对应不同的路由逻辑交换机和路由规则是多对多绑定适配不同的业务场景。RabbitMQ提供4种默认交换机类型其中前3种最常用。1、Direct Exchange直连交换机精准匹配一对一/多路由Direct交换机是最基础的类型核心逻辑是“路由键Routing Key与绑定键Binding Key完全匹配”仅当两者字符完全一致时消息才会被路由到对应队列。核心特性路由规则简单直接精准度高。一个队列可绑定多个Binding Key一个Binding Key也可绑定多个队列此时消息会被路由到所有匹配队列类似“多播”。适用场景需要精准路由的场景例如业务模块拆分“订单支付”消息仅路由到“支付处理队列”“订单退款”消息仅路由到“退款处理队列”。任务分发特定类型的任务分配给指定的工作队列如视频转码任务分配给转码 worker 队列。工作流程示例1. 声明Direct交换机名称direct_exchange2. 队列A绑定Binding Key order.pay队列B绑定Binding Key order.refund队列C绑定Binding Key order.pay3. 生产者发送消息指定Routing Key order.pay4. 交换机匹配后将消息路由到队列A和队列C队列B无消息。交换机绑定队列的代码如下// 声明一个直连交换机channel.exchangeDeclare(direct_exchange, direct, true);// 声明一个队列channel.queueDeclare(order_queue, true, false, false, null);// 将队列绑定到交换机绑定键为 order.createchannel.queueBind(order_queue, direct_exchange, order.create);2、Fanout Exchange扇出交换机无差别广播一对多路由Fanout交换机是“广播型”交换机核心逻辑是“忽略Routing Key将消息路由到所有与该交换机绑定的队列”无需匹配规则只要队列绑定了交换机就能收到消息。核心特性路由逻辑最简单效率最高无需匹配计算。消息会被复制到所有绑定队列每个队列都能收到完整消息。适用场景需要广播消息的场景例如系统通知服务启动/下线通知、全局配置更新所有相关服务都需接收。日志收集应用日志同时发送到“实时分析队列”和“归档存储队列”。事件同步用户注册成功后同步触发“发送欢迎短信”“创建用户档案”“添加积分”等多个任务。工作流程示例1. 声明Fanout交换机名称fanout_exchange2. 队列1、队列2绑定该交换机队列3未绑定3. 生产者发送消息即使指定Routing Key也会被忽略4. 交换机将消息路由到队列1和队列2队列3无消息。3、Topic Exchange主题交换机模糊匹配按“主题”路由Topic交换机是最灵活的类型核心逻辑是“通过通配符匹配Routing Key与Binding Key”支持按“主题”批量路由消息兼顾精准性和灵活性。核心特性Routing Key和Binding Key需为“多段字符串”段之间用“.”分隔如“user.create.wechat”每段代表一个业务维度如业务类型、操作、渠道。支持两种通配符*星号匹配1个任意段如“user.*”可匹配“user.create”“user.delete”但不匹配“user.create.wechat”#井号匹配0个或多个任意段如“user.#”可匹配“user”“user.create”“user.create.wechat”。适用场景需要按“主题”分类路由的场景例如多维度业务消息通过“user.#”接收所有用户相关消息通过“user.create.*”仅接收用户创建的细分消息。跨模块消息分发订单消息按地区拆分Binding Key order.#.beijing仅接收北京地区的订单消息。工作流程示例1. 声明Topic交换机名称topic_exchange2. 队列A绑定Binding Key user.create.*队列B绑定Binding Key user.#队列C绑定Binding Key user.*.alipay3. 生产者发送消息指定Routing Key user.create.wechat4. 交换机匹配后将消息路由到队列A*匹配“wechat”和队列B#匹配“create.wechat”队列C不匹配无消息。4、Headers Exchange头部交换机按消息头匹配忽略Routing KeyHeaders交换机通过消息的头部属性而非Routing Key进行匹配灵活性较高但路由逻辑复杂性能略差实际应用中较少使用。核心逻辑是生产者发送消息时设置消息头如“typeorder”“priorityhigh”交换机根据绑定队列时指定的头部规则如“匹配所有头”“匹配任意头”路由消息。适用场景需根据多维度属性路由消息且不希望依赖Routing Key的特殊场景如复杂的权限控制消息。
