rabbitmq 消费中间件应作为独立后台服务运行，而非挂载于 express 请求生命周期；需通过 workers/rabbit-consumer.js 实现自动重连、手动 ack、错误分类处理及进程安全退出，并与 express 分开部署管理。
在 express.js 项目中，rabbitmq 消费中间件不应直接挂载在请求生命周期里（比如 app.use()），而是作为独立、常驻的后台服务运行——它和 http 服务并行存在，通过监听队列自动处理消息。健壮性的核心在于：连接容错、消息确认、重试控制、异常隔离和进程生命周期管理。
用单独模块启动消费者，不混入 Express 请求流
RabbitMQ 消费者本质是长连接后台任务，强行塞进 Express 中间件链会导致：
- 每次 HTTP 请求都尝试创建新 channel，资源泄漏
- 连接中断后无法自动恢复，且无重连逻辑
- 消息处理阻塞导致整个 Web 服务响应变慢
正确做法：新建 workers/rabbit-consumer.js，用 amqplib 独立连接，配合 process.on('SIGTERM') 安全关闭。
实现带自动重连与手动 ACK 的消费循环
关键点不是“连上就消费”，而是“断了能重连、消息不丢、失败可重试”。示例结构：
- 使用
connect()封装连接逻辑，内部含指数退避重连（如 1s → 2s → 4s） -
channel.consume()时传入{ noAck: false }，禁用自动确认 - 业务处理成功后调用
channel.ack(msg)；失败时根据错误类型决定：临时错误（如 DB 超时）→nack(msg, false, true)重回队列头部重试；**永久错误（如 JSON 解析失败）→ack(msg)丢弃或转发到死信队列**
把业务逻辑抽离为纯函数，便于测试与复用
消费者模块只负责“收消息 → 调函数 → 回执”，不写具体业务。例如：
async function handleOrderCreated(msg) {
const data = JSON.parse(msg.content.toString());
await orderService.create(data);
return { success: true };
}
这样单元测试可直接传入 mock 消息对象，无需启动 RabbitMQ；后续也可复用于其他触发源（如 Kafka、HTTP webhook）。
用 PM2 或 Docker 管理消费者进程，与 Express 分开启停
在 package.json 中定义多进程脚本：
"scripts": {
"start": "concurrently \"npm run serve:api\" \"npm run serve:worker\"",
"serve:api": "node ./bin/www",
"serve:worker": "node ./workers/rabbit-consumer.js"
}
生产环境推荐用 PM2 启动 worker 进程，并配置 watch: false 和 restart_delay: 5000 防止频繁崩溃重启。Docker 则用多 stage 构建 + docker-compose 编排两个 service。
