http handler 中直接调用 ch.publish() 会因连接复用或关闭导致消息丢失，必须用独立 goroutine + context 控制、channel 中转、新建 amqp.publishing 实例、启用 confirm 模式并监听 ack/nack、consumer 禁用 autoack、显式 ack/nack、设置 qos、声明 durable 队列/交换机。
HTTP handler 里直接 ch.Publish() 必丢消息
Gin 的 handler 函数返回响应后，底层 TCP 连接可能立刻被复用或关闭。此时若 ch.Publish() 还在发包，会触发 amqp.Error{Code: 541}（channel closed）或静默失败——不是“异步”，是“不管了”。
必须把发布逻辑剥离到独立 goroutine，并传入 context.Context 控制超时和取消。不能裸起 go func() {}()，否则无法感知请求中断、重试无依据、错误不落地。
- 每次发送前检查
ch.IsClosed()，为 true 时重建 channel（不要重用已关闭的） - 用带缓冲的
chan []byte做中转：Gin handler 只做序列化 + 写入 channel；独立 goroutine 持续消费并重试 - 不要复用
amqp.Publishing实例：并发下Headers是 map 引用，会导致污染甚至PRECONDITION_FAILED - 封装工厂函数：
func newPublishing(body []byte) amqp.Publishing，每次调用都返回新值
没开 Confirm 模式，DeliveryMode: amqp.Persistent 形同虚设
DeliveryMode: amqp.Persistent 只是告诉 RabbitMQ “请存盘”，但不确认它真落盘了。网络抖动、broker 拒收、路由失败时，消息照样消失，且你完全不知道。
必须显式调用 ch.Confirm(false)，再监听 ch.NotifyPublish() 接收 ack/nack。收到 nack 必须重试，不能忽略；select 超时也得 fallback 处理。
-
channel.Publish()是非阻塞的，只写入 TCP 缓冲区，真正落盘靠 Confirm 机制兜底 - 没监听
NotifyPublish就等于没开 Confirm——Confirm(false)只是开启开关，不监听等于没装保险丝 - 若
confirm.Select失败（比如 broker 不支持），需降级日志并拒绝后续 publish，避免假成功
consumer autoAck = true 是最大陷阱
只要 ch.Consume(queue, "", false, false, false, false, nil) 第四个参数传 true，RabbitMQ 一推送就删消息，哪怕你的业务代码第一行还没执行。这不是“快”，是“直接丢”。
必须设为 false，并在业务逻辑成功后显式调 msg.Ack(false)；失败时用 msg.Nack(false, true) 让消息重入队列头部——requeue=true 是防丢底线，但别无脑用，要配合 DLX+TTL 控制重试次数。
- 务必先调
ch.Qos(1, 0, false)限制预取数量，否则大量消息堆积在 consumer 内存里，OOM 或重启即丢 -
for range msgs循环内，msg是循环变量，不能defer msg.Ack()，会捕获到最后一次迭代的值 - 处理前先拷贝 body：
data := append([]byte(nil), msg.Body)，避免后续迭代覆盖内存 - 多个 goroutine 共享一个 channel 时，
msg.Ack()必须加锁或通过 channel 同步，否则 deliveryTag 冲突报PRECONDITION_FAILED
QueueDeclare / ExchangeDeclare 没设 durable = true，重启就归零
RabbitMQ 默认所有 Queue 和 Exchange 都是临时的，Broker 重启后全部消失。光消息持久化没用，队列没了，新消息根本无处可去。
必须四点齐备：Exchange 持久化、Queue 持久化、Binding 在两者都声明后再做、消息本身设 DeliveryMode: amqp.Persistent。漏一个，前面全白干。
-
ch.ExchangeDeclare(..., true, ...)：第二个参数durable必须为true -
ch.QueueDeclare("", true, false, false, false, nil)：第二个参数durable必须为true；autoDelete和exclusive应为false - Binding 不需要单独设 durable，但必须在 Exchange 和 Queue 都已声明为
durable后再调ch.QueueBind() - 不要依赖框架自动配——
github.com/streadway/amqp不做任何默认可靠性保障，全靠你手填参数
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
