<p>RabbitMQ 的 Topic Exchange 基于点分 routing key 和通配符（* 匹配单个单词，# 匹配零或多个单词）实现主题式路由；绑定由队列侧指定 binding key，发送方仅设置 routing key，匹配由 RabbitMQ 内部完成。</p>
RabbitMQ 通过 Exchange（交换机） 和 Binding（绑定） 实现消息路由，而 Topic 类型交换机则基于 模式匹配规则 对消息的 routing key 进行主题式路由。关键在于理解 routing key 的结构、通配符语义，以及队列与 Exchange 之间的绑定方式。
Topic Exchange 的匹配规则
Topic Exchange 要求 routing key 是以点号（.）分隔的单词列表，例如 stock.usd.nyse 或 logs.error.backend。绑定时使用的 binding key 同样是点分字符串，支持两个特殊通配符：
-
*（星号）：匹配一个单词（不能是空，也不能含点） -
#（井号）：匹配零个或多个单词（可跨段，可为空）
例如：
– logs.*.backend 匹配 logs.error.backend、logs.info.backend，但不匹配 logs.debug.us.backend
– logs.# 匹配 logs、logs.error、logs.error.backend、logs.a.b.c.d
声明 Topic Exchange 和绑定队列
使用客户端（如 Python 的 pika）时需显式声明 Exchange 类型为 topic，再将队列通过 binding key 绑定到该 Exchange：
你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。 它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在
# 声明 topic 类型交换机 channel.exchange_declare(exchange='topic_logs', exchange_type='topic') <h1>声明队列（自动命名或指定）</h1><p>result = channel.queue_declare(queue='', exclusive=True) queue_name = result.method.queue</p><h1>绑定队列，binding key 支持通配符</h1><p>channel.queue_bind(exchange='topic_logs', queue=queue_name, routing_key='logs.*.backend')
注意：binding key 由队列绑定时指定，不是发送方决定；发送方只负责设置消息的 routing_key（如 'logs.warning.backend'），RabbitMQ 内部根据所有绑定关系做匹配分发。
典型使用场景与设计建议
Topic Exchange 适合多维度、可扩展的日志分发、微服务事件通知等场景。设计时注意：
- routing key 长度不宜过长，建议控制在 5 段以内（如
service.env.level.module） - 避免过度依赖
#，尤其是开头用#.error可能导致意外匹配，推荐前缀明确（如logs.#安全，#.error不安全） - 同一 Exchange 下多个队列可以绑定相同 binding key，实现广播；也可用不同 binding key 实现精准分流
- 不区分大小写，但建议统一小写 + 下划线风格，提升可读性与一致性
验证路由是否生效的小技巧
可通过 RabbitMQ 管理界面（http://localhost:15672）查看 Exchange 的绑定关系（Bindings 标签页），确认队列是否已正确绑定并显示对应 binding key。发送测试消息后，观察队列的 Ready/Unacked 消息数变化；也可开启队列的 auto-delete 或使用临时队列快速验证匹配逻辑。
