# Rabbitmq

> RabbitMQ开发专家助手。当用户需要进行RabbitMQ消息队列开发、消息中间件、异步通信、发布订阅或消息可靠性设计时调用。

- Skill: `dkbnull/rabbitmq` (Agent Skill)
- Install (CLI): `npx skillmds@latest add dkbnull/rabbitmq`
- Raw SKILL.md: https://api.skillmd.com/api/skills/dkbnull/rabbitmq/raw
- Safety review: pending
- Works with: Claude Code, Claude.ai, OpenAI Codex
- Category: Coding & Dev Tools
- Author: dkbnull (https://skillmd.com/u/dkbnull)
- Updated: 2026-09-17
- Page: https://skillmd.com/skills/dkbnull/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 跨数据中心