在node.js中使用amqplib实现可靠发布确认需创建confirmchannel、配合waitforconfirms或异步confirm事件监听，并启用mandatory+return机制兜底。
在 Node.js 中使用 amqplib 实现可靠的发布确认（Publisher Confirms），关键在于启用确认通道、正确处理返回结果，并配合消息持久化与错误重试策略。这不是简单的“发完就不管”，而是让生产者明确知道每条消息是否已被 RabbitMQ 成功接收并入队。
创建 confirmChannel 并启用发布确认
普通 channel 不支持发布确认，必须调用 connection.createConfirmChannel() 创建专用通道：
- 该通道会自动为每条发布的消息分配唯一 deliveryTag，并等待 Broker 的 confirm 帧
- 不需额外配置，只要用 confirmChannel.publish()，RabbitMQ 就会在消息成功入队（或写入磁盘）后返回确认
- 若 Broker 崩溃或消息被拒（如 mandatory=true 但无匹配队列），会触发 error 或 waitForConfirms() 拒绝
同步等待单条消息确认
对关键消息，可用 channel.waitForConfirms() 阻塞等待确认结果：
- 返回 true 表示已确认；抛出异常（如 ChannelClosedError）表示失败
- 适合低频、高一致性要求的场景（如订单创建后发通知）
- 注意：不要在高并发循环中直接 await 它，否则会串行阻塞，吞吐下降
异步批量确认与错误处理
高频发送时推荐批量发布 + 异步监听确认事件：
- 调用 channel.waitForConfirmsNoWait() 发送多条后立即继续，再用 channel.on('confirm', (ack, multiple) => {...}) 监听回调
- ack 为 true 表示单条确认；multiple 为 true 时，表示 deliveryTag ≤ 当前值的所有未确认消息均已确认
- 同时监听 channel.on('error', err => {...}) 捕获通道级异常（如网络中断、Broker 关闭）
结合 mandatory 和 return 机制兜底
防止消息因路由失败而静默丢失：
- publish 时设置 mandatory: true，若消息无法路由到任何队列，RabbitMQ 会通过 basic.return 返回给生产者
- 监听 channel.on('return', (msg, exchange, routingKey) => {...}) 拿到被退回的消息内容和原因
- 此时可记录日志、落库待重发，或触发告警
不复杂但容易忽略
