4. RabbitMQ 基础概念：Exchange、Queue、Binding、Message、Vhost

在深入 KEDA 基于 RabbitMQ 队列深度进行弹性伸缩之前，必须透彻理解 RabbitMQ 的核心抽象模型。KEDA 的 ScaledObject 本质上是在监听 Queue 的深度指标，但消息从生产者到达队列，再到被消费者拉取，中间涉及 Exchange、Binding、Message 和 Vhost 等多个关键角色。本节将逐一拆解这些概念，为后续配置 KEDA 触发器奠定基础。

4.1 核心概念总览

RabbitMQ 采用 AMQP 0-9-1 协议模型，消息的流转遵循一条清晰的路径：生产者 → Exchange → Binding → Queue → 消费者。Vhost 则为这一切提供隔离的虚拟运行环境。下表总结了五个核心概念及其在 KEDA 弹性伸缩场景中的角色：

4.2 Exchange（交换机）—— 消息的路由中枢

Exchange 是消息进入 RabbitMQ 的第一站。生产者不会直接将消息发送到队列，而是发送到 Exchange。Exchange 根据其类型和路由键（Routing Key）决定将消息投递到哪些绑定的队列。

RabbitMQ 支持四种内置 Exchange 类型，每种类型对应不同的路由策略：

4.3 Queue（队列）—— 消息的缓冲区与 KEDA 的监控焦点

Queue 是消息的存储容器，也是 KEDA 监控的核心对象。KEDA 的 RabbitMQ 触发器通过 RabbitMQ Management HTTP API 或 AMQP 协议定期查询指定队列的 Ready 消息数量（即队列深度），并根据该数值与配置的阈值进行比较，驱动 HPA 调整 Pod 副本数。

队列的关键属性包括：

• 名称： 唯一标识，KEDA 的 queueName 字段直接引用此名称。
• 持久化（Durable）： 声明为持久化的队列在 RabbitMQ 重启后依然存在。生产环境必须设置为 true。
• 自动删除（Auto-delete）： 当最后一个消费者取消订阅后，队列自动删除。KEDA 场景下通常设为 false。
• 排他性（Exclusive）： 仅限当前连接使用，连接关闭后删除。KEDA 场景下通常设为 false。

4.4 Binding（绑定）—— 连接 Exchange 与 Queue 的规则

Binding 定义了 Exchange 和 Queue 之间的关联关系，并指定了路由键（Routing Key）。当 Exchange 收到消息时，它会将消息的路由键与所有绑定的路由键进行匹配，匹配成功的消息才会被投递到对应的 Queue。

一个 Queue 可以绑定到多个 Exchange，一个 Exchange 也可以绑定多个 Queue。Binding 是消息路由策略的具体实现载体。

# 示例：将队列 "order.queue" 绑定到 Direct 类型 Exchange "order.exchange"
# 路由键为 "order.created"
rabbitmqadmin declare binding source="order.exchange" \
  destination_type="queue" destination="order.queue" routing_key="order.created"

4.5 Message（消息）—— 数据的最小单元

Message 是 RabbitMQ 传输的基本数据单元，由两部分组成：

• 属性（Properties）： 包括路由键、优先级、持久化标志、内容类型、消息 ID、时间戳等元数据。
• 负载（Payload）： 实际传输的业务数据，通常为 JSON、XML 或纯文本格式。

在 KEDA 弹性伸缩上下文中，消息本身的内容并不重要，重要的是消息的数量。KEDA 只关心队列中堆积了多少条消息，而不关心消息体里写了什么。但消息的持久化属性会影响可靠性：持久化消息（delivery_mode=2）会写入磁盘，确保 RabbitMQ 重启后不丢失，这对生产环境至关重要。

4.6 Vhost（虚拟主机）—— 多租户隔离的基础

Vhost 是 RabbitMQ 中最基本的资源隔离单元。一个 Vhost 拥有自己独立的 Exchange、Queue、Binding 命名空间，以及独立的权限控制。不同 Vhost 之间的资源完全隔离，互不可见。

在 KEDA 配置中，vhostName 字段用于指定连接哪个虚拟主机。默认 Vhost 是 /。对于多环境（开发、测试、生产）或多团队共享同一 RabbitMQ 集群的场景，使用不同的 Vhost 可以实现逻辑隔离。

# KEDA ScaledObject 中指定 Vhost 的示例
triggers:
- type: rabbitmq
  metadata:
    queueName: "task.queue"
    host: "amqp://guest:guest@rabbitmq-service:5672"
    vhostName: "production"   # 指定 Vhost
    queueLength: "10"

4.7 消息流转全流程 SVG 架构图

下图展示了从生产者到消费者的完整消息流转路径，以及 KEDA 如何从 Queue 采集深度指标：

4.8 概念关系总结

为了帮助记忆，可以将这五个概念类比为现实中的邮政系统：

• Vhost 相当于不同的城市，每个城市有独立的邮政体系。
• Exchange 相当于邮局分拣中心，根据地址（路由键）决定信件去向。
• Binding 相当于分拣规则，规定哪些地址的信件送到哪个投递站。
• Queue 相当于投递站的信箱，信件到达后等待投递员（消费者）取走。
• Message 就是信件本身，包含信封（属性）和信纸（负载）。