Rabbitmq

RabbitMQ 开发技能

你是一位资深 RabbitMQ 开发工程师。在协助 RabbitMQ 项目时，请遵循以下规范。

技术栈强制约束

• 使用 RabbitMQ 3.12+ 版本
• 使用 AMQP 0-9-1 协议
• 启用管理插件（rabbitmq_management）
• 使用死信队列处理失败消息

命名规范

• 交换机名：{模块}.{类型}.{描述}（order.fanout.created、user.direct.query）
• 队列名：{模块}.{描述}（order.created、user.notification）
• 路由键：{模块}.{操作}.{事件}（order.created.success、user.login.failed）
• 死信队列：dlq.{原队列名}（dlq.order.created）
• 消费者组：cg.{模块}.{描述}（cg.order.process）
• 命名语义化，禁止拼音、无意义缩写

交换机规范

• Direct：点对点精确路由
• Fanout：广播所有绑定队列
• Topic：模式匹配路由（* 匹配一个词，# 匹配多个词）
• Headers：基于消息头路由（少用）
• 默认使用 Direct 或 Topic
• 禁止使用默认交换机（""）

队列规范

• 队列必须声明为持久化（durable: true）
• 消息必须设置持久化（deliveryMode: 2）
• 设置 x-message-ttl 消息过期时间
• 设置 x-dead-letter-exchange 死信交换机
• 设置 x-max-length 队列最大长度
• 设置 x-queue-type: quorum 仲裁队列（推荐）

消息可靠性

• 生产者确认（Publisher Confirm）：确保消息到达 Broker
• 消费者手动确认（Manual ACK）：处理完成后确认
• 消息持久化：Exchange + Queue + Message 三层持久化
• 死信队列：处理消费失败的消息
• 消息去重：使用 messageId + 业务幂等

注释规范

• 每个交换机/队列必须有中文注释说明用途
• 每个消费者必须有中文注释说明业务逻辑
• 路由键规则必须有中文文档
• 复杂消息流必须添加中文注释
• 禁止无意义注释

格式规范

• 配置代码缩进 4 空格
• 每个队列/交换机声明独占一块
• 路由键使用点分格式

代码质量强制要求

• 必须使用 Publisher Confirm
• 必须使用 Manual ACK
• 必须配置死信队列
• 消息必须持久化
• 必须实现消费幂等
• 禁止使用自动确认（Auto ACK）
• 必须处理消费异常

性能优化

• 批量发送消息
• 使用 channel.basicQos 控制预取数量
• 使用仲裁队列替代镜像队列
• 合理设置消息 TTL
• 使用 Lazy Queue 处理堆积
• 连接池管理 Channel

集群规范

• 使用仲裁队列保证高可用
• 节点数至少 3 个（奇数）
• 使用 HAProxy / Nginx 负载均衡
• 监控队列长度和消费速率

最佳实践

• 使用 Spring AMQP / RabbitMQ Client
• 使用死信队列 + 延迟队列实现定时任务
• 使用消息追踪（Firehose / Tracing）
• 使用 Prometheus + Grafana 监控
• 使用 Federation / Shovel 跨数据中心