Channel.NotifyPublish不能直接用，因需先调ch.Confirm(false)启用发布者确认模式；Confirm(false)为非阻塞启用，Confirm(true)为阻塞等待响应；NotifyPublish返回的channel通过ack.Acknowledged区分成功或失败确认；DeliveryTag由broker分配且仅channel内唯一，业务需自定义x-msg-id关联消息。
为什么 Channel.NotifyPublish 不能直接用？
很多人看到方法名就以为调用 ch.notifypublish() 就能监听发布确认，结果发现 channel 一直收不到消息——因为这个方法只是注册通知通道，**真正触发确认事件的前提是先启用发布者确认模式**。没调 ch.confirm()，rabbitmq 根本不会发 confirm 帧，通知 channel 自然永远空着。
Confirm(false) 和 Confirm(true) 的区别在哪？
这是最容易混淆的点：Confirm() 的布尔参数控制的是「是否等待服务器响应后再返回」，不是「是否开启确认」。
-
ch.Confirm(false)：非阻塞启用，函数立即返回，后续所有Publish都走异步确认流程 -
ch.Confirm(true)：阻塞启用，会同步等待 RabbitMQ 返回confirm.select-ok帧才返回（极少用，增加连接建立延迟）
生产环境一律用 false，否则初始化通道时可能卡住。
怎么安全地接收异步确认并区分成功/失败？
NotifyPublish 返回的 channel 会同时收到成功和失败通知，靠 ack.Acknowledged 字段区分：
-
ack.Acknowledged == true：消息已入队（不等于被消费） -
ack.Acknowledged == false：消息被服务器拒绝（比如路由失败、mandatory=true 但无匹配队列）
示例代码片段：
confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 100))
if err := ch.Confirm(false); err != nil {
log.Fatal(err)
}
// 发布消息
err := ch.Publish("", "test.queue", false, false, amqp091.Publishing{
Body: []byte("hello"),
})
if err != nil {
log.Printf("publish failed: %v", err)
}
// 异步读取确认
go func() {
for ack := range confirms {
if ack.Acknowledged {
log.Printf("✅ msg %d confirmed", ack.DeliveryTag)
} else {
log.Printf("❌ msg %d nacked", ack.DeliveryTag)
}
}
}()
为什么 DeliveryTag 不是自增整数？
AMQP 协议里 DeliveryTag 是由 broker 分配的 uint64，**不是客户端递增计数器**。它只在当前 channel 内唯一，且重启后重置。如果你需要追踪某条消息，必须在 Publishing 的 Headers 里手动加业务 ID，比如 amqp091.Table{"x-msg-id": "order-123"}，否则确认回调里根本无法关联原始消息内容。
