不能在main()里直接Dial后一直挂着，因为amqp.Connection和Channel非线程安全、长期空闲会被RabbitMQ静默断开（默认heartbeat=60s），且未监听NotifyClose会导致失效；Channel不显式Close会泄漏，突破2047上限；全局conn一旦断开，所有依赖ch均不可用，必须整体重建。
延迟加载消费者连接不是“等会儿再连”，而是按需建立、复用并管控生命周期——不提前 Dial，不长期空闲占资源，更不能每次消费都重连。
为什么不能在 main() 里直接 dial 后一直挂着
Go 的 amqp.Connection 和 amqp.Channel 不是线程安全的，也不能跨 goroutine 复用；长期空闲连接会被 RabbitMQ 主动断开（默认 heartbeat=60s），而客户端若没监听 NotifyClose 就会静默失效；Redis 的 redis.Client 虽支持连接池，但过早初始化仍浪费 fd 和心跳开销。
- 连接对象本身不轻量：每个
*amqp.Connection维护 TCP + AMQP 协议状态 + 心跳 goroutine - Channel 更要命：
ch, _ := conn.Channel()每次都新建，但未显式ch.Close()就泄漏，RabbitMQ 有 channel 数上限（默认 2047） - Redis 的
client.Ping()成功率 ≠ 连接池健康，得靠client.PoolStats()看IdleCount和ActiveCount
用 sync.Once + 函数闭包实现首次调用才建连
适用于单消费者、低频触发场景（比如后台定时补偿任务），避免全局变量污染，又杜绝重复初始化。
var (
once sync.Once
mqChan *amqp.Channel
mqErr error
)
func getConsumerChannel() (*amqp.Channel, error) {
once.Do(func() {
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
if err != nil {
mqErr = fmt.Errorf("dial failed: %w", err)
return
}
ch, err := conn.Channel()
if err != nil {
mqErr = fmt.Errorf("channel create failed: %w", err)
return
}
mqChan = ch
})
return mqChan, mqErr
}
- 注意：
once.Do只保证初始化一次，但不保证连接始终可用——后续仍需检查ch.NotifyClose并重建 - 别把
conn存成全局变量：它一旦断开，所有依赖它的ch都不可用，必须整体重建 - 这个模式不适合高并发消费者：多个 goroutine 同时触发
once.Do会阻塞等待，应改用连接池
go-redis/v9 怎么让 ZRANGEBYSCORE 轮询不依赖常驻 client
Redis 延迟队列轮询本质是「周期性查询」，不需要长连接维持状态，反而该用短生命周期 client 控制资源边界。
立即学习“go语言免费学习笔记（深入）”；
- 每次轮询前 new 一个
redis.NewClient()，设PoolSize: 2、MinIdleConns: 1，用完立刻client.Close() - 更推荐复用 client，但禁用自动重连：
client.Options().MaxRetries = 0，出错就退，由上层控制重试节奏 - 关键点：轮询逻辑里别用
ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)—— timeout 太短会导致频繁报context deadline exceeded，掩盖真实连接问题 - 真正该加 timeout 的是业务处理环节，不是 Redis 查询本身
最容易被忽略的点：连接泄漏比连不上更难排查
AMQP 的 Channel 泄漏不会立即报错，但 RabbitMQ 管理界面的 Channels 数会持续上涨，直到触发 CHANNEL_ERROR；Redis 的 CLIENT LIST 里能看到大量 idle 状态连接堆积。
- AMQP：每个
ch.Consume()后必须配对ch.Cancel()，哪怕只是测试代码 - Redis：用
defer client.Close()仅在函数退出时生效，轮询 goroutine 是长运行的，得自己管 - 最稳妥做法：把连接创建和销毁封装进 struct 方法，用
Open()/Close()显式生命周期管理
