RabbitMQ的Topic Exchange通过点分routing key与binding key配合*（匹配单个单词）和#（匹配零或多个单词）实现语义化路由，需遵守层级对齐规则，避免非法写法如#开头或单独使用通配符。
RabbitMQ 的 Topic Exchange 是实现多维度、语义化消息路由的关键机制，Java 中通过规范构造 routing key 和 binding key，配合 * 与 # 通配符，就能完成灵活的模糊匹配与多播分发。
通配符规则必须吃透
Topic Exchange 要求 routing key 和 binding key 都是用点号（.）分隔的单词序列，比如 user.login.success 或 log.db.error。匹配逻辑不是字符串层面的正则，而是层级对齐的语义匹配：
-
*匹配恰好一个单词，不能跨点，也不能为空 ——order.*.paid可匹配order.sh.paid、order.nj.paid，但不匹配order.paid（只有两级）或order.hz.finance.paid（三级超限） -
#匹配零个或多个单词，可跨级、可为空 ——log.#可匹配log、log.warn、log.db.timeout，甚至log.api.v2.response - 非法写法要避开：
#不能开头（如#.error合法，但#error不合法），*或#单独作 binding key（如*）无效，*.#这类混合写法也不被支持
Java 客户端声明方式（Spring AMQP 推荐）
使用 Spring Boot + Spring AMQP 时，声明交换机、队列和绑定关系更简洁，框架自动处理底层 declare 操作：
- 定义 Topic Exchange：
@Bean public TopicExchange topicExchange() { return new TopicExchange("app.topic"); } - 声明队列（持久化）：
@Bean public Queue smsQueue() { return QueueBuilder.durable("queue.sms").build(); } - 设置绑定关系：
@Bean public Binding smsBinding() { return BindingBuilder.bind(smsQueue()).to(topicExchange()).with("notify.*.sms"); }—— 表示只收二级路径中第二段为sms的通知，如notify.cn.sms、notify.us.sms - 宽泛绑定示例：
with("alert.#.critical")可捕获alert.db.critical、alert.cache.redis.critical等任意深度的 critical 告警
原生 Java Client 基础操作要点
若不用 Spring，直接用官方 amqp-client，需手动调用 channel 方法：
立即学习“Java免费学习笔记（深入）”；
- 声明交换机：
channel.exchangeDeclare("topic.logs", BuiltinExchangeType.TOPIC, true); - 声明队列：
channel.queueDeclare("queue.error", true, false, false, null); - 绑定并指定 binding key：
channel.queueBind("queue.error", "topic.logs", "log.*.error"); - 发送消息时指定 routing key：
channel.basicPublish("topic.logs", "log.auth.error", null, msgBody);—— 此消息会投递到所有 binding key 匹配的队列（可能多个）
典型场景与设计建议
合理设计 routing key 结构是发挥 Topic 能力的前提，常见模式有：
-
微服务事件分类：按
{service}.{module}.{action}.{status}构造，如order.payment.confirm.success，消费者可按order.#.success订阅全部成功事件，或*.payment.*关注所有支付动作 -
日志分级路由：用
{app}.{level}.{area}，例如auth.info.prod、billing.warn.dev，让监控系统绑定*.warn.#，审计服务绑定billing.*.* -
避免过度宽泛：慎用
#开头或结尾的 binding key（如#本身），易导致消息爆炸式投递；优先用*控制粒度，再用#扩展层级
